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 2016/08/25 18:55:54 UTC
[40/50] incubator-beam git commit: This closes #803
This closes #803
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/b4c0bb9f
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/b4c0bb9f
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/b4c0bb9f
Branch: refs/heads/gearpump-runner
Commit: b4c0bb9fa9951e6cfbc6aa56edcb8235a81216b1
Parents: fa0e395 fcdd15b
Author: Kenneth Knowles <kl...@google.com>
Authored: Wed Aug 10 13:41:29 2016 -0700
Committer: Kenneth Knowles <kl...@google.com>
Committed: Wed Aug 10 13:41:29 2016 -0700
----------------------------------------------------------------------
.../beam/runners/dataflow/DataflowRunner.java | 92 ++++++++++----------
.../apache/beam/sdk/transforms/DoFnTester.java | 29 +++++-
.../org/apache/beam/sdk/transforms/ParDo.java | 6 ++
3 files changed, 77 insertions(+), 50 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/b4c0bb9f/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowRunner.java
----------------------------------------------------------------------
diff --cc runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowRunner.java
index 54d1923,4d34ec4..bea6264
--- a/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowRunner.java
+++ b/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowRunner.java
@@@ -2370,11 -2370,10 +2368,11 @@@ public class DataflowRunner extends Pip
}
/**
- * A specialized {@link OldDoFn} for writing the contents of a {@link PCollection}
+ * A specialized {@link DoFn} for writing the contents of a {@link PCollection}
* to a streaming {@link PCollectionView} backend implementation.
*/
- private static class StreamingPCollectionViewWriterFn<T>
+ @Deprecated
+ public static class StreamingPCollectionViewWriterFn<T>
extends OldDoFn<Iterable<T>, T> implements OldDoFn.RequiresWindowAccess {
private final PCollectionView<?> view;
private final Coder<T> dataCoder;
http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/b4c0bb9f/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/DoFnTester.java
----------------------------------------------------------------------