# Licensed to the Apache Software Foundation (ASF) under one # or more contributor license agreements. See the NOTICE file # distributed with this work for additional information # regarding copyright ownership. The ASF licenses this file # to you 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. module Arrow class Datum class << self # @api private def try_convert(value) case value when Array ArrayDatum.new(value) when ChunkedArray ChunkedArrayDatum.new(value) when Scalar ScalarDatum.new(value) when ::Array ArrayDatum.new(ArrayBuilder.build(value)) when Integer case value when (0..((2 ** 8) - 1)) try_convert(UInt8Scalar.new(value)) when ((-(2 ** 7))..((2 ** 7) - 1)) try_convert(Int8Scalar.new(value)) when (0..((2 ** 16) - 1)) try_convert(UInt16Scalar.new(value)) when ((-(2 ** 15))..((2 ** 15) - 1)) try_convert(Int16Scalar.new(value)) when (0..((2 ** 32) - 1)) try_convert(UInt32Scalar.new(value)) when ((-(2 ** 31))..((2 ** 31) - 1)) try_convert(Int32Scalar.new(value)) when (0..((2 ** 64) - 1)) try_convert(UInt64Scalar.new(value)) when ((-(2 ** 63))..((2 ** 63) - 1)) try_convert(Int64Scalar.new(value)) else nil end when Float try_convert(DoubleScalar.new(value)) when true, false try_convert(BooleanScalar.new(value)) when String if value.ascii_only? or value.encoding == Encoding::UTF_8 if value.bytesize <= ((2 ** 31) - 1) try_convert(StringScalar.new(value)) else try_convert(LargeStringScalar.new(value)) end else if value.bytesize <= ((2 ** 31) - 1) try_convert(BinaryScalar.new(value)) else try_convert(LargeBinaryScalar.new(value)) end end when Date date32_value = (value - Date32ArrayBuilder::UNIX_EPOCH).to_i try_convert(Date32Scalar.new(date32_value)) when Time case value.unit when TimeUnit::SECOND, TimeUnit::MILLI data_type = Time32DataType.new(value.unit) scalar_class = Time32Scalar else data_type = Time64DataType.new(value.unit) scalar_class = Time64Scalar end try_convert(scalar_class.new(data_type, value.value)) when ::Time data_type = TimestampDataType.new(:nano) timestamp_value = value.to_i * 1_000_000_000 + value.nsec try_convert(TimestampScalar.new(data_type, timestamp_value)) when Decimal128 data_type = TimestampDataType.new(:nano) timestamp_value = value.to_i * 1_000_000_000 + value.nsec try_convert(Decimal128Scalar.new(data_type, timestamp_value)) else nil end end end end end