Thrill  0.1
JoinNode< ValueType, FirstDIA, SecondDIA, KeyExtractor1, KeyExtractor2, JoinFunction, HashFunction, UseLocationDetection > Member List

This is the complete list of members for JoinNode< ValueType, FirstDIA, SecondDIA, KeyExtractor1, KeyExtractor2, JoinFunction, HashFunction, UseLocationDetection >, including all inherited members.

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 typedefDIANode< ValueType >
children() const overrideDIANode< ValueType >inlinevirtual
children_DIANode< ValueType >protected
consume_counter() constDIABaseinlinevirtual
consume_counter_DIABaseprotected
context()DIABaseinline
context_DIABaseprotected
debugJoinNode< ValueType, FirstDIA, SecondDIA, KeyExtractor1, KeyExtractor2, JoinFunction, HashFunction, UseLocationDetection >privatestatic
dec_reference() const noexceptReferenceCounterinline
DecConsumeCounter(size_t counter)DIABaseinlinevirtual
dia_id() constDIABaseinline
dia_id_DIABaseprotected
DIABase(Context &ctx, const char *label, const std::initializer_list< size_t > &parent_ids, const std::initializer_list< DIABasePtr > &parents)DIABaseinline
DIABase(Context &ctx, const char *label, std::vector< size_t > &&parent_ids, std::vector< DIABasePtr > &&parents)DIABaseinline
DIABase(const DIABase &)=deleteDIABase
DIABase(DIABase &&)=defaultDIABase
DIABasePtr typedefDIABase
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() finalJoinNode< 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() finalJoinNode< ValueType, FirstDIA, SecondDIA, KeyExtractor1, KeyExtractor2, JoinFunction, HashFunction, UseLocationDetection >inlinevirtual
ExecuteMemUse() finalJoinNode< 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() constDIABaseinlinevirtual
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 noexceptReferenceCounterinline
IncConsumeCounter(size_t counter)DIABaseinlinevirtual
InputTypeFirst typedefJoinNode< ValueType, FirstDIA, SecondDIA, KeyExtractor1, KeyExtractor2, JoinFunction, HashFunction, UseLocationDetection >private
InputTypeSecond typedefJoinNode< 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 typedefJoinNode< 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
kNeverConsumeDIABasestatic
label() constDIABaseinline
label_DIABaseprotected
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_DIABaseprotected
mem_manager()DIABaseinline
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)DIABaseinlinevirtual
operator=(const DIABase &)=deleteDIABase
operator=(DIABase &&)=defaultDIABase
tlx::ReferenceCounter::operator=(const ReferenceCounter &) noexceptReferenceCounterinline
parent_ids() constDIABaseinline
parents() constDIABaseinline
parents_DIABaseprotected
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() finalJoinNode< ValueType, FirstDIA, SecondDIA, KeyExtractor1, KeyExtractor2, JoinFunction, HashFunction, UseLocationDetection >inlineprivatevirtual
PushData(bool consume) finalJoinNode< ValueType, FirstDIA, SecondDIA, KeyExtractor1, KeyExtractor2, JoinFunction, HashFunction, UseLocationDetection >inlinevirtual
PushDataMemUse() finalJoinNode< ValueType, FirstDIA, SecondDIA, KeyExtractor1, KeyExtractor2, JoinFunction, HashFunction, UseLocationDetection >inlineprivatevirtual
PushFile(data::File &file, bool consume) constDIANode< ValueType >inline
PushItem(const ValueType &item) constDIANode< 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 noexceptReferenceCounterinline
ReferenceCounter() noexceptReferenceCounterinline
ReferenceCounter(const ReferenceCounter &) noexceptReferenceCounterinline
RemoveAllChildren() overrideDIANode< ValueType >inlinevirtual
RemoveChild(DIABase *node) overrideDIANode< ValueType >inlinevirtual
RemoveParent(DIABase *p)DIABaseinline
RequireParentPushData(size_t) constDIABaseinlinevirtual
RunPushData() overrideDIANode< ValueType >inlinevirtual
RunScope()DIABase
set_mem_limit(const DIAMemUse &mem_limit)DIABaseinline
set_state(const DIAState &state)DIABaseinline
SetConsumeCounter(size_t counter)DIABaseinlinevirtual
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) finalJoinNode< ValueType, FirstDIA, SecondDIA, KeyExtractor1, KeyExtractor2, JoinFunction, HashFunction, UseLocationDetection >inlineprivatevirtual
state() constDIABaseinline
state_DIABaseprotected
StopPreOp(size_t parent_index) finalJoinNode< ValueType, FirstDIA, SecondDIA, KeyExtractor1, KeyExtractor2, JoinFunction, HashFunction, UseLocationDetection >inlineprivatevirtual
Super typedefJoinNode< ValueType, FirstDIA, SecondDIA, KeyExtractor1, KeyExtractor2, JoinFunction, HashFunction, UseLocationDetection >private
unique() const noexceptReferenceCounterinline
~DIABase()DIABaseinlinevirtual
~ReferenceCounter()ReferenceCounterinline