Repository: incubator-beam Updated Branches: refs/heads/master 6893a7270 -> b8e93fff8
This closes #1478 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/b8e93fff Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/b8e93fff Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/b8e93fff Branch: refs/heads/master Commit: b8e93fff8d8ef85357eb5d4ade0a29dae60c3e04 Parents: 6893a72 8a2f020 Author: Kenneth Knowles <k...@google.com> Authored: Mon Dec 5 14:55:02 2016 -0800 Committer: Kenneth Knowles <k...@google.com> Committed: Mon Dec 5 14:55:02 2016 -0800 ---------------------------------------------------------------------- .../operators/ApexGroupByKeyOperator.java | 4 +- .../apache/beam/runners/core/DoFnRunner.java | 1 - .../apache/beam/runners/core/DoFnRunners.java | 1 - .../core/GroupAlsoByWindowViaWindowSetDoFn.java | 1 - .../apache/beam/runners/core/KeyedWorkItem.java | 44 +++++++ .../beam/runners/core/KeyedWorkItemCoder.java | 130 +++++++++++++++++++ .../beam/runners/core/KeyedWorkItems.java | 122 +++++++++++++++++ .../core/LateDataDroppingDoFnRunner.java | 2 - .../beam/runners/core/SplittableParDo.java | 2 - .../runners/core/KeyedWorkItemCoderTest.java | 64 +++++++++ .../beam/runners/core/SplittableParDoTest.java | 2 - ...ectGBKIntoKeyedWorkItemsOverrideFactory.java | 2 +- .../beam/runners/direct/DirectGroupByKey.java | 4 +- .../direct/ExecutorServiceParallelExecutor.java | 4 +- .../GroupAlsoByWindowEvaluatorFactory.java | 2 +- .../direct/GroupByKeyOnlyEvaluatorFactory.java | 4 +- ...littableProcessElementsEvaluatorFactory.java | 2 +- .../direct/GroupByKeyEvaluatorFactoryTest.java | 4 +- .../GroupByKeyOnlyEvaluatorFactoryTest.java | 4 +- .../streaming/SingletonKeyedWorkItem.java | 2 +- .../streaming/SingletonKeyedWorkItemCoder.java | 4 +- .../wrappers/streaming/WindowDoFnOperator.java | 6 +- .../wrappers/streaming/WorkItemKeySelector.java | 2 +- .../beam/runners/dataflow/DataflowRunner.java | 4 +- .../org/apache/beam/sdk/util/KeyedWorkItem.java | 43 ------ .../beam/sdk/util/KeyedWorkItemCoder.java | 128 ------------------ .../apache/beam/sdk/util/KeyedWorkItems.java | 121 ----------------- .../beam/sdk/util/KeyedWorkItemCoderTest.java | 62 --------- 28 files changed, 383 insertions(+), 388 deletions(-) ----------------------------------------------------------------------
