Sha256: 0acaf3af6ec6d719e5121ba5f7257498df8bc634980ccfec73ed551cb3546656
Contents?: true
Size: 412 Bytes
Versions: 30
Compression:
Stored size: 412 Bytes
Contents
module Embulk class PageBuilder def initialize(schema, java_page_output) @page_builder = Java::PageBuilder.new(Java::Injected::BufferAllocator, schema.to_java, java_page_output) @schema = schema end def add(record) @schema.write_record(@page_builder, record) end def finish @page_builder.finish end def close @page_builder.close end end end
Version data entries
30 entries across 30 versions & 1 rubygems