#include <DistributedAccess.h>
Inheritance diagram for Impala::Core::Matrix::DistributedAccess:
Public Member Functions | |
DistributedAccess (String filenamebase, Core::Database::RawDataSet *set, Core::Database::RawDataSet *set2, int startNode, int nodeCount) | |
~DistributedAccess () | |
bool | Valid () |
int | GetRows () |
int | GetColumns () |
Table::QuidTable * | GetColumnQuids () |
Table::QuidTable * | GetRowQuids () |
void | Subscribe () |
void | Unsubscribe () |
int | GetColumn (int index, double *buffer, int bufferlength) |
int | GetRow (int index, double *buffer, int bufferlength) |
int | GetDiagonal (double *buffer, int bufferlength) |
void | StartEventLoop () |
void | CopyParts (Matrix::Mat *dst) |
This function copies the data of all its parts into the array at the 'correct' position. | |
Private Member Functions | |
bool | ReadInfoFile (String filenamebase, Core::Database::RawDataSet *set, Core::Database::RawDataSet *set2) |
void | LoadParts (String filenamebase, Core::Database::RawDataSet *set, Core::Database::RawDataSet *set2) |
void | LoadQuids (String filenamebase, Core::Database::RawDataSet *set, Core::Database::RawDataSet *set2) |
int | GetPartNr (int rowpart, int columnpart) |
int | GetOwnerOfPart (int partNr) |
Matrix::Mat * | GetPart (int partNr) |
int | GetData (double *buffer, int bufferlength, Util::PropertySet &cmd, const std::vector< int > &parts) |
Private Attributes | |
bool | mValid |
IndexConverter * | mRows |
IndexConverter * | mColumns |
int | mStartNode |
int | mNodeCount |
std::vector< Matrix::Mat * > | mParts |
Table::QuidTable * | mColumnQuids |
Table::QuidTable * | mRowQuids |
ILOG_VAR_DEC | |
Classes | |
class | IndexConverter |
A number of nodes load the parts and these nodes should respond to access requests. On these nodes the function StartEventLoop() should be called. Other nodes can access parts on other nodes by calling GetColumn() or GetDiagonal(). Because this class is created for use by the SVM these are the only accessors currently implemented.
Each class knows on what node a part is so communication can be kept to a minimum.
Definition at line 39 of file DistributedAccess.h.