AddChild(DIABase *node, const Callback &callback=Callback(), size_t parent_index=0) | DIANode< ValueType > | inlinevirtual |
AddEqualKeysToFile(MergeTree &puller, const KeyExtractor &key_extractor, data::File::Writer &writer, const Key &key) | JoinNode< ValueType, FirstDIA, SecondDIA, KeyExtractor1, KeyExtractor2, JoinFunction, HashFunction, UseLocationDetection > | inlineprivate |
AddEqualKeysToVec(std::vector< ItemType > &vec, MergeTree &puller, const KeyExtractor &key_extractor, data::FilePtr &file_ptr) | JoinNode< ValueType, FirstDIA, SecondDIA, KeyExtractor1, KeyExtractor2, JoinFunction, HashFunction, UseLocationDetection > | inlineprivate |
Callback typedef | DIANode< ValueType > | |
children() const override | DIANode< ValueType > | inlinevirtual |
children_ | DIANode< ValueType > | protected |
consume_counter() const | DIABase | inlinevirtual |
consume_counter_ | DIABase | protected |
context() | DIABase | inline |
context_ | DIABase | protected |
debug | JoinNode< ValueType, FirstDIA, SecondDIA, KeyExtractor1, KeyExtractor2, JoinFunction, HashFunction, UseLocationDetection > | privatestatic |
dec_reference() const noexcept | ReferenceCounter | inline |
DecConsumeCounter(size_t counter) | DIABase | inlinevirtual |
dia_id() const | DIABase | inline |
dia_id_ | DIABase | protected |
DIABase(Context &ctx, const char *label, const std::initializer_list< size_t > &parent_ids, const std::initializer_list< DIABasePtr > &parents) | DIABase | inline |
DIABase(Context &ctx, const char *label, std::vector< size_t > &&parent_ids, std::vector< DIABasePtr > &&parents) | DIABase | inline |
DIABase(const DIABase &)=delete | DIABase | |
DIABase(DIABase &&)=default | DIABase | |
DIABasePtr typedef | DIABase | |
DIANode(Context &ctx, const char *label, const std::initializer_list< size_t > &parent_ids, const std::initializer_list< DIABasePtr > &parents) | DIANode< ValueType > | inline |
DIANode(Context &ctx, const char *label, std::vector< size_t > &&parent_ids, std::vector< DIABasePtr > &&parents) | DIANode< ValueType > | inline |
Dispose() final | JoinNode< ValueType, FirstDIA, SecondDIA, KeyExtractor1, KeyExtractor2, JoinFunction, HashFunction, UseLocationDetection > | inlinevirtual |
DOpNode(Context &ctx, const char *label, const std::initializer_list< size_t > &parent_ids, const std::initializer_list< DIABasePtr > &parents) | DOpNode< ValueType > | inline |
DOpNode(Context &ctx, const char *label, std::vector< size_t > &&parent_ids, std::vector< DIABasePtr > &&parents) | DOpNode< ValueType > | inline |
Execute() final | JoinNode< ValueType, FirstDIA, SecondDIA, KeyExtractor1, KeyExtractor2, JoinFunction, HashFunction, UseLocationDetection > | inlinevirtual |
ExecuteMemUse() final | JoinNode< ValueType, FirstDIA, SecondDIA, KeyExtractor1, KeyExtractor2, JoinFunction, HashFunction, UseLocationDetection > | inlineprivatevirtual |
files1_ | JoinNode< ValueType, FirstDIA, SecondDIA, KeyExtractor1, KeyExtractor2, JoinFunction, HashFunction, UseLocationDetection > | private |
files2_ | JoinNode< ValueType, FirstDIA, SecondDIA, KeyExtractor1, KeyExtractor2, JoinFunction, HashFunction, UseLocationDetection > | private |
ForwardDataOnly() const | DIABase | inlinevirtual |
hash_function_ | JoinNode< ValueType, FirstDIA, SecondDIA, KeyExtractor1, KeyExtractor2, JoinFunction, HashFunction, UseLocationDetection > | private |
hash_stream1_ | JoinNode< ValueType, FirstDIA, SecondDIA, KeyExtractor1, KeyExtractor2, JoinFunction, HashFunction, UseLocationDetection > | private |
hash_stream2_ | JoinNode< ValueType, FirstDIA, SecondDIA, KeyExtractor1, KeyExtractor2, JoinFunction, HashFunction, UseLocationDetection > | private |
hash_writers1_ | JoinNode< ValueType, FirstDIA, SecondDIA, KeyExtractor1, KeyExtractor2, JoinFunction, HashFunction, UseLocationDetection > | private |
hash_writers2_ | JoinNode< ValueType, FirstDIA, SecondDIA, KeyExtractor1, KeyExtractor2, JoinFunction, HashFunction, UseLocationDetection > | private |
inc_reference() const noexcept | ReferenceCounter | inline |
IncConsumeCounter(size_t counter) | DIABase | inlinevirtual |
InputTypeFirst typedef | JoinNode< ValueType, FirstDIA, SecondDIA, KeyExtractor1, KeyExtractor2, JoinFunction, HashFunction, UseLocationDetection > | private |
InputTypeSecond typedef | JoinNode< ValueType, FirstDIA, SecondDIA, KeyExtractor1, KeyExtractor2, JoinFunction, HashFunction, UseLocationDetection > | private |
join_file1_ | JoinNode< ValueType, FirstDIA, SecondDIA, KeyExtractor1, KeyExtractor2, JoinFunction, HashFunction, UseLocationDetection > | private |
join_file2_ | JoinNode< ValueType, FirstDIA, SecondDIA, KeyExtractor1, KeyExtractor2, JoinFunction, HashFunction, UseLocationDetection > | private |
join_function_ | JoinNode< ValueType, FirstDIA, SecondDIA, KeyExtractor1, KeyExtractor2, JoinFunction, HashFunction, UseLocationDetection > | private |
JoinAllElements(const std::vector< InputTypeFirst > &vec1, bool external1, const std::vector< InputTypeSecond > &vec2, bool external2) | JoinNode< ValueType, FirstDIA, SecondDIA, KeyExtractor1, KeyExtractor2, JoinFunction, HashFunction, UseLocationDetection > | inlineprivate |
JoinCapacity() | JoinNode< ValueType, FirstDIA, SecondDIA, KeyExtractor1, KeyExtractor2, JoinFunction, HashFunction, UseLocationDetection > | inlineprivate |
JoinNode(const FirstDIA &parent1, const SecondDIA &parent2, const KeyExtractor1 &key_extractor1, const KeyExtractor2 &key_extractor2, const JoinFunction &join_function, const HashFunction &hash_function) | JoinNode< ValueType, FirstDIA, SecondDIA, KeyExtractor1, KeyExtractor2, JoinFunction, HashFunction, UseLocationDetection > | inline |
Key typedef | JoinNode< ValueType, FirstDIA, SecondDIA, KeyExtractor1, KeyExtractor2, JoinFunction, HashFunction, UseLocationDetection > | private |
key_extractor1_ | JoinNode< ValueType, FirstDIA, SecondDIA, KeyExtractor1, KeyExtractor2, JoinFunction, HashFunction, UseLocationDetection > | private |
key_extractor2_ | JoinNode< ValueType, FirstDIA, SecondDIA, KeyExtractor1, KeyExtractor2, JoinFunction, HashFunction, UseLocationDetection > | private |
kNeverConsume | DIABase | static |
label() const | DIABase | inline |
label_ | DIABase | protected |
location_detection_ | JoinNode< ValueType, FirstDIA, SecondDIA, KeyExtractor1, KeyExtractor2, JoinFunction, HashFunction, UseLocationDetection > | private |
location_detection_initialized_ | JoinNode< ValueType, FirstDIA, SecondDIA, KeyExtractor1, KeyExtractor2, JoinFunction, HashFunction, UseLocationDetection > | private |
logger_ | DIABase | |
MainOp() | JoinNode< ValueType, FirstDIA, SecondDIA, KeyExtractor1, KeyExtractor2, JoinFunction, HashFunction, UseLocationDetection > | inlineprivate |
MakePuller(std::deque< data::File > &files, std::vector< data::File::Reader > &seq, CompareFunction compare_function, bool consume) | JoinNode< ValueType, FirstDIA, SecondDIA, KeyExtractor1, KeyExtractor2, JoinFunction, HashFunction, UseLocationDetection > | inline |
mem_limit_ | DIABase | protected |
mem_manager() | DIABase | inline |
MergeFiles(std::deque< data::File > &files, CompareFunction compare_function) | JoinNode< ValueType, FirstDIA, SecondDIA, KeyExtractor1, KeyExtractor2, JoinFunction, HashFunction, UseLocationDetection > | inlineprivate |
OnPreOpFile(const data::File &, size_t) | DIABase | inlinevirtual |
operator=(const DIABase &)=delete | DIABase | |
operator=(DIABase &&)=default | DIABase | |
tlx::ReferenceCounter::operator=(const ReferenceCounter &) noexcept | ReferenceCounter | inline |
parent_ids() const | DIABase | inline |
parents() const | DIABase | inline |
parents_ | DIABase | protected |
pre_file1_ | JoinNode< ValueType, FirstDIA, SecondDIA, KeyExtractor1, KeyExtractor2, JoinFunction, HashFunction, UseLocationDetection > | private |
pre_file2_ | JoinNode< ValueType, FirstDIA, SecondDIA, KeyExtractor1, KeyExtractor2, JoinFunction, HashFunction, UseLocationDetection > | private |
pre_writer1_ | JoinNode< ValueType, FirstDIA, SecondDIA, KeyExtractor1, KeyExtractor2, JoinFunction, HashFunction, UseLocationDetection > | private |
pre_writer2_ | JoinNode< ValueType, FirstDIA, SecondDIA, KeyExtractor1, KeyExtractor2, JoinFunction, HashFunction, UseLocationDetection > | private |
PreOp1(const InputTypeFirst &input) | JoinNode< ValueType, FirstDIA, SecondDIA, KeyExtractor1, KeyExtractor2, JoinFunction, HashFunction, UseLocationDetection > | inlineprivate |
PreOp2(const InputTypeSecond &input) | JoinNode< ValueType, FirstDIA, SecondDIA, KeyExtractor1, KeyExtractor2, JoinFunction, HashFunction, UseLocationDetection > | inlineprivate |
PreOpMemUse() final | JoinNode< ValueType, FirstDIA, SecondDIA, KeyExtractor1, KeyExtractor2, JoinFunction, HashFunction, UseLocationDetection > | inlineprivatevirtual |
PushData(bool consume) final | JoinNode< ValueType, FirstDIA, SecondDIA, KeyExtractor1, KeyExtractor2, JoinFunction, HashFunction, UseLocationDetection > | inlinevirtual |
PushDataMemUse() final | JoinNode< ValueType, FirstDIA, SecondDIA, KeyExtractor1, KeyExtractor2, JoinFunction, HashFunction, UseLocationDetection > | inlineprivatevirtual |
PushFile(data::File &file, bool consume) const | DIANode< ValueType > | inline |
PushItem(const ValueType &item) const | DIANode< ValueType > | inline |
ReceiveItems(size_t capacity, data::MixStream::MixReader &reader, std::deque< data::File > &files, const KeyExtractor &key_extractor) | JoinNode< ValueType, FirstDIA, SecondDIA, KeyExtractor1, KeyExtractor2, JoinFunction, HashFunction, UseLocationDetection > | inlineprivate |
reference_count() const noexcept | ReferenceCounter | inline |
ReferenceCounter() noexcept | ReferenceCounter | inline |
ReferenceCounter(const ReferenceCounter &) noexcept | ReferenceCounter | inline |
RemoveAllChildren() override | DIANode< ValueType > | inlinevirtual |
RemoveChild(DIABase *node) override | DIANode< ValueType > | inlinevirtual |
RemoveParent(DIABase *p) | DIABase | inline |
RequireParentPushData(size_t) const | DIABase | inlinevirtual |
RunPushData() override | DIANode< ValueType > | inlinevirtual |
RunScope() | DIABase | |
set_mem_limit(const DIAMemUse &mem_limit) | DIABase | inline |
set_state(const DIAState &state) | DIABase | inline |
SetConsumeCounter(size_t counter) | DIABase | inlinevirtual |
SortAndWriteToFile(std::vector< ItemType > &vec, std::deque< data::File > &files, const KeyExtractor &key_extractor) | JoinNode< ValueType, FirstDIA, SecondDIA, KeyExtractor1, KeyExtractor2, JoinFunction, HashFunction, UseLocationDetection > | inlineprivate |
StartPreOp(size_t parent_index) final | JoinNode< ValueType, FirstDIA, SecondDIA, KeyExtractor1, KeyExtractor2, JoinFunction, HashFunction, UseLocationDetection > | inlineprivatevirtual |
state() const | DIABase | inline |
state_ | DIABase | protected |
StopPreOp(size_t parent_index) final | JoinNode< ValueType, FirstDIA, SecondDIA, KeyExtractor1, KeyExtractor2, JoinFunction, HashFunction, UseLocationDetection > | inlineprivatevirtual |
Super typedef | JoinNode< ValueType, FirstDIA, SecondDIA, KeyExtractor1, KeyExtractor2, JoinFunction, HashFunction, UseLocationDetection > | private |
unique() const noexcept | ReferenceCounter | inline |
~DIABase() | DIABase | inlinevirtual |
~ReferenceCounter() | ReferenceCounter | inline |