beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From k...@apache.org
Subject [2/2] beam git commit: This closes #2311: Second clean up pass of dataflow references/URLs in Java SDK
Date Mon, 27 Mar 2017 20:17:03 GMT
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 <klk@google.com>
Authored: Mon Mar 27 13:16:01 2017 -0700
Committer: Kenneth Knowles <klk@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
----------------------------------------------------------------------


Mime
View raw message