Class: Embulk::OutputPlugin::JavaAdapter

Inherits:
Object
  • Object
show all
Includes:
Java::OutputPlugin
Defined in:
lib/embulk/output_plugin.rb

Defined Under Namespace

Classes: OutputAdapter

Instance Method Summary collapse

Constructor Details

#initialize(ruby_class) ⇒ JavaAdapter

Returns a new instance of JavaAdapter.



54
55
56
 
# File 'lib/embulk/output_plugin.rb', line 54

def initialize(ruby_class)
  @ruby_class = ruby_class
end

Instance Method Details

#cleanup(java_task_source, java_schema, processor_count, java_commit_reports) ⇒ Object 



86
87
88
89
90
91
92
 
# File 'lib/embulk/output_plugin.rb', line 86

def cleanup(java_task_source, java_schema, processor_count, java_commit_reports)
  task_source = DataSource.from_java_object(java_task_source)
  schema = Schema.from_java_object(java_schema)
  commit_reports = java_commit_reports.map {|c| DataSource.from_java_object(c) }
  @ruby_class.cleanup(task_source, schema, processor_count, commit_reports)
  return nil
end

#open(java_task_source, java_schema, processor_index) ⇒ Object 



94
95
96
97
98
99
 
# File 'lib/embulk/output_plugin.rb', line 94

def open(java_task_source, java_schema, processor_index)
  task_source = DataSource.from_java_object(java_task_source)
  schema = Schema.from_java_object(java_schema)
  ruby_object = @ruby_class.new(task_source, schema, processor_index)
  return OutputAdapter.new(ruby_object, schema)
end

#resume(java_task_source, java_schema, processor_count, java_control) ⇒ Object 



72
73
74
75
76
77
78
79
80
81
82
83
84
 
# File 'lib/embulk/output_plugin.rb', line 72

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

#transaction(java_config, java_schema, processor_count, java_control) ⇒ Object 



58
59
60
61
62
63
64
65
66
67
68
69
70
 
# File 'lib/embulk/output_plugin.rb', line 58

def transaction(java_config, java_schema, processor_count, java_control)
  config = DataSource.from_java_object(java_config)
  schema = Schema.from_java_object(java_schema)
  next_config_hash = @ruby_class.transaction(config, schema, processor_count) do |task_source_hash|
    java_task_source = DataSource.from_ruby_hash(task_source_hash).java_object
    java_commit_reports = java_control.run(java_task_source)
    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