Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
19 changes: 18 additions & 1 deletion ruby/red-arrow-format/lib/arrow-format/type.rb
Original file line number Diff line number Diff line change
Expand Up @@ -388,14 +388,27 @@ def build_array(size, validity_buffer, values_buffer)
end

class TimeType < TemporalType
attr_reader :bit_width
attr_reader :unit
def initialize(unit)
def initialize(bit_width, unit)
super()
@bit_width = bit_width
@unit = unit
end

def to_flatbuffers
fb_type = FB::Time::Data.new
fb_type.bit_width = @bit_width
fb_type.unit = FB::TimeUnit.try_convert(@unit.to_s.upcase)
fb_type
end
end

class Time32Type < TimeType
def initialize(unit)
super(32, unit)
end

def name
"Time32"
end
Expand All @@ -406,6 +419,10 @@ def build_array(size, validity_buffer, values_buffer)
end

class Time64Type < TimeType
def initialize(unit)
super(64, unit)
end

def name
"Time64"
end
Expand Down
3 changes: 2 additions & 1 deletion ruby/red-arrow-format/test/test-reader.rb
Original file line number Diff line number Diff line change
Expand Up @@ -225,7 +225,8 @@ def setup(&block)
end

def build_array
Arrow::Time32Array.new(:second, [@time_00_00_10, nil, @time_00_01_10])
Arrow::Time32Array.new(:second,
[@time_00_00_10, nil, @time_00_01_10])
end

def test_read
Expand Down
114 changes: 114 additions & 0 deletions ruby/red-arrow-format/test/test-writer.rb
Original file line number Diff line number Diff line change
Expand Up @@ -46,6 +46,20 @@ def convert_type(red_arrow_type)
ArrowFormat::Date32Type.singleton
when Arrow::Date64DataType
ArrowFormat::Date64Type.singleton
when Arrow::Time32DataType
case red_arrow_type.unit.nick
when "second"
ArrowFormat::Time32Type.new(:second)
when "milli"
ArrowFormat::Time32Type.new(:millisecond)
end
when Arrow::Time64DataType
case red_arrow_type.unit.nick
when "micro"
ArrowFormat::Time64Type.new(:microsecond)
when "nano"
ArrowFormat::Time64Type.new(:nanosecond)
end
when Arrow::BinaryDataType
ArrowFormat::BinaryType.singleton
when Arrow::LargeBinaryDataType
Expand Down Expand Up @@ -268,6 +282,106 @@ def test_write
end
end

sub_test_case("Time32(:second)") do
def setup(&block)
@time_00_00_10 = 10
@time_00_01_10 = 60 + 10
super(&block)
end

def build_array
Arrow::Time32Array.new(:second,
[@time_00_00_10, nil, @time_00_01_10])
end

def test_write
assert_equal([
Arrow::Time.new(:second, @time_00_00_10),
nil,
Arrow::Time.new(:second, @time_00_01_10),
],
@values)
end
end

sub_test_case("Time32(:millisecond)") do
def setup(&block)
@time_00_00_10_000 = 10 * 1000
@time_00_01_10_000 = (60 + 10) * 1000
super(&block)
end

def build_array
Arrow::Time32Array.new(:milli,
[
@time_00_00_10_000,
nil,
@time_00_01_10_000,
])
end

def test_write
assert_equal([
Arrow::Time.new(:milli, @time_00_00_10_000),
nil,
Arrow::Time.new(:milli, @time_00_01_10_000),
],
@values)
end
end

sub_test_case("Time64(:microsecond)") do
def setup(&block)
@time_00_00_10_000_000 = 10 * 1_000_000
@time_00_01_10_000_000 = (60 + 10) * 1_000_000
super(&block)
end

def build_array
Arrow::Time64Array.new(:micro,
[
@time_00_00_10_000_000,
nil,
@time_00_01_10_000_000,
])
end

def test_write
assert_equal([
Arrow::Time.new(:micro, @time_00_00_10_000_000),
nil,
Arrow::Time.new(:micro, @time_00_01_10_000_000),
],
@values)
end
end

sub_test_case("Time64(:nanosecond)") do
def setup(&block)
@time_00_00_10_000_000_000 = 10 * 1_000_000_000
@time_00_01_10_000_000_000 = (60 + 10) * 1_000_000_000
super(&block)
end

def build_array
Arrow::Time64Array.new(:nano,
[
@time_00_00_10_000_000_000,
nil,
@time_00_01_10_000_000_000,
])
end

def test_write
assert_equal([
Arrow::Time.new(:nano, @time_00_00_10_000_000_000),
nil,
Arrow::Time.new(:nano, @time_00_01_10_000_000_000),
],
@values)
end
end

sub_test_case("Binary") do
def build_array
Arrow::BinaryArray.new(["Hello".b, nil, "World".b])
Expand Down
Loading