| /dports/misc/thrill/thrill-12c5b59bca66df93b66628b3829027bd0f110dd9/thrill/api/ |
| H A D | dia_base.hpp | 99 : context_(ctx), dia_id_(ctx.next_dia_id()), in DIABase()
114 : context_(ctx), dia_id_(ctx.next_dia_id()), in DIABase()
214 return dia_id_; in dia_id()
296 const size_t dia_id_; member in thrill::api::DIABase
|
| H A D | dia.hpp | 197 dia_id_(dia_id), label_(label) { } in DIA()
215 dia_id_(dia_id), label_(label) { } in DIA()
285 size_t id() const { return dia_id_; } in id()
382 << "parents" << (common::Array<size_t>{ dia_id_ }); in Map()
427 << "parents" << (common::Array<size_t>{ dia_id_ }); in Filter()
469 << "parents" << (common::Array<size_t>{ dia_id_ }); in FlatMap()
2035 size_t dia_id_ = 0; member in thrill::api::DIA
|
| H A D | bernoulli_sample.hpp | 101 << "parents" << (common::Array<size_t>{ dia_id_ }); in BernoulliSample()
|
| /dports/misc/thrill/thrill-12c5b59bca66df93b66628b3829027bd0f110dd9/thrill/core/ |
| H A D | reduce_table.hpp | 123 : ctx_(ctx), dia_id_(dia_id), in ReduceTable()
141 partition_files_.push_back(ctx.GetFile(dia_id_)); in ReduceTable()
174 size_t dia_id() const { return dia_id_; } in dia_id()
279 size_t dia_id_; member in thrill::core::ReduceTable
|
| H A D | reduce_by_index_post_phase.hpp | 65 : ctx_(ctx), dia_id_(dia_id), in ReduceByIndexPostPhase()
122 auto file = ctx_.GetFilePtr(dia_id_); in Initialize()
207 data::FilePtr cache = ctx_.GetFilePtr(dia_id_); in PushData()
232 subtable(ctx_, dia_id_, key_extractor_, reduce_function_, in PushData()
290 size_t dia_id_; member in thrill::core::ReduceByIndexPostPhase
|
| H A D | location_detection.hpp | 167 dia_id_(dia_id), in LocationDetection()
222 context_.GetNewCatStream(dia_id_); in Flush()
263 data::CatStreamPtr location_stream = context_.GetNewCatStream(dia_id_); in Flush()
370 size_t dia_id_; member in thrill::core::LocationDetection
|
| /dports/misc/thrill/thrill-12c5b59bca66df93b66628b3829027bd0f110dd9/thrill/data/ |
| H A D | file.cpp | 24 id_(block_pool.next_file_id()), dia_id_(dia_id) { } in File()
37 << "dia_id" << dia_id_ in ~File()
43 File f(*block_pool(), local_worker_id(), dia_id_); in Copy()
|
| H A D | stream_data.cpp | 32 dia_id_(dia_id), in StreamData()
67 << "dia_id" << dia_id_ in OnAllWritersClosed()
|
| H A D | file.hpp | 252 void set_dia_id(size_t dia_id) { dia_id_ = dia_id; } in set_dia_id()
259 size_t dia_id_; member in thrill::data::File
|
| H A D | stream_data.hpp | 174 size_t dia_id_; member in thrill::data::StreamData
|
| H A D | multiplexer.cpp | 211 if (ptr && ptr->dia_id_ == 0) in IntGetOrCreateCatStreamData()
243 if (ptr && ptr->dia_id_ == 0) in IntGetOrCreateMixStreamData()
|
| H A D | mix_stream.cpp | 44 dia_id_ = dia_id; in set_dia_id()
|
| H A D | cat_stream.cpp | 79 dia_id_ = dia_id; in set_dia_id()
|