Eugene Kirpichov created BEAM-3698:
--------------------------------------
Summary: Support SDF over Fn API
Key: BEAM-3698
URL: https://issues.apache.org/jira/browse/BEAM-3698
Project: Beam
Issue Type: Bug
Components: beam-model, runner-core
Reporter: Eugene Kirpichov
Assignee: Eugene Kirpichov
SDF is the only API for emitting unbounded data in Fn API. This issue is about
supporting SDF in an SDK harness, with its checkpointing controlled by the
runner harness.
++Umbrella issue: includes design and implementation in various SDK languages.
First practically useful goal in sight: Kafka source implemented in the Python
SDK, running over Fn API using the Dataflow runner.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
