Class: Flydata::SourceMysql::PluginSupport::BinlogRecordDispatcher
- Inherits:
-
Object
- Object
- Flydata::SourceMysql::PluginSupport::BinlogRecordDispatcher
show all
- Defined in:
- lib/flydata/source_mysql/plugin_support/binlog_record_dispatcher.rb
Instance Method Summary
collapse
Instance Method Details
#dispatch(event) ⇒ Object
11
12
13
14
15
16
17
18
19
20
21
22
|
# File 'lib/flydata/source_mysql/plugin_support/binlog_record_dispatcher.rb', line 11
def dispatch(event)
method_name = "on_#{event.event_type.downcase}"
if self.respond_to?(method_name)
record = Fluent::MysqlBinlogInput::BinlogUtil.to_hash(event)
self.send(method_name, record)
else
end
end
|