search

andresvivancov / BDAPRO-WindowsBenchmarking

Project of BDAPRO with Flink, Spark and Storm
0 stars 0 forks source link

Dec 20 2. Is it possible to see the in the output the time-stamp?: #19

Open andresvivancov opened 7 years ago

andresvivancov commented 7 years ago
  1. Is it possible to see the in the output the time stamp?:

.assignAscendingTimestamps( _.time )?

o

assignTimestampsAndWatermarks?

for example based in the ridecleansing example in flink. I changed the id, first attribute to receive the timestamp, but I cannot see the change:

Code:

Just the two lines where I am adding it:

val withTimestampsAndWatermarks = rides.assignAscendingTimestamps(_.rideId) withTimestampsAndWatermarks.print()

image

andresvivancov commented 7 years ago

FYI @jeyhunkarimov