Implements Impala::IDistributedAccess. Definition at line 159 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(). Referenced by Impala::Core::Training::TrainDataSrcKernelDistributed::MakeDataCopy(), and Impala::Core::Training::Svm::PredictForActiveLearn(). 00160 { 00161 // for all pieces that contain that column, broadcast it. 00162 ILOG_DEBUG_NODE("*** GetColumn " << index); 00163 Util::PropertySet cmd; 00164 cmd.Add("cmd","column"); 00165 cmd.Add("arg",index); 00166 int columnPart = mColumns->IndexToPart(index); 00167 std::vector<int> parts; 00168 for(int i=0 ; i<mRows->PartCount() ; ++i) 00169 parts.push_back(GetPartNr(i, columnPart)); 00170 int msglength = GetData(buffer, bufferlength, cmd, parts); 00171 //ILOG_DEBUG_NODE("GetColumn done, received " << msglength << " elements"); 00172 return msglength; 00173 }
Here is the call graph for this function:
|