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 <dhalp...@google.com> Authored: Sat Nov 5 01:30:41 2016 -0700 Committer: Dan Halperin <dhalp...@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(-) ----------------------------------------------------------------------
