[
https://issues.apache.org/jira/browse/BEAM-8907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16989871#comment-16989871
]
Ismaël Mejía edited comment on BEAM-8907 at 12/6/19 3:18 PM:
-------------------------------------------------------------
SDF is implemented in a naive an simple way for all runners by expanding SDF
into two continuous ParDos in the batch case. Most tests already pass for the
Structured Streaming runner so this ticket could be closed given that the only
missing bit is BEAM-8859
was (Author: iemejia):
SDF is implemented in a naive an simple way for all runners by expanding SDF
into two continuous ParDos in the batch case. Most tests already pass for the
Structured Streaming runner so this ticket could closed given that the only
missing bit is BEAM-8859
> Implement SplittableDoFn translation in spark runner
> ----------------------------------------------------
>
> Key: BEAM-8907
> URL: https://issues.apache.org/jira/browse/BEAM-8907
> Project: Beam
> Issue Type: Improvement
> Components: runner-spark
> Reporter: Etienne Chauchot
> Priority: Major
> Labels: structured-streaming
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
