class Fluent::Plugin::ArrowMemoryBuffer

Attributes

arrow_schema[R]

Public Instance Methods

configure(conf) click to toggle source
Calls superclass method
# File lib/fluent/plugin/buf_arrow_memory.rb, line 31
def configure(conf)
  super

  # [{"name" => foo1, "type" => "uint64"}, {"name" => foo2, "type" => "struct", "fields" => [{"name" => bar1, "type" => "string"}]}
  @arrow_schema = ::Arrow::Schema.new(@schema)
end
generate_chunk(metadata) click to toggle source
# File lib/fluent/plugin/buf_arrow_memory.rb, line 42
def generate_chunk(metadata)
  Fluent::Plugin::Buffer::ArrowMemoryChunk.new(metadata, @arrow_schema, chunk_size: @row_group_chunk_size, format: @arrow_format)
end
resume() click to toggle source
# File lib/fluent/plugin/buf_arrow_memory.rb, line 38
def resume
  return {}, []
end