Remove unused generic arguments in ReduceFnRunnerTest.
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/fa458091 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/fa458091 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/fa458091 Branch: refs/heads/master Commit: fa4580915943a0bac58f1452f1ef1e43aad986fb Parents: 0952f44 Author: bchambers <bchamb...@google.com> Authored: Tue Apr 19 11:34:25 2016 -0700 Committer: bchambers <bchamb...@google.com> Committed: Tue Apr 19 15:23:53 2016 -0700 ---------------------------------------------------------------------- .../apache/beam/sdk/util/ReduceFnRunnerTest.java | 18 +++++++++--------- 1 file changed, 9 insertions(+), 9 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/fa458091/sdks/java/core/src/test/java/org/apache/beam/sdk/util/ReduceFnRunnerTest.java ---------------------------------------------------------------------- diff --git a/sdks/java/core/src/test/java/org/apache/beam/sdk/util/ReduceFnRunnerTest.java b/sdks/java/core/src/test/java/org/apache/beam/sdk/util/ReduceFnRunnerTest.java index 1939b20..5eccb04 100644 --- a/sdks/java/core/src/test/java/org/apache/beam/sdk/util/ReduceFnRunnerTest.java +++ b/sdks/java/core/src/test/java/org/apache/beam/sdk/util/ReduceFnRunnerTest.java @@ -500,8 +500,8 @@ public class ReduceFnRunnerTest { ReduceFnTester<Integer, Iterable<Integer>, IntervalWindow> tester = ReduceFnTester.nonCombining( WindowingStrategy.of(FixedWindows.of(Duration.millis(10))) .withTrigger(Repeatedly.<IntervalWindow>forever(AfterFirst.<IntervalWindow>of( - AfterPane.<IntervalWindow>elementCountAtLeast(2), - AfterWatermark.<IntervalWindow>pastEndOfWindow()))) + AfterPane.elementCountAtLeast(2), + AfterWatermark.pastEndOfWindow()))) .withMode(AccumulationMode.DISCARDING_FIRED_PANES) .withAllowedLateness(Duration.millis(100)) .withClosingBehavior(ClosingBehavior.FIRE_ALWAYS)); @@ -552,8 +552,8 @@ public class ReduceFnRunnerTest { ReduceFnTester<Integer, Iterable<Integer>, IntervalWindow> tester = ReduceFnTester.nonCombining( WindowingStrategy.of(FixedWindows.of(Duration.millis(10))) .withTrigger(Repeatedly.<IntervalWindow>forever(AfterFirst.<IntervalWindow>of( - AfterPane.<IntervalWindow>elementCountAtLeast(2), - AfterWatermark.<IntervalWindow>pastEndOfWindow()))) + AfterPane.elementCountAtLeast(2), + AfterWatermark.pastEndOfWindow()))) .withMode(AccumulationMode.ACCUMULATING_FIRED_PANES) .withAllowedLateness(Duration.millis(100)) .withClosingBehavior(ClosingBehavior.FIRE_ALWAYS)); @@ -604,8 +604,8 @@ public class ReduceFnRunnerTest { ReduceFnTester<Integer, Iterable<Integer>, IntervalWindow> tester = ReduceFnTester.nonCombining( WindowingStrategy.of(FixedWindows.of(Duration.millis(10))) .withTrigger( - Repeatedly.<IntervalWindow>forever(AfterPane.<IntervalWindow>elementCountAtLeast(2)) - .orFinally(AfterWatermark.<IntervalWindow>pastEndOfWindow())) + Repeatedly.<IntervalWindow>forever(AfterPane.elementCountAtLeast(2)) + .orFinally(AfterWatermark.pastEndOfWindow())) .withMode(AccumulationMode.DISCARDING_FIRED_PANES) .withAllowedLateness(Duration.millis(100)) .withClosingBehavior(ClosingBehavior.FIRE_ALWAYS)); @@ -890,7 +890,7 @@ public class ReduceFnRunnerTest { ReduceFnTester<Integer, Integer, IntervalWindow> tester = ReduceFnTester.combining( WindowingStrategy.of( SlidingWindows.of(Duration.millis(100)).every(Duration.millis(30))) - .withTrigger(AfterWatermark.<IntervalWindow>pastEndOfWindow()) + .withTrigger(AfterWatermark.pastEndOfWindow()) .withAllowedLateness(Duration.millis(1000)), new Sum.SumIntegerFn().<String>asKeyedFn(), VarIntCoder.of()); @@ -1024,7 +1024,7 @@ public class ReduceFnRunnerTest { .<IntervalWindow>forever( AfterProcessingTime.<IntervalWindow>pastFirstElementInPane().plusDelayOf( new Duration(5))) - .orFinally(AfterWatermark.<IntervalWindow>pastEndOfWindow()), + .orFinally(AfterWatermark.pastEndOfWindow()), Repeatedly.<IntervalWindow>forever( AfterProcessingTime.<IntervalWindow>pastFirstElementInPane().plusDelayOf( new Duration(25)))), @@ -1074,7 +1074,7 @@ public class ReduceFnRunnerTest { .<IntervalWindow>forever( AfterProcessingTime.<IntervalWindow>pastFirstElementInPane().plusDelayOf( new Duration(5))) - .orFinally(AfterWatermark.<IntervalWindow>pastEndOfWindow()), + .orFinally(AfterWatermark.pastEndOfWindow()), Repeatedly.<IntervalWindow>forever( AfterProcessingTime.<IntervalWindow>pastFirstElementInPane().plusDelayOf( new Duration(25)))),