Class: Embulk::PageBuilder

Inherits:
Object
  • Object
show all
Defined in:
lib/embulk/page_builder.rb

Instance Method Summary collapse

Constructor Details

#initialize(schema, java_page_output) ⇒ PageBuilder

Returns a new instance of PageBuilder.



4
5
6
7
# File 'lib/embulk/page_builder.rb', line 4

def initialize(schema, java_page_output)
  @page_builder = Java::PageBuilder.new(Java::Injected::BufferAllocator, schema.to_java, java_page_output)
  @schema = schema
end

Instance Method Details

#add(record) ⇒ Object



9
10
11
# File 'lib/embulk/page_builder.rb', line 9

def add(record)
  @schema.write_record(@page_builder, record)
end

#closeObject



17
18
19
# File 'lib/embulk/page_builder.rb', line 17

def close
  @page_builder.close
end

#finishObject



13
14
15
# File 'lib/embulk/page_builder.rb', line 13

def finish
  @page_builder.finish
end