Method _select

join/LSH/datasketch/storage.py:460–482

Execute a list of statements and parameters returning data. :param iterable[tuple] statements_and_parameters: list of statements and parameters :rtype: list[Row] :return: the rows matching the queries

(self, statements_and_parameters)

                item = list(itertools.islice(iterator, size))

        def _select(self, statements_and_parameters):
            """
            Execute a list of statements and parameters returning data.

            :param iterable[tuple] statements_and_parameters: list of statements and parameters
            :rtype: list[Row]
            :return: the rows matching the queries
            """
            ret = []
            size = self.CONCURRENCY
            for sub_sequence in CassandraClient.split_sequence(statements_and_parameters, size):
                results = c_concurrent.execute_concurrent(
                    self._session,
                    sub_sequence,
                    concurrency=size,
                )
                for result in results:
                    success, rows = result
                    if success:
                        ret.append(rows)
                    else:
                        raise RuntimeError
            return ret

        def _execute(self, statements_and_parameters):
            """