Select all values for the given keys. :param iterable[byte|str] keys: the keys :rtype: dict[byte|str,list[byte|str] :return: a dictionary of lists
(self, keys)
| 645 | ] |
| 646 | |
| 647 | def select(self, keys): |
| 648 | """ |
| 649 | Select all values for the given keys. |
| 650 | |
| 651 | :param iterable[byte|str] keys: the keys |
| 652 | :rtype: dict[byte|str,list[byte|str] |
| 653 | :return: a dictionary of lists |
| 654 | """ |
| 655 | statements_and_parameters = [ |
| 656 | (self._stmt_get, (self._key_encoder(key), )) |
| 657 | for key in keys |
| 658 | ] |
| 659 | ret = collections.defaultdict(list) |
| 660 | for rows in self._select(statements_and_parameters): |
| 661 | for row in rows: |
| 662 | ret[self._key_decoder(row.key)].append((self._val_decoder(row.value), row.ts)) |
| 663 | return { |
| 664 | k: [x[0] for x in sorted(v, key=operator.itemgetter(1))] |
| 665 | for k, v in ret.items() |
| 666 | } |
| 667 | |
| 668 | def select_count(self, keys): |
| 669 | """ |
no test coverage detected