Eugene Kirpichov created BEAM-3833:
--------------------------------------
Summary: Java SDK harness should detect SDF ProcessFn and
proactively checkpoint it
Key: BEAM-3833
URL: https://issues.apache.org/jira/browse/BEAM-3833
Project: Beam
Issue Type: Sub-task
Components: runner-dataflow
Reporter: Eugene Kirpichov
Assignee: Eugene Kirpichov
and return a BundleSplit.
This should probably be done using a special FnApiSplittableProcessFnRunner or
something like that, that's like FnApiDoFnRunner but for SDFs.
Then combined with BEAM-3832, we'll get the Java SDF tests to pass on Fn API.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
