beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dhalp...@apache.org
Subject [3/3] beam git commit: This closes #2523
Date Tue, 18 Apr 2017 19:01:44 GMT
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 <dhalperi@google.com>
Authored: Tue Apr 18 11:53:08 2017 -0700
Committer: Dan Halperin <dhalperi@google.com>
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(-)
----------------------------------------------------------------------



Mime
View raw message