Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Implement streaming operator #540

Open
wants to merge 1 commit into
base: master
Choose a base branch
from
Open

Conversation

senderista
Copy link
Contributor

The design is described in uwescience/myria#858. RACO does the work of translating a stream(relationVar) statement into a logical Stream operator, and expanding that into a physical operator chain CollectProducer->CollectConsumer->StreamingSink, while MyriaX expands StreamingSink into a TupleSink with PipeSink instances that register their InputStreams under the running query, so we can construct an HTTP streaming response entity with the sequenced output of all stream() statements.

@coveralls
Copy link

Coverage Status

Coverage decreased (-0.2%) to 91.601% when pulling adba8c8 on streaming_query_results into cf26abe on master.

@senderista senderista force-pushed the streaming_query_results branch from adba8c8 to c2d0b0a Compare August 28, 2017 19:07
@senderista senderista force-pushed the streaming_query_results branch from c2d0b0a to ad97764 Compare August 28, 2017 19:36
@coveralls
Copy link

Coverage Status

Coverage decreased (-0.1%) to 91.565% when pulling ad97764 on streaming_query_results into c6fdede on master.

@coveralls
Copy link

Coverage Status

Coverage decreased (-0.1%) to 91.565% when pulling ad97764 on streaming_query_results into c6fdede on master.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Projects
None yet
Development

Successfully merging this pull request may close these issues.

3 participants