Class: Embulk::OutputPlugin

Inherits:
Object
  • Object
show all
Defined in:
lib/embulk/output_plugin.rb

Direct Known Subclasses

OutputExample

Defined Under Namespace

Classes: JavaAdapter

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(task, schema, index) ⇒ OutputPlugin

Returns a new instance of OutputPlugin.



13
14
15
16
17
 
# File 'lib/embulk/output_plugin.rb', line 13

def initialize(task, schema, index)
  @task = task
  @schema = schema
  @index = index
end

Instance Attribute Details

#index ⇒ Object (readonly)

Returns the value of attribute index.



19
20
21
 
# File 'lib/embulk/output_plugin.rb', line 19

def index
  @index
end

#schema ⇒ Object (readonly)

Returns the value of attribute schema.



19
20
21
 
# File 'lib/embulk/output_plugin.rb', line 19

def schema
  @schema
end

#task ⇒ Object (readonly)

Returns the value of attribute task.



19
20
21
 
# File 'lib/embulk/output_plugin.rb', line 19

def task
  @task
end

Class Method Details

.java_object ⇒ Object 



39
40
41
 
# File 'lib/embulk/output_plugin.rb', line 39

def self.java_object
  JavaAdapter.new(self)
end

.transaction(config, schema, processor_count) {|config| ... } ⇒ Object

Yields:

  • (config) 


8
9
10
11
 
# File 'lib/embulk/output_plugin.rb', line 8

def self.transaction(config, schema, processor_count, &control)
  yield(config)
  return {}
end

Instance Method Details

#abort ⇒ Object 



31
32
 
# File 'lib/embulk/output_plugin.rb', line 31

def abort
end

#add(page) ⇒ Object

Raises:

  • (NotImplementedError) 


21
22
23
 
# File 'lib/embulk/output_plugin.rb', line 21

def add(page)
  raise NotImplementedError, "OutputPlugin#add(page) must be implemented"
end

#close ⇒ Object 



28
29
 
# File 'lib/embulk/output_plugin.rb', line 28

def close
end

#commit ⇒ Object 



34
35
36
 
# File 'lib/embulk/output_plugin.rb', line 34

def commit
  {}
end

#finish ⇒ Object 



25
26
 
# File 'lib/embulk/output_plugin.rb', line 25

def finish
end