DIA API Layer

Modules
	API Internals

Classes
class	ActionNode
class	AllGatherNode< ValueType >
class	AllReduceNode< ValueType, ReduceFunction >
class	BaseWindowNode< ValueType, Input, WindowFunction, PartialWindowFunction >
class	BernoulliSampleNode< ValueType >
class	CacheNode< ValueType >
	A DOpNode which caches all items in an external file. More...
class	CollapseNode< ValueType >
class	ConcatNode< ValueType >
class	ConcatToDIANode< ValueType >
class	DIANode< ValueType >
	A DIANode is a typed node representing and operation in Thrill. More...
class	DisjointWindowNode< ValueType, Input, WindowFunction, PartialWindowFunction >
class	DistributeNode< ValueType >
class	DOpNode< ValueType >
	A DOpNode is a typed node representing and distributed operations in Thrill. More...
class	EqualToDIANode< ValueType >
class	GatherNode< ValueType >
class	GenerateNode< ValueType, GenerateFunction >
	A DIANode which performs a Generate operation. More...
class	GroupByNode< ValueType, KeyExtractor, GroupFunction, HashFunction, UseLocationDetection >
class	GroupToIndexNode< ValueType, KeyExtractor, GroupFunction >
class	HyperLogLogNode< p, ValueType >
class	MergeNode< ValueType, Comparator, kNumInputs >
	Implementation of Thrill's merge. More...
class	OverlapWindowNode< ValueType, Input, WindowFunction, PartialWindowFunction >
class	PrefixSumNode< ValueType, SumFunction, Inclusive >
class	ReadBinaryNode< ValueType >
	A DIANode which performs a line-based Read operation. More...
class	ReadLinesNode
	A DIANode which performs a line-based Read operation. More...
class	RebalanceNode< ValueType >
class	ReduceNode< ValueType, KeyExtractor, ReduceFunction, ReduceConfig, KeyHashFunction, KeyEqualFunction, VolatileKey, UseDuplicateDetection >
	A DIANode which performs a Reduce operation. More...
class	ReduceToIndexNode< ValueType, KeyExtractor, ReduceFunction, ReduceConfig, VolatileKey, SkipPreReducePhase >
	A DIANode which performs a ReduceToIndex operation. More...
class	SampleNode< ValueType >
	A DIANode which performs sampling without replacement. More...
class	SizeNode< ValueType >
class	SortNode< ValueType, CompareFunction, SortAlgorithm, Stable >
	A DIANode which performs a Sort operation. More...
class	SourceNode< ValueType >
class	UnionNode< ValueType >
	Implements a Union operation by hooking any number of input DIANodes and forwarding the output immediately to all children. More...
struct	VolatileKeyFlag< Value >
	tag structure for ReduceByKey(), and ReduceToIndex() More...
class	WriteBinaryNode< ValueType >
class	WriteLinesNode< ValueType >
class	WriteLinesOneNode< ValueType >
class	ZipNode< ValueType, ZipFunction, Pad, UnequalCheck, NoRebalance, kNumInputs >
	A DIANode which performs a Zip operation. More...
class	ZipWithIndexNode< ValueType, ZipFunction >
	A DIANode which calculates the array index for each items and performs a Zip-like operation without extra rebalancing of the DIA data. More...
enum	DIAState { NEW, EXECUTED, DISPOSED }
	Possible states a DIABase can be in. More...
using	DIABasePtr = tlx::CountingPtr< DIABase >

Detailed Description

Typedef Documentation

DIABasePtr

using DIABasePtr = tlx::CountingPtr<DIABase>

Definition at line 334 of file dia_base.hpp.

Enumeration Type Documentation

DIAState

enum DIAState

strong

Possible states a DIABase can be in.

Enumerator
NEW	The DIABase has not been computed yet.
EXECUTED	The DIABase has been calculated but not explicitly cached. Data might be available or has to be recalculated when needed
DISPOSED	The DIABase is manually disposed by the user, needs to be recomputed when accessed.

Definition at line 33 of file dia_base.hpp.