You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by tg...@apache.org on 2016/11/29 01:51:18 UTC
[1/2] incubator-beam git commit: Remove the Experimental Annotation
from the DirectRunner
Repository: incubator-beam
Updated Branches:
refs/heads/master 4bcef03d9 -> cdb7ba165
Remove the Experimental Annotation from the DirectRunner
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/0ae18124
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/0ae18124
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/0ae18124
Branch: refs/heads/master
Commit: 0ae181248823b08803a8f8ac0d39a35a190c4acd
Parents: 4bcef03
Author: Thomas Groh <tg...@google.com>
Authored: Mon Nov 28 15:52:03 2016 -0800
Committer: Thomas Groh <tg...@google.com>
Committed: Mon Nov 28 15:52:51 2016 -0800
----------------------------------------------------------------------
.../main/java/org/apache/beam/runners/direct/DirectRunner.java | 5 +----
1 file changed, 1 insertion(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/0ae18124/runners/direct-java/src/main/java/org/apache/beam/runners/direct/DirectRunner.java
----------------------------------------------------------------------
diff --git a/runners/direct-java/src/main/java/org/apache/beam/runners/direct/DirectRunner.java b/runners/direct-java/src/main/java/org/apache/beam/runners/direct/DirectRunner.java
index cb31947..f71e109 100644
--- a/runners/direct-java/src/main/java/org/apache/beam/runners/direct/DirectRunner.java
+++ b/runners/direct-java/src/main/java/org/apache/beam/runners/direct/DirectRunner.java
@@ -41,7 +41,6 @@ import org.apache.beam.sdk.AggregatorValues;
import org.apache.beam.sdk.Pipeline;
import org.apache.beam.sdk.Pipeline.PipelineExecutionException;
import org.apache.beam.sdk.PipelineResult;
-import org.apache.beam.sdk.annotations.Experimental;
import org.apache.beam.sdk.io.Read;
import org.apache.beam.sdk.io.Write;
import org.apache.beam.sdk.metrics.MetricResults;
@@ -71,9 +70,7 @@ import org.joda.time.Instant;
* An In-Memory implementation of the Dataflow Programming Model. Supports Unbounded
* {@link PCollection PCollections}.
*/
-@Experimental
-public class DirectRunner
- extends PipelineRunner<DirectPipelineResult> {
+public class DirectRunner extends PipelineRunner<DirectPipelineResult> {
/**
* The default set of transform overrides to use in the {@link DirectRunner}.
*
[2/2] incubator-beam git commit: This closes #1447
Posted by tg...@apache.org.
This closes #1447
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/cdb7ba16
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/cdb7ba16
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/cdb7ba16
Branch: refs/heads/master
Commit: cdb7ba165fb29d7e870ff959fd7bd00416c863bb
Parents: 4bcef03 0ae1812
Author: Thomas Groh <tg...@google.com>
Authored: Mon Nov 28 17:51:04 2016 -0800
Committer: Thomas Groh <tg...@google.com>
Committed: Mon Nov 28 17:51:04 2016 -0800
----------------------------------------------------------------------
.../main/java/org/apache/beam/runners/direct/DirectRunner.java | 5 +----
1 file changed, 1 insertion(+), 4 deletions(-)
----------------------------------------------------------------------