[49/50] [abbrv] beam git commit: [BEAM-911] This closes #2510

[jbonofre]

[BEAM-911] This closes #2510


Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/1788cef9
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/1788cef9
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/1788cef9

Branch: refs/heads/DSL_SQL
Commit: 1788cef96916ebfb588848922a5cbc2584586e9b
Parents: a405a2c 024b6e0
Author: Jean-Baptiste Onofré <jbono...@apache.org>
Authored: Wed Apr 12 21:53:15 2017 +0200
Committer: Jean-Baptiste Onofré <jbono...@apache.org>
Committed: Wed Apr 12 21:53:15 2017 +0200

----------------------------------------------------------------------
 .../org/apache/beam/sdk/io/elasticsearch/ElasticsearchIO.java     | 2 ++
 .../beam/sdk/io/hadoop/inputformat/HadoopInputFormatIO.java       | 3 ++-
 .../src/main/java/org/apache/beam/sdk/io/hdfs/HDFSFileSink.java   | 2 ++
 .../src/main/java/org/apache/beam/sdk/io/hdfs/HDFSFileSource.java | 2 ++
 .../io/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 ++
 .../kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java | 2 ++
 .../src/main/java/org/apache/beam/sdk/io/kinesis/KinesisIO.java   | 2 ++
 .../main/java/org/apache/beam/sdk/io/mongodb/MongoDbGridFSIO.java | 2 ++
 .../src/main/java/org/apache/beam/sdk/io/mongodb/MongoDbIO.java   | 2 ++
 .../io/mqtt/src/main/java/org/apache/beam/sdk/io/mqtt/MqttIO.java | 2 ++
 11 files changed, 22 insertions(+), 1 deletion(-)
----------------------------------------------------------------------