beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Thomas Groh (JIRA)" <>
Subject [jira] [Created] (BEAM-3779) Enable deserialization of a non-java Pipeline
Date Mon, 05 Mar 2018 22:50:00 GMT
Thomas Groh created BEAM-3779:

             Summary: Enable deserialization of a non-java Pipeline
                 Key: BEAM-3779
             Project: Beam
          Issue Type: Bug
          Components: runner-core
            Reporter: Thomas Groh
            Assignee: Thomas Groh

Currently, rehydrating a Pipeline works on the PCollection and PTransform levels with the
use of RawPTransform, but the runner-core-construction-java utilities will throw if the runner
attempts to deserialize a WindowingStrategy or Coder which contains non-Java custom (or otherwise
unknown) Coders or WindowFns.


Use a strategy like RawPTransform to deserialize WindowFns and Coders, so they can be interacted
with as intermediate tokens in the java form.

This message was sent by Atlassian JIRA

View raw message