#include <AggregationJobStage.h>

Inheritance diagram for pdb::AggregationJobStage:

Collaboration diagram for pdb::AggregationJobStage:

Public Member Functions
	AggregationJobStage ()

	AggregationJobStage (JobStageID stageId, bool materializeOrNot, Handle< AbstractAggregateComp > aggComputation)

	AggregationJobStage (JobStageID stageId, bool materializeOrNot, Handle< AbstractAggregateComp > aggComputation, int numNodePartitions)

	~AggregationJobStage ()

void	setNumNodePartitions (int numNodePartitions)

int	getNumNodePartitions ()

std::string	getJobStageType () override

int16_t	getJobStageTypeID () override

void	setSourceContext (Handle< SetIdentifier > sourceContext)

Handle< SetIdentifier >	getSourceContext ()

void	setSinkContext (Handle< SetIdentifier > sinkContext)

Handle< SetIdentifier >	getSinkContext ()

JobStageID	getStageId () override

bool	needsToMaterializeAggOut ()

void	print () override

std::string	getOutputTypeName ()

void	setOutputTypeName (std::string outputTypeName)

Handle< AbstractAggregateComp >	getAggComputation ()

void	setAggTotalPartitions (int numPartitions)

void	setAggBatchSize (int batchSize)

void	setAggComputation (Handle< AbstractAggregateComp > aggComputation)

void	setTotalMemoryOnThisNode (size_t totalMem)

size_t	getTotalMemoryOnThisNode ()

Public Member Functions inherited from pdb::AbstractJobStage
void	setJobId (std::string jobId)

std::string	getJobId ()

Public Member Functions inherited from pdb::Object
void	setVTablePtr (void *setToMe)

void *	getVTablePtr ()

virtual void	setUpAndCopyFrom (void target, void source) const

virtual void	deleteObject (void *deleteMe)

virtual size_t	getSize (void *ofMe)

Private Attributes
Handle< SetIdentifier >	sourceContext

Handle< SetIdentifier >	sinkContext

JobStageID	id

String	outputTypeName

bool	materializeOrNot

Handle< AbstractAggregateComp >	aggComputation

int	numNodePartitions

size_t	totalMemoryOnThisNode

Additional Inherited Members
Static Public Member Functions inherited from pdb::Object
static void *	operator new (size_t sz, const std::nothrow_t &tag)

static void *	operator new (size_t sz)

static void	operator delete (void *me)

static void *	operator new (std::size_t count, void *ptr)

Protected Attributes inherited from pdb::AbstractJobStage
String	jobId

Detailed Description

Definition at line 37 of file AggregationJobStage.h.

Constructor & Destructor Documentation

pdb::AggregationJobStage::AggregationJobStage ( )

inline

Definition at line 40 of file AggregationJobStage.h.

pdb::AggregationJobStage::AggregationJobStage	(	JobStageID	stageId,
		bool	materializeOrNot,
		Handle< AbstractAggregateComp >	aggComputation
	)

inline

Definition at line 42 of file AggregationJobStage.h.

pdb::AggregationJobStage::AggregationJobStage	(	JobStageID	stageId,
		bool	materializeOrNot,
		Handle< AbstractAggregateComp >	aggComputation,
		int	numNodePartitions
	)

inline

Definition at line 50 of file AggregationJobStage.h.

pdb::AggregationJobStage::~AggregationJobStage ( )

inline

Definition at line 60 of file AggregationJobStage.h.

Member Function Documentation

Handle<AbstractAggregateComp> pdb::AggregationJobStage::getAggComputation ( )

inline

Definition at line 134 of file AggregationJobStage.h.

std::string pdb::AggregationJobStage::getJobStageType ( )

inlineoverridevirtual

Implements pdb::AbstractJobStage.

Definition at line 70 of file AggregationJobStage.h.

Here is the caller graph for this function:

int16_t pdb::AggregationJobStage::getJobStageTypeID ( )

inlineoverridevirtual

Implements pdb::AbstractJobStage.

Definition at line 74 of file AggregationJobStage.h.

int pdb::AggregationJobStage::getNumNodePartitions ( )

inline

Definition at line 66 of file AggregationJobStage.h.

std::string pdb::AggregationJobStage::getOutputTypeName ( )

inline

Definition at line 126 of file AggregationJobStage.h.

Here is the caller graph for this function:

Handle<SetIdentifier> pdb::AggregationJobStage::getSinkContext ( )

inline

Definition at line 94 of file AggregationJobStage.h.

Handle<SetIdentifier> pdb::AggregationJobStage::getSourceContext ( )

inline

Definition at line 84 of file AggregationJobStage.h.

JobStageID pdb::AggregationJobStage::getStageId ( )

inlineoverridevirtual

Implements pdb::AbstractJobStage.

Definition at line 98 of file AggregationJobStage.h.

size_t pdb::AggregationJobStage::getTotalMemoryOnThisNode ( )

inline

Definition at line 154 of file AggregationJobStage.h.

bool pdb::AggregationJobStage::needsToMaterializeAggOut ( )

inline

Definition at line 102 of file AggregationJobStage.h.

void pdb::AggregationJobStage::print ( )

inlineoverridevirtual

Implements pdb::AbstractJobStage.

Definition at line 106 of file AggregationJobStage.h.

Here is the call graph for this function:

void pdb::AggregationJobStage::setAggBatchSize ( int batchSize )

inline

Definition at line 142 of file AggregationJobStage.h.

void pdb::AggregationJobStage::setAggComputation ( Handle< AbstractAggregateComp > aggComputation )

inline

Definition at line 146 of file AggregationJobStage.h.

void pdb::AggregationJobStage::setAggTotalPartitions ( int numPartitions )

inline

Definition at line 138 of file AggregationJobStage.h.

void pdb::AggregationJobStage::setNumNodePartitions ( int numNodePartitions )

inline

Definition at line 62 of file AggregationJobStage.h.

void pdb::AggregationJobStage::setOutputTypeName ( std::string outputTypeName )

inline

Definition at line 130 of file AggregationJobStage.h.

void pdb::AggregationJobStage::setSinkContext ( Handle< SetIdentifier > sinkContext )

inline

Definition at line 89 of file AggregationJobStage.h.

void pdb::AggregationJobStage::setSourceContext ( Handle< SetIdentifier > sourceContext )

inline

Definition at line 79 of file AggregationJobStage.h.

void pdb::AggregationJobStage::setTotalMemoryOnThisNode ( size_t totalMem )

inline

Definition at line 150 of file AggregationJobStage.h.

Member Data Documentation

Handle<AbstractAggregateComp> pdb::AggregationJobStage::aggComputation

private

Definition at line 174 of file AggregationJobStage.h.

JobStageID pdb::AggregationJobStage::id

private

Definition at line 168 of file AggregationJobStage.h.

bool pdb::AggregationJobStage::materializeOrNot

private

Definition at line 172 of file AggregationJobStage.h.

int pdb::AggregationJobStage::numNodePartitions

private

Definition at line 176 of file AggregationJobStage.h.

String pdb::AggregationJobStage::outputTypeName

private

Definition at line 170 of file AggregationJobStage.h.

Handle<SetIdentifier> pdb::AggregationJobStage::sinkContext

private

Definition at line 165 of file AggregationJobStage.h.

Handle<SetIdentifier> pdb::AggregationJobStage::sourceContext

private

Definition at line 163 of file AggregationJobStage.h.

size_t pdb::AggregationJobStage::totalMemoryOnThisNode

private

Definition at line 178 of file AggregationJobStage.h.

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

plinycompute/pdb/src/builtInPDBObjects/headers/AggregationJobStage.h

Public Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation