Method: Flydata::SourceOracle::DumpParser#initialize

Defined in:
lib/flydata/source_oracle/parse_dump_and_send.rb

#initialize(dump_pos_info, dmpio, create_table_block, insert_record_block, check_point_block) ⇒ DumpParser

Parser holds rows until the total byte size reaches this number

Raises:

  • (ArgumentError) 


34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
 
# File 'lib/flydata/source_oracle/parse_dump_and_send.rb', line 34

def initialize(dump_pos_info, dmpio, create_table_block, insert_record_block,
               check_point_block)
  @source_pos = dump_pos_info[:source_pos]
  raise ArgumentError.new("source position is required") unless @source_pos
  @current_table = nil
  @last_pos = 0
  @row_head_pos = nil
  @rows = []
  @dmpio = dmpio
  @create_table_block = create_table_block
  @insert_record_block = insert_record_block
  @check_point_block = check_point_block

  resume(dump_pos_info)
end