[FLINK-3747] Consolidate TimestampAssigner Methods in Kafka Consumer

• Type: Improvement
• Status: Closed
• Priority: Blocker
• Resolution: Fixed
• Fix Version/s: 1.1.0
• Assignee: Aljoscha Krettek
• Reporter: Aljoscha Krettek
• Created: 13/Apr/16 08:56
• Updated: 28/Feb/19 11:14
• Resolved: 13/Apr/16 18:52

Description

On DataStream the methods for setting a TimestampAssigner/WatermarkEmitter are called assignTimestampsAndWatermarks() while on FlinkKafkaConsumer* they are called setPunctuatedWatermarkEmitter() and setPeriodicWatermarkEmitter().

I think these names should be matched, also the name setWatermarkEmitter does not hint at the fact that the assigner primarily assigns timestamps.