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)

Reply via email to