[ https://issues.apache.org/jira/browse/FLINK-18873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Dawid Wysakowicz updated FLINK-18873: ------------------------------------- Fix Version/s: (was: 1.13.0) 1.14.0 > Make the WatermarkStrategy API more scala friendly > -------------------------------------------------- > > Key: FLINK-18873 > URL: https://issues.apache.org/jira/browse/FLINK-18873 > Project: Flink > Issue Type: Improvement > Components: API / Core, API / DataStream > Affects Versions: 1.11.0 > Reporter: Dawid Wysakowicz > Priority: Major > Labels: stale-major > Fix For: 1.14.0 > > > Right now there is no reliable way of passing WatermarkGeneratorSupplier > and/or TimestampAssigner as lambdas in scala. > The only way to use this API is: > {code} > .assignTimestampsAndWatermarks( > WatermarkStrategy.forGenerator[(String, Long)]( > new WatermarkGeneratorSupplier[(String, Long)] { > override def createWatermarkGenerator(context: > WatermarkGeneratorSupplier.Context): WatermarkGenerator[(String, Long)] = > new MyPeriodicGenerator > } > ) > .withTimestampAssigner(new SerializableTimestampAssigner[(String, > Long)] { > override def extractTimestamp(t: (String, Long), l: Long): Long = > t._2 > }) > ) > {code} -- This message was sent by Atlassian Jira (v8.3.4#803005)