Repository: incubator-beam Updated Branches: refs/heads/master f184bcf37 -> 2f18cd268
Add accessors for sub-coders of KeyedWorkItemCoder Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/ca1b3a87 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/ca1b3a87 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/ca1b3a87 Branch: refs/heads/master Commit: ca1b3a87fbe7218c0af912ba0f0deae8b903b1ac Parents: 93a5d39 Author: Kenneth Knowles <[email protected]> Authored: Thu Apr 28 15:51:40 2016 -0700 Committer: Kenneth Knowles <[email protected]> Committed: Fri May 13 12:02:02 2016 -0700 ---------------------------------------------------------------------- .../java/org/apache/beam/sdk/util/KeyedWorkItemCoder.java | 8 ++++++++ 1 file changed, 8 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/ca1b3a87/sdks/java/core/src/main/java/org/apache/beam/sdk/util/KeyedWorkItemCoder.java ---------------------------------------------------------------------- diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/util/KeyedWorkItemCoder.java b/sdks/java/core/src/main/java/org/apache/beam/sdk/util/KeyedWorkItemCoder.java index 763f68b..ec5d821 100644 --- a/sdks/java/core/src/main/java/org/apache/beam/sdk/util/KeyedWorkItemCoder.java +++ b/sdks/java/core/src/main/java/org/apache/beam/sdk/util/KeyedWorkItemCoder.java @@ -79,6 +79,14 @@ public class KeyedWorkItemCoder<K, ElemT> extends StandardCoder<KeyedWorkItem<K, this.elemsCoder = IterableCoder.of(FullWindowedValueCoder.of(elemCoder, windowCoder)); } + public Coder<K> getKeyCoder() { + return keyCoder; + } + + public Coder<ElemT> getElementCoder() { + return elemCoder; + } + @Override public void encode(KeyedWorkItem<K, ElemT> value, OutputStream outStream, Coder.Context context) throws CoderException, IOException {
