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