Ning Kang created BEAM-12506:
--------------------------------
Summary: Change WindowedValueHolder into a Row Schema
Key: BEAM-12506
URL: https://issues.apache.org/jira/browse/BEAM-12506
Project: Beam
Issue Type: Improvement
Components: runner-py-interactive
Reporter: Ning Kang
Assignee: Ning Kang
The WindowedValueHolder is a Python type that requires a special
`SafeFastPrimitivesCoder` instead of the native `FastPrimitivesCoder` in
cache_manager to encode and decode.
When reading cache of it and applying an external transform such as a
SqlTransform, it introduces a pickled Python coder that is not xLang friendly.
We could build a Row schema to hold the WindowedValueHolder to make the cache
reading xLang friendly and also get rid of the additional layer of
`SafeFastPrimitivesCoder`.
We could
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
