Я использую приведенный ниже код для запуска в Qubole Notebook, и код выполняется успешно. case...

Я заархивировал три RDD и в результате получил вложенную структуру. val rdd1 = sc

Я хочу заархивировать все файлы и подкаталоги в каталоге s3 в другое место s3, используя java. Есть...

Мне нужно реализовать настроенный синтаксический анализатор Spark Sql, и я нашел эту ссылку ,...

У меня есть набор классов моделей, а подмножество этих моделей имеет 2 свойства, называемых...

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

Я пытаюсь проанализировать некоторые примеры файлов журнала в формате ниже в Spark DataFrame. 66

Я хочу создать простой поток Кафки, который пытается преобразовывать события, основываясь на...

i have a dataframe with these column. Column 1 and Column2 are array and rest of the columns are...

У меня есть список пар (id- (имя-значение)). Вот так val input = sc.parallelize(Array(Array(1,...

Я пытаюсь запустить мою программу в yarn cluster mode. Я на 100% уверен, что класс в fat jar от sbt...

Я пытаюсь собрать банку, используя sbt package. build.sbt: name := "Simple Project"...

Может быть, это глупо, я являюсь разработчиком Microsoft SQL / C # и никогда раньше не использовал...

Я пытаюсь использовать строки в классе case, как в выражениях java switch-case switch(someString)

Сопоставление с образцом не работает согласно пониманию. Я прочитал концепции сопоставления с...

Я определяю некоторые функции Scala в записной книжке Zeppelin, и одна из них - это оконная функция...

Я хочу проверить, все ли значения в моем фрейме данных имеют правильный формат "MM / dd / yy". val...

Я знаю, что эта проблема чтения большого количества маленьких файлов в HDFS всегда была проблемой и...

Я создаю приложение Spark и пытаюсь запустить его локально, прежде чем запускать его в EMR или в...

Мне сложно найти хороший способ отфильтровать набор данных искры. Я описал основную проблему ниже:...

Я пытаюсь использовать Apache Spark для загрузки результатов (большого) запроса SQL с несколькими...

Я пытаюсь перенести следующий код scala на c ++ Scala код: def getLong(bytes: Array[Byte]): Long =...

В моей многомодульной структуре проекта в sbt я определил конфигурационный тест конфигурации как в...

spark-shell --packages com.databricks:spark-csv_2.11:1.5.0 spark > val flightData2015 = spark

Вот мой код;работает нормально val client =Option (new RestHighLevelClient(RestClient.builder(new...