Right now @collect also is used for DataStreams sinks, but in some ways that is not correct, because in that case things are streamed into the sink, but nothing is returned from the query. It might be better to have a separate command for that kind of operation.