[ 
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)

Reply via email to