class Embulk::Page

TODO pure-ruby page reader

Attributes

schema[R]

Public Class Methods

new(java_page, schema) click to toggle source
# File lib/embulk/page.rb, line 9
def initialize(java_page, schema)
  @java_page = java_page
  @schema = schema
end

Public Instance Methods

each() { |read_record| ... } click to toggle source
# File lib/embulk/page.rb, line 16
def each
  schema = @schema
  reader = Java::PageReader.new(schema.to_java)
  begin
    reader.setPage(@java_page)
    while reader.nextRecord
      yield schema.read_record(reader)
    end
  ensure
    reader.close
  end
end