Я использую spark, чтобы соединить таблицу с другой базой данных и couchbase, используя наборы данных Spark.
val couchbaseTable = session.read.couchbase(StructType(StructField("name",StringType) ::Nil))
На консоли Couchbase я вижу, что число операций увеличивается до 500 с заглушкой, а затем через несколько становится равным 0секунд.Я провел нагрузочный тест, используя java api и реактив, и смог достичь 20 000 операций.
Как я могу увеличить размер выборки (пакетной, объемной), чтобы все документы сразу извлекались искрой, чтобыобработано, как я могу сделать с разъемом Cassandra?