Я пытаюсь реализовать потоковую передачу для добавления тем kafka в hbase. Когда я внедряю Maven в...
Я не могу расширить объект ведения журнала, потому что это вид частного, как я могу его решить?
Разработано: хотите реализовать scala-код с использованием структурированной потоковой обработки...
Используя Spark для обучения модели, параметры трансляции обновляются во время обучения, и в начале...
Я пытаюсь опросить тему kafka с помощью API KafkaConsumer. Но он переходит в состояние ожидания на...
Я работаю с API-интерфейсом Stream Streaming, чтобы ознакомиться с ним. Я реализую проблему...
Нужна помощь, пожалуйста. Я использую IntelliJ с SBT для сборки своих приложений. Я работаю над...
Я работаю с dstream из kafka, который выглядит как запись ниже. Я изо всех сил пытался получить...
Я пытаюсь читать темы Кафки через Apache Spark Streaming и не могу понять, как преобразовать данные...
Я получаю логи в формате log4j, обрабатываю их и сохраняю в Spark. Я не в кластерной или...
Я пытаюсь запустить несколько заданий Spark на DSE Cassandra, используя dse> bin/dse...
У меня есть поток данных, поступающих из таблицы mysql в kafka в мою программу spark. Когда...
Объясните связь между библиотеками, такими как SparkSQL, MLib, GraphX и Spark Streaming, и...
Мы вручную отслеживаем потоковые задания на запуск, нам нужно автоматизировать мониторинг заданий...
Я использую потоковую передачу pyspark для выполнения преобразования с сохранением состояния....
Я использую spark stream (scala) и получаю записи звонков клиентов в колл-центр через kafka через...
У нас есть DStream, например val ssc = new StreamingContext(sc, Seconds(1)) val kS = KafkaUtils
Я пытаюсь выполнить запрос Cypher, используя соединитель Spark-Neo4j. Я хочу передать параметры в...
TL; DR Какова наилучшая практика в отношении определения максимальной скорости входящих данных,...
Я ищу соединители с открытым исходным кодом, которые могут передавать данные из Spark Streaming в...
String folder = "/Users/test/data/*/*"; sparkContext.textFile(folder, 1).toJavaRDD()...