dispatch.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 mplied.
// See the License for the specific language governing permissions and
// limitations under the License.
 
#pragma once
 
#include <type_traits>
 
#include "sparrow/layout/array_wrapper.hpp"
#include "sparrow/layout/decimal_array.hpp"
#include "sparrow/layout/dictionary_encoded_array.hpp"
#include "sparrow/layout/fixed_width_binary_array.hpp"
#include "sparrow/layout/list_layout/list_array.hpp"
#include "sparrow/layout/nested_value_types.hpp"
#include "sparrow/layout/null_array.hpp"
#include "sparrow/layout/primitive_layout/primitive_array.hpp"
#include "sparrow/layout/run_end_encoded_layout/run_end_encoded_array.hpp"
#include "sparrow/layout/struct_layout/struct_array.hpp"
#include "sparrow/layout/temporal/date_array.hpp"
#include "sparrow/layout/temporal/duration_array.hpp"
#include "sparrow/layout/temporal/interval_array.hpp"
#include "sparrow/layout/temporal/time_array.hpp"
#include "sparrow/layout/temporal/timestamp_array.hpp"
#include "sparrow/layout/temporal/timestamp_without_timezone_array.hpp"
#include "sparrow/layout/union_array.hpp"
#include "sparrow/layout/variable_size_binary_layout/variable_size_binary_array.hpp"
#include "sparrow/types/data_traits.hpp"
#include "sparrow/types/data_type.hpp"
#include "sparrow/utils/temporal.hpp"
 
namespace sparrow
{
    template <class F>
    using visit_result_t = std::invoke_result_t<F, null_array>;
 
