beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From al...@apache.org
Subject [9/9] beam git commit: This closes #2202
Date Wed, 08 Mar 2017 22:25:24 GMT
This closes #2202


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

Branch: refs/heads/release-0.6.0
Commit: b25a0369dc5e5e4eacdc6e40b1e81452f9685579
Parents: 1c91d0e edaf3ac
Author: Ahmet Altay <altay@google.com>
Authored: Wed Mar 8 14:07:45 2017 -0800
Committer: Ahmet Altay <altay@google.com>
Committed: Wed Mar 8 14:07:45 2017 -0800

----------------------------------------------------------------------
 examples/java/pom.xml                           |   5 +-
 examples/java8/pom.xml                          |   2 +-
 examples/pom.xml                                |   2 +-
 pom.xml                                         |   4 +-
 runners/apex/pom.xml                            |   2 +-
 runners/core-construction-java/pom.xml          |   5 +-
 runners/core-java/pom.xml                       |   5 +-
 runners/direct-java/pom.xml                     |   5 +-
 runners/flink/examples/pom.xml                  |   2 +-
 runners/flink/pom.xml                           |   2 +-
 runners/flink/runner/pom.xml                    |   2 +-
 runners/google-cloud-dataflow-java/pom.xml      |   7 +-
 .../dataflow/BatchStatefulParDoOverrides.java   | 283 +++++++++++++++++++
 .../dataflow/DataflowPipelineTranslator.java    |   5 +-
 .../beam/runners/dataflow/DataflowRunner.java   |   6 +
 .../beam/runners/dataflow/util/DoFnInfo.java    |   9 +
 .../BatchStatefulParDoOverridesTest.java        | 169 +++++++++++
 .../DataflowPipelineTranslatorTest.java         |  72 +++++
 runners/pom.xml                                 |   2 +-
 runners/spark/pom.xml                           |   2 +-
 sdks/common/fn-api/pom.xml                      |   2 +-
 sdks/common/pom.xml                             |   2 +-
 sdks/common/runner-api/pom.xml                  |   2 +-
 sdks/java/build-tools/pom.xml                   |   2 +-
 sdks/java/core/pom.xml                          |   5 +-
 .../apache/beam/sdk/transforms/ParDoTest.java   | 117 ++++++++
 sdks/java/extensions/jackson/pom.xml            |   7 +-
 sdks/java/extensions/join-library/pom.xml       |   2 +-
 sdks/java/extensions/pom.xml                    |   2 +-
 sdks/java/extensions/sorter/pom.xml             |   5 +-
 sdks/java/harness/pom.xml                       |   2 +-
 sdks/java/io/elasticsearch/pom.xml              |   9 +-
 .../sdk/io/elasticsearch/ElasticsearchIO.java   | 102 ++++---
 sdks/java/io/google-cloud-platform/pom.xml      |   2 +-
 sdks/java/io/hadoop-common/pom.xml              |   2 +-
 sdks/java/io/hbase/pom.xml                      |   5 +-
 sdks/java/io/hdfs/pom.xml                       |   5 +-
 sdks/java/io/jdbc/pom.xml                       |   2 +-
 sdks/java/io/jms/pom.xml                        |   2 +-
 sdks/java/io/kafka/pom.xml                      |   5 +-
 sdks/java/io/kinesis/pom.xml                    |   2 +-
 sdks/java/io/mongodb/pom.xml                    |   2 +-
 sdks/java/io/mqtt/pom.xml                       |   2 +-
 sdks/java/io/pom.xml                            |   2 +-
 sdks/java/java8tests/pom.xml                    |   2 +-
 sdks/java/javadoc/pom.xml                       |   2 +-
 .../maven-archetypes/examples-java8/pom.xml     |   2 +-
 .../main/resources/archetype-resources/pom.xml  |  11 +-
 sdks/java/maven-archetypes/examples/pom.xml     |   2 +-
 .../main/resources/archetype-resources/pom.xml  |  11 +-
 sdks/java/maven-archetypes/pom.xml              |   2 +-
 sdks/java/maven-archetypes/starter/pom.xml      |   2 +-
 sdks/java/pom.xml                               |   2 +-
 sdks/pom.xml                                    |   2 +-
 sdks/python/apache_beam/io/range_trackers.py    |   2 +-
 sdks/python/apache_beam/transforms/trigger.py   |   2 +-
 sdks/python/apache_beam/typehints/decorators.py |   5 +-
 sdks/python/apache_beam/typehints/typehints.py  |   3 +-
 .../apache_beam/utils/pipeline_options.py       |   2 +-
 sdks/python/apache_beam/version.py              |   2 +-
 sdks/python/pom.xml                             |   2 +-
 sdks/python/setup.py                            |   1 -
 62 files changed, 807 insertions(+), 131 deletions(-)
----------------------------------------------------------------------



Mime
View raw message