fixup! Make PassThroughWindowFn and NeverTrigger available

apache · Apr 14, 2016 · 52e2c65 · 52e2c65
1 parent e2b10af
commit 52e2c65
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 5 deletions.
diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/AfterWatermark.java b/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/AfterWatermark.java
@@ -109,8 +109,8 @@ private static class AfterWatermarkEarlyAndLate
     @SuppressWarnings("unchecked")
     private AfterWatermarkEarlyAndLate(OnceTrigger earlyTrigger, OnceTrigger lateTrigger) {
       super(lateTrigger == null
-              ? ImmutableList.<Trigger>of(earlyTrigger)
-              : ImmutableList.<Trigger>of(earlyTrigger, lateTrigger));
+          ? ImmutableList.<Trigger>of(earlyTrigger)
+          : ImmutableList.<Trigger>of(earlyTrigger, lateTrigger));
       this.earlyTrigger = checkNotNull(earlyTrigger, "earlyTrigger should not be null");
       this.lateTrigger = lateTrigger;
     }

diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/util/IdentityWindowFn.java b/sdks/java/core/src/main/java/org/apache/beam/sdk/util/IdentityWindowFn.java
@@ -26,6 +26,7 @@
 import org.apache.beam.sdk.transforms.windowing.Window;
 import org.apache.beam.sdk.transforms.windowing.WindowFn;
 import org.apache.beam.sdk.values.PCollection;
+
 import org.joda.time.Instant;
 
 import java.util.Collection;
@@ -81,7 +82,7 @@ public boolean isCompatible(WindowFn<?, ?> other) {
         String.format(
             "%s.isCompatible() should never be called."
                 + " It is a private implementation detail of sdk utilities."
-                + " This message indicates a bug in the Dataflow SDK.",
+                + " This message indicates a bug in the Beam SDK.",
             getClass().getCanonicalName()));
   }
 
@@ -102,8 +103,8 @@ public BoundedWindow getSideInputWindow(BoundedWindow window) {
     throw new UnsupportedOperationException(
         String.format(
             "%s.getSideInputWindow() should never be called."
-                + " It is a private implementation detail sdk utilities."
-                + " This message indicates a bug in the Dataflow SDK.",
+                + " It is a private implementation detail of sdk utilities."
+                + " This message indicates a bug in the Beam SDK.",
             getClass().getCanonicalName()));
   }