module Fluent::Plugin::KinesisHelper::Aggregator::Mixin
Constants
- AggregateOffset
- RecordOffset
Public Class Methods
included(mod)
click to toggle source
# File lib/fluent/plugin/kinesis_helper/aggregator.rb, line 90 def self.included(mod) mod.include Params end
Public Instance Methods
aggregator()
click to toggle source
# File lib/fluent/plugin/kinesis_helper/aggregator.rb, line 94 def aggregator @aggregator ||= Aggregator.new end