File tree Expand file tree Collapse file tree 1 file changed +3
-0
lines changed
runners/core-java/src/main/java/org/apache/beam/runners/core Expand file tree Collapse file tree 1 file changed +3
-0
lines changed Original file line number Diff line number Diff line change 2525import org .apache .beam .sdk .values .WindowingStrategy ;
2626import org .apache .beam .vendor .guava .v32_1_2_jre .com .google .common .collect .FluentIterable ;
2727import org .apache .beam .vendor .guava .v32_1_2_jre .com .google .common .collect .Iterables ;
28+ import org .checkerframework .dataflow .qual .Pure ;
2829import org .joda .time .Duration ;
2930import org .joda .time .Instant ;
3031
@@ -41,6 +42,7 @@ private LateDataUtils() {}
4142 * Return when {@code window} should be garbage collected. If the window's expiration time is on
4243 * or after the end of the global window, it will be truncated to the end of the global window.
4344 */
45+ @ Pure
4446 public static Instant garbageCollectionTime (
4547 BoundedWindow window , WindowingStrategy windowingStrategy ) {
4648 return garbageCollectionTime (window , windowingStrategy .getAllowedLateness ());
@@ -50,6 +52,7 @@ public static Instant garbageCollectionTime(
5052 * Return when {@code window} should be garbage collected. If the window's expiration time is on
5153 * or after the end of the global window, it will be truncated to the end of the global window.
5254 */
55+ @ Pure
5356 public static Instant garbageCollectionTime (BoundedWindow window , Duration allowedLateness ) {
5457
5558 // If the end of the window + allowed lateness is beyond the "end of time" aka the end of the
You can’t perform that action at this time.
0 commit comments