data_type.hpp

Go to the documentation of this file.

// Copyright 2024 Man Group Operations Limited
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
//     http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.
 
#pragma once
 
#include <chrono>
#include <version>
 
#include "sparrow/layout/date_types.hpp"
#include "sparrow/layout/interval_types.hpp"
#include "sparrow/layout/time_types.hpp"
#include "sparrow/layout/timestamp_without_timezone_types.hpp"
#include "sparrow/utils/sequence_view.hpp"
 
#if defined(SPARROW_USE_DATE_POLYFILL)
 
#    include <date/tz.h>
 
#    if defined(__cpp_lib_format)
#        include <format>
 
template <typename T>
struct std::formatter<date::zoned_time<T>>
{
    constexpr auto parse(std::format_parse_context& ctx)
    {
        return ctx.begin();  // Simple implementation
    }
 
    auto format(const date::zoned_time<T>& date, std::format_context& ctx) const
    {
        std::ostringstream oss;
        oss << date;
        std::string date_str = oss.str();
        return std::format_to(ctx.out(), "{}", date_str);
    }
};
#    endif
 
#else
namespace date = std::chrono;
#endif
 
#include <climits>
#include <concepts>
#include <cstdint>
#include <cstring>
#include <sstream>
#include <string>
 
#include "sparrow/config/config.hpp"
#include "sparrow/utils/contracts.hpp"
#include "sparrow/utils/decimal.hpp"
#include "sparrow/utils/large_int.hpp"
#include "sparrow/utils/mp_utils.hpp"
 
 
#if __cplusplus > 202002L and defined(__STDCPP_FLOAT16_T__) and defined(__STDCPP_FLOAT32_T__) \
    and defined(__STDCPP_FLOAT64_T__)
#    define SPARROW_STD_FIXED_FLOAT_SUPPORT
#endif
 
// TODO: use exclusively `std::float16_t etc. once we switch to c++23, see
// https://en.cppreference.com/w/cpp/types/floating-point
#if defined(SPARROW_STD_FIXED_FLOAT_SUPPORT)
#    include <stdfloat>
#else
#    include "sparrow/details/3rdparty/float16_t.hpp"
#endif
 
 
namespace sparrow
{
 
// TODO: use exclusively `std::float16_t etc. once we switch to c++23, see
// https://en.cppreference.com/w/cpp/types/floating-point
#if defined(SPARROW_STD_FIXED_FLOAT_SUPPORT)
    using float16_t = std::float16_t;
    using float32_t = std::float32_t;
    using float64_t = std::float64_t;
#else
    using float16_t = half_float::half;
    using float32_t = float;
    using float64_t = double;
#endif
 
    // P0355R7 (Extending chrono to Calendars and Time Zones) has not been entirely implemented in libc++ yet.
    // See: https://libcxx.llvm.org/Status/Cxx20.html#note-p0355
    // For now, we use HowardHinnant/date as a replacement if we are compiling with libc++.
    // TODO: use the following once libc++ has full support for P0355R7.
    // using timestamp = std::chrono::time_point<std::chrono::system_clock, std::chrono::nanoseconds>;
    template <typename Duration, typename TimeZonePtr = const date::time_zone*>
    using timestamp = date::zoned_time<Duration, TimeZonePtr>;
 
    // We need to be sure the current target platform is setup to support correctly these types.
    static_assert(sizeof(float16_t) == 2);
    static_assert(sizeof(float32_t) == 4);
    static_assert(sizeof(float64_t) == 8);
    static_assert(std::is_floating_point_v<float16_t>);
    static_assert(std::is_floating_point_v<float32_t>);
    static_assert(std::is_floating_point_v<float64_t>);
    static_assert(CHAR_BIT == 8);
 
    using byte_t = std::byte;  // For now we will use this to represent raw data TODO: evaluate later if it's
                               // the right choice, switch to char if not
 
    struct null_type
    {
    };
 
    constexpr bool operator==(const null_type&, const null_type&) noexcept
    {
        return true;
    }

