You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by lc...@apache.org on 2016/08/26 22:48:19 UTC
[2/2] incubator-beam git commit: [BEAM-589] Fixing IO.Read
transformation
[BEAM-589] Fixing IO.Read transformation
This closes #889
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/95ab4380
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/95ab4380
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/95ab4380
Branch: refs/heads/master
Commit: 95ab438095b04a3defbc1a21fcd65ac2f3910715
Parents: 9abd0bc 310ea74
Author: Luke Cwik <lc...@google.com>
Authored: Fri Aug 26 15:14:45 2016 -0700
Committer: Luke Cwik <lc...@google.com>
Committed: Fri Aug 26 15:14:45 2016 -0700
----------------------------------------------------------------------
.../java/org/apache/beam/examples/complete/TfIdf.java | 6 +++---
.../runners/core/UnboundedReadFromBoundedSource.java | 6 +++---
.../org/apache/beam/runners/flink/examples/TFIDF.java | 6 +++---
.../apache/beam/runners/dataflow/DataflowRunner.java | 6 +++---
.../DataflowUnboundedReadFromBoundedSource.java | 6 +++---
.../beam/runners/dataflow/DataflowRunnerTest.java | 4 ++--
.../org/apache/beam/runners/spark/io/CreateStream.java | 7 +++----
.../java/org/apache/beam/runners/spark/io/KafkaIO.java | 6 +++---
.../apache/beam/runners/spark/io/hadoop/HadoopIO.java | 6 +++---
.../src/main/java/org/apache/beam/sdk/io/AvroIO.java | 6 +++---
.../beam/sdk/io/BoundedReadFromUnboundedSource.java | 6 +++---
.../src/main/java/org/apache/beam/sdk/io/PubsubIO.java | 6 +++---
.../core/src/main/java/org/apache/beam/sdk/io/Read.java | 10 +++++-----
.../src/main/java/org/apache/beam/sdk/io/TextIO.java | 6 +++---
.../java/org/apache/beam/sdk/transforms/Create.java | 12 ++++++------
.../test/java/org/apache/beam/sdk/io/AvroIOTest.java | 2 +-
.../test/java/org/apache/beam/sdk/io/PubsubIOTest.java | 2 +-
.../test/java/org/apache/beam/sdk/io/TextIOTest.java | 2 +-
.../org/apache/beam/sdk/io/gcp/bigquery/BigQueryIO.java | 8 ++++----
.../apache/beam/sdk/io/gcp/bigquery/BigQueryIOTest.java | 4 ++--
.../src/main/java/org/apache/beam/sdk/io/jms/JmsIO.java | 3 +--
.../main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java | 3 +--
22 files changed, 60 insertions(+), 63 deletions(-)
----------------------------------------------------------------------