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 <owenzhang1...@gmail.com> Authored: Fri Jul 7 16:33:03 2017 +0800 Committer: manuzhang <owenzhang1...@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 ----------------------------------------------------------------------