Repository: beam Updated Branches: refs/heads/master 6ca53055b -> da3b8bfde
Add missing displayData to ElasticsearchIO.Read Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/d9fc36ae Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/d9fc36ae Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/d9fc36ae Branch: refs/heads/master Commit: d9fc36ae7ffd127b93a0b9a03b4ce8c86e5cc1fb Parents: 6ca5305 Author: Etienne Chauchot <echauc...@gmail.com> Authored: Mon Jul 24 12:03:24 2017 +0200 Committer: Ismaël MejÃa <ieme...@gmail.com> Committed: Fri Jul 28 16:24:15 2017 +0200 ---------------------------------------------------------------------- .../java/org/apache/beam/sdk/io/elasticsearch/ElasticsearchIO.java | 2 ++ 1 file changed, 2 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/d9fc36ae/sdks/java/io/elasticsearch/src/main/java/org/apache/beam/sdk/io/elasticsearch/ElasticsearchIO.java ---------------------------------------------------------------------- diff --git a/sdks/java/io/elasticsearch/src/main/java/org/apache/beam/sdk/io/elasticsearch/ElasticsearchIO.java b/sdks/java/io/elasticsearch/src/main/java/org/apache/beam/sdk/io/elasticsearch/ElasticsearchIO.java index 8e6e253..acc7f2f 100644 --- a/sdks/java/io/elasticsearch/src/main/java/org/apache/beam/sdk/io/elasticsearch/ElasticsearchIO.java +++ b/sdks/java/io/elasticsearch/src/main/java/org/apache/beam/sdk/io/elasticsearch/ElasticsearchIO.java @@ -392,6 +392,8 @@ public class ElasticsearchIO { public void populateDisplayData(DisplayData.Builder builder) { super.populateDisplayData(builder); builder.addIfNotNull(DisplayData.item("query", getQuery())); + builder.addIfNotNull(DisplayData.item("batchSize", getBatchSize())); + builder.addIfNotNull(DisplayData.item("scrollKeepalive", getScrollKeepalive())); getConnectionConfiguration().populateDisplayData(builder); } }
