Язык - Scala Версия Spark - 2,4 Я новичок в Scala и Spark. (Я из Python, поэтому вся экосистема JVM...

Я пытаюсь запустить команду Sqoop с параметром - query в оболочке Scala, используя...

Допустим, список из Seq("a", "b", "c") и eventDF, eventDF

Я работаю со следующим классом и не могу преобразовать длинный список Scala в java.util.List...

Мы используем Spark StandAlone 2.3.2 and logback-core/logback-classic with 1.2.3 Имеет очень...

У меня есть кластер Databricks 5.3 в Azure, на котором работают Apache Spark 2.4.0 и Scala 2.11. Я...

Я инициализирую сопутствующий объект для одного из моих наборов тестов Scala.Одно из полей в этом...

Я использую Spark / Scala для обработки таблицы Hive, которая содержит данные транзакций для...

Я работаю над простым примером подсчета слов SparkStreaming для подсчета количества слов в...

У меня есть Spark DataFrame, состоящий из столбцов целых чисел. Я хочу табулировать каждый столбец...

object micro extends App { sealed trait FuncExpr sealed trait FuncSpecialize sealed case class...

ребята. Я использую HDP Sandbox от Hortonwork.Я настроил простое задание на искру (которое берет...

Я получаю события от Kafka и сохраняю в Cassandra. Синтаксический анализ json, который содержит...

Я выполняю некоторые упражнения на виртуальной машине DataStax.Дается таблица CassandraTable, и я...

У меня есть модель XGBoost, обученная Python API, и теперь я просто хочу использовать ее в спарке...

f(Int) - это функция, которая возвращает Option[Int]. def findIntPair(x: Int, y: Int): (Int, Int) =...

У меня Spark 2.3 очень большой фрейм данных: ------------------------- | col_key | col1 | col2 |...

Я читаю в JSON файле и сохраняю его в Dataframe . val df1 = spark.read.option("multiline"...

Я использую структурированную потоковую передачу для чтения csvs и записи в kafka. Вкладка...

У меня есть класс Java, сгенерированный ломбок equals и hashCode @EqualsAndHashCode...

Я работал над простым примером подсчета слов SparkStreaming, чтобы подсчитать количество слов в...

Возможно ли взаимодействие с таблицей с помощью клиентского интерфейса командной строки Flink SQL,...

Учитывая это: trait TraitClass[A <: TraitObject] { def name = A.getName // <-- How ??? }...

Итерация вложенных циклов * DataFrams foreach создает исключение NullPointerException: def...

У меня есть топология, где у меня есть поток A. Из этого потока A я создаю WindowedStore S. A...