Implements Impala::IDistributedAccess. Definition at line 175 of file DistributedAccess.h. References Impala::Util::PropertySet::Add(), GetData(), GetPartNr(), Impala::Core::Matrix::DistributedAccess::IndexConverter::IndexToPart(), mColumns, mRows, and Impala::Core::Matrix::DistributedAccess::IndexConverter::PartCount(). 00176 { 00177 // for all pieces that contain that row, broadcast it. 00178 ILOG_DEBUG_NODE("*** GetRow " << index); 00179 Util::PropertySet cmd; 00180 cmd.Add("cmd","row"); 00181 cmd.Add("arg",index); 00182 int rowPart = mRows->IndexToPart(index); 00183 std::vector<int> parts; 00184 for(int i=0 ; i<mColumns->PartCount() ; ++i) 00185 parts.push_back(GetPartNr(rowPart, i)); 00186 int msglength = GetData(buffer, bufferlength, cmd, parts); 00187 //ILOG_DEBUG_NODE("GetRow done, received " << msglength << " elements"); 00188 return msglength; 00189 }
Here is the call graph for this function:
|