This closes #409
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/0e4d0a9a Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/0e4d0a9a Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/0e4d0a9a Branch: refs/heads/master Commit: 0e4d0a9ae0250863d7144ffdcc6c4e9cc099611f Parents: 69a4141 93ca508 Author: Aljoscha Krettek <aljoscha.kret...@gmail.com> Authored: Sun Jun 19 11:35:19 2016 +0200 Committer: Aljoscha Krettek <aljoscha.kret...@gmail.com> Committed: Sun Jun 19 11:35:19 2016 +0200 ---------------------------------------------------------------------- runners/flink/runner/pom.xml | 10 + .../beam/runners/flink/FlinkRunnerResult.java | 8 + .../FlinkBatchTransformTranslators.java | 49 +--- .../FlinkBatchTranslationContext.java | 13 +- .../translation/types/CoderComparator.java | 217 ---------------- .../translation/types/CoderTypeInformation.java | 14 +- .../translation/types/CoderTypeSerializer.java | 37 +-- .../types/EncodedValueComparator.java | 197 ++++++++++++++ .../types/EncodedValueSerializer.java | 113 ++++++++ .../types/EncodedValueTypeInformation.java | 111 ++++++++ .../translation/types/KvCoderComperator.java | 259 ------------------- .../types/KvCoderTypeInformation.java | 207 --------------- .../flink/translation/types/KvKeySelector.java | 51 ++++ .../flink/EncodedValueComparatorTest.java | 71 +++++ .../beam/sdk/transforms/GroupByKeyTest.java | 206 ++++++++++++++- 15 files changed, 799 insertions(+), 764 deletions(-) ----------------------------------------------------------------------
