Sha256: 40868b21cbc8d622e9ce045e044a1b2d9703b0198a486cf0c4e72b09e320944a
Contents?: true
Size: 489 Bytes
Versions: 14
Compression:
Stored size: 489 Bytes
Contents
require 'flydata/parser_provider' require 'flydata/fluent-plugins/mysql/ddl_query_handler' module Mysql class TruncateTableQueryHandler < DdlQueryHandler PATTERN = /^TRUNCATE/i def initialize(context) super end def pattern PATTERN end def process(record) emit_record(:truncate_table, record) do |opt| { table_name: table_info(record)[:table_name], query: record["query"] } end end end end
Version data entries
14 entries across 14 versions & 1 rubygems