Sha256: 0a780aff5e1951c2f4e63b1f4ed06c8c46d29b72766e879664a20f850c3dbb44
Contents?: true
Size: 494 Bytes
Versions: 189
Compression:
Stored size: 494 Bytes
Contents
module Embulk
# TODO pure-ruby page reader
class Page
include Enumerable
def initialize(java_page, schema)
@java_page = java_page
@schema = schema
end
attr_reader :schema
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
end
end
Version data entries
189 entries across 189 versions & 1 rubygems