beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From aljos...@apache.org
Subject [2/2] incubator-beam git commit: This closes #409
Date Sun, 19 Jun 2016 09:36:10 GMT
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.krettek@gmail.com>
Authored: Sun Jun 19 11:35:19 2016 +0200
Committer: Aljoscha Krettek <aljoscha.krettek@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(-)
----------------------------------------------------------------------



Mime
View raw message