beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From t..@apache.org
Subject [41/50] incubator-beam git commit: Closes #1290
Date Mon, 07 Nov 2016 19:59:31 GMT
Closes #1290


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

Branch: refs/heads/apex-runner
Commit: 5864a38ba595cdf90d2d5559e4312ef6144f60c7
Parents: 14e093a 717b431
Author: Dan Halperin <dhalperi@google.com>
Authored: Sat Nov 5 01:30:41 2016 -0700
Committer: Dan Halperin <dhalperi@google.com>
Committed: Sat Nov 5 01:30:41 2016 -0700

----------------------------------------------------------------------
 examples/java/pom.xml                           | 68 -------------------
 examples/java8/pom.xml                          |  8 ---
 .../beam/examples/complete/game/GameStats.java  |  3 +-
 .../examples/complete/game/LeaderBoard.java     |  2 +-
 .../beam/examples/complete/game/UserScore.java  |  2 +-
 pom.xml                                         | 11 ++-
 runners/core-java/pom.xml                       | 23 -------
 runners/direct-java/pom.xml                     | 61 -----------------
 runners/flink/examples/pom.xml                  |  8 ---
 .../flink/examples/streaming/AutoComplete.java  |  8 +--
 .../flink/examples/streaming/JoinExamples.java  | 12 ++--
 .../examples/streaming/KafkaIOExamples.java     |  2 +-
 .../examples/streaming/WindowedWordCount.java   |  8 +--
 runners/flink/runner/pom.xml                    |  8 ---
 runners/google-cloud-dataflow-java/pom.xml      | 70 --------------------
 .../runners/dataflow/DataflowPipelineJob.java   |  1 -
 .../runners/dataflow/internal/IsmFormat.java    |  5 +-
 .../runners/dataflow/util/MonitoringUtil.java   |  1 -
 .../runners/dataflow/util/RandomAccessData.java |  2 +-
 runners/spark/pom.xml                           |  4 --
 sdks/java/core/pom.xml                          | 70 --------------------
 .../java/org/apache/beam/sdk/io/AvroIO.java     |  4 +-
 .../org/apache/beam/sdk/io/BoundedSource.java   | 11 ++-
 .../apache/beam/sdk/io/CompressedSource.java    |  2 -
 .../org/apache/beam/sdk/io/FileBasedSink.java   |  9 +--
 .../java/org/apache/beam/sdk/io/XmlSource.java  |  2 +-
 .../apache/beam/sdk/io/range/ByteKeyRange.java  |  2 +-
 .../apache/beam/sdk/options/ValueProvider.java  |  2 +-
 .../apache/beam/sdk/transforms/Aggregator.java  | 12 ++--
 .../apache/beam/sdk/transforms/CombineFns.java  |  4 +-
 .../org/apache/beam/sdk/transforms/DoFn.java    | 22 +++---
 .../org/apache/beam/sdk/transforms/ParDo.java   |  2 +-
 .../org/apache/beam/sdk/transforms/View.java    |  2 +-
 .../sdk/transforms/display/DisplayData.java     |  5 +-
 .../beam/sdk/transforms/join/CoGroupByKey.java  |  6 +-
 .../sdk/transforms/reflect/DoFnSignature.java   |  2 +-
 .../splittabledofn/RestrictionTracker.java      |  2 +-
 .../transforms/splittabledofn/package-info.java |  4 +-
 .../beam/sdk/util/BaseExecutionContext.java     |  2 +-
 .../BufferedElementCountingOutputStream.java    |  4 +-
 .../apache/beam/sdk/util/ExecutionContext.java  |  8 +--
 .../sdk/util/ExposedByteArrayInputStream.java   |  5 +-
 .../sdk/util/ExposedByteArrayOutputStream.java  |  2 -
 .../java/org/apache/beam/sdk/util/GcsUtil.java  |  2 -
 .../apache/beam/sdk/util/MovingFunction.java    |  4 +-
 .../org/apache/beam/sdk/util/PubsubClient.java  | 32 ++-------
 .../org/apache/beam/sdk/util/StringUtils.java   |  8 +--
 .../apache/beam/sdk/util/TimerInternals.java    |  8 ++-
 .../beam/sdk/util/state/StateNamespace.java     | 16 ++---
 .../java/org/apache/beam/sdk/values/PDone.java  |  2 +-
 .../beam/sdk/io/gcp/datastore/DatastoreV1.java  |  2 +-
 sdks/java/io/jdbc/pom.xml                       |  4 --
 sdks/java/io/kafka/pom.xml                      |  7 --
 sdks/java/io/kinesis/pom.xml                    |  7 --
 .../apache/beam/sdk/io/kinesis/KinesisIO.java   | 35 +++++-----
 sdks/java/io/mongodb/pom.xml                    |  4 --
 56 files changed, 119 insertions(+), 503 deletions(-)
----------------------------------------------------------------------



Mime
View raw message