You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by al...@apache.org on 2017/03/08 22:25:24 UTC
[9/9] beam git commit: This closes #2202
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(-)
----------------------------------------------------------------------