У меня есть данные следующим образом. Я хочу обобщить это следующим образом: Я хочу взять первую...
Я написал запрос hbase в scala spark, и он работает хорошо.Я хочу реализовать это в записной книжке...
Я пытаюсь эмулировать этот пример из книги Яцека Ласковского о чтении CSV-файла и агрегировании...
В нашем приложении мы соединяем искру с HBase, используя следующий код: val hBaseRDD:...
Я пытаюсь решить проблему перекос данных в кадре данных.Я ввел новый столбец, основанный на...
Исходная проблема: В Scala , я хотел бы использовать неявное Ordering[T]#Ops для сравнения двух...
У меня есть проект SBT Scala, который отправляет пользователям электронные письма с некоторой...
Я добавил несколько журналов, используя log4J, но он не печатается, когда я запускаю свое...
Возможно, это глупые вопросы, но я застрял и не смог начать свои проекты Spark.Я никогда не делал...
У меня есть некоторый искровой код, мне нужно по какой-то причине перехватить все исключения и...
У меня есть несколько схем, как показано ниже, с разными именами столбцов и типами данных.Я хочу...
Следующая codenippet вызывает исключение NullPointerException.Я не уверен, происходит ли это...
Я разработал потоковую искру (1.6.2) с Kafka в модели приемника и выполняю это задание с размером...
У меня есть пример, я хочу создать Dataframe в UDF.Нечто похожее на приведенное ниже import org
Привет, я новичок в PlayFramework, и я делаю учебник, который нашел в Интернете при создании...
Я пытаюсь применить миграции для поддержки базы данных H2 в тесте, моя структура папок: src - test...
Ценю вашу помощь заранее.Уже 2-й день я продолжал пробовать все перестановки и комбинации, не мог...
Допустим, у меня есть две таблицы в отдельных кешах Ignite, A и B с соответствующими ключами: case...
У меня есть следующий DataFrame: [info] root [info] |-- id: integer (nullable = true) [info] |--...
У меня есть функция Scala следующим образом: val func1(field1: String, field2: String, field3:...
У меня есть следующий фрейм данных: val df = Seq(("x", "y", 1),("x",...
У меня есть искра DataFrame (в Scala), например:...
Я заметил кое-что интересное при работе с spark-shell, и мне интересно, почему это происходит.Я...
В следующем коде гарантированно выполняется цикл BLOCK 2 только после того, как все задачи...
Я пробовал этот код и заменил # на # Apple. val ssc = new StreamingContext("local[*]",...