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/04/08 19:28:52 UTC
[2/2] incubator-beam git commit: This closes #131
This closes #131
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/6348a1fe
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/6348a1fe
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/6348a1fe
Branch: refs/heads/master
Commit: 6348a1fe24683d531e053d5be1e56e38635d2957
Parents: 245cffa d1486c6
Author: Kenneth Knowles <kl...@google.com>
Authored: Fri Apr 8 10:28:32 2016 -0700
Committer: Kenneth Knowles <kl...@google.com>
Committed: Fri Apr 8 10:28:32 2016 -0700
----------------------------------------------------------------------
.../inprocess/GroupByKeyEvaluatorFactory.java | 21 +++++++++-
.../sdk/runners/inprocess/InProcessCreate.java | 18 ++++++++
.../inprocess/InProcessPipelineRunner.java | 43 +++++++-------------
.../inprocess/PTransformOverrideFactory.java | 33 +++++++++++++++
.../runners/inprocess/ViewEvaluatorFactory.java | 28 +++++++++++--
5 files changed, 110 insertions(+), 33 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/6348a1fe/sdks/java/core/src/main/java/com/google/cloud/dataflow/sdk/runners/inprocess/InProcessCreate.java
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/6348a1fe/sdks/java/core/src/main/java/com/google/cloud/dataflow/sdk/runners/inprocess/InProcessPipelineRunner.java
----------------------------------------------------------------------
diff --cc sdks/java/core/src/main/java/com/google/cloud/dataflow/sdk/runners/inprocess/InProcessPipelineRunner.java
index f5b7f3c,9ce4430..fa93994
--- a/sdks/java/core/src/main/java/com/google/cloud/dataflow/sdk/runners/inprocess/InProcessPipelineRunner.java
+++ b/sdks/java/core/src/main/java/com/google/cloud/dataflow/sdk/runners/inprocess/InProcessPipelineRunner.java
@@@ -33,9 -35,7 +35,8 @@@ import com.google.cloud.dataflow.sdk.tr
import com.google.cloud.dataflow.sdk.transforms.Create;
import com.google.cloud.dataflow.sdk.transforms.GroupByKey;
import com.google.cloud.dataflow.sdk.transforms.PTransform;
+import com.google.cloud.dataflow.sdk.transforms.ParDo;
import com.google.cloud.dataflow.sdk.transforms.View.CreatePCollectionView;
- import com.google.cloud.dataflow.sdk.util.InstanceBuilder;
import com.google.cloud.dataflow.sdk.util.MapAggregatorValues;
import com.google.cloud.dataflow.sdk.util.TimerInternals.TimerData;
import com.google.cloud.dataflow.sdk.util.UserCodeException;