|
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_ > |