class Embulk::OutputPlugin::JavaAdapter::OutputAdapter

def abort
  @ruby_object.abort
end

def add(java_page)
  # TODO reuse page reader
  @ruby_object.add Page.new(java_page, @schema)
end

def close
  @ruby_object.close
end

def commit
  task_report_hash = @ruby_object.commit
  return DataSource.from_ruby_hash(task_report_hash).to_java
end

def finish
  @ruby_object.finish
end

def initialize(ruby_object, schema)
  @ruby_object = ruby_object
  @schema = schema
end