A platform for high-performance distributed tool and library development written in C++. It can be deployed in two different cluster modes: standalone or distributed. API for v0.5.0, released on June 13, 2018.
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros
ApplyJoin Struct Reference

#include <AtomicComputationClasses.h>

+ Inheritance diagram for ApplyJoin:
+ Collaboration diagram for ApplyJoin:

Public Member Functions

 ApplyJoin (TupleSpec &output, TupleSpec &lInput, TupleSpec &rInput, TupleSpec &lProjection, TupleSpec &rProjection, std::string nodeName)
 
 ApplyJoin (TupleSpec &output, TupleSpec &lInput, TupleSpec &rInput, TupleSpec &lProjection, TupleSpec &rProjection, std::string nodeName, KeyValueList &useMe)
 
TupleSpecgetRightProjection ()
 
TupleSpecgetRightInput ()
 
std::string getAtomicComputationType () override
 
AtomicComputationTypeID getAtomicComputationTypeID () override
 
bool isTraversed ()
 
void setTraversed (bool traversed)
 
bool isPartitioningLHS ()
 
void setPartitioningLHS (bool toPartitionLHS)
 
std::pair< std::string,
std::string > 
findSource (std::string attName, AtomicComputationList &allComps) override
 
- Public Member Functions inherited from AtomicComputation
virtual ~AtomicComputation ()
 
AtomicComputationPtr getShared ()
 
void destroyPtr ()
 
 AtomicComputation (TupleSpec inputIn, TupleSpec outputIn, TupleSpec projectionIn, std::string computationName)
 
std::shared_ptr< std::map
< std::string, std::string > > & 
getKeyValuePairs ()
 
void setShared (AtomicComputationPtr meIn)
 
TupleSpecgetOutput ()
 
std::string & getOutputName ()
 
TupleSpecgetInput ()
 
std::string & getInputName ()
 
TupleSpecgetProjection ()
 
std::string & getComputationName ()
 
int findPosInOutputAtts (std::string &findMe)
 

Public Attributes

TupleSpec rightInput
 
TupleSpec rightProjection
 
bool traversed = false
 
bool toPartitionLHS = false
 

Additional Inherited Members

- Protected Attributes inherited from AtomicComputation
TupleSpec input
 
TupleSpec output
 
TupleSpec projection
 
std::string computationName
 
AtomicComputationPtr me
 
std::shared_ptr< std::map
< std::string, std::string > > 
keyValuePairs
 

Detailed Description

Definition at line 557 of file AtomicComputationClasses.h.

Constructor & Destructor Documentation

ApplyJoin::ApplyJoin ( TupleSpec output,
TupleSpec lInput,
TupleSpec rInput,
TupleSpec lProjection,
TupleSpec rProjection,
std::string  nodeName 
)
inline

Definition at line 569 of file AtomicComputationClasses.h.

ApplyJoin::ApplyJoin ( TupleSpec output,
TupleSpec lInput,
TupleSpec rInput,
TupleSpec lProjection,
TupleSpec rProjection,
std::string  nodeName,
KeyValueList useMe 
)
inline

Definition at line 583 of file AtomicComputationClasses.h.

+ Here is the call graph for this function:

Member Function Documentation

std::pair<std::string, std::string> ApplyJoin::findSource ( std::string  attName,
AtomicComputationList allComps 
)
inlineoverridevirtual

Implements AtomicComputation.

Definition at line 632 of file AtomicComputationClasses.h.

+ Here is the call graph for this function:

std::string ApplyJoin::getAtomicComputationType ( )
inlineoverridevirtual

Implements AtomicComputation.

Definition at line 608 of file AtomicComputationClasses.h.

AtomicComputationTypeID ApplyJoin::getAtomicComputationTypeID ( )
inlineoverridevirtual

Implements AtomicComputation.

Definition at line 612 of file AtomicComputationClasses.h.

TupleSpec& ApplyJoin::getRightInput ( )
inline

Definition at line 604 of file AtomicComputationClasses.h.

+ Here is the caller graph for this function:

TupleSpec& ApplyJoin::getRightProjection ( )
inline

Definition at line 600 of file AtomicComputationClasses.h.

+ Here is the caller graph for this function:

bool ApplyJoin::isPartitioningLHS ( )
inline

Definition at line 624 of file AtomicComputationClasses.h.

bool ApplyJoin::isTraversed ( )
inline

Definition at line 616 of file AtomicComputationClasses.h.

void ApplyJoin::setPartitioningLHS ( bool  toPartitionLHS)
inline

Definition at line 628 of file AtomicComputationClasses.h.

void ApplyJoin::setTraversed ( bool  traversed)
inline

Definition at line 620 of file AtomicComputationClasses.h.

Member Data Documentation

TupleSpec ApplyJoin::rightInput

Definition at line 559 of file AtomicComputationClasses.h.

TupleSpec ApplyJoin::rightProjection

Definition at line 560 of file AtomicComputationClasses.h.

bool ApplyJoin::toPartitionLHS = false

Definition at line 566 of file AtomicComputationClasses.h.

bool ApplyJoin::traversed = false

Definition at line 564 of file AtomicComputationClasses.h.


The documentation for this struct was generated from the following file: