18 #ifndef BROADCAST_JOIN_BUILDHT_STAGE_H
19 #define BROADCAST_JOIN_BUILDHT_STAGE_H
88 return "BroadcastJoinBuildHTJobStage";
93 return BroadcastJoinBuildHTJobStage_TYPEID;
112 std::cout <<
"[JOB ID] jobId = " <<
jobId << std::endl;
113 std::cout <<
"[INPUT] databaseName=" <<
sourceContext->getDatabase()
115 std::cout <<
"[STAGE ID] id = " <<
id << std::endl;
118 std::cout <<
"[NUM PAGES] numPages=" <<
numPages << std::endl;
Handle< SetIdentifier > getSourceContext()
std::string getSourceTupleSetSpecifier()
void setSourceContext(Handle< SetIdentifier > sourceContext)
std::string getTargetTupleSetSpecifier()
String targetComputationSpecifier
Handle< ComputePlan > sharedPlan
int16_t getJobStageTypeID() override
String targetTupleSetSpecifier
size_t totalMemoryOnThisNode
void setComputePlan(const Handle< ComputePlan > &plan, const std::string &sourceTupleSetSpecifier, const std::string &targetTupleSetSpecifier, const std::string &targetComputationSpecifier)
ENABLE_DEEP_COPY BroadcastJoinBuildHTJobStage()
String sourceTupleSetSpecifier
Handle< SetIdentifier > sourceContext
Handle< ComputePlan > getComputePlan()
std::string getJobStageType() override
void setHashSetName(std::string hashSetName)
void setNumPages(int numPages)
void nullifyComputePlanPointer()
std::string getTargetComputationSpecifier()
size_t getTotalMemoryOnThisNode()
BroadcastJoinBuildHTJobStage(std::string jobId, JobStageID stageId, std::string hashSetName)
std::string getHashSetName()
JobStageID getStageId() override
void setTotalMemoryOnThisNode(size_t totalMem)