Я храню данные в Kafka, используя схему реестра и сериализацию avro.Теперь я должен использовать...

У меня есть следующий код: import java.text.SimpleDateFormat import java.util.Calendar import scala

Я работаю над проектом с моими друзьями, в котором есть много зависимостей, которые требуются для...

Я пытаюсь запустить несколько заданий Spark на DSE Cassandra, используя dse> bin/dse...

Я извлекаю содержимое из таблицы Cassandra, используя функции коннектора Dataframe. После этого я...

Я использую потоковую передачу pyspark для выполнения преобразования с сохранением состояния....

У меня следующий код: - val result = session.execute("Select * from table where imei=...

Более новый соединитель spark-cassandra устарел / удалил CassandraSQLContext, который позволял...

У меня есть следующий код: - case class event(imei: String, date: String, gpsdt: String,dt: String...

У меня есть данные в Кассандре (3.11.2), которые также являются моими df: Данные в Кассандре: id |...

Я попытался сравнить cassandra save для таблицы с 30 000 записей для RDD и DataSet.Я обнаружил, что...

У меня есть следующий код: val conf = new SparkConf() .setAppName("KafkaReceiver")