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
pdb::JoinComp< Out, In1, In2, Args > Member List

This is the complete list of members for pdb::JoinComp< Out, In1, In2, Args >, including all inherited members.

analyzeInputSets(std::vector< std::string > &inputNames)pdb::JoinCompBase< Out, In1, In2, Args... >inline
deleteObject(void *deleteMe)pdb::Objectinlinevirtual
extractLambdas(std::map< std::string, GenericLambdaObjectPtr > &returnVal) overridepdb::JoinCompBase< Out, In1, In2, Args... >inlinevirtual
getAllocatorPolicy()pdb::Computationinline
getBatchSize()pdb::JoinCompBase< Out, In1, In2, Args... >inline
getComputationType() overridepdb::JoinCompBase< Out, In1, In2, Args... >inlinevirtual
getComputationTypeID() overridepdb::JoinCompBase< Out, In1, In2, Args... >inlinevirtual
getComputeSink(TupleSpec &consumeMe, TupleSpec &attsToOpOn, TupleSpec &projection, ComputePlan &plan) overridepdb::JoinCompBase< Out, In1, In2, Args... >inlinevirtual
pdb::AbstractJoinComp::getComputeSink(TupleSpec &consumeMe, TupleSpec &projection, ComputePlan &plan)pdb::Computationinlinevirtual
getComputeSource(TupleSpec &outputScheme, ComputePlan &plan) overridepdb::JoinCompBase< Out, In1, In2, Args... >inlinevirtual
getDatabaseName()pdb::Computationinlinevirtual
getExecutor(bool needToSwapAtts, TupleSpec &hashedInputSchema, TupleSpec &pipelinedInputSchema, TupleSpec &pipelinedAttsToOperateOn, TupleSpec &pipelinedAttsToIncludeInOutput, ComputeInfoPtr arg) overridepdb::JoinCompBase< Out, In1, In2, Args... >inlinevirtual
getExecutor(bool needToSwapAtts, TupleSpec &hashedInputSchema, TupleSpec &pipelinedInputSchema, TupleSpec &pipelinedAttsToOperateOn, TupleSpec &pipelinedAttsToIncludeInOutput) overridepdb::JoinCompBase< Out, In1, In2, Args... >inlinevirtual
getIthInput(int i) const pdb::Computationinline
getIthInputType(int i)pdb::JoinCompBase< Out, In1, In2, Args... >inlinevirtual
getIthInputType(int i)pdb::JoinCompBase< Out, In1, In2, Args... >inlinevirtual
getIthInputType(int i) finalpdb::JoinCompBase< Out, In1, In2, Args... >inlinevirtual
getJoinType()pdb::JoinCompBase< Out, In1, In2, Args... >inline
getMultiInputsBase()pdb::JoinCompBase< Out, In1, In2, Args... >inline
getNumConsumers()pdb::Computationinline
getNumInputs() finalpdb::JoinCompBase< Out, In1, In2, Args... >inlinevirtual
getNumNodes()pdb::JoinCompBase< Out, In1, In2, Args... >inline
getNumNodesToCollect()pdb::Computationinlinevirtual
getNumPartitions()pdb::JoinCompBase< Out, In1, In2, Args... >inline
getObjectPolicy()pdb::Computationinline
getOutputColumnToApply()pdb::Computationinline
getOutputTupleSetName()pdb::Computationinline
getOutputType() overridepdb::JoinCompBase< Out, In1, In2, Args... >inlinevirtual
getPartitionId()pdb::JoinCompBase< Out, In1, In2, Args... >inline
getProjection(Handle< In1 > in1, Handle< In2 > in2, Handle< Args >...otherArgs)=0pdb::JoinComp< Out, In1, In2, Args >privatepure virtual
JoinCompBase< Out, In1, In2, Args... >::getProjection(Handle< In1 > in1, Handle< In2 > in2, Handle< Rest >...otherArgs)=0pdb::JoinCompBase< Out, In1, In2, Args... >pure virtual
getSelection(Handle< In1 > in1, Handle< In2 > in2, Handle< Args >...otherArgs)=0pdb::JoinComp< Out, In1, In2, Args >privatepure virtual
JoinCompBase< Out, In1, In2, Args... >::getSelection(Handle< In1 > in1, Handle< In2 > in2, Handle< Rest >...otherArgs)=0pdb::JoinCompBase< Out, In1, In2, Args... >pure virtual
getSetName()pdb::Computationinlinevirtual
getSinkMerger(TupleSpec &consumeMe, TupleSpec &attsToOpOn, TupleSpec &projection, ComputePlan &plan) overridepdb::JoinCompBase< Out, In1, In2, Args... >inlinevirtual
pdb::AbstractJoinComp::getSinkMerger(TupleSpec &consumeMe, TupleSpec &projection, ComputePlan &plan)pdb::Computationinlinevirtual
getSinkShuffler(TupleSpec &consumeMe, TupleSpec &attsToOpOn, TupleSpec &projection, ComputePlan &plan) overridepdb::JoinCompBase< Out, In1, In2, Args... >inlinevirtual
pdb::AbstractJoinComp::getSinkShuffler(TupleSpec &consumeMe, TupleSpec &projection, ComputePlan &plan)pdb::Computationinlinevirtual
getSize(void *ofMe)pdb::Objectinlinevirtual
getVTablePtr()pdb::Objectinline
hasInput()pdb::Computationinline
isCollectAsMap()pdb::Computationinlinevirtual
isTraversed()pdb::Computationinline
isUsingCombiner()pdb::Computationinlinevirtual
needsMaterializeOutput()pdb::Computationinlinevirtual
operator delete(void *me)pdb::Objectinlinestatic
operator new(size_t sz, const std::nothrow_t &tag)pdb::Objectinlinestatic
operator new(size_t sz)pdb::Objectinlinestatic
operator new(std::size_t count, void *ptr)pdb::Objectinlinestatic
setAllocatorPolicy(AllocatorPolicy myPolicy)pdb::Computationinline
setBatchSize(int batchSize) overridepdb::JoinCompBase< Out, In1, In2, Args... >inlinevirtual
setCollectAsMap(bool collectAsMapOrNot)pdb::Computationinlinevirtual
setInput(Handle< Computation > toMe)pdb::Computationinline
setInput(int whichSlot, Handle< Computation > toMe)pdb::Computationinline
setIterator(PageCircularBufferIteratorPtr iterator)pdb::JoinCompBase< Out, In1, In2, Args... >inline
setJoinType(JoinType joinType)pdb::JoinCompBase< Out, In1, In2, Args... >inline
setMultiInputsBaseToNull()pdb::JoinCompBase< Out, In1, In2, Args... >inline
setNumConsumers(int numConsumers)pdb::Computationinline
setNumNodes(int numNodes)pdb::JoinCompBase< Out, In1, In2, Args... >inline
setNumNodesToCollect(int numNodesToCollect)pdb::Computationinlinevirtual
setNumPartitions(int numPartitions)pdb::JoinCompBase< Out, In1, In2, Args... >inline
setObjectPolicy(ObjectPolicy myPolicy)pdb::Computationinline
setOutput(std::string dbName, std::string setName)pdb::Computationinlinevirtual
setOutputColumnToApply(std::string outputColumnToApply)pdb::Computationinline
setOutputTupleSetName(std::string outputTupleSetName)pdb::Computationinline
setPartitionId(size_t myPartitionId)pdb::JoinCompBase< Out, In1, In2, Args... >inline
setProxy(DataProxyPtr proxy)pdb::JoinCompBase< Out, In1, In2, Args... >inline
setTraversed(bool traversed)pdb::Computationinline
setUpAndCopyFrom(void *target, void *source) const pdb::Objectinlinevirtual
setUsingCombiner(bool useCombinerOrNot)pdb::Computationinlinevirtual
setVTablePtr(void *setToMe)pdb::Objectinline
toTCAPString(std::vector< InputTupleSetSpecifier > &inputTupleSets, int computationLabel, std::string &outputTupleSetName, std::vector< std::string > &outputColumnNames, std::string &addedOutputColumnName) overridepdb::JoinCompBase< Out, In1, In2, Args... >inlinevirtual
~JoinCompBase()pdb::JoinCompBase< Out, In1, In2, Args... >inlinevirtual