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