Thrill
0.1
|
This is the complete list of members for DIA< ValueType_, Stack_ >, including all inherited members.
AllGather() const | DIA< ValueType_, Stack_ > | |
AllGather(std::vector< ValueType > *out_vector) const | DIA< ValueType_, Stack_ > | |
AllGatherFuture() const | DIA< ValueType_, Stack_ > | |
AllReduce(const ReduceFunction &reduce_function) const | DIA< ValueType_, Stack_ > | |
AllReduce(const ReduceFunction &reduce_function, const ValueType &initial_value) const | DIA< ValueType_, Stack_ > | |
AllReduceFuture(const ReduceFunction &reduce_function) const | DIA< ValueType_, Stack_ > | |
AllReduceFuture(const ReduceFunction &reduce_function, const ValueType &initial_value) const | DIA< ValueType_, Stack_ > | |
AssertValid() const | DIA< ValueType_, Stack_ > | inline |
BernoulliSample(double p) const | DIA< ValueType_, Stack_ > | |
Cache() const | DIA< ValueType_, Stack_ > | |
Collapse() const | DIA< ValueType_, Stack_ > | |
Concat(const SecondDIA &second_dia) const | DIA< ValueType_, Stack_ > | |
context() const | DIA< ValueType_, Stack_ > | inline |
ctx() const | DIA< ValueType_, Stack_ > | inline |
DIA()=default | DIA< 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 typedef | DIA< ValueType_, Stack_ > | |
Dispose() const | DIA< ValueType_, Stack_ > | inline |
Execute() const | DIA< ValueType_, Stack_ > | inline |
ExPrefixSum(const SumFunction &sum_function=SumFunction(), const ValueType &initial_element=ValueType()) const | DIA< ValueType_, Stack_ > | |
Filter(const FilterFunction &filter_function) const | DIA< ValueType_, Stack_ > | inline |
FlatMap(const FlatmapFunction &flatmap_function) const | DIA< ValueType_, Stack_ > | inline |
FlatWindow(size_t window_size, const WindowFunction &window_function=WindowFunction()) const | DIA< ValueType_, Stack_ > | |
FlatWindow(size_t window_size, const WindowFunction &window_function, const PartialWindowFunction &partial_window_function) const | DIA< ValueType_, Stack_ > | |
FlatWindow(struct DisjointTag const &, size_t window_size, const WindowFunction &window_function) const | DIA< ValueType_, Stack_ > | |
FunctionTraits typedef | DIA< ValueType_, Stack_ > | private |
Gather(size_t target_id=0) const | DIA< ValueType_, Stack_ > | |
Gather(size_t target_id, std::vector< ValueType > *out_vector) const | DIA< ValueType_, Stack_ > | |
GroupByKey(const KeyExtractor &key_extractor, const GroupByFunction &groupby_function) const | DIA< ValueType_, Stack_ > | |
GroupByKey(const KeyExtractor &key_extractor, const GroupByFunction &groupby_function, const HashFunction &hash_function) const | DIA< ValueType_, Stack_ > | |
GroupByKey(const LocationDetectionFlag< LocationDetectionTagValue > &, const KeyExtractor &key_extractor, const GroupByFunction &groupby_function, const HashFunction &hash_function=HashFunction()) const | DIA< ValueType_, Stack_ > | |
GroupByKey(const LocationDetectionFlag< LocationDetectionValue > &, const KeyExtractor &key_extractor, const GroupFunction &groupby_function, const HashFunction &hash_function) const | DIA< ValueType_, Stack_ > | |
GroupByKey(const KeyExtractor &key_extractor, const GroupFunction &groupby_function, const HashFunction &hash_function) const | DIA< ValueType_, Stack_ > | |
GroupByKey(const KeyExtractor &key_extractor, const GroupFunction &groupby_function) const | DIA< ValueType_, Stack_ > | |
GroupToIndex(const KeyExtractor &key_extractor, const GroupByFunction &groupby_function, const size_t size, const ValueOut &neutral_element=ValueOut()) const | DIA< ValueType_, Stack_ > | |
GroupToIndex(const KeyExtractor &key_extractor, const GroupFunction &groupby_function, const size_t result_size, const ValueOut &neutral_element) const | DIA< ValueType_, Stack_ > | |
HyperLogLog() const | DIA< ValueType_, Stack_ > | |
id() const | DIA< ValueType_, Stack_ > | inline |
IsValid() const | DIA< ValueType_, Stack_ > | inline |
Keep(size_t increase=1) const | DIA< ValueType_, Stack_ > | inline |
KeepForever() const | DIA< ValueType_, Stack_ > | inline |
label() const | DIA< ValueType_, Stack_ > | inline |
label_ | DIA< ValueType_, Stack_ > | private |
Map(const MapFunction &map_function) const | DIA< ValueType_, Stack_ > | inline |
Max() const | DIA< ValueType_, Stack_ > | |
Max(const ValueType &initial_value) const | DIA< ValueType_, Stack_ > | |
MaxFuture() const | DIA< ValueType_, Stack_ > | |
MaxFuture(const ValueType &initial_value) const | DIA< ValueType_, Stack_ > | |
Merge(const SecondDIA &second_dia, const Comparator &comparator=Comparator()) const | DIA< ValueType_, Stack_ > | |
Min() const | DIA< ValueType_, Stack_ > | |
Min(const ValueType &initial_value) const | DIA< ValueType_, Stack_ > | |
MinFuture() const | DIA< ValueType_, Stack_ > | |
MinFuture(const ValueType &initial_value) const | DIA< ValueType_, Stack_ > | |
next_dia_id() | DIA< ValueType_, Stack_ > | inlineprivate |
node() const | DIA< ValueType_, Stack_ > | inline |
node_ | DIA< ValueType_, Stack_ > | private |
node_refcount() const | DIA< ValueType_, Stack_ > | inline |
PrefixSum(const SumFunction &sum_function=SumFunction(), const ValueType &initial_element=ValueType()) const | DIA< ValueType_, Stack_ > | |
Print(const std::string &name=std::string()) const | DIA< ValueType_, Stack_ > | |
Print(const std::string &name, std::ostream &out) const | DIA< ValueType_, Stack_ > | |
Rebalance() const | DIA< ValueType_, Stack_ > | |
ReduceByKey(const KeyExtractor &key_extractor, const ReduceFunction &reduce_function, const ReduceConfig &reduce_config=ReduceConfig()) const | DIA< ValueType_, Stack_ > | |
ReduceByKey(const KeyExtractor &key_extractor, const ReduceFunction &reduce_function, const ReduceConfig &reduce_config, const KeyHashFunction &key_hash_function) const | DIA< 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) const | DIA< 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()) const | DIA< 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()) const | DIA< 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()) const | DIA< ValueType_, Stack_ > | |
ReducePair(const ReduceFunction &reduce_function, const ReduceConfig &reduce_config=ReduceConfig()) const | DIA< ValueType_, Stack_ > | |
ReducePair(const ReduceFunction &reduce_function, const ReduceConfig &reduce_config, const KeyHashFunction &key_hash_function) const | DIA< ValueType_, Stack_ > | |
ReducePair(const ReduceFunction &reduce_function, const ReduceConfig &reduce_config, const KeyHashFunction &key_hash_function, const KeyEqualFunction &key_equal_function) const | DIA< 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()) const | DIA< ValueType_, Stack_ > | |
ReduceToIndex(const KeyExtractor &key_extractor, const ReduceFunction &reduce_function, size_t size, const ValueType &neutral_element=ValueType(), const ReduceConfig &reduce_config=ReduceConfig()) const | DIA< 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()) const | DIA< 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()) const | DIA< ValueType_, Stack_ > | |
Sample(size_t sample_size) const | DIA< ValueType_, Stack_ > | |
Size() const | DIA< ValueType_, Stack_ > | |
SizeFuture() const | DIA< ValueType_, Stack_ > | |
Sort(const CompareFunction &compare_function=CompareFunction()) const | DIA< ValueType_, Stack_ > | |
Sort(const CompareFunction &compare_function, const SortAlgorithm &sort_algorithm) const | DIA< ValueType_, Stack_ > | |
SortStable(const CompareFunction &compare_function=CompareFunction()) const | DIA< ValueType_, Stack_ > | |
SortStable(const CompareFunction &compare_function, const SortAlgorithm &sort_algorithm) const | DIA< ValueType_, Stack_ > | |
stack() const | DIA< ValueType_, Stack_ > | inline |
Stack typedef | DIA< ValueType_, Stack_ > | |
stack_ | DIA< ValueType_, Stack_ > | private |
stack_empty | DIA< ValueType_, Stack_ > | static |
StackInput typedef | DIA< ValueType_, Stack_ > | |
Sum(const SumFunction &sum_function=SumFunction()) const | DIA< ValueType_, Stack_ > | |
Sum(const SumFunction &sum_function, const ValueType &initial_value) const | DIA< ValueType_, Stack_ > | |
SumFuture(const SumFunction &sum_function=SumFunction(), const ValueType &initial_value=ValueType()) const | DIA< ValueType_, Stack_ > | |
Union(const SecondDIA &second_dia) const | DIA< ValueType_, Stack_ > | |
ValueType typedef | DIA< ValueType_, Stack_ > | |
Window(size_t window_size, const WindowFunction &window_function=WindowFunction()) const | DIA< ValueType_, Stack_ > | |
Window(size_t window_size, const WindowFunction &window_function, const PartialWindowFunction &partial_window_function) const | DIA< ValueType_, Stack_ > | |
Window(struct DisjointTag const &, size_t window_size, const WindowFunction &window_function) const | DIA< ValueType_, Stack_ > | |
WriteBinary(const std::string &filepath, size_t max_file_size=128 *1024 *1024) const | DIA< ValueType_, Stack_ > | |
WriteBinaryFuture(const std::string &filepath, size_t max_file_size=128 *1024 *1024) const | DIA< ValueType_, Stack_ > | |
WriteLines(const std::string &filepath, size_t target_file_size=128 *1024 *1024) const | DIA< ValueType_, Stack_ > | |
WriteLinesFuture(const std::string &filepath, size_t target_file_size=128 *1024 *1024) const | DIA< ValueType_, Stack_ > | |
WriteLinesOne(const std::string &filepath) const | DIA< ValueType_, Stack_ > | |
WriteLinesOneFuture(const std::string &filepath) const | DIA< ValueType_, Stack_ > | |
Zip(const SecondDIA &second_dia, const ZipFunction &zip_function) const | DIA< ValueType_, Stack_ > | |
Zip(struct CutTag const &, const SecondDIA &second_dia, const ZipFunction &zip_function) const | DIA< ValueType_, Stack_ > | |
Zip(struct PadTag const &, const SecondDIA &second_dia, const ZipFunction &zip_function) const | DIA< ValueType_, Stack_ > | |
Zip(struct NoRebalanceTag const &, const SecondDIA &second_dia, const ZipFunction &zip_function) const | DIA< ValueType_, Stack_ > | |
ZipWithIndex(const ZipFunction &zip_function) const | DIA< ValueType_, Stack_ > |