[
https://issues.apache.org/jira/browse/BEAM-7515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17407794#comment-17407794
]
Ning commented on BEAM-7515:
----------------------------
Hi Pablo, I could take the ticket since I'm trying to support Beam SQL for
notebooks with streaming pipelines.
A summary of things notebooks care:
FnApiRunner
* Support SqlTransform
* Does not support TestStream
* Does not support NativeSources such as ReadFromPubSub
BundleBasedDirectRunner
* Support TestStream and ReadFromPubSub
* Does not support SqlTransform
Make FnApiRunner support TestStream so that
* Support SqlTransform
* Support TestStream/NativeSources such as ReadFromPubSub (locally an
InteractiveRunner uses TestStream to replace all ReadFromPubSubs and other
unbounded sources)
* Not to be deprecated and xLang friendly.
> Support TestStream on the fn_api_runner
> ---------------------------------------
>
> Key: BEAM-7515
> URL: https://issues.apache.org/jira/browse/BEAM-7515
> Project: Beam
> Issue Type: Sub-task
> Components: sdk-py-core
> Reporter: Pablo Estrada
> Priority: P3
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
