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