beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From lc...@apache.org
Subject incubator-beam git commit: fixup! Fix CountingInput naming
Date Fri, 09 Dec 2016 03:18:57 GMT
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));
 


Mime
View raw message