eriodicWatermarks[Row] {
>>>>
>>>>override def extractTimestamp(element: Row,
>>>>previousElementTimestamp: Long): Long = { element.minTime }
>>>>
>>>>override def getCurrentWatermark(): Watermark = { new
>>>>W
>>> Long): Long = {
>>> element.minTime
>>> }
>>>
>>> override def getCurrentWatermark(): Watermark = {
>>> new Watermark(System.currentTimeMillis() - maxLateness)
>>> }
>>> }
>>> ```
>>>
gt; }
>>
>> override def getCurrentWatermark(): Watermark = {
>> new Watermark(System.currentTimeMillis() - maxLateness)
>> }
>> }
>> ```
>>
>> Where Row is a class representing the incoming JSON object coming from
>> Kafka, which includes
presenting the incoming JSON object coming from
> Kafka, which includes the timestamp
>
> Thanks,
> -Ethan
>
>
>
> --
> View this message in context: http://apache-flink-user-
> mailing-list-archive.2336050.n4.nabble.com/Issues-with-
> Event-Time-and-Kafka-tp12061p12090.html
> Sent from the Apache Flink User Mailing List archive. mailing list archive
> at Nabble.com.
>
ge in context:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Issues-with-Event-Time-and-Kafka-tp12061p12090.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at
Nabble.com.
ter if folks believe that is
>>> the issue I would be happy to provide that code here as well.
>>>
>>> 2) On top of all this, we would really prefer to write the records
>>> directly
>>> to Aurora in RDS rather than to an intermediate s3 bucket, but it seems
ontext: http://apache-flink-user-maili
>> ng-list-archive.2336050.n4.nabble.com/Issues-with-Event-
>> Time-and-Kafka-tp12061.html
>> Sent from the Apache Flink User Mailing List archive. mailing list
>> archive at Nabble.com.
>>
>
>
>
> ---
Thanks in advance for all the help / insight on this,
>
> Max Walker
>
>
>
> --
> View this message in context: http://apache-flink-user-
> mailing-list-archive.2336050.n4.nabble.com/Issues-with-
> Event-Time-and-Kafka-tp12061.html
> Sent from the Apache Flink User Mailing List archive. mailing list archive
> at Nabble.com.
>
e for all the help / insight on this,
Max Walker
--
View this message in context:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Issues-with-Event-Time-and-Kafka-tp12061.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at
Nabble.com.
