You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by jb...@apache.org on 2017/04/12 19:57:20 UTC
[49/50] [abbrv] beam git commit: [BEAM-911] This closes #2510
[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� <jb...@apache.org>
Authored: Wed Apr 12 21:53:15 2017 +0200
Committer: Jean-Baptiste Onofr� <jb...@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(-)
----------------------------------------------------------------------