Skip to content

Implement streaming operator - #540

Open
senderista wants to merge 1 commit into
masterfrom
streaming_query_results
Open

Implement streaming operator#540
senderista wants to merge 1 commit into
masterfrom
streaming_query_results

Conversation

@senderista

Copy link
Copy Markdown
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
Copy Markdown

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
Copy Markdown

Coverage Status

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

@coveralls

Copy link
Copy Markdown

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