Contents

module Embulk

  class PageBuilder
    def initialize(schema, java_page_output)
      @page_builder = Java::PageBuilder.new(Java::Injected::BufferAllocator, schema.java_object, 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

6 entries across 6 versions & 1 rubygems

Version	Path
embulk-0.3.2	lib/embulk/page_builder.rb
embulk-0.3.1	lib/embulk/page_builder.rb
embulk-0.3.0	lib/embulk/page_builder.rb
embulk-0.2.1	lib/embulk/page_builder.rb
embulk-0.2.0	lib/embulk/page_builder.rb
embulk-0.1.0	lib/embulk/page_builder.rb