class Embulk::Input::ExampleInputPlugin

def self.transaction(config, &control)
  files = ['file1', 'file2']
  task = {
    'files' => files,
    'hostname' => config.param('hostname', :string, default: nil)
  }
  columns = [
    Column.new(0, 'file', :string),
    Column.new(1, 'hostname', :string),
    Column.new(2, 'col0', :long),
    Column.new(3, 'col1', :double),
  ]
  resume(task, columns, files.length, &control)
end