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