    enum class data_type : uint8_t
    {
        NA,
        BOOL,
        UINT8,
        INT8,
        UINT16,
        INT16,
        UINT32,
        INT32,
        UINT64,
        INT64,
        HALF_FLOAT,
        FLOAT,
        DOUBLE,
        // UTF8 variable-length string
        STRING,
        LARGE_STRING,
        // Variable-length bytes (no guarantee of UTF8-ness)
        BINARY,
        LARGE_BINARY,
        LIST,
        LARGE_LIST,
        LIST_VIEW,
        LARGE_LIST_VIEW,
        FIXED_SIZED_LIST,
        STRUCT,
        MAP,
        STRING_VIEW,
        BINARY_VIEW,
        DENSE_UNION,
        SPARSE_UNION,
        RUN_ENCODED,
        DECIMAL32,
        DECIMAL64,
        DECIMAL128,
        DECIMAL256,
        FIXED_WIDTH_BINARY,
        DATE_DAYS,
        DATE_MILLISECONDS,
        TIMESTAMP_SECONDS,
        TIMESTAMP_MILLISECONDS,
        TIMESTAMP_MICROSECONDS,
        TIMESTAMP_NANOSECONDS,
        TIME_SECONDS,
        TIME_MILLISECONDS,
        TIME_MICROSECONDS,
        TIME_NANOSECONDS,
        DURATION_SECONDS,
        DURATION_MILLISECONDS,
        DURATION_MICROSECONDS,
        DURATION_NANOSECONDS,
        INTERVAL_MONTHS,
        INTERVAL_DAYS_TIME,
        INTERVAL_MONTHS_DAYS_NANOSECONDS
    };
 
    // helper function to check if a string is all digits
    [[nodiscard]] constexpr bool all_digits(const std::string_view s)
    {
        return !s.empty()
               && std::find_if(
                      s.begin(),
                      s.end(),
                      [](unsigned char c)
                      {
                          return !std::isdigit(c);
                      }
                  ) == s.end();
    }
 
    // get the bit width for decimal value type from format
    [[nodiscard]] SPARROW_API std::size_t num_bytes_for_decimal(const char* format);

