[
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)
