После прочтения документа doc (драйвера документа) и нескольких ответов кажется, что Cassandra 2.0+ имеет функцию автоматической подкачки.Но все такие примеры включали ключевое слово LIMIT
.
Применим ли этот запрос к автоматической подкачке:
current_version_query = "SELECT id, row_hash FROM {} WHERE version={}".format(
self.table_name, self.diff_source_version
)
current_version_rows = self.session.execute(
current_version_query
)
Я повторяю его здесь: for current_version_row in current_version_rows: