Я пишу DStream в Elasticsearch, используя соединитель Elasticsearch-Hadoop.По этой ссылке вы можете...

версия spark: 2.3 Потоковое приложение Spark выполняет потоковую передачу по пути hdfs...

У меня есть две таблицы A и B. Мне нужно загружать данные из таблицы A каждый час в таблицу B...

Я читаю поток Твиттера из моей темы Kafka при преобразовании его в JSON в коде Pyspark, данные...

Мы разрабатываем потоковое приложение, используя Kafka, Spark Structured Streaming, Hive и s3. Мой...

Я новичок в потоковой передаче и пытаюсь работать с прецедентным сценарием технического...

Я использую PySpark 2.3.1 для чтения потока значений из Kafka как DStream s. Я хочу выполнить...

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

Я пытаюсь прочитать kafka, используя spark, но, похоже, столкнулся с некоторой библиотечной...

Я новичок в скале и искре.Мне нужны некоторые предложения, поскольку я борюсь со множеством ошибок....

Я новичок в Apache Spark и хотел бы написать некоторый код на Python, используя PySpark для чтения...

Объяснить мой вопрос иначе: Этот вопрос отличается от отмеченного. Во-первых, входной параметр уже...

Я пытаюсь настроить поступление данных Кафки в реальном времени в HBase через PySpark.У меня...

Можем ли мы объявить, что значение окна меньше скользящего значения? Это действительно один?...

Я хочу обновить коллекцию Solr-4.10 в приложении spark-streaming. Я наткнулся на разъем spark-solr...

Каким будет эквивалентный строковый SQL-запрос для этого же запроса: val streamingWindowDF =...

В PySpark Steaming, если включена контрольная точка и есть операция transform-join, выдается ошибка

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

Мне нужно прочитать CSV-файлы в виде потока, а затем преобразовать это в pandas dataframe. Вот что...

Мне нужно скопировать данные с Кассандры в Elastic search.В таблице Кассандры есть почти 5 ТБ...

Я выполняю потоковую передачу файлов из каталога, находящегося в состоянии копирования, и я хочу,...

Попытка подключения к Hbase с использованием искры на основе приведенной ниже документации,...

Я пытаюсь настроить поступление данных Кафки в реальном времени в HBase через PySpark в...

Я впервые использую pyspark. Версия Spark: 2.3.0 Версия Kafka: 2.2.0 У меня есть производитель...

У меня есть одно задание на обогащение событий, при котором я вызываю несколько внешних API...