Class: Embulk::InputPlugin::JavaAdapter

Inherits:
Object
  • Object
show all
Includes:
Java::InputPlugin
Defined in:
lib/embulk/input_plugin.rb

Instance Method Summary collapse

Constructor Details

#initialize(ruby_class) ⇒ JavaAdapter

Returns a new instance of JavaAdapter.



31
32
33
 
# File 'lib/embulk/input_plugin.rb', line 31

def initialize(ruby_class)
  @ruby_class = ruby_class
end

Instance Method Details

#run(java_task_source, java_schema, processor_index, java_output) ⇒ Object 



49
50
51
52
53
54
55
 
# File 'lib/embulk/input_plugin.rb', line 49

def run(java_task_source, java_schema, processor_index, java_output)
  task_source = DataSource.from_java_object(java_task_source)
  schema = Schema.from_java_object(java_schema)
  page_builder = PageBuilder.new(schema, java_output)
  commit_report_hash = @ruby_class.new(task_source, schema, processor_index, page_builder).run
  return DataSource.from_ruby_hash(commit_report_hash).java_object
end

#transaction(java_config, java_control) ⇒ Object 



35
36
37
38
39
40
41
42
43
44
45
46
47
 
# File 'lib/embulk/input_plugin.rb', line 35

def transaction(java_config, java_control)
  config = DataSource.from_java_object(java_config)
  next_config_hash = @ruby_class.transaction(config) do |task_source_hash,columns,processor_count|
    java_task_source = DataSource.from_ruby_hash(task_source_hash).java_object
    java_schema = Schema.new(columns).java_object
    java_commit_reports = java_control.run(java_task_source, java_schema, processor_count)
    java_commit_reports.map {|java_commit_report|
      DataSource.from_java_object(java_commit_report)
    }
  end
  # TODO check return type of #transaction
  return DataSource.from_ruby_hash(next_config_hash).java_object
end