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
Public Member Functions | Private Attributes | List of all members
pdb::AggregationJobStageBuilder Class Reference

#include <AggregationJobStageBuilder.h>

+ Collaboration diagram for pdb::AggregationJobStageBuilder:

Public Member Functions

 AggregationJobStageBuilder ()
 
void setJobId (const std::string &jobId)
 
void setJobStageId (int jobStageId)
 
void setAggComp (const Handle< AbstractAggregateComp > &aggComp)
 
void setSourceContext (const Handle< SetIdentifier > &sourceContext)
 
void setSinkContext (const Handle< SetIdentifier > &sinkContext)
 
void setMaterializeOrNot (bool materializeOrNot)
 
Handle< AggregationJobStage > build ()
 

Private Attributes

std::string jobId
 
int jobStageId
 
Handle< AbstractAggregateComp > aggComp
 
Handle< SetIdentifier > sourceContext
 
Handle< SetIdentifier > sinkContext
 
bool materializeOrNot
 

Detailed Description

Definition at line 30 of file AggregationJobStageBuilder.h.

Constructor & Destructor Documentation

pdb::AggregationJobStageBuilder::AggregationJobStageBuilder ( )

Definition at line 22 of file AggregationJobStageBuilder.cc.

Member Function Documentation

Handle< AggregationJobStage > pdb::AggregationJobStageBuilder::build ( )

Return the build AggregationJobStage

Returns
the AggregationJobStage

Definition at line 50 of file AggregationJobStageBuilder.cc.

void pdb::AggregationJobStageBuilder::setAggComp ( const Handle< AbstractAggregateComp > &  aggComp)

The computation associated with this aggregation

Parameters
aggComp- an instance of the AbstractAggregateComp

Definition at line 34 of file AggregationJobStageBuilder.cc.

void pdb::AggregationJobStageBuilder::setJobId ( const std::string &  jobId)

The id of the job this job stage belongs to

Parameters
jobId- string identifier of the job

Definition at line 26 of file AggregationJobStageBuilder.cc.

void pdb::AggregationJobStageBuilder::setJobStageId ( int  jobStageId)

Sets the id of this job stage

Parameters
jobStageId- the id that uniquely identifies this stage within the current job

Definition at line 30 of file AggregationJobStageBuilder.cc.

void pdb::AggregationJobStageBuilder::setMaterializeOrNot ( bool  materializeOrNot)

Should we materialize the output of this aggregation or should we keep it as a hash set?

Parameters
materializeOrNot- true if we should, false otherwise

Definition at line 46 of file AggregationJobStageBuilder.cc.

void pdb::AggregationJobStageBuilder::setSinkContext ( const Handle< SetIdentifier > &  sinkContext)

Sets the set identifier of the output This is used by the

See Also
FrontendQueryTestServer to create the output set
Parameters
sinkContext- the set identifier

Definition at line 42 of file AggregationJobStageBuilder.cc.

void pdb::AggregationJobStageBuilder::setSourceContext ( const Handle< SetIdentifier > &  sourceContext)

Sets the set identifier by the source set This is used by the

See Also
FrontendQueryTestServer to get the info about the source set
Parameters
sourceContext- the set identifier

Definition at line 38 of file AggregationJobStageBuilder.cc.

Member Data Documentation

Handle<AbstractAggregateComp> pdb::AggregationJobStageBuilder::aggComp
private

The computation associated with this aggregation

Definition at line 94 of file AggregationJobStageBuilder.h.

std::string pdb::AggregationJobStageBuilder::jobId
private

The id of the job this job stage belongs to

Definition at line 84 of file AggregationJobStageBuilder.h.

int pdb::AggregationJobStageBuilder::jobStageId
private

The id of this job stage. It uniquely identifies this stage within this job

Definition at line 89 of file AggregationJobStageBuilder.h.

bool pdb::AggregationJobStageBuilder::materializeOrNot
private

Should we materialize this as a set or keep it as a hashSet

Definition at line 111 of file AggregationJobStageBuilder.h.

Handle<SetIdentifier> pdb::AggregationJobStageBuilder::sinkContext
private

The set identifier of the output This is used by the

See Also
FrontendQueryTestServer to create the output set

Definition at line 106 of file AggregationJobStageBuilder.h.

Handle<SetIdentifier> pdb::AggregationJobStageBuilder::sourceContext
private

The set identifier by the source set This is used by the

See Also
FrontendQueryTestServer to get the info about the source set

Definition at line 100 of file AggregationJobStageBuilder.h.

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