You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ke...@apache.org on 2017/08/07 23:54:03 UTC
[38/50] [abbrv] beam git commit: Merge branch 'master' of
https://github.com/apache/beam into sync-master
Merge branch 'master' of https://github.com/apache/beam into sync-master
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/c2d3fbc3
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/c2d3fbc3
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/c2d3fbc3
Branch: refs/heads/master
Commit: c2d3fbc3a85a276850a2a56e040eccf2e2079339
Parents: 627ae0b 9e565f2
Author: manuzhang <ow...@gmail.com>
Authored: Fri Jul 7 16:33:03 2017 +0800
Committer: manuzhang <ow...@gmail.com>
Committed: Fri Jul 7 16:33:03 2017 +0800
----------------------------------------------------------------------
.../jenkins/common_job_properties.groovy | 5 +-
.../job_beam_PreCommit_Website_Merge.groovy | 59 +++++++++
examples/java/pom.xml | 20 ++-
examples/java8/pom.xml | 20 ++-
.../examples/complete/game/LeaderBoardTest.java | 2 +
examples/pom.xml | 2 +-
pom.xml | 87 ++++++++++++-
runners/apex/pom.xml | 11 +-
runners/core-construction-java/pom.xml | 2 +-
runners/core-java/pom.xml | 2 +-
...eBoundedSplittableProcessElementInvoker.java | 5 +
.../beam/runners/core/ReduceFnRunner.java | 106 ++++++++++-----
.../beam/runners/core/SimpleDoFnRunner.java | 20 +++
.../beam/runners/core/ReduceFnRunnerTest.java | 81 +++++++++++-
runners/direct-java/pom.xml | 4 +-
runners/flink/pom.xml | 2 +-
runners/google-cloud-dataflow-java/pom.xml | 2 +-
.../dataflow/DataflowPipelineTranslator.java | 1 +
.../runners/dataflow/TransformTranslator.java | 4 +-
.../beam/runners/dataflow/util/TimeUtil.java | 24 ++--
.../runners/dataflow/util/TimeUtilTest.java | 6 +
runners/pom.xml | 2 +-
runners/spark/pom.xml | 16 +--
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 | 2 +-
.../org/apache/beam/sdk/transforms/DoFn.java | 2 +-
.../apache/beam/sdk/transforms/DoFnTester.java | 5 +
.../reflect/ByteBuddyDoFnInvokerFactory.java | 6 +
.../reflect/ByteBuddyOnTimerInvokerFactory.java | 73 ++++-------
.../sdk/transforms/reflect/DoFnInvoker.java | 13 +-
.../sdk/transforms/reflect/DoFnSignature.java | 23 ++++
.../sdk/transforms/reflect/DoFnSignatures.java | 22 +++-
.../reflect/OnTimerMethodSpecifier.java | 37 ++++++
.../apache/beam/sdk/transforms/ParDoTest.java | 63 +++++++++
.../transforms/reflect/DoFnSignaturesTest.java | 14 ++
.../google-cloud-platform-core/pom.xml | 2 +-
sdks/java/extensions/jackson/pom.xml | 2 +-
sdks/java/extensions/join-library/pom.xml | 2 +-
sdks/java/extensions/pom.xml | 2 +-
sdks/java/extensions/protobuf/pom.xml | 2 +-
sdks/java/extensions/sorter/pom.xml | 8 +-
sdks/java/harness/pom.xml | 2 +-
sdks/java/io/amqp/pom.xml | 2 +-
sdks/java/io/cassandra/pom.xml | 2 +-
sdks/java/io/common/pom.xml | 2 +-
sdks/java/io/elasticsearch/pom.xml | 2 +-
sdks/java/io/google-cloud-platform/pom.xml | 2 +-
sdks/java/io/hadoop-common/pom.xml | 2 +-
sdks/java/io/hadoop-file-system/pom.xml | 33 +----
sdks/java/io/hadoop/input-format/pom.xml | 2 +-
sdks/java/io/hadoop/jdk1.8-tests/pom.xml | 4 +-
sdks/java/io/hadoop/pom.xml | 2 +-
sdks/java/io/hbase/pom.xml | 18 ++-
sdks/java/io/hcatalog/pom.xml | 20 ++-
sdks/java/io/jdbc/pom.xml | 4 +-
sdks/java/io/jms/pom.xml | 2 +-
sdks/java/io/kafka/pom.xml | 2 +-
.../org/apache/beam/sdk/io/kafka/KafkaIO.java | 130 +++++++++++++------
.../apache/beam/sdk/io/kafka/KafkaIOTest.java | 30 +++++
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 | 33 +----
sdks/java/io/xml/pom.xml | 2 +-
sdks/java/java8tests/pom.xml | 2 +-
sdks/java/javadoc/pom.xml | 19 ++-
.../maven-archetypes/examples-java8/pom.xml | 2 +-
.../main/resources/archetype-resources/pom.xml | 1 -
sdks/java/maven-archetypes/examples/pom.xml | 2 +-
.../main/resources/archetype-resources/pom.xml | 1 -
sdks/java/maven-archetypes/pom.xml | 2 +-
sdks/java/maven-archetypes/starter/pom.xml | 2 +-
.../resources/projects/basic/reference/pom.xml | 2 +-
sdks/java/pom.xml | 2 +-
sdks/pom.xml | 2 +-
sdks/python/apache_beam/io/gcp/gcsio.py | 10 +-
.../runners/direct/transform_evaluator.py | 5 +-
sdks/python/apache_beam/version.py | 2 +-
sdks/python/pom.xml | 2 +-
sdks/python/setup.py | 4 +-
83 files changed, 828 insertions(+), 303 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/beam/blob/c2d3fbc3/examples/java/pom.xml
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/beam/blob/c2d3fbc3/pom.xml
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/beam/blob/c2d3fbc3/runners/pom.xml
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/beam/blob/c2d3fbc3/sdks/java/pom.xml
----------------------------------------------------------------------