Динамический выбор нескольких столбцов при объединении разных Dataframe в Scala Spark По...
Я пытаюсь выполнить Естественное Преобразование между видами * -> * -> * поэтому хочу взять...
Давайте посмотрим на следующий очень простой пример торта: trait PrintSomething{ def...
У меня есть оператор выбора, который я храню в кадре данных .... val df = spark.sqlContext
Я новичок в искре и скале. Я работаю над проектом по прогнозированию с использованием моделей ARIMA
Мне нужно запросить HBASE, а затем работать с данными с помощью spark и scala. Моя проблема в том,...
У меня есть строка и шаблон регулярных выражений заменяется следующим: //1 - var x =...
У нас недавно была проблема, когда некоторые из разделов Kafka были потеряны, и работа продолжалась...
Я новичок в Spark, поэтому мне нужно создать RDD только с двумя элементами. Array1 = ((1,1)(1,2)(1...
Есть ли способ обновить объект конфигурации новым значением, присвоенным атрибуту и используемым...
Здравствуйте, я написал следующий код val receivedStream: DStream[PubsubSparkMessage] =...
выпуск Сценарий Гатлинга в настоящее время останавливается на 14 запросах и не продолжает итерацию...
Я пытаюсь динамически вызывать функцию, используя переменную типа String, т.е. переменная будет...
Используя Scala, я получаю эту ошибку «Карта значений не является членом chemins.Point» точка
Я читаю сжатый файл в Spark, используя val prsTypeDetails = sqlContext.read.load(inputPath) и...
Контекст : я работаю над веб-приложением, которое должно отображать некоторые довольно сложные и...
Я хочу назначить искровую функцию SQL переменной. Например: val func = org.apache.spark.sql
Я разрабатываю приложение Scala Spark Streaming для получения данных от Kafka. Так как у меня были...
Я новичок в scala & IntelliJ, так что это может звучать глупо. Однако я вижу, что при отладке...
Я работаю над spark-sql-2_11-2.3.1, я получаю сообщение об ошибке, при попытке отладки он выводит...
Я использую Spark Structured Streaming для обработки входящих и исходящих потоков данных от и до...
У меня есть DataFrame с 4 столбцами....
Я пытаюсь преобразовать приведенный ниже формат строки в метку времени Mon Oct 29 14:33:09 MYT 2018...
Допустим, у меня есть модель, которая выглядит примерно так: case class User(username: String,...
Я работаю с классом Scala Seq в Java (scala.collection.Seq<A>) и, согласно документации Scala...