#include <thrill/common/stats_counter.hpp>
#include <thrill/common/stats_timer.hpp>
#include <thrill/data/block_writer.hpp>
#include <thrill/data/file.hpp>
#include <thrill/data/multiplexer.hpp>
#include <tlx/semaphore.hpp>
#include <mutex>
#include <vector>

Include dependency graph for stream_data.hpp:

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Classes
class	StreamData
	Base class for common structures for ConcatStream and MixedStream. More...

class	StreamData::Writers
	An extra class derived from std::vector<> for delivery of the BlockWriters of a Stream. More...

class	StreamSet< StreamData >
	Simple structure that holds a all stream instances for the workers on the local host for a given stream id. More...

class	StreamSetBase
	Base class for StreamSet. More...

Namespaces
	thrill

	thrill::data

Macros
#define	THRILL_DATA_STREAM_DATA_HEADER

Typedefs
using	StreamDataPtr = tlx::CountingPtr< StreamData >

using	StreamId = size_t

Enumerations
enum	MagicByte : uint8_t { Invalid, CatStreamBlock, MixStreamBlock, PartitionBlock }

Macro Definition Documentation

◆ THRILL_DATA_STREAM_DATA_HEADER

#define THRILL_DATA_STREAM_DATA_HEADER

Definition at line 14 of file stream_data.hpp.

Classes

Namespaces

Macros

Typedefs

Enumerations

Macro Definition Documentation

◆ THRILL_DATA_STREAM_DATA_HEADER