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

Возможно ли это в spark-scala? Я использую свечи 2.2 val...

Я пытаюсь инициализировать список в Spark, используя scala, из столбца данных. Значение в некоторых...

Я просматривал примеры преобразования из строки JSON, полученной от Кафки, в объект JSON. Я нашел...

Я запускаю следующий код: import com.holdenkarau.spark.testing.DatasetSuiteBase import org.apache

Dataset<Tweet> ds = sc.read().json("path").as(Encoders.bean(Tweet.class)); ds

У меня есть датафрейм с 4 столбцами co1, col2, col3 и col4. Мне нужно: Группировка данных на основе...

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

Когда я запускаю этот код, в некоторых случаях я получаю пустую ошибку коллекции. val result = df

Я новичок в Spark, и я хотел бы прочитать CSV-файл на Dataframe. Spark 1.3.0 / Scala 2.3.0 Это то,...

У меня есть две таблицы с двумя общими столбцами.Я делаю объединение с использованием этих столбцов

Я пытаюсь разорвать строку (технически строки, переданные из столбца в кадре данных) и вернуть эти...

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