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

Reply via email to