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