    // TODO: consider returning an optional instead
    [[nodiscard]] constexpr data_type format_to_data_type(std::string_view format)
    {
        if (format.size() == 1)
        {
            switch (format[0])
            {
                case 'n':
                    return data_type::NA;
                case 'b':
                    return data_type::BOOL;
                case 'C':
                    return data_type::UINT8;
                case 'c':
                    return data_type::INT8;
                case 'S':
                    return data_type::UINT16;
                case 's':
                    return data_type::INT16;
                case 'I':
                    return data_type::UINT32;
                case 'i':
                    return data_type::INT32;
                case 'L':
                    return data_type::UINT64;
                case 'l':
                    return data_type::INT64;
                case 'e':
                    return data_type::HALF_FLOAT;
                case 'f':
                    return data_type::FLOAT;
                case 'g':
                    return data_type::DOUBLE;
                case 'u':
                    return data_type::STRING;
                case 'U':
                    return data_type::LARGE_STRING;
                case 'z':
                    return data_type::BINARY;
                case 'Z':
                    return data_type::LARGE_BINARY;
                default:
                    return data_type::NA;
            }
        }
        else if (format == "vu")  // string view
        {
            return data_type::STRING_VIEW;
        }
        else if (format == "vz")  // binary view
        {
            return data_type::BINARY_VIEW;
        }
        else if (format.starts_with("t"))
        {
            if (format == "tdD")
            {
                return data_type::DATE_DAYS;
            }
            else if (format == "tdm")
            {
                return data_type::DATE_MILLISECONDS;
            }
            else if (format.starts_with("tss:"))
            {
                return data_type::TIMESTAMP_SECONDS;
            }
            else if (format.starts_with("tsm:"))
            {
                return data_type::TIMESTAMP_MILLISECONDS;
            }
            else if (format.starts_with("tsu:"))
            {
                return data_type::TIMESTAMP_MICROSECONDS;
            }
            else if (format.starts_with("tsn:"))
            {
                return data_type::TIMESTAMP_NANOSECONDS;
            }
            else if (format == "tDs")
            {
                return data_type::DURATION_SECONDS;
            }
            else if (format == "tDm")
            {
                return data_type::DURATION_MILLISECONDS;
            }
            else if (format == "tDu")
            {
                return data_type::DURATION_MICROSECONDS;
            }
            else if (format == "tDn")
            {
                return data_type::DURATION_NANOSECONDS;
            }
            else if (format == "tiM")
            {
                return data_type::INTERVAL_MONTHS;
            }
            else if (format == "tiD")
            {
                return data_type::INTERVAL_DAYS_TIME;
            }
            else if (format == "tin")
            {
                return data_type::INTERVAL_MONTHS_DAYS_NANOSECONDS;
            }
            else if (format == "tts")
            {
                return data_type::TIME_SECONDS;
            }
            else if (format == "ttm")
            {
                return data_type::TIME_MILLISECONDS;
            }
            else if (format == "ttu")
            {
                return data_type::TIME_MICROSECONDS;
            }
            else if (format == "ttn")
            {
                return data_type::TIME_NANOSECONDS;
            }
        }
        else if (format == "+l")
        {
            return data_type::LIST;
        }
        else if (format == "+L")
        {
            return data_type::LARGE_LIST;
        }
        else if (format == "+vl")
        {
            return data_type::LIST_VIEW;
        }
        else if (format == "+vL")
        {
            return data_type::LARGE_LIST_VIEW;
        }
        else if (format.starts_with("+w:"))
        {
            return data_type::FIXED_SIZED_LIST;
        }
        else if (format == "+s")
        {
            return data_type::STRUCT;
        }
        else if (format == "+m")
        {
            return data_type::MAP;
        }
        else if (format.starts_with("+ud:"))
        {
            return data_type::DENSE_UNION;
        }
        else if (format.starts_with("+us:"))
        {
            return data_type::SPARSE_UNION;
        }
        else if (format.starts_with("+r"))
        {
            return data_type::RUN_ENCODED;
        }
        else if (format.starts_with("d:"))
        {
            const auto num_bytes = num_bytes_for_decimal(format.data());
            switch (num_bytes)
            {
                case 4:
                    return data_type::DECIMAL32;
                case 8:
                    return data_type::DECIMAL64;
                case 16:
                    return data_type::DECIMAL128;
                case 32:
                    return data_type::DECIMAL256;
                default:
                    throw std::runtime_error("Invalid format for decimal");
            }
        }
        else if (format.starts_with("w:"))
        {
            return data_type::FIXED_WIDTH_BINARY;
        }
 
        return data_type::NA;
    }

    template <std::floating_point T>
        requires(sizeof(T) >= 2 && sizeof(T) <= 8)
    [[nodiscard]] constexpr data_type data_type_from_size(T = {}) noexcept
    {
        switch (sizeof(T))
        {
            case 2:
                return data_type::HALF_FLOAT;
            case 4:
                return data_type::FLOAT;
            case 8:
                return data_type::DOUBLE;
        }
 
        mpl::unreachable();
    }

    template <std::integral T>
        requires(sizeof(T) >= 1 && sizeof(T) <= 8)
    [[nodiscard]] constexpr data_type data_type_from_size(T = {}) noexcept
    {
        if constexpr (std::same_as<bool, T>)
        {
            return data_type::BOOL;
        }
        else if constexpr (std::signed_integral<T>)
        {
            switch (sizeof(T))
            {
                case 1:
                    return data_type::INT8;
                case 2:
                    return data_type::INT16;
                case 4:
                    return data_type::INT32;
                case 8:
                    return data_type::INT64;
            }
        }
        else
        {
            static_assert(std::unsigned_integral<T>);
            switch (sizeof(T))
            {
                case 1:
                    return data_type::UINT8;
                case 2:
                    return data_type::UINT16;
                case 4:
                    return data_type::UINT32;
                case 8:
                    return data_type::UINT64;
            }
        }
 
        mpl::unreachable();
    }
 
    namespace detail
    {
        template <class A>
        struct get_data_type_from_array;
    }
 
