This closes #3458
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/23a34f5d Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/23a34f5d Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/23a34f5d Branch: refs/heads/gearpump-runner Commit: 23a34f5dff8d3fe60f7a584045d227d622215a8e Parents: 6573e2e 2cb2161 Author: Jean-Baptiste Onofré <[email protected]> Authored: Wed Jun 28 17:07:47 2017 +0200 Committer: Jean-Baptiste Onofré <[email protected]> Committed: Wed Jun 28 17:07:47 2017 +0200 ---------------------------------------------------------------------- .../amqp/src/main/java/org/apache/beam/sdk/io/amqp/AmqpIO.java | 2 ++ .../java/org/apache/beam/sdk/io/cassandra/CassandraIO.java | 2 +- .../org/apache/beam/sdk/io/elasticsearch/ElasticsearchIO.java | 2 +- .../java/org/apache/beam/sdk/io/gcp/bigtable/BigtableIO.java | 6 +++--- .../java/org/apache/beam/sdk/io/gcp/spanner/SpannerIO.java | 2 +- .../beam/sdk/io/hadoop/inputformat/HadoopInputFormatIO.java | 2 +- .../src/main/java/org/apache/beam/sdk/io/hbase/HBaseIO.java | 2 +- .../main/java/org/apache/beam/sdk/io/hcatalog/HCatalogIO.java | 2 +- .../jdbc/src/main/java/org/apache/beam/sdk/io/jdbc/JdbcIO.java | 2 +- .../io/jms/src/main/java/org/apache/beam/sdk/io/jms/JmsIO.java | 2 +- .../src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java | 2 +- .../main/java/org/apache/beam/sdk/io/kinesis/KinesisIO.java | 2 +- .../java/org/apache/beam/sdk/io/mongodb/MongoDbGridFSIO.java | 2 +- .../main/java/org/apache/beam/sdk/io/mongodb/MongoDbIO.java | 2 +- .../mqtt/src/main/java/org/apache/beam/sdk/io/mqtt/MqttIO.java | 2 +- 15 files changed, 18 insertions(+), 16 deletions(-) ----------------------------------------------------------------------
