class Embulk::ParserPlugin::JavaAdapter

def transaction(java_config, java_control)
  config = DataSource.from_java(java_config)
  @ruby_class.transaction(config) do |task_source_hash,columns|
    java_task_source = DataSource.from_ruby_hash(task_source_hash).to_java
    java_schema = Schema.new(columns).to_java
    java_control.run(java_task_source, java_schema)
  end
  nil
end