[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(-) ----------------------------------------------------------------------