This closes #2523
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/3101e69c Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/3101e69c Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/3101e69c Branch: refs/heads/master Commit: 3101e69c438d5c42577fc7d3476d623f6e551837 Parents: 4124cc6 62464b5 Author: Dan Halperin <[email protected]> Authored: Tue Apr 18 11:53:08 2017 -0700 Committer: Dan Halperin <[email protected]> Committed: Tue Apr 18 12:01:28 2017 -0700 ---------------------------------------------------------------------- .../apex/translation/utils/ValuesSource.java | 2 +- .../apex/examples/UnboundedTextSource.java | 2 +- .../translation/GroupByKeyTranslatorTest.java | 2 +- .../apex/translation/utils/CollectionSource.java | 2 +- .../UnboundedReadFromBoundedSource.java | 7 ++++--- .../direct/BoundedReadEvaluatorFactory.java | 2 +- .../direct/UnboundedReadEvaluatorFactory.java | 2 +- .../direct/BoundedReadEvaluatorFactoryTest.java | 4 ++-- .../beam/runners/direct/DirectRunnerTest.java | 4 ++-- .../UnboundedReadEvaluatorFactoryTest.java | 2 +- .../translation/wrappers/SourceInputFormat.java | 3 ++- .../streaming/io/BoundedSourceWrapper.java | 2 +- .../streaming/io/UnboundedSocketSource.java | 2 +- .../streaming/io/UnboundedSourceWrapper.java | 2 +- .../flink/streaming/TestCountingSource.java | 2 +- .../runners/dataflow/internal/CustomSources.java | 2 +- .../beam/runners/spark/io/MicrobatchSource.java | 5 ++--- .../beam/runners/spark/io/SourceDStream.java | 2 +- .../apache/beam/runners/spark/io/SourceRDD.java | 4 ++-- .../sdk/io/BoundedReadFromUnboundedSource.java | 4 ++-- .../org/apache/beam/sdk/io/BoundedSource.java | 13 +++++++++++-- .../org/apache/beam/sdk/io/CountingSource.java | 2 +- .../org/apache/beam/sdk/io/FileBasedSource.java | 9 +++++---- .../apache/beam/sdk/io/OffsetBasedSource.java | 4 ++-- .../org/apache/beam/sdk/io/UnboundedSource.java | 2 +- .../apache/beam/sdk/testing/SourceTestUtils.java | 6 +++--- .../org/apache/beam/sdk/io/AvroSourceTest.java | 10 +++++----- .../apache/beam/sdk/io/CountingSourceTest.java | 6 +++--- .../apache/beam/sdk/io/FileBasedSourceTest.java | 8 ++++---- .../beam/sdk/io/OffsetBasedSourceTest.java | 8 ++++---- .../java/org/apache/beam/sdk/io/ReadTest.java | 4 ++-- .../java/org/apache/beam/sdk/io/TextIOTest.java | 16 ++++++++-------- .../org/apache/beam/sdk/io/XmlSourceTest.java | 8 ++++---- .../sdk/runners/dataflow/TestCountingSource.java | 2 +- .../beam/sdk/testing/SourceTestUtilsTest.java | 2 +- .../apache/beam/sdk/transforms/CreateTest.java | 12 ++++++------ .../sdk/io/elasticsearch/ElasticsearchIO.java | 2 +- .../sdk/io/elasticsearch/ElasticsearchIOIT.java | 2 +- .../io/elasticsearch/ElasticsearchIOTest.java | 4 ++-- .../sdk/io/gcp/bigquery/BigQuerySourceBase.java | 2 +- .../sdk/io/gcp/bigquery/TransformingSource.java | 4 ++-- .../beam/sdk/io/gcp/bigtable/BigtableIO.java | 6 +++--- .../sdk/io/gcp/pubsub/PubsubUnboundedSource.java | 6 +++--- .../beam/sdk/io/gcp/bigquery/BigQueryIOTest.java | 10 +++++----- .../beam/sdk/io/gcp/bigtable/BigtableIOTest.java | 8 +++++--- .../io/gcp/pubsub/PubsubUnboundedSourceTest.java | 4 ++-- .../hadoop/inputformat/HadoopInputFormatIO.java | 4 ++-- .../inputformat/HadoopInputFormatIOTest.java | 19 +++++++++++-------- .../org/apache/beam/sdk/io/hbase/HBaseIO.java | 7 +++---- .../apache/beam/sdk/io/hbase/HBaseIOTest.java | 2 +- .../apache/beam/sdk/io/hdfs/HDFSFileSource.java | 6 +++--- .../beam/sdk/io/hdfs/HDFSFileSourceTest.java | 4 ++-- .../java/org/apache/beam/sdk/io/jms/JmsIO.java | 2 +- .../org/apache/beam/sdk/io/jms/JmsIOTest.java | 4 ++-- .../org/apache/beam/sdk/io/kafka/KafkaIO.java | 12 ++++++------ .../apache/beam/sdk/io/kafka/KafkaIOTest.java | 8 ++++---- .../beam/sdk/io/kinesis/KinesisSource.java | 2 +- .../beam/sdk/io/mongodb/MongoDbGridFSIO.java | 4 ++-- .../apache/beam/sdk/io/mongodb/MongoDbIO.java | 2 +- .../beam/sdk/io/mongodb/MongoDBGridFSIOTest.java | 2 +- .../java/org/apache/beam/sdk/io/mqtt/MqttIO.java | 2 +- 61 files changed, 156 insertions(+), 141 deletions(-) ----------------------------------------------------------------------
