Method: Fluent::FlydataSyncDiffBased#configure

Defined in:
lib/flydata/fluent-plugins/flydata_plugin_ext/flydata_sync_diff_based.rb

#configure(conf) ⇒ Object 



19
20
21
22
23
24
25
26
27
 
# File 'lib/flydata/fluent-plugins/flydata_plugin_ext/flydata_sync_diff_based.rb', line 19

def configure(conf)
  super
  @table_src_pos_files = @tables.inject({}) do |ret, table_name|
    ret[table_name.to_sym] = self.class::SOURCE_POSITION_FILE_CLASS.new(
      @sync_fm.table_source_pos_file_path(table_name)
    )
    ret
  end
end