offset

in lib/fluent/plugin/out_kinesis_streams_aggregated.rb [59:62]

• 3 lines of code
• 2 McCabe index (conditional complexity)

      def offset
        @offset ||= AggregateOffset + @partition_key_generator.call.size*2
      end