-
Notifications
You must be signed in to change notification settings - Fork 624
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
[FLINK-23926] one timestamp #36
Conversation
709a68f
to
5a3bfcf
Compare
5a3bfcf
to
aaffd3f
Compare
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Thanks for getting this change in - it maps better to the streaming approach.
I have a couple of smaller things around the code but once addressed, we can merge
common/src/main/java/org/apache/flink/training/exercises/common/datatypes/TaxiRide.java
Outdated
Show resolved
Hide resolved
common/src/main/java/org/apache/flink/training/exercises/common/sources/TaxiRideGenerator.java
Outdated
Show resolved
Hide resolved
...lerts/src/solution/java/org/apache/flink/training/solutions/longrides/LongRidesSolution.java
Show resolved
Hide resolved
...lerts/src/solution/java/org/apache/flink/training/solutions/longrides/LongRidesSolution.java
Outdated
Show resolved
Hide resolved
...lerts/src/solution/java/org/apache/flink/training/solutions/longrides/LongRidesSolution.java
Outdated
Show resolved
Hide resolved
...c/solution/scala/org/apache/flink/training/solutions/longrides/scala/LongRidesSolution.scala
Outdated
Show resolved
Hide resolved
...de-alerts/src/test/java/org/apache/flink/training/exercises/longrides/LongRidesUnitTest.java
Outdated
Show resolved
Hide resolved
...de-alerts/src/test/java/org/apache/flink/training/exercises/longrides/LongRidesUnitTest.java
Outdated
Show resolved
Hide resolved
f1f945e
to
a7150df
Compare
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
One tiny bit in a sentence seems wrong. I'll approve now assuming you'll address that one
961be5d
to
a7deba1
Compare
a7deba1
to
395ee90
Compare
@NicoK I've reworked the DISCUSSION for the long-rides exercise again. It should be correct now. |
This PR is layered on top of #31.
The objective is to replace the startTime and endTime fields with a single eventTime field. This is more natural, and will make it more straightforward to convert a
DataStream<TaxiRide>
into a table.This does affect the long rides exercise. The biggest change is that it is no longer possible to determine if a ride has been too long in the case where the START event is missing.