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 <al...@google.com> Authored: Wed Mar 8 14:07:45 2017 -0800 Committer: Ahmet Altay <al...@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(-) ----------------------------------------------------------------------