[ https://issues.apache.org/jira/browse/BEAM-3780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Thomas Groh closed BEAM-3780. ----------------------------- Resolution: Duplicate Fix Version/s: Not applicable This is handled via the {{LengthPrefixUnknownCoders#forCoder(id, components, true)}} call, followed by an instantiation of the returned Coder - due to the idempotence of the call, it can be used to construct the equivalent (length-prefixed byte array coder) of an SDK-side wire coder. > Add a utility to instantiate a partially unknown coder > ------------------------------------------------------ > > Key: BEAM-3780 > URL: https://issues.apache.org/jira/browse/BEAM-3780 > Project: Beam > Issue Type: Bug > Components: runner-core > Reporter: Thomas Groh > Assignee: Thomas Groh > Priority: Major > Fix For: Not applicable > > > Coders must be understood by the SDK harness that is encoding or decoding the > associated elements. However, the pipeline runner is capable of constructing > partial coders, where an unknown coder is replaced with a ByteArrayCoder. It > then can decompose the portions of elements it is aware of, without having to > understand the custom element encodings. > > This should go in CoderTranslation, as an alternative to the full-fidelity > rehydration of a coder. -- This message was sent by Atlassian JIRA (v7.6.3#76005)