This closes #2311: Second clean up pass of dataflow references/URLs in Java SDK
[BEAM-1778] Second clean up pass of dataflow references/URLs in Java SDK Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/ced1e5c3 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/ced1e5c3 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/ced1e5c3 Branch: refs/heads/master Commit: ced1e5c3a1ee1e90ffe5843f7b4e8daf2cb3d46e Parents: 1ea3b35 07a50b4 Author: Kenneth Knowles <k...@google.com> Authored: Mon Mar 27 13:16:01 2017 -0700 Committer: Kenneth Knowles <k...@google.com> Committed: Mon Mar 27 13:16:01 2017 -0700 ---------------------------------------------------------------------- .../main/java/org/apache/beam/sdk/io/AvroSource.java | 2 +- .../java/org/apache/beam/sdk/io/BoundedSource.java | 4 +--- .../main/java/org/apache/beam/sdk/io/PubsubIO.java | 6 ------ .../org/apache/beam/sdk/io/PubsubUnboundedSink.java | 2 -- .../apache/beam/sdk/io/PubsubUnboundedSource.java | 2 -- .../main/java/org/apache/beam/sdk/io/TFRecordIO.java | 6 +++--- .../main/java/org/apache/beam/sdk/io/XmlSink.java | 4 ++-- .../org/apache/beam/sdk/io/range/ByteKeyRange.java | 4 +--- .../java/org/apache/beam/sdk/options/GcpOptions.java | 2 +- .../beam/sdk/testing/SerializableMatchers.java | 2 +- .../org/apache/beam/sdk/testing/StreamingIT.java | 2 +- .../java/org/apache/beam/sdk/util/CoderUtils.java | 15 +++++++-------- .../beam/sdk/coders/protobuf/ProtobufUtilTest.java | 1 - .../apache/beam/sdk/runners/PipelineRunnerTest.java | 2 +- .../io/gcp/bigquery/BigQueryTableRowIterator.java | 3 +-- .../beam/sdk/io/gcp/datastore/DatastoreV1.java | 2 +- .../org/apache/beam/sdk/io/hdfs/HDFSFileSink.java | 3 +-- .../java/org/apache/beam/sdk/io/jdbc/JdbcIO.java | 4 ---- .../java/org/apache/beam/sdk/io/kafka/KafkaIO.java | 4 +--- .../resources/META-INF/maven/archetype-metadata.xml | 2 +- .../resources/META-INF/maven/archetype-metadata.xml | 2 +- .../resources/META-INF/maven/archetype-metadata.xml | 2 +- 22 files changed, 26 insertions(+), 50 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/ced1e5c3/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java ----------------------------------------------------------------------