[FLINK-4019] Expose approximateArrivalTimestamp through the KinesisDeserializationSchema interface

• Type: Sub-task
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.1.0
• Fix Version/s: 1.1.0
• Component/s: Connectors / Common
• Assignee: Tzu-Li (Gordon) Tai
• Reporter: Tzu-Li (Gordon) Tai
• Created: 04/Jun/16 09:14
• Updated: 09/Jul/16 09:25
• Resolved: 09/Jul/16 09:24

Description

Amazon's Record class also gives information about the timestamp of when Kinesis successfully receives the record: http://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/services/kinesis/model/Record.html#getApproximateArrivalTimestamp().

This should be useful info for users and should be exposed through the deserialization schema.

Issue Links

• links to: GitHub Pull Request #2214