[ https://issues.apache.org/jira/browse/BEAM-3698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16362952#comment-16362952 ]
Eugene Kirpichov commented on BEAM-3698: ---------------------------------------- CC: [~herohde] > 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 > > 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)