Class: Mysql::FlydataJsonHandlerFactory::FlydataJsonHandler

Inherits:

Object

Object
Mysql::FlydataJsonHandlerFactory::FlydataJsonHandler

show all

Defined in:: lib/flydata/fluent-plugins/mysql/binlog_record_handler.rb

Direct Known Subclasses

DatabaseFlydataJsonHandler, TableFlydataJsonHandler

Constant Summary collapse

TABLE_NAME = A Flydata JSON tag to specify a table name

:table_name

TYPE =

:type

SEQ =

:seq

RESPECT_ORDER =

:respect_order

SRC_POS =

:src_pos

TABLE_REV =

:table_rev

V = FlyData record format version

:v

DB_NAME =

:db_name

Instance Method Summary collapse

#emit(timestamp, row) ⇒ Object
#initialize(records, record, context, type, increment_table_rev = nil) ⇒ FlydataJsonHandler constructor
A new instance of FlydataJsonHandler.

Constructor Details

#initialize(records, record, context, type, increment_table_rev = nil) ⇒ `FlydataJsonHandler`



104
105
106

# File 'lib/flydata/fluent-plugins/mysql/binlog_record_handler.rb', line 104

def initialize(records, record, context, type, increment_table_rev=nil)
  @context = context
end

Instance Method Details

#emit(timestamp, row) ⇒ `Object`



108
109

# File 'lib/flydata/fluent-plugins/mysql/binlog_record_handler.rb', line 108

def emit(timestamp, row)
end