class Embulk::FilterPlugin

Attributes

in_schema[R]
out_schema[R]
page_builder[R]
task[R]

Public Class Methods

from_java(java_class) click to toggle source
# File lib/embulk/filter_plugin.rb, line 93
def self.from_java(java_class)
  JavaPlugin.ruby_adapter_class(java_class, FilterPlugin, RubyAdapter)
end
new(task, in_schema, out_schema, page_builder) click to toggle source
# File lib/embulk/filter_plugin.rb, line 14
def initialize(task, in_schema, out_schema, page_builder)
  @task = task
  @in_schema = in_schema
  @out_schema = out_schema
  @page_builder = page_builder
  init
end
new_java() click to toggle source
# File lib/embulk/filter_plugin.rb, line 37
def self.new_java
  JavaAdapter.new(self)
end
transaction(config, in_schema) { |config| ... } click to toggle source
# File lib/embulk/filter_plugin.rb, line 9
def self.transaction(config, in_schema, &control)
  yield(config)
  return {}
end

Public Instance Methods

add(page) click to toggle source
# File lib/embulk/filter_plugin.rb, line 27
def add(page)
  raise NotImplementedError, "FilterPlugin#add(page) must be implemented"
end
close() click to toggle source
# File lib/embulk/filter_plugin.rb, line 34
def close
end
finish() click to toggle source
# File lib/embulk/filter_plugin.rb, line 31
def finish
end
init() click to toggle source
# File lib/embulk/filter_plugin.rb, line 24
def init
end