beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From da...@apache.org
Subject [11/11] incubator-beam git commit: Merge branch 'master' into release-0.1.0-incubating
Date Tue, 07 Jun 2016 16:59:56 GMT
Merge branch 'master' into release-0.1.0-incubating


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

Branch: refs/heads/release-0.1.0-incubating
Commit: 54942431ad391232a9caac83fc7ee80fb64db24c
Parents: d6a3baa bbd05a9
Author: Davor Bonaci <davor@google.com>
Authored: Tue Jun 7 09:58:38 2016 -0700
Committer: Davor Bonaci <davor@google.com>
Committed: Tue Jun 7 09:58:38 2016 -0700

----------------------------------------------------------------------
 .travis.yml                                     |   2 +-
 distributions/pom.xml                           |  62 +++
 distributions/src/main/assembly/src.xml         |  55 +++
 examples/java/pom.xml                           |  14 +-
 examples/java8/pom.xml                          |  16 +-
 examples/pom.xml                                |   6 +-
 pom.xml                                         |  45 +-
 runners/core-java/pom.xml                       |  10 +-
 runners/direct-java/pom.xml                     |  18 +-
 .../beam/runners/direct/BundleFactory.java      |   4 +-
 .../direct/ExecutorServiceParallelExecutor.java |  19 +-
 .../ImmutabilityCheckingBundleFactory.java      |   4 +-
 .../direct/InMemoryWatermarkManager.java        |  70 +--
 .../runners/direct/InProcessBundleFactory.java  |  25 +-
 .../direct/InProcessEvaluationContext.java      |  10 +-
 .../direct/InProcessExecutionContext.java       |   4 +-
 ...InProcessGroupByKeyOnlyEvaluatorFactory.java |   6 +-
 .../runners/direct/InProcessPipelineRunner.java |   7 +-
 .../apache/beam/runners/direct/StepAndKey.java  |   8 +-
 .../beam/runners/direct/StructuralKey.java      |  77 ++++
 .../direct/GroupByKeyEvaluatorFactoryTest.java  |  27 +-
 .../ImmutabilityCheckingBundleFactoryTest.java  |  13 +-
 .../direct/InMemoryWatermarkManagerTest.java    |  95 ++--
 .../direct/InProcessBundleFactoryTest.java      |  54 ++-
 .../direct/InProcessEvaluationContextTest.java  |  52 ++-
 ...ocessGroupByKeyOnlyEvaluatorFactoryTest.java |  33 +-
 .../direct/InProcessPipelineRunnerTest.java     |  60 +++
 .../direct/InProcessTimerInternalsTest.java     |   3 +-
 .../direct/ParDoInProcessEvaluatorTest.java     |   2 +-
 .../direct/ParDoMultiEvaluatorFactoryTest.java  |  29 +-
 .../direct/ParDoSingleEvaluatorFactoryTest.java |  35 +-
 .../beam/runners/direct/StructuralKeyTest.java  |  81 ++++
 runners/flink/examples/pom.xml                  |  10 +-
 runners/flink/pom.xml                           |   6 +-
 runners/flink/runner/pom.xml                    |  20 +-
 runners/google-cloud-dataflow-java/pom.xml      |  14 +-
 runners/pom.xml                                 |   7 +-
 runners/spark/pom.xml                           |  32 +-
 sdks/java/build-tools/pom.xml                   |   4 +-
 sdks/java/build-tools/src/main/assembly/src.xml |  56 ---
 sdks/java/core/pom.xml                          |   4 +-
 .../org/apache/beam/sdk/util/PubsubClient.java  |  54 ++-
 sdks/java/extensions/join-library/pom.xml       |   8 +-
 sdks/java/extensions/pom.xml                    |   5 +-
 sdks/java/io/google-cloud-platform/pom.xml      |  10 +-
 sdks/java/io/hdfs/pom.xml                       |   8 +-
 sdks/java/io/kafka/pom.xml                      |   8 +-
 .../org/apache/beam/sdk/io/kafka/KafkaIO.java   | 441 ++++++++++++++++++-
 .../apache/beam/sdk/io/kafka/KafkaIOTest.java   | 300 ++++++++++++-
 sdks/java/io/pom.xml                            |   5 +-
 sdks/java/java8tests/pom.xml                    |   8 +-
 sdks/java/maven-archetypes/examples/pom.xml     |   4 +-
 .../main/resources/archetype-resources/pom.xml  |   6 +-
 sdks/java/maven-archetypes/pom.xml              |   4 +-
 sdks/java/maven-archetypes/starter/pom.xml      |   5 +-
 .../main/resources/archetype-resources/pom.xml  |   2 +-
 .../resources/projects/basic/reference/pom.xml  |   2 +-
 sdks/java/pom.xml                               |   4 +-
 sdks/pom.xml                                    |   6 +-
 testing/travis/README.md                        |  23 +
 testing/travis/test_wordcount.sh                | 125 ++++++
 travis/README.md                                |  23 -
 travis/test_wordcount.sh                        | 125 ------
 63 files changed, 1632 insertions(+), 643 deletions(-)
----------------------------------------------------------------------



Mime
View raw message