(columns)
| 240 | end |
| 241 | |
| 242 | def build_table(columns) |
| 243 | fields = [] |
| 244 | chunked_arrays = [] |
| 245 | columns.each do |name, data| |
| 246 | case data |
| 247 | when Arrow::Array |
| 248 | chunked_array = Arrow::ChunkedArray.new([data]) |
| 249 | when Array |
| 250 | chunked_array = Arrow::ChunkedArray.new(data) |
| 251 | else |
| 252 | chunked_array = data |
| 253 | end |
| 254 | fields << Arrow::Field.new(name, chunked_array.value_data_type) |
| 255 | chunked_arrays << chunked_array |
| 256 | end |
| 257 | schema = Arrow::Schema.new(fields) |
| 258 | Arrow::Table.new(schema, chunked_arrays) |
| 259 | end |
| 260 | |
| 261 | def build_record_batch(columns) |
| 262 | n_rows = columns.collect {|_, array| array.length}.min || 0 |
nothing calls this directly
no test coverage detected