Class: Flydata::Source::ParseDumpAndSend

Inherits:
Component
  • Object
show all
Defined in:
lib/flydata/source/parse_dump_and_send.rb

Class Method Summary collapse

Instance Method Summary collapse

Methods inherited from Component

#initialize

Constructor Details

This class inherits a constructor from Flydata::Source::Component

Class Method Details

.inherited(child_class) ⇒ Object 



9
10
11
 
# File 'lib/flydata/source/parse_dump_and_send.rb', line 9

def self.inherited(child_class)
  Source.register(child_class, self)
end

Instance Method Details

#parse_dump(dump_pos_info, dmpio, create_table_block, insert_record_block, check_point_block) ⇒ Object

Public Interface: Parse Dump

dump_pos_info: A hash containing the dump position from where the parse starts dmpio: A read IO object to the dump create_table_block: A callback called with a table info before its data gets sent callback parameters: source_table: A SourceTable object insert_record_block: A callback called with parsed records callback parameters: source_table: A SourceTable object values_set: An array of arrays. Each array has values for a row. check_point_block: A callback called between transactions. Dump position gets saved for resume at this timing. callback_parameters: source_table: A SourceTable object last_pos: An IO location as of the check point bytesize: Number of bytes which have been processed source_pos: Source position of the dump state: Current dump state substate: Current dump sub-state

Returns none

Raises:



46
47
48
 
# File 'lib/flydata/source/parse_dump_and_send.rb', line 46

def parse_dump(dump_pos_info, dmpio, create_table_block, insert_record_block, check_point_block)
  raise UnsupportedSourceError,  "subclass must implement"
end

#value_converters ⇒ Object

Public Interface: Value Converters

Returns a hash of value converters which convert source values to FlyData values. Hash key is a data type for which the converter is called. A conveter takes a source value and returns a converted value.

Raises:



18
19
20
 
# File 'lib/flydata/source/parse_dump_and_send.rb', line 18

def value_converters
  raise UnsupportedSourceError,  "subclass must implement"
end