|
| 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)=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)=0 |
|
virtual void | setDataRaw (void *, void *, size_t *, size_t)=0 |
|
virtual size_t * | getLineSizes ()=0 |
|
virtual void | insertl (void *v)=0 |
|
virtual void | insert (void *k, void *v, size_t s)=0 |
|
virtual void | apply (void *func, fddOpType op, workerFddBase *dest, fastCommBuffer &buffer)=0 |
|
virtual void | collect (fastComm *comm)=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) |
|