    template <class F>
    [[nodiscard]] visit_result_t<F> visit(F&& func, const array_wrapper& ar)
    {
        if (ar.is_dictionary())
        {
            switch (ar.data_type())
            {
                case data_type::UINT8:
                    return func(unwrap_array<dictionary_encoded_array<std::uint8_t>>(ar));
                case data_type::INT8:
                    return func(unwrap_array<dictionary_encoded_array<std::int8_t>>(ar));
                case data_type::UINT16:
                    return func(unwrap_array<dictionary_encoded_array<std::uint16_t>>(ar));
                case data_type::INT16:
                    return func(unwrap_array<dictionary_encoded_array<std::int16_t>>(ar));
                case data_type::UINT32:
                    return func(unwrap_array<dictionary_encoded_array<std::uint32_t>>(ar));
                case data_type::INT32:
                    return func(unwrap_array<dictionary_encoded_array<std::int32_t>>(ar));
                case data_type::UINT64:
                    return func(unwrap_array<dictionary_encoded_array<std::uint64_t>>(ar));
                case data_type::INT64:
                    return func(unwrap_array<dictionary_encoded_array<std::int64_t>>(ar));
                default:
                    throw std::runtime_error("data datype of dictionary encoded array must be an integer");
            }
        }
        else
        {
            switch (ar.data_type())
            {
                case data_type::NA:
                    return func(unwrap_array<null_array>(ar));
                case data_type::BOOL:
                    return func(unwrap_array<primitive_array<bool>>(ar));
                case data_type::UINT8:
                    return func(unwrap_array<primitive_array<std::uint8_t>>(ar));
                case data_type::INT8:
                    return func(unwrap_array<primitive_array<std::int8_t>>(ar));
                case data_type::UINT16:
                    return func(unwrap_array<primitive_array<std::uint16_t>>(ar));
                case data_type::INT16:
                    return func(unwrap_array<primitive_array<std::int16_t>>(ar));
                case data_type::UINT32:
                    return func(unwrap_array<primitive_array<std::uint32_t>>(ar));
                case data_type::INT32:
                    return func(unwrap_array<primitive_array<std::int32_t>>(ar));
                case data_type::UINT64:
                    return func(unwrap_array<primitive_array<std::uint64_t>>(ar));
                case data_type::INT64:
                    return func(unwrap_array<primitive_array<std::int64_t>>(ar));
                case data_type::HALF_FLOAT:
                    return func(unwrap_array<primitive_array<float16_t>>(ar));
                case data_type::FLOAT:
                    return func(unwrap_array<primitive_array<float32_t>>(ar));
                case data_type::DOUBLE:
                    return func(unwrap_array<primitive_array<float64_t>>(ar));
                case data_type::STRING:
                    return func(unwrap_array<string_array>(ar));
                case data_type::LARGE_STRING:
                    return func(unwrap_array<big_string_array>(ar));
                case data_type::BINARY:
                    return func(unwrap_array<binary_array>(ar));
                case data_type::LARGE_BINARY:
                    return func(unwrap_array<big_binary_array>(ar));
                case data_type::RUN_ENCODED:
                    return func(unwrap_array<run_end_encoded_array>(ar));
                case data_type::LIST:
                    return func(unwrap_array<list_array>(ar));
                case data_type::LARGE_LIST:
                    return func(unwrap_array<big_list_array>(ar));
                case data_type::LIST_VIEW:
                    return func(unwrap_array<list_view_array>(ar));
                case data_type::LARGE_LIST_VIEW:
                    return func(unwrap_array<big_list_view_array>(ar));
                case data_type::FIXED_SIZED_LIST:
                    return func(unwrap_array<fixed_sized_list_array>(ar));
                case data_type::STRUCT:
                    return func(unwrap_array<struct_array>(ar));
                case data_type::DENSE_UNION:
                    return func(unwrap_array<dense_union_array>(ar));
                case data_type::SPARSE_UNION:
                    return func(unwrap_array<sparse_union_array>(ar));
                case data_type::DECIMAL32:
                    return func(unwrap_array<decimal_32_array>(ar));
                case data_type::DECIMAL64:
                    return func(unwrap_array<decimal_64_array>(ar));
                case data_type::DECIMAL128:
                    return func(unwrap_array<decimal_128_array>(ar));
                case data_type::DECIMAL256:
                    return func(unwrap_array<decimal_256_array>(ar));
                case data_type::FIXED_WIDTH_BINARY:
                    return func(unwrap_array<fixed_width_binary_array>(ar));
                case sparrow::data_type::DATE_DAYS:
                    return func(unwrap_array<date_days_array>(ar));
                case data_type::DATE_MILLISECONDS:
                    return func(unwrap_array<date_milliseconds_array>(ar));
                case data_type::TIMESTAMP_SECONDS:
                    if (get_timezone(ar.get_arrow_proxy()) == nullptr)
                    {
                        return func(unwrap_array<timestamp_without_timezone_seconds_array>(ar));
                    }
                    else
                    {
                        return func(unwrap_array<timestamp_seconds_array>(ar));
                    }
                case data_type::TIMESTAMP_MILLISECONDS:
                    if (get_timezone(ar.get_arrow_proxy()) == nullptr)
                    {
                        return func(unwrap_array<timestamp_without_timezone_milliseconds_array>(ar));
                    }
                    else
                    {
                        return func(unwrap_array<timestamp_milliseconds_array>(ar));
                    }
                case data_type::TIMESTAMP_MICROSECONDS:
                    if (get_timezone(ar.get_arrow_proxy()) == nullptr)
                    {
                        return func(unwrap_array<timestamp_without_timezone_microseconds_array>(ar));
                    }
                    else
                    {
                        return func(unwrap_array<timestamp_microseconds_array>(ar));
                    }
                case data_type::TIMESTAMP_NANOSECONDS:
                    if (get_timezone(ar.get_arrow_proxy()) == nullptr)
                    {
                        return func(unwrap_array<timestamp_without_timezone_nanoseconds_array>(ar));
                    }
                    else
                    {
                        return func(unwrap_array<timestamp_nanoseconds_array>(ar));
                    }
                case data_type::TIME_SECONDS:
                    return func(unwrap_array<time_seconds_array>(ar));
                case data_type::TIME_MILLISECONDS:
                    return func(unwrap_array<time_milliseconds_array>(ar));
                case data_type::TIME_MICROSECONDS:
                    return func(unwrap_array<time_microseconds_array>(ar));
                case data_type::TIME_NANOSECONDS:
                    return func(unwrap_array<time_nanoseconds_array>(ar));
                case data_type::DURATION_SECONDS:
                    return func(unwrap_array<duration_seconds_array>(ar));
                case data_type::DURATION_MILLISECONDS:
                    return func(unwrap_array<duration_milliseconds_array>(ar));
                case data_type::DURATION_MICROSECONDS:
                    return func(unwrap_array<duration_microseconds_array>(ar));
                case data_type::DURATION_NANOSECONDS:
                    return func(unwrap_array<duration_nanoseconds_array>(ar));
                case data_type::INTERVAL_MONTHS:
                    return func(unwrap_array<months_interval_array>(ar));
                case data_type::INTERVAL_DAYS_TIME:
                    return func(unwrap_array<days_time_interval_array>(ar));
                case data_type::INTERVAL_MONTHS_DAYS_NANOSECONDS:
                    return func(unwrap_array<month_day_nanoseconds_interval_array>(ar));
                default:
                    throw std::invalid_argument("array type not supported");
            }
        }
    }
}