Skip to content

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