Thrill  0.1
StreamSink Member List

This is the complete list of members for StreamSink, including all inherited members.

allocate_can_fail_StreamSinkstatic
AllocateByteBlock(size_t block_size)BlockSinkinlinevirtual
AppendBlock(const Block &block, bool is_last_block) finalStreamSinkvirtual
AppendBlock(Block &&block, bool is_last_block) finalStreamSinkvirtual
AppendPinnedBlock(PinnedBlock &&block, bool is_last_block) finalStreamSinkvirtual
block_counter_StreamSinkprivate
block_pool() constBlockSinkinline
block_queue_StreamSinkprivate
BlockSink(BlockPool &block_pool, size_t local_worker_id)BlockSinkinlineexplicit
BlockSink(BlockPool *block_pool, size_t local_worker_id)BlockSinkinlineexplicit
BlockSink(const BlockSink &)=defaultBlockSink
BlockSink(BlockSink &&)=defaultBlockSink
byte_counter_StreamSinkprivate
Close() finalStreamSinkvirtual
closed() constStreamSinkinline
closed_StreamSinkprivate
connection_StreamSinkprivate
debugStreamSinkprivatestatic
Finalize()StreamSink
host_rank_StreamSinkprivate
id_StreamSinkprivate
IsValid() constStreamSinkinline
item_counter_StreamSinkprivate
local_worker_id() constBlockSinkinline
local_worker_id_BlockSinkprotected
logger()BlockSinkinline
magic_StreamSinkprivate
my_worker_rank() constStreamSink
operator=(StreamSink &&)=defaultStreamSink
thrill::data::BlockSink::operator=(const BlockSink &)=defaultBlockSink
thrill::data::BlockSink::operator=(BlockSink &&)=defaultBlockSink
peer_local_worker_StreamSinkprivate
peer_rank_StreamSinkprivate
peer_worker_rank() constStreamSink
ReleaseByteBlock(ByteBlockPtr &block)BlockSinkinlinevirtual
stream_StreamSinkprivate
StreamId typedefStreamSink
StreamSink()StreamSink
StreamSink(StreamDataPtr stream, BlockPool &block_pool, net::Connection *connection, MagicByte magic, StreamId stream_id, size_t host_rank, size_t host_local_worker, size_t peer_rank, size_t peer_local_worker)StreamSink
StreamSink(StreamDataPtr stream, BlockPool &block_pool, BlockQueue *block_queue, StreamId stream_id, size_t host_rank, size_t host_local_worker, size_t peer_rank, size_t peer_local_worker)StreamSink
StreamSink(StreamDataPtr stream, BlockPool &block_pool, MixStreamDataPtr target, StreamId stream_id, size_t host_rank, size_t host_local_worker, size_t peer_rank, size_t peer_local_worker)StreamSink
StreamSink(StreamSink &&)=defaultStreamSink
target_mix_stream_StreamSinkprivate
timespan_StreamSinkprivate
workers_per_host() constBlockSinkinline
~BlockSink()BlockSinkinlinevirtual