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 <k...@google.com> Authored: Fri Apr 8 10:28:32 2016 -0700 Committer: Kenneth Knowles <k...@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;