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