class Embulk::OutputPlugin
Attributes
index[R]
schema[R]
task[R]
Public Class Methods
cleanup(task, schema, count, task_reports)
click to toggle source
# File lib/embulk/output_plugin.rb, line 17 def self.cleanup(task, schema, count, task_reports) # do nothing by default end
from_java(java_class)
click to toggle source
# File lib/embulk/output_plugin.rb, line 136 def self.from_java(java_class) JavaPlugin.ruby_adapter_class(java_class, OutputPlugin, RubyAdapter) end
new(task, schema, index)
click to toggle source
# File lib/embulk/output_plugin.rb, line 21 def initialize(task, schema, index) @task = task @schema = schema @index = index init end
new_java()
click to toggle source
# File lib/embulk/output_plugin.rb, line 50 def self.new_java JavaAdapter.new(self) end
resume(task, schema, count, &control)
click to toggle source
# File lib/embulk/output_plugin.rb, line 13 def self.resume(task, schema, count, &control) raise NotImplementedError, "#{self}.resume(task, schema, count, &control) is not implemented. This plugin is not resumable" end
transaction(config, schema, task_count) { |config| ... }
click to toggle source
# File lib/embulk/output_plugin.rb, line 8 def self.transaction(config, schema, task_count, &control) yield(config) return {} end
Public Instance Methods
abort()
click to toggle source
# File lib/embulk/output_plugin.rb, line 43 def abort end
add(page)
click to toggle source
# File lib/embulk/output_plugin.rb, line 33 def add(page) raise NotImplementedError, "OutputPlugin#add(page) must be implemented" end
close()
click to toggle source
# File lib/embulk/output_plugin.rb, line 40 def close end
commit()
click to toggle source
# File lib/embulk/output_plugin.rb, line 46 def commit {} end
finish()
click to toggle source
# File lib/embulk/output_plugin.rb, line 37 def finish end
init()
click to toggle source
# File lib/embulk/output_plugin.rb, line 30 def init end