Repository: beam Updated Branches: refs/heads/master f32cb3e7a -> 98d8834af
Changed name of ToString.of() to ToString.elements(). Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/a49acdad Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/a49acdad Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/a49acdad Branch: refs/heads/master Commit: a49acdadac37fd52cc1184e5d29cc30b99742a35 Parents: effca63 Author: Jesse Anderson <je...@smokinghand.com> Authored: Fri Feb 10 12:17:21 2017 -0800 Committer: Jesse Anderson <je...@smokinghand.com> Committed: Fri Feb 10 12:17:21 2017 -0800 ---------------------------------------------------------------------- .../src/main/java/org/apache/beam/sdk/transforms/ToString.java | 4 ++-- .../core/src/test/java/org/apache/beam/sdk/io/WriteTest.java | 2 +- .../test/java/org/apache/beam/sdk/transforms/ToStringTest.java | 2 +- 3 files changed, 4 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/a49acdad/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/ToString.java ---------------------------------------------------------------------- diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/ToString.java b/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/ToString.java index d5c9784..5069a3c 100644 --- a/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/ToString.java +++ b/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/ToString.java @@ -42,7 +42,7 @@ public final class ToString { * element of the input {@link PCollection} to a {@link String} using the * {@link Object#toString} method. */ - public static PTransform<PCollection<?>, PCollection<String>> of() { + public static PTransform<PCollection<?>, PCollection<String>> elements() { return new SimpleToString(); } @@ -97,7 +97,7 @@ public final class ToString { * <p>Example of use: * <pre>{@code * PCollection<Long> longs = ...; - * PCollection<String> strings = longs.apply(ToString.of()); + * PCollection<String> strings = longs.apply(ToString.elements()); * }</pre> * * http://git-wip-us.apache.org/repos/asf/beam/blob/a49acdad/sdks/java/core/src/test/java/org/apache/beam/sdk/io/WriteTest.java ---------------------------------------------------------------------- diff --git a/sdks/java/core/src/test/java/org/apache/beam/sdk/io/WriteTest.java b/sdks/java/core/src/test/java/org/apache/beam/sdk/io/WriteTest.java index f81cc0c..846d445 100644 --- a/sdks/java/core/src/test/java/org/apache/beam/sdk/io/WriteTest.java +++ b/sdks/java/core/src/test/java/org/apache/beam/sdk/io/WriteTest.java @@ -297,7 +297,7 @@ public class WriteTest { @Test public void testWriteUnbounded() { PCollection<String> unbounded = p.apply(CountingInput.unbounded()) - .apply(ToString.of()); + .apply(ToString.elements()); TestSink sink = new TestSink(); thrown.expect(IllegalArgumentException.class); http://git-wip-us.apache.org/repos/asf/beam/blob/a49acdad/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/ToStringTest.java ---------------------------------------------------------------------- diff --git a/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/ToStringTest.java b/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/ToStringTest.java index ab984f1..d2116da 100644 --- a/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/ToStringTest.java +++ b/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/ToStringTest.java @@ -48,7 +48,7 @@ public class ToStringTest { Integer[] ints = {1, 2, 3, 4, 5}; String[] strings = {"1", "2", "3", "4", "5"}; PCollection<Integer> input = p.apply(Create.of(Arrays.asList(ints))); - PCollection<String> output = input.apply(ToString.of()); + PCollection<String> output = input.apply(ToString.elements()); PAssert.that(output).containsInAnyOrder(strings); p.run(); }
