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