|
| _workerIFdd (unsigned int ident, fddType kt, fddType t) |
|
| _workerIFdd (unsigned int ident, fddType kt, fddType t, size_t size) |
|
void | setData (K *keys, T *data, size_t size) |
|
void | setData (void *keys, void *data, size_t size) |
|
void | setData (void *keys, void *data, size_t *lineSizes UNUSED, size_t size) |
|
void | setDataRaw (void *keys, void *data, size_t size) override |
|
void | setDataRaw (void *keys UNUSED, void *data UNUSED, size_t *lineSizes UNUSED, size_t size UNUSED) override |
|
size_t * | getLineSizes () |
|
void | insert (void *k, void *in, size_t s) |
|
void | insertl (void *in) |
|
void | insert (K &key, T &in) |
|
void | insert (std::deque< std::pair< K, T > > &in) |
|
void | apply (void *func, fddOpType op, workerFddBase *dest, fastCommBuffer &buffer) |
|
void | collect (fastComm *comm) override |
|
| workerIFddCore (unsigned int ident, fddType kt, fddType t) |
|
| workerIFddCore (unsigned int ident, fddType kt, fddType t, size_t size) |
|
fddType | getType () override |
|
fddType | getKeyType () override |
|
void | setData (void *data UNUSED, size_t size UNUSED) |
|
void | setData (void *data UNUSED, size_t *ls UNUSED, size_t size UNUSED) |
|
void | setDataRaw (void *data UNUSED, size_t size UNUSED) override |
|
void | setDataRaw (void *data UNUSED, size_t *lineSizes UNUSED, size_t size UNUSED) override |
|
T & | operator[] (size_t address) |
|
void * | getItem (size_t address) |
|
void * | getData () override |
|
void * | getKeys () |
|
size_t | getSize () override |
|
size_t | itemSize () override |
|
size_t | baseSize () override |
|
void | setSize (size_t s) |
|
void | deleteItem (void *item) override |
|
void | shrink () |
|
void | preapply (unsigned long int id, void *func, fddOpType op, workerFddBase *dest, fastComm *comm) |
|
void | groupByKey (fastComm *comm) |
|
void | countByKey (fastComm *comm) |
|
void | exchangeDataByKey (fastComm *comm, void *keyMap) |
|
std::vector< std::vector< void * > > * | getKeyLocations () |
|
| workerFddBase (unsigned int ident, fddType t) |
|
virtual void | setData (void *, size_t)=0 |
|
virtual void | setData (void *, size_t *, size_t)=0 |
|
virtual void | setData (void *, void *, size_t *, size_t)=0 |
|
virtual void | setDataRaw (void *, size_t)=0 |
|
virtual void | setDataRaw (void *, size_t *, size_t)=0 |
|
virtual void | setDataRaw (void *, void *, size_t *, size_t)=0 |
|
|
K * | distributeOwnership (fastComm *comm, K *uKeys, size_t cSize) |
|
void | sendPartKeyCount (fastComm *comm) |
|
std::unordered_map< K, size_t > | recvPartKeyMaxCount (fastComm *comm, std::unordered_map< K, std::pair< size_t, std::deque< int >> > &keyPPMaxCount) |
|
std::unordered_map< K, size_t > | recvPartKeyCount (fastComm *comm) |
|
std::unordered_map< K, size_t > | distributedMaxKeyCount (fastComm *comm, std::unordered_map< K, std::pair< size_t, std::deque< int >> > &keyPPMaxCount) |
|
indexedFddStorage< K, T > * | localData |
|
std::vector< K > | uKeys |
|
std::vector< std::vector< void * > > | keyLocations |
|
bool | groupedByKey |
|
unsigned long int | id |
|
fddType | type |
|
fddType | keyType |
|