    // REMARK: this functions is non-applicable for the following types
    // - all decimal types because further information is needed (precision, scale)
    // - fixed-sized binary because further information is needed (element size)
    [[nodiscard]] constexpr std::string_view data_type_to_format(data_type type)
    {
        switch (type)
        {
            case data_type::NA:
                return "n";
            case data_type::BOOL:
                return "b";
            case data_type::UINT8:
                return "C";
            case data_type::INT8:
                return "c";
            case data_type::UINT16:
                return "S";
            case data_type::INT16:
                return "s";
            case data_type::UINT32:
                return "I";
            case data_type::INT32:
                return "i";
            case data_type::UINT64:
                return "L";
            case data_type::INT64:
                return "l";
            case data_type::HALF_FLOAT:
                return "e";
            case data_type::FLOAT:
                return "f";
            case data_type::DOUBLE:
                return "g";
            case data_type::STRING:
                return "u";
            case data_type::LARGE_STRING:
                return "U";
            case data_type::BINARY:
                return "z";
            case data_type::LARGE_BINARY:
                return "Z";
            case data_type::STRING_VIEW:
                return "vu";
            case data_type::BINARY_VIEW:
                return "vz";
            case data_type::DATE_DAYS:
                return "tdD";
            case data_type::DATE_MILLISECONDS:
                return "tdm";
            case data_type::TIMESTAMP_SECONDS:
                return "tss:";
            case data_type::TIMESTAMP_MILLISECONDS:
                return "tsm:";
            case data_type::TIMESTAMP_MICROSECONDS:
                return "tsu:";
            case data_type::TIMESTAMP_NANOSECONDS:
                return "tsn:";
            case data_type::DURATION_SECONDS:
                return "tDs";
            case data_type::DURATION_MILLISECONDS:
                return "tDm";
            case data_type::DURATION_MICROSECONDS:
                return "tDu";
            case data_type::DURATION_NANOSECONDS:
                return "tDn";
            case data_type::INTERVAL_MONTHS:
                return "tiM";
            case data_type::INTERVAL_DAYS_TIME:
                return "tiD";
            case data_type::INTERVAL_MONTHS_DAYS_NANOSECONDS:
                return "tin";
            case data_type::TIME_SECONDS:
                return "tts";
            case data_type::TIME_MILLISECONDS:
                return "ttm";
            case data_type::TIME_MICROSECONDS:
                return "ttu";
            case data_type::TIME_NANOSECONDS:
                return "ttn";
            case data_type::LIST:
                return "+l";
            case data_type::LARGE_LIST:
                return "+L";
            case data_type::LIST_VIEW:
                return "+vl";
            case data_type::LARGE_LIST_VIEW:
                return "+vL";
            case data_type::STRUCT:
                return "+s";
            case data_type::MAP:
                return "+m";
            case data_type::RUN_ENCODED:
                return "+r";
            default:
                throw std::runtime_error("Unsupported data type");
        }
    }

    [[nodiscard]] constexpr bool data_type_is_primitive(data_type dt) noexcept
    {
        switch (dt)
        {
            case data_type::BOOL:
            case data_type::UINT8:
            case data_type::INT8:
            case data_type::UINT16:
            case data_type::INT16:
            case data_type::UINT32:
            case data_type::INT32:
            case data_type::UINT64:
            case data_type::INT64:
            case data_type::HALF_FLOAT:
            case data_type::FLOAT:
            case data_type::DOUBLE:
                return true;
            default:
                return false;
        }
    }

    [[nodiscard]] constexpr bool data_type_is_integer(data_type dt) noexcept
    {
        switch (dt)
        {
            case data_type::UINT8:
            case data_type::INT8:
            case data_type::UINT16:
            case data_type::INT16:
            case data_type::UINT32:
            case data_type::INT32:
            case data_type::UINT64:
            case data_type::INT64:
                return true;
            default:
                return false;
        }
    }
 
    class list_value;
    class struct_value;
    class map_value;

