class KinesisAnalyticsConverter

Public Class Methods

new(kinesis_analytics_record) click to toggle source
# File lib/kinesis/aggregation/kinesis_analytics_converter.rb, line 2
def initialize(kinesis_analytics_record)
  @kinesis_analytics_record = kinesis_analytics_record
end

Public Instance Methods

convert() click to toggle source
# File lib/kinesis/aggregation/kinesis_analytics_converter.rb, line 6
def convert
  {
    kinesis: {
      kinesisSchemaVersion: '1.0',
      sequenceNumber: @kinesis_analytics_record[:kinesisStreamRecordMetadata][:sequenceNumber],
      partitionKey: @kinesis_analytics_record[:kinesisStreamRecordMetadata][:partitionKey],
      approximateArrivalTimestamp: @kinesis_analytics_record[:kinesisStreamRecordMetadata][:approximateArrivalTimestamp],
      shardId: @kinesis_analytics_record[:kinesisStreamRecordMetadata][:shardId],
      data: @kinesis_analytics_record[:data],
      recordId: @kinesis_analytics_record[:recordId]
    }
  }
end