Searched refs:cat_stream_ (Results 1 – 2 of 2) sorted by relevance
108 cat_stream_(use_mix_stream_ ?111 mix_stream_->GetWriters() : cat_stream_->GetWriters()),181 use_mix_stream_ ? mix_stream_.reset() : cat_stream_.reset(); in StopPreOp()199 use_mix_stream_ ? mix_stream_.reset() : cat_stream_.reset(); in PushData()219 auto reader = cat_stream_->GetCatReader(/* consume */ true); in ProcessChannel()220 sLOG << "reading data from" << cat_stream_->id() in ProcessChannel()236 data::CatStreamPtr cat_stream_; member in thrill::api::ReduceToIndexNode
111 cat_stream_(use_mix_stream_ ?114 mix_stream_->GetWriters() : cat_stream_->GetWriters()),166 use_mix_stream_ ? mix_stream_.reset() : cat_stream_.reset(); in StopPreOp()184 use_mix_stream_ ? mix_stream_.reset() : cat_stream_.reset(); in PushData()204 auto reader = cat_stream_->GetCatReader(/* consume */ true); in ProcessChannel()205 sLOG << "reading data from" << cat_stream_->id() in ProcessChannel()221 data::CatStreamPtr cat_stream_; member in thrill::api::ReduceNode