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

Version Path
embulk-0.6.12 lib/embulk/page_builder.rb
embulk-0.6.11 lib/embulk/page_builder.rb
embulk-0.6.10 lib/embulk/page_builder.rb
embulk-0.6.9 lib/embulk/page_builder.rb
embulk-0.6.8 lib/embulk/page_builder.rb
embulk-0.6.7 lib/embulk/page_builder.rb
embulk-0.6.6 lib/embulk/page_builder.rb
embulk-0.6.5 lib/embulk/page_builder.rb
embulk-0.6.4 lib/embulk/page_builder.rb
embulk-0.6.3 lib/embulk/page_builder.rb
embulk-0.6.2 lib/embulk/page_builder.rb
embulk-0.6.1 lib/embulk/page_builder.rb
embulk-0.6.0 lib/embulk/page_builder.rb
embulk-0.5.5 lib/embulk/page_builder.rb
embulk-0.5.4 lib/embulk/page_builder.rb
embulk-0.5.3 lib/embulk/page_builder.rb
embulk-0.5.2 lib/embulk/page_builder.rb
embulk-0.5.1 lib/embulk/page_builder.rb
embulk-0.5.0 lib/embulk/page_builder.rb
embulk-0.4.10 lib/embulk/page_builder.rb