Thrill  0.1
DIA< ValueType_, Stack_ > Member List

This is the complete list of members for DIA< ValueType_, Stack_ >, including all inherited members.

AllGather() constDIA< ValueType_, Stack_ >
AllGather(std::vector< ValueType > *out_vector) constDIA< ValueType_, Stack_ >
AllGatherFuture() constDIA< ValueType_, Stack_ >
AllReduce(const ReduceFunction &reduce_function) constDIA< ValueType_, Stack_ >
AllReduce(const ReduceFunction &reduce_function, const ValueType &initial_value) constDIA< ValueType_, Stack_ >
AllReduceFuture(const ReduceFunction &reduce_function) constDIA< ValueType_, Stack_ >
AllReduceFuture(const ReduceFunction &reduce_function, const ValueType &initial_value) constDIA< ValueType_, Stack_ >
AssertValid() constDIA< ValueType_, Stack_ >inline
BernoulliSample(double p) constDIA< ValueType_, Stack_ >
Cache() constDIA< ValueType_, Stack_ >
Collapse() constDIA< ValueType_, Stack_ >
Concat(const SecondDIA &second_dia) constDIA< ValueType_, Stack_ >
context() constDIA< ValueType_, Stack_ >inline
ctx() constDIA< ValueType_, Stack_ >inline
DIA()=defaultDIA< ValueType_, Stack_ >
DIA(const DIANodePtr &node, const Stack &stack, size_t dia_id, const char *label)DIA< ValueType_, Stack_ >inline
DIA(DIANodePtr &&node, const Stack &stack, size_t dia_id, const char *label)DIA< ValueType_, Stack_ >inline
DIA(DIANodePtr &&node)DIA< ValueType_, Stack_ >inlineexplicit
DIA(const DIA< ValueType, AnyStack > &rhs)DIA< ValueType_, Stack_ >
dia_id_DIA< ValueType_, Stack_ >private
DIANodePtr typedefDIA< ValueType_, Stack_ >
Dispose() constDIA< ValueType_, Stack_ >inline
Execute() constDIA< ValueType_, Stack_ >inline
ExPrefixSum(const SumFunction &sum_function=SumFunction(), const ValueType &initial_element=ValueType()) constDIA< ValueType_, Stack_ >
Filter(const FilterFunction &filter_function) constDIA< ValueType_, Stack_ >inline
FlatMap(const FlatmapFunction &flatmap_function) constDIA< ValueType_, Stack_ >inline
FlatWindow(size_t window_size, const WindowFunction &window_function=WindowFunction()) constDIA< ValueType_, Stack_ >
FlatWindow(size_t window_size, const WindowFunction &window_function, const PartialWindowFunction &partial_window_function) constDIA< ValueType_, Stack_ >
FlatWindow(struct DisjointTag const &, size_t window_size, const WindowFunction &window_function) constDIA< ValueType_, Stack_ >
FunctionTraits typedefDIA< ValueType_, Stack_ >private
Gather(size_t target_id=0) constDIA< ValueType_, Stack_ >
Gather(size_t target_id, std::vector< ValueType > *out_vector) constDIA< ValueType_, Stack_ >
GroupByKey(const KeyExtractor &key_extractor, const GroupByFunction &groupby_function) constDIA< ValueType_, Stack_ >
GroupByKey(const KeyExtractor &key_extractor, const GroupByFunction &groupby_function, const HashFunction &hash_function) constDIA< ValueType_, Stack_ >
GroupByKey(const LocationDetectionFlag< LocationDetectionTagValue > &, const KeyExtractor &key_extractor, const GroupByFunction &groupby_function, const HashFunction &hash_function=HashFunction()) constDIA< ValueType_, Stack_ >
GroupByKey(const LocationDetectionFlag< LocationDetectionValue > &, const KeyExtractor &key_extractor, const GroupFunction &groupby_function, const HashFunction &hash_function) constDIA< ValueType_, Stack_ >
GroupByKey(const KeyExtractor &key_extractor, const GroupFunction &groupby_function, const HashFunction &hash_function) constDIA< ValueType_, Stack_ >
GroupByKey(const KeyExtractor &key_extractor, const GroupFunction &groupby_function) constDIA< ValueType_, Stack_ >
GroupToIndex(const KeyExtractor &key_extractor, const GroupByFunction &groupby_function, const size_t size, const ValueOut &neutral_element=ValueOut()) constDIA< ValueType_, Stack_ >
GroupToIndex(const KeyExtractor &key_extractor, const GroupFunction &groupby_function, const size_t result_size, const ValueOut &neutral_element) constDIA< ValueType_, Stack_ >
HyperLogLog() constDIA< ValueType_, Stack_ >
id() constDIA< ValueType_, Stack_ >inline
IsValid() constDIA< ValueType_, Stack_ >inline
Keep(size_t increase=1) constDIA< ValueType_, Stack_ >inline
KeepForever() constDIA< ValueType_, Stack_ >inline
label() constDIA< ValueType_, Stack_ >inline
label_DIA< ValueType_, Stack_ >private
Map(const MapFunction &map_function) constDIA< ValueType_, Stack_ >inline
Max() constDIA< ValueType_, Stack_ >
Max(const ValueType &initial_value) constDIA< ValueType_, Stack_ >
MaxFuture() constDIA< ValueType_, Stack_ >
MaxFuture(const ValueType &initial_value) constDIA< ValueType_, Stack_ >
Merge(const SecondDIA &second_dia, const Comparator &comparator=Comparator()) constDIA< ValueType_, Stack_ >
Min() constDIA< ValueType_, Stack_ >
Min(const ValueType &initial_value) constDIA< ValueType_, Stack_ >
MinFuture() constDIA< ValueType_, Stack_ >
MinFuture(const ValueType &initial_value) constDIA< ValueType_, Stack_ >
next_dia_id()DIA< ValueType_, Stack_ >inlineprivate
node() constDIA< ValueType_, Stack_ >inline
node_DIA< ValueType_, Stack_ >private
node_refcount() constDIA< ValueType_, Stack_ >inline
PrefixSum(const SumFunction &sum_function=SumFunction(), const ValueType &initial_element=ValueType()) constDIA< ValueType_, Stack_ >
Print(const std::string &name=std::string()) constDIA< ValueType_, Stack_ >
Print(const std::string &name, std::ostream &out) constDIA< ValueType_, Stack_ >
Rebalance() constDIA< ValueType_, Stack_ >
ReduceByKey(const KeyExtractor &key_extractor, const ReduceFunction &reduce_function, const ReduceConfig &reduce_config=ReduceConfig()) constDIA< ValueType_, Stack_ >
ReduceByKey(const KeyExtractor &key_extractor, const ReduceFunction &reduce_function, const ReduceConfig &reduce_config, const KeyHashFunction &key_hash_function) constDIA< ValueType_, Stack_ >
ReduceByKey(const KeyExtractor &key_extractor, const ReduceFunction &reduce_function, const ReduceConfig &reduce_config, const KeyHashFunction &key_hash_function, const KeyEqualFunction &key_equal_function) constDIA< ValueType_, Stack_ >
ReduceByKey(const VolatileKeyFlag< VolatileKeyValue > &, const KeyExtractor &key_extractor, const ReduceFunction &reduce_function, const ReduceConfig &reduce_config=ReduceConfig(), const KeyHashFunction &key_hash_function=KeyHashFunction(), const KeyEqualFunction &key_equal_function=KeyEqualFunction()) constDIA< ValueType_, Stack_ >
ReduceByKey(const DuplicateDetectionFlag< DuplicateDetectionValue > &, const KeyExtractor &key_extractor, const ReduceFunction &reduce_function, const ReduceConfig &reduce_config=ReduceConfig(), const KeyHashFunction &key_hash_function=KeyHashFunction(), const KeyEqualFunction &key_equal_function=KeyEqualFunction()) constDIA< ValueType_, Stack_ >
ReduceByKey(const VolatileKeyFlag< VolatileKeyValue > &, const DuplicateDetectionFlag< DuplicateDetectionValue > &, const KeyExtractor &key_extractor, const ReduceFunction &reduce_function, const ReduceConfig &reduce_config=ReduceConfig(), const KeyHashFunction &key_hash_function=KeyHashFunction(), const KeyEqualFunction &key_equal_function=KeyEqualFunction()) constDIA< ValueType_, Stack_ >
ReducePair(const ReduceFunction &reduce_function, const ReduceConfig &reduce_config=ReduceConfig()) constDIA< ValueType_, Stack_ >
ReducePair(const ReduceFunction &reduce_function, const ReduceConfig &reduce_config, const KeyHashFunction &key_hash_function) constDIA< ValueType_, Stack_ >
ReducePair(const ReduceFunction &reduce_function, const ReduceConfig &reduce_config, const KeyHashFunction &key_hash_function, const KeyEqualFunction &key_equal_function) constDIA< ValueType_, Stack_ >
ReducePair(const DuplicateDetectionFlag< DuplicateDetectionValue > &, const ReduceFunction &reduce_function, const ReduceConfig &reduce_config=ReduceConfig(), const KeyHashFunction &key_hash_function=KeyHashFunction(), const KeyEqualFunction &key_equal_function=KeyEqualFunction()) constDIA< ValueType_, Stack_ >
ReduceToIndex(const KeyExtractor &key_extractor, const ReduceFunction &reduce_function, size_t size, const ValueType &neutral_element=ValueType(), const ReduceConfig &reduce_config=ReduceConfig()) constDIA< ValueType_, Stack_ >
ReduceToIndex(const VolatileKeyFlag< VolatileKeyValue > &, const KeyExtractor &key_extractor, const ReduceFunction &reduce_function, size_t size, const ValueType &neutral_element=ValueType(), const ReduceConfig &reduce_config=ReduceConfig()) constDIA< ValueType_, Stack_ >
ReduceToIndex(const struct SkipPreReducePhaseTag &, const KeyExtractor &key_extractor, const ReduceFunction &reduce_function, size_t size, const ValueType &neutral_element=ValueType(), const ReduceConfig &reduce_config=ReduceConfig()) constDIA< ValueType_, Stack_ >
Sample(size_t sample_size) constDIA< ValueType_, Stack_ >
Size() constDIA< ValueType_, Stack_ >
SizeFuture() constDIA< ValueType_, Stack_ >
Sort(const CompareFunction &compare_function=CompareFunction()) constDIA< ValueType_, Stack_ >
Sort(const CompareFunction &compare_function, const SortAlgorithm &sort_algorithm) constDIA< ValueType_, Stack_ >
SortStable(const CompareFunction &compare_function=CompareFunction()) constDIA< ValueType_, Stack_ >
SortStable(const CompareFunction &compare_function, const SortAlgorithm &sort_algorithm) constDIA< ValueType_, Stack_ >
stack() constDIA< ValueType_, Stack_ >inline
Stack typedefDIA< ValueType_, Stack_ >
stack_DIA< ValueType_, Stack_ >private
stack_emptyDIA< ValueType_, Stack_ >static
StackInput typedefDIA< ValueType_, Stack_ >
Sum(const SumFunction &sum_function=SumFunction()) constDIA< ValueType_, Stack_ >
Sum(const SumFunction &sum_function, const ValueType &initial_value) constDIA< ValueType_, Stack_ >
SumFuture(const SumFunction &sum_function=SumFunction(), const ValueType &initial_value=ValueType()) constDIA< ValueType_, Stack_ >
Union(const SecondDIA &second_dia) constDIA< ValueType_, Stack_ >
ValueType typedefDIA< ValueType_, Stack_ >
Window(size_t window_size, const WindowFunction &window_function=WindowFunction()) constDIA< ValueType_, Stack_ >
Window(size_t window_size, const WindowFunction &window_function, const PartialWindowFunction &partial_window_function) constDIA< ValueType_, Stack_ >
Window(struct DisjointTag const &, size_t window_size, const WindowFunction &window_function) constDIA< ValueType_, Stack_ >
WriteBinary(const std::string &filepath, size_t max_file_size=128 *1024 *1024) constDIA< ValueType_, Stack_ >
WriteBinaryFuture(const std::string &filepath, size_t max_file_size=128 *1024 *1024) constDIA< ValueType_, Stack_ >
WriteLines(const std::string &filepath, size_t target_file_size=128 *1024 *1024) constDIA< ValueType_, Stack_ >
WriteLinesFuture(const std::string &filepath, size_t target_file_size=128 *1024 *1024) constDIA< ValueType_, Stack_ >
WriteLinesOne(const std::string &filepath) constDIA< ValueType_, Stack_ >
WriteLinesOneFuture(const std::string &filepath) constDIA< ValueType_, Stack_ >
Zip(const SecondDIA &second_dia, const ZipFunction &zip_function) constDIA< ValueType_, Stack_ >
Zip(struct CutTag const &, const SecondDIA &second_dia, const ZipFunction &zip_function) constDIA< ValueType_, Stack_ >
Zip(struct PadTag const &, const SecondDIA &second_dia, const ZipFunction &zip_function) constDIA< ValueType_, Stack_ >
Zip(struct NoRebalanceTag const &, const SecondDIA &second_dia, const ZipFunction &zip_function) constDIA< ValueType_, Stack_ >
ZipWithIndex(const ZipFunction &zip_function) constDIA< ValueType_, Stack_ >