Class: Embulk::FilterPlugin
- Inherits:
-
Object
- Object
- Embulk::FilterPlugin
show all
- Defined in:
- lib/embulk/filter_plugin.rb
Defined Under Namespace
Modules: RubyAdapter
Classes: JavaAdapter
Instance Attribute Summary collapse
Class Method Summary
collapse
Instance Method Summary
collapse
Constructor Details
#initialize(task, in_schema, out_schema, page_builder) ⇒ FilterPlugin
Returns a new instance of FilterPlugin.
14
15
16
17
18
19
20
|
# 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
|
Instance Attribute Details
#in_schema ⇒ Object
Returns the value of attribute in_schema.
22
23
24
|
# File 'lib/embulk/filter_plugin.rb', line 22
def in_schema
@in_schema
end
|
#out_schema ⇒ Object
Returns the value of attribute out_schema.
22
23
24
|
# File 'lib/embulk/filter_plugin.rb', line 22
def out_schema
@out_schema
end
|
#page_builder ⇒ Object
Returns the value of attribute page_builder.
22
23
24
|
# File 'lib/embulk/filter_plugin.rb', line 22
def page_builder
@page_builder
end
|
#task ⇒ Object
Returns the value of attribute task.
22
23
24
|
# File 'lib/embulk/filter_plugin.rb', line 22
def task
@task
end
|
Class Method Details
.from_java(java_class) ⇒ Object
.new_java ⇒ Object
37
38
39
|
# File 'lib/embulk/filter_plugin.rb', line 37
def self.new_java
JavaAdapter.new(self)
end
|
.transaction(config, in_schema) {|config| ... } ⇒ Object
9
10
11
12
|
# File 'lib/embulk/filter_plugin.rb', line 9
def self.transaction(config, in_schema, &control)
yield(config)
return {}
end
|
Instance Method Details
#add(page) ⇒ Object
27
28
29
|
# File 'lib/embulk/filter_plugin.rb', line 27
def add(page)
raise NotImplementedError, "FilterPlugin#add(page) must be implemented"
end
|
#close ⇒ Object
34
35
|
# File 'lib/embulk/filter_plugin.rb', line 34
def close
end
|
#finish ⇒ Object
31
32
|
# File 'lib/embulk/filter_plugin.rb', line 31
def finish
end
|
#init ⇒ Object
24
25
|
# File 'lib/embulk/filter_plugin.rb', line 24
def init
end
|