Method _execute

join/LSH/datasketch/storage.py:484–496

Execute a list of statements and parameters NOT returning data. :param iterable[tuple] statements_and_parameters: list of statements and parameters

(self, statements_and_parameters)

            return ret

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

            :param iterable[tuple] statements_and_parameters: list of statements and parameters
            """
            size = self.CONCURRENCY
            for sub_sequence in CassandraClient.split_sequence(statements_and_parameters, size):
                c_concurrent.execute_concurrent(
                    self._session,
                    sub_sequence,
                    concurrency=size,
                )

        def _buffer(self, statements_and_parameters):
            """