Searched refs:ConsumeBlockQueueSource (Results 1 – 4 of 4) sorted by relevance
49 return ConsumeReader(ConsumeBlockQueueSource(*this, local_worker_id)); in GetConsumeReader()56 return ConstructDynBlockSource<ConsumeBlockQueueSource>( in GetBlockSource()92 ConsumeBlockQueueSource::ConsumeBlockQueueSource( in ConsumeBlockQueueSource() function in thrill::data::ConsumeBlockQueueSource96 void ConsumeBlockQueueSource::Prefetch(size_t /* prefetch */) { in Prefetch()100 PinnedBlock ConsumeBlockQueueSource::NextBlock() { in NextBlock()
34 class ConsumeBlockQueueSource;54 using ConsumeReader = BlockReader<ConsumeBlockQueueSource>;233 class ConsumeBlockQueueSource class239 explicit ConsumeBlockQueueSource(BlockQueue& queue, size_t local_worker_id);
60 using BlockQueueSource = ConsumeBlockQueueSource;
21 using MyBlockSource = data::ConsumeBlockQueueSource;