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::TopKComp< InputClass, Score, ValueType > Member List

This is the complete list of members for pdb::TopKComp< InputClass, Score, ValueType >, including all inherited members.

AbstractAggregateComp()=defaultpdb::AbstractAggregateComp
batchSizepdb::AbstractAggregateCompprotected
collectAsMapOrNotpdb::AggregateCompBase< TopKQueue< Score, ValueType >, InputClass, int, TopKQueue< Score, ValueType > >protected
deleteObject(void *deleteMe)pdb::Objectinlinevirtual
extractLambdas(std::map< std::string, GenericLambdaObjectPtr > &returnVal) overridepdb::AggregateCompBase< TopKQueue< Score, ValueType >, InputClass, int, TopKQueue< Score, ValueType > >inlinevirtual
getAggOutProcessor() overridepdb::AggregateCompBase< TopKQueue< Score, ValueType >, InputClass, int, TopKQueue< Score, ValueType > >inlinevirtual
getAggregationProcessor(HashPartitionID id) overridepdb::AggregateCompBase< TopKQueue< Score, ValueType >, InputClass, int, TopKQueue< Score, ValueType > >inlinevirtual
getAllocatorPolicy()pdb::Computationinline
getBatchSize()pdb::AbstractAggregateCompinline
getCombinerProcessor(std::vector< HashPartitionID > partitions) overridepdb::AggregateCompBase< TopKQueue< Score, ValueType >, InputClass, int, TopKQueue< Score, ValueType > >inlinevirtual
getComputationType() overridepdb::AggregateCompBase< TopKQueue< Score, ValueType >, InputClass, int, TopKQueue< Score, ValueType > >inlinevirtual
getComputationTypeID() overridepdb::AggregateCompBase< TopKQueue< Score, ValueType >, InputClass, int, TopKQueue< Score, ValueType > >inlinevirtual
getComputeSink(TupleSpec &consumeMe, TupleSpec &projection, ComputePlan &plan) overridepdb::AggregateCompBase< TopKQueue< Score, ValueType >, InputClass, int, TopKQueue< Score, ValueType > >inlinevirtual
pdb::AbstractAggregateComp::getComputeSink(TupleSpec &consumeMe, TupleSpec &whichAttsToOpOn, TupleSpec &projection, ComputePlan &plan)pdb::Computationinlinevirtual
getComputeSource(TupleSpec &outputScheme, ComputePlan &plan) overridepdb::AggregateCompBase< TopKQueue< Score, ValueType >, InputClass, int, TopKQueue< Score, ValueType > >inlinevirtual
getDatabaseName() overridepdb::AggregateCompBase< TopKQueue< Score, ValueType >, InputClass, int, TopKQueue< Score, ValueType > >inlinevirtual
getIthInput(int i) const pdb::Computationinline
getIthInputType(int i) overridepdb::AggregateCompBase< TopKQueue< Score, ValueType >, InputClass, int, TopKQueue< Score, ValueType > >inlinevirtual
getKeyProjection(Handle< InputClass > aggMe) finalpdb::TopKComp< InputClass, Score, ValueType >inlinevirtual
getNumConsumers()pdb::Computationinline
getNumInputs() overridepdb::AggregateCompBase< TopKQueue< Score, ValueType >, InputClass, int, TopKQueue< Score, ValueType > >inlinevirtual
getNumNodes()pdb::AbstractAggregateCompinline
getNumNodesToCollect() overridepdb::AggregateCompBase< TopKQueue< Score, ValueType >, InputClass, int, TopKQueue< Score, ValueType > >inlinevirtual
getNumPartitions()pdb::AbstractAggregateCompinline
getObjectPolicy()pdb::Computationinline
getOutputColumnToApply()pdb::Computationinline
getOutputSetScanner()pdb::AggregateCompBase< TopKQueue< Score, ValueType >, InputClass, int, TopKQueue< Score, ValueType > >inline
getOutputTupleSetName()pdb::Computationinline
getOutputType() overridepdb::AggregateCompBase< TopKQueue< Score, ValueType >, InputClass, int, TopKQueue< Score, ValueType > >inlinevirtual
getSetName() overridepdb::AggregateCompBase< TopKQueue< Score, ValueType >, InputClass, int, TopKQueue< Score, ValueType > >inlinevirtual
getSinkMerger(TupleSpec &consumeMe, TupleSpec &projection, ComputePlan &plan)pdb::Computationinlinevirtual
getSinkMerger(TupleSpec &consumeMe, TupleSpec &whichAttsToOpOn, TupleSpec &projection, ComputePlan &plan)pdb::Computationinlinevirtual
getSinkShuffler(TupleSpec &consumeMe, TupleSpec &projection, ComputePlan &plan)pdb::Computationinlinevirtual
getSinkShuffler(TupleSpec &consumeMe, TupleSpec &whichAttsToOpOn, TupleSpec &projection, ComputePlan &plan)pdb::Computationinlinevirtual
getSize(void *ofMe)pdb::Objectinlinevirtual
getValueProjection(Handle< InputClass > aggMe) overridepdb::TopKComp< InputClass, Score, ValueType >inlinevirtual
getVTablePtr()pdb::Objectinline
hasInput()pdb::Computationinline
isCollectAsMap() overridepdb::AggregateCompBase< TopKQueue< Score, ValueType >, InputClass, int, TopKQueue< Score, ValueType > >inlinevirtual
isTraversed()pdb::Computationinline
isUsingCombiner() overridepdb::AbstractAggregateCompinlinevirtual
materializeAggOutpdb::AbstractAggregateCompprotected
needsMaterializeOutput() overridepdb::AbstractAggregateCompinlinevirtual
numNodespdb::AbstractAggregateCompprotected
numNodesToCollectpdb::AggregateCompBase< TopKQueue< Score, ValueType >, InputClass, int, TopKQueue< Score, ValueType > >protected
numPartitionspdb::AbstractAggregateCompprotected
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
outputSetScannerpdb::AggregateCompBase< TopKQueue< Score, ValueType >, InputClass, int, TopKQueue< Score, ValueType > >protected
setAllocatorPolicy(AllocatorPolicy myPolicy)pdb::Computationinline
setBatchSize(int batchSize) overridepdb::AbstractAggregateCompinlinevirtual
setCollectAsMap(bool collectAsMapOrNot) overridepdb::AggregateCompBase< TopKQueue< Score, ValueType >, InputClass, int, TopKQueue< Score, ValueType > >inlinevirtual
setDatabaseName(std::string dbName) overridepdb::AggregateCompBase< TopKQueue< Score, ValueType >, InputClass, int, TopKQueue< Score, ValueType > >inlinevirtual
setHashTable(void *hashTableLocation)pdb::AbstractAggregateCompinline
setHashTablePointer(void *hashTablePointer)pdb::AggregateCompBase< TopKQueue< Score, ValueType >, InputClass, int, TopKQueue< Score, ValueType > >inline
setInput(Handle< Computation > toMe)pdb::Computationinline
setInput(int whichSlot, Handle< Computation > toMe)pdb::Computationinline
setIterator(PageCircularBufferIteratorPtr iterator) overridepdb::AggregateCompBase< TopKQueue< Score, ValueType >, InputClass, int, TopKQueue< Score, ValueType > >inlinevirtual
setNumConsumers(int numConsumers)pdb::Computationinline
setNumNodes(int numNodes)pdb::AbstractAggregateCompinline
setNumNodesToCollect(int numNodesToCollect) overridepdb::AggregateCompBase< TopKQueue< Score, ValueType >, InputClass, int, TopKQueue< Score, ValueType > >inlinevirtual
setNumPartitions(int numPartitions)pdb::AbstractAggregateCompinline
setObjectPolicy(ObjectPolicy myPolicy)pdb::Computationinline
setOutput(std::string dbName, std::string setName) overridepdb::AggregateCompBase< TopKQueue< Score, ValueType >, InputClass, int, TopKQueue< Score, ValueType > >inlinevirtual
setOutputColumnToApply(std::string outputColumnToApply)pdb::Computationinline
setOutputTupleSetName(std::string outputTupleSetName)pdb::Computationinline
setProxy(DataProxyPtr proxy) overridepdb::AggregateCompBase< TopKQueue< Score, ValueType >, InputClass, int, TopKQueue< Score, ValueType > >inlinevirtual
setSetName(std::string setName) overridepdb::AggregateCompBase< TopKQueue< Score, ValueType >, InputClass, int, TopKQueue< Score, ValueType > >inlinevirtual
setTraversed(bool traversed)pdb::Computationinline
setUpAndCopyFrom(void *target, void *source) const pdb::Objectinlinevirtual
setUsingCombiner(bool useCombinerOrNot) overridepdb::AbstractAggregateCompinlinevirtual
setVTablePtr(void *setToMe)pdb::Objectinline
toTCAPString(std::vector< InputTupleSetSpecifier > &inputTupleSets, int computationLabel, std::string &outputTupleSetName, std::vector< std::string > &outputColumnNames, std::string &addedOutputColumnName) overridepdb::AggregateCompBase< TopKQueue< Score, ValueType >, InputClass, int, TopKQueue< Score, ValueType > >inlinevirtual
toTCAPString(std::string inputTupleSetName, std::vector< std::string > &inputColumnNames, std::vector< std::string > &inputColumnsToApply, std::vector< std::string > &childrenLambdaNames, int computationLabel, std::string &outputTupleSetName, std::vector< std::string > &outputColumnNames, std::string &addedOutputColumnName, std::string &myLambdaName)pdb::AggregateCompBase< TopKQueue< Score, ValueType >, InputClass, int, TopKQueue< Score, ValueType > >inline
useCombinerOrNotpdb::AbstractAggregateCompprotected
whereHashTableSitsForThePartitionpdb::AbstractAggregateCompprotected