Repository: incubator-beam
Updated Branches:
refs/heads/master ddb59125a -> 5169e4925
fixup! Fix CountingInput naming
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/5169e492
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/5169e492
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/5169e492
Branch: refs/heads/master
Commit: 5169e492578a3759e20b50e36ace61bc86636ad2
Parents: ddb5912
Author: Luke Cwik <lcwik@google.com>
Authored: Thu Dec 8 19:17:21 2016 -0800
Committer: Luke Cwik <lcwik@google.com>
Committed: Thu Dec 8 19:17:21 2016 -0800
----------------------------------------------------------------------
.../test/java/org/apache/beam/sdk/io/CountingInputTest.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/5169e492/sdks/java/core/src/test/java/org/apache/beam/sdk/io/CountingInputTest.java
----------------------------------------------------------------------
diff --git a/sdks/java/core/src/test/java/org/apache/beam/sdk/io/CountingInputTest.java b/sdks/java/core/src/test/java/org/apache/beam/sdk/io/CountingInputTest.java
index 4349f66..063bead 100644
--- a/sdks/java/core/src/test/java/org/apache/beam/sdk/io/CountingInputTest.java
+++ b/sdks/java/core/src/test/java/org/apache/beam/sdk/io/CountingInputTest.java
@@ -71,7 +71,7 @@ public class CountingInputTest {
public void testBoundedInput() {
Pipeline p = TestPipeline.create();
long numElements = 1000;
- PCollection<Long> input = p.apply(Read.from(CountingSource.upTo(numElements)));
+ PCollection<Long> input = p.apply(CountingInput.upTo(numElements)));
addCountingAsserts(input, 0, numElements);
p.run();
@@ -79,7 +79,7 @@ public class CountingInputTest {
@Test
@Category(RunnableOnService.class)
- public void testEmptyBoundedSource() {
+ public void testEmptyBoundedInput() {
Pipeline p = TestPipeline.create();
PCollection<Long> input = p.apply(CountingInput.upTo(0));
@@ -89,7 +89,7 @@ public class CountingInputTest {
@Test
@Category(RunnableOnService.class)
- public void testEmptyBoundedSourceUsingRange() {
+ public void testEmptyBoundedInputSubrange() {
Pipeline p = TestPipeline.create();
PCollection<Long> input = p.apply(CountingInput.forSubrange(42, 42));
|