[ https://issues.apache.org/jira/browse/BEAM-3698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Eugene Kirpichov closed BEAM-3698. ---------------------------------- Resolution: Duplicate Fix Version/s: Not applicable > 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 > Priority: Major > Fix For: Not applicable > > > 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)