module Fluent::Plugin::Buffer::ArrowBufferStringBuilder

Private Instance Methods

build_arrow_buffer_string() click to toggle source
# File lib/fluent/plugin/buffer/arrow_buffer_string_builder.rb, line 12
def build_arrow_buffer_string
  record_batch = ::Arrow::RecordBatch.new(@schema, each_record)
  arrow_buf = ::Arrow::ResizableBuffer.new(bytesize * 1.2)
  record_batch.to_table.save(arrow_buf,
                             format: @format,
                             chunk_size: @chunk_size)
  arrow_buf.data.to_s
end
each_record(&block) click to toggle source
# File lib/fluent/plugin/buffer/arrow_buffer_string_builder.rb, line 8
def each_record(&block)
  raise NotImplementedError
end