|
@@ -48,9 +48,7 @@ class CKeyedJoinMaster : public CMasterActivity
|
|
|
// CMap contains mappings and lists of parts for each slave
|
|
|
class CMap
|
|
|
{
|
|
|
- CKeyedJoinMaster &activity;
|
|
|
public:
|
|
|
- CMap(CKeyedJoinMaster &_activity) : activity(_activity) {}
|
|
|
std::vector<unsigned> allParts;
|
|
|
std::vector<std::vector<unsigned>> slavePartMap; // vector of slave parts (IPartDescriptor's slavePartMap[<slave>] serialized to each slave)
|
|
|
std::vector<unsigned> partToSlave; // vector mapping part index to slave (sent to all slaves)
|
|
@@ -269,7 +267,7 @@ class CKeyedJoinMaster : public CMasterActivity
|
|
|
|
|
|
|
|
|
public:
|
|
|
- CKeyedJoinMaster(CMasterGraphElement *info) : CMasterActivity(info), indexMap(*this), dataMap(*this)
|
|
|
+ CKeyedJoinMaster(CMasterGraphElement *info) : CMasterActivity(info)
|
|
|
{
|
|
|
helper = (IHThorKeyedJoinArg *) queryHelper();
|
|
|
unsigned numStats = helper->diskAccessRequired() ? 8 : 5; // see progressKinds array
|