class Embulk::InputPlugin
Attributes
index[R]
page_builder[R]
schema[R]
task[R]
Public Class Methods
cleanup(task, schema, count, task_reports)
click to toggle source
# File lib/embulk/input_plugin.rb, line 16 def self.cleanup(task, schema, count, task_reports) # do nothing by default end
create_page_builder(task_source: nil, schema: nil, processor_index: nil, java_page_output: nil)
click to toggle source
# File lib/embulk/input_plugin.rb, line 37 def self.create_page_builder(task_source: nil, schema: nil, processor_index: nil, java_page_output: nil) return PageBuilder.new(schema, java_page_output) end
from_java(java_class)
click to toggle source
# File lib/embulk/input_plugin.rb, line 115 def self.from_java(java_class) JavaPlugin.ruby_adapter_class(java_class, InputPlugin, RubyAdapter) end
guess(config)
click to toggle source
# File lib/embulk/input_plugin.rb, line 20 def self.guess(config) raise NotImplementedError, "#{self}.guess(config) is not implemented. This input plugin does not support guess." end
new(task, schema, index, page_builder)
click to toggle source
# File lib/embulk/input_plugin.rb, line 24 def initialize(task, schema, index, page_builder) @task = task @schema = schema @index = index @page_builder = page_builder init end
new_java()
click to toggle source
# File lib/embulk/input_plugin.rb, line 45 def self.new_java JavaAdapter.new(self) end
resume(task, columns, count, &control)
click to toggle source
# File lib/embulk/input_plugin.rb, line 12 def self.resume(task, columns, count, &control) raise NotImplementedError, "#{self}.resume(task, columns, count, &control) is not implemented. This plugin is not resumable" end
transaction(config, &control)
click to toggle source
# File lib/embulk/input_plugin.rb, line 8 def self.transaction(config, &control) raise NotImplementedError, "InputPlugin.transaction(config, &control) must be implemented" end
Public Instance Methods
init()
click to toggle source
# File lib/embulk/input_plugin.rb, line 34 def init end
run()
click to toggle source
# File lib/embulk/input_plugin.rb, line 41 def run raise NotImplementedError, "InputPlugin#run must be implemented" end