Add informative Instant formatter to BoundedWindow
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/280a6a8f Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/280a6a8f Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/280a6a8f Branch: refs/heads/python-sdk Commit: 280a6a8f729cb382616ad65f71860b61277cbd6f Parents: ff39516 Author: Kenneth Knowles <k...@google.com> Authored: Mon Dec 19 20:40:11 2016 -0800 Committer: Kenneth Knowles <k...@google.com> Committed: Wed Dec 21 13:45:36 2016 -0800 ---------------------------------------------------------------------- .../beam/sdk/transforms/windowing/BoundedWindow.java | 12 ++++++++++++ 1 file changed, 12 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/280a6a8f/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/BoundedWindow.java ---------------------------------------------------------------------- diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/BoundedWindow.java b/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/BoundedWindow.java index 3654074..6da2495 100644 --- a/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/BoundedWindow.java +++ b/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/BoundedWindow.java @@ -39,6 +39,18 @@ public abstract class BoundedWindow { public static final Instant TIMESTAMP_MAX_VALUE = new Instant(TimeUnit.MICROSECONDS.toMillis(Long.MAX_VALUE)); + public static String formatTimestamp(Instant timestamp) { + if (timestamp.equals(TIMESTAMP_MIN_VALUE)) { + return timestamp.toString() + " (TIMESTAMP_MIN_VALUE)"; + } else if (timestamp.equals(TIMESTAMP_MAX_VALUE)) { + return timestamp.toString() + " (TIMESTAMP_MAX_VALUE)"; + } else if (timestamp.equals(GlobalWindow.INSTANCE.maxTimestamp())) { + return timestamp.toString() + " (end of global window)"; + } else { + return timestamp.toString(); + } + } + /** * Returns the inclusive upper bound of timestamps for values in this window. */