    // NOTE: this needs to be in sync-order with `data_type`
    using all_base_types_t = mpl::typelist<
        null_type,
        bool,
        std::uint8_t,
        std::int8_t,
        std::uint16_t,
        std::int16_t,
        std::uint32_t,
        std::int32_t,
        std::uint64_t,
        std::int64_t,
        float16_t,
        float32_t,
        float64_t,
        std::string,
        std::vector<byte_t>,
        date_days,
        date_milliseconds,
        timestamp<std::chrono::seconds>,
        timestamp<std::chrono::milliseconds>,
        timestamp<std::chrono::microseconds>,
        timestamp<std::chrono::nanoseconds>,
        zoned_time_without_timezone_seconds,
        zoned_time_without_timezone_milliseconds,
        zoned_time_without_timezone_microseconds,
        zoned_time_without_timezone_nanoseconds,
        std::chrono::seconds,
        std::chrono::milliseconds,
        std::chrono::microseconds,
        std::chrono::nanoseconds,
        chrono::months,
        days_time_interval,
        month_day_nanoseconds_interval,
        chrono::time_seconds,
        chrono::time_milliseconds,
        chrono::time_microseconds,
        chrono::time_nanoseconds,
        list_value,
        struct_value,
        map_value,
        decimal<std::int32_t>,
        decimal<std::int64_t>,
        decimal<int128_t>,
        decimal<int256_t>>;

    template <class T>
    concept is_arrow_base_type = mpl::contains<all_base_types_t, T>();

    // template <class T>
    // concept is_arrow_base_type_or_compound = is_arrow_base_type<T> || is_list_value_v<T>;
    using all_base_types_extended_t = mpl::append_t<all_base_types_t, char, std::string_view>;

    template <class T>
    concept is_arrow_base_type_extended = mpl::contains<all_base_types_extended_t, T>();

    template <class T>
    using get_corresponding_arrow_type_t = std::conditional_t<std::same_as<T, std::string_view>, std::string, T>;

    template <class T>
    struct arrow_traits;
 
    namespace detail
    {
        template <template <class> class>
        struct accepts_template
        {
        };
    }
    template <class T>
    concept is_arrow_traits = mpl::is_type_instance_of_v<T, arrow_traits> and requires {
        typename T::value_type;

        // typename detail::accepts_template<T::template default_layout>;
 
        // TODO: add more interface requirements on the traits here
        // TODO: add conversion operations between bytes and the value type
    };
 

    template <class T>
    concept has_arrow_type_traits = requires { typename ::sparrow::arrow_traits<T>; }
                                    and is_arrow_traits<::sparrow::arrow_traits<T>>;

    template <class T>
    concept any_arrow_type = is_arrow_base_type<T> or has_arrow_type_traits<T>;
 

    template <has_arrow_type_traits T>
    using default_layout_t = typename arrow_traits<T>::default_layout;
 
    // For now, a tiny wrapper around data_type
    // TODO: More data and functions to come
    class data_descriptor
    {
    public:
 
        constexpr data_descriptor() noexcept
            : data_descriptor(data_type::UINT8)
        {
        }
 
        data_descriptor(std::string_view format) noexcept
            : data_descriptor(format_to_data_type(format))
        {
        }
 
        constexpr explicit data_descriptor(data_type id) noexcept
            : m_id(id)
        {
        }
 
        [[nodiscard]] constexpr data_type id() const noexcept
        {
            return m_id;
        }
 
    private:
 
        data_type m_id;
    };
 
    namespace impl
    {
        template <class C, bool is_const>
        struct get_inner_reference
            : std::conditional<is_const, typename C::inner_const_reference, typename C::inner_reference>
        {
        };
 
        template <class C, bool is_const>
        using get_inner_reference_t = typename get_inner_reference<C, is_const>::type;
    }  // namespace impl
 
    template <class T>
    concept layout_offset = std::same_as<T, std::int32_t> || std::same_as<T, std::int64_t>;
}
 
#if defined(__cpp_lib_format)
 
namespace std
{
    template <>
    struct formatter<sparrow::data_type>
    {
        constexpr auto parse(std::format_parse_context& ctx)
        {
            return ctx.begin();  // Simple implementation
        }
 
        auto format(const sparrow::data_type& data_type, std::format_context& ctx) const
        {
            static const auto get_enum_name = [](sparrow::data_type dt) -> std::string_view
            {
                using enum sparrow::data_type;
                switch (dt)
                {
                    case NA:
                        return "N/A";
                    case BOOL:
                        return "bool";
                    case UINT8:
                        return "uint8";
                    case INT8:
                        return "int8";
                    case UINT16:
                        return "uint16";
                    case INT16:
                        return "int16";
                    case UINT32:
                        return "uint32";
                    case INT32:
                        return "int32";
                    case UINT64:
                        return "uint64";
                    case INT64:
                        return "int64";
                    case HALF_FLOAT:
                        return "float16";
                    case FLOAT:
                        return "float32";
                    case DOUBLE:
                        return "double";
                    case STRING:
                        return "String";
                    case LARGE_STRING:
                        return "Large string";
                    case BINARY:
                        return "Binary";
                    case LARGE_BINARY:
                        return "Large binary";
                    case DATE_DAYS:
                        return "Date days";
                    case DATE_MILLISECONDS:
                        return "Date milliseconds";
                    case TIMESTAMP_SECONDS:
                        return "Timestamp seconds";
                    case TIMESTAMP_MILLISECONDS:
                        return "Timestamp milliseconds";
                    case TIMESTAMP_MICROSECONDS:
                        return "Timestamp microseconds";
                    case TIMESTAMP_NANOSECONDS:
                        return "Timestamp nanoseconds";
                    case DURATION_SECONDS:
                        return "Duration seconds";
                    case DURATION_MILLISECONDS:
                        return "Duration milliseconds";
                    case DURATION_MICROSECONDS:
                        return "Duration microseconds";
                    case DURATION_NANOSECONDS:
                        return "Duration nanoseconds";
                    case INTERVAL_MONTHS:
                        return "Interval months";
                    case INTERVAL_DAYS_TIME:
                        return "Interval days time";
                    case INTERVAL_MONTHS_DAYS_NANOSECONDS:
                        return "Interval months days nanoseconds";
                    case TIME_SECONDS:
                        return "Time seconds";
                    case TIME_MILLISECONDS:
                        return "Time milliseconds";
                    case TIME_MICROSECONDS:
                        return "Time microseconds";
                    case TIME_NANOSECONDS:
                        return "Time nanoseconds";
                    case LIST:
                        return "List";
                    case LARGE_LIST:
                        return "Large list";
                    case LIST_VIEW:
                        return "List view";
                    case LARGE_LIST_VIEW:
                        return "Large list view";
                    case FIXED_SIZED_LIST:
                        return "Fixed sized list";
                    case STRUCT:
                        return "Struct";
                    case MAP:
                        return "Map";
                    case DENSE_UNION:
                        return "Dense union";
                    case SPARSE_UNION:
                        return "Sparse union";
                    case RUN_ENCODED:
                        return "Run encoded";
                    case DECIMAL32:
                        return "Decimal32";
                    case DECIMAL64:
                        return "Decimal64";
                    case DECIMAL128:
                        return "Decimal128";
                    case DECIMAL256:
                        return "Decimal256";
                    case FIXED_WIDTH_BINARY:
                        return "Fixed width binary";
                    case STRING_VIEW:
                        return "String view";
                    case BINARY_VIEW:
                        return "Binary view";
                };
                return "UNKNOWN";
            };
 
            return std::format_to(ctx.out(), "{}", get_enum_name(data_type));
        }
    };
}
 
template <>
struct std::formatter<sparrow::null_type>
{
    constexpr auto parse(std::format_parse_context& ctx)
    {
        return ctx.begin();  // Simple implementation
    }
 
    auto format(const sparrow::null_type&, std::format_context& ctx) const
    {
        return std::format_to(ctx.out(), "null_type");
    }
};
 
namespace sparrow
{
    inline std::ostream& operator<<(std::ostream& os, const null_type&)
    {
        os << std::format("{}", "null");
        return os;
    }
}
 
#endif