| __del__(self) (defined in kmr4py.KVS) | kmr4py.KVS | |
| __init__(self, kmr_or_ckvs, keyty="opaque", valty="opaque") | kmr4py.KVS | |
| add(self, key, val) | kmr4py.KVS | |
| add_kv(self, key, val) | kmr4py.KVS | |
| add_kv_done(self) | kmr4py.KVS | |
| concatenate(self, morekvs) | kmr4py.KVS | |
| distribute(self, cyclic, mopts) | kmr4py.KVS | |
| free(self) | kmr4py.KVS | |
| get_element_count(self) | kmr4py.KVS | |
| get_field_type(self, key_or_value) | kmr4py.KVS | |
| local_element_count(self) | kmr4py.KVS | |
| map(self, fn, mopts) | kmr4py.KVS | |
| map_for_some(self, fn, mopts) | kmr4py.KVS | |
| map_ms(self, fn, mopts) | kmr4py.KVS | |
| map_ms_commands(self, fn, xopts) | kmr4py.KVS | |
| map_on_rank_zero(self, fn, mopts) | kmr4py.KVS | |
| map_once(self, rank_zero_only, fn, mopts) | kmr4py.KVS | |
| map_parallel_processes(self, fn, sopts) | kmr4py.KVS | |
| map_processes(self, nonmpi, fn, sopts) | kmr4py.KVS | |
| map_rank_by_rank(self, fn, mopts) | kmr4py.KVS | |
| map_serial_processes(self, fn, sopts) | kmr4py.KVS | |
| map_via_spawn(self, fn, xopts) | kmr4py.KVS | |
| mr | kmr4py.KVS | |
| read_file_by_segments(self, filename, color) | kmr4py.KVS | |
| read_files_reassemble(self, filename, color, offset, bytes_) | kmr4py.KVS | |
| reduce(self, fn, mopts) | kmr4py.KVS | |
| reduce_as_one(self, fn, mopts) | kmr4py.KVS | |
| reduce_for_some(self, fn, mopts) | kmr4py.KVS | |
| replicate(self, mopts) | kmr4py.KVS | |
| restore(self, data) | kmr4py.KVS | |
| reverse(self, mopts) | kmr4py.KVS | |
| save(self) | kmr4py.KVS | |
| shuffle(self, mopts) | kmr4py.KVS | |
| sort(self, mopts) | kmr4py.KVS | |
| sort_locally(self, shuffling, mopts) | kmr4py.KVS | |
