Я использую Spark Structured Streaming с Spark 2.3.1 и ниже мой код: val sparkSession =...
Это пример файла JSON.Я хочу сделать это в целом, например, если у меня есть корневые теги, то как...
Я пытаюсь получить исходный код любого класса (если он доступен) из Java-программы для целей...
В моей работе есть разные среды (разработка, подготовка производства и производства), и в каждой...
Я разрабатываю приложение, используя scala 2.11 и apache-flink 1.6 .Это sbt проект, поэтому я не...
У меня сложная топология, включающая в себя KStreams, KTables, объединения, повторное использование...
Я новичок в Spark, и мне нужно перегруппировать все данные, хранящиеся в нескольких файлах, в один....
Я хотел бы знать, когда мне следует использовать sbt assembly, а когда sbt compile && sbt...
У меня есть три класса class C { var id: String = _ } class B { var c: List[C] = _ } class A { var...
Я запустил следующий код: object AirportsInUsaSolution { def main(args: Array[String]) { val conf =...
как я могу получить доступ к webHDFS с помощью spark. Постановка проблемы: «Необходимо получить...
У меня есть столбец json в postgresql, сопоставленный с JsValue в гладкой модели. case class...
У меня проблемы с объединением двух потоков кафки, извлекающих дату из полей моего события
Я пытаюсь найти правильный способ выполнения связанных функций, пока возвращаются некоторые
У меня есть фрейм данных, к которому я применил filter условие val colNames = customerCountDF
У меня есть фрейм данных, скажем DF Animal ====== Cat Dog Horse Я хочу повторить эти значения и...
Я новичок в разработке scala / Spark.Я создал простое потоковое приложение из темы Kafka, используя...
Мне нужно найти среднее расстояние пути, и Spark Scala отнимает целую вечность (оказывается, я даже...
Я могу запустить приложение Spark, которое я написал в Scala локально: sbt run ... , и оно работает...
Я пытаюсь запустить новый проект SBT Scala и получить в файле build.sbt следующее: name :=...
Я пытался: def convert[E, A](in: List[ValidatedNel[E, A]]): Ior[NonEmptyList[E], List[A]] = in
Я подозреваю, что ответ НЕТ, но подумал, что все равно спрошу. Учитывая что-то вроде trait foo {...
У меня есть таблица без первичных ключей.Как я могу вставить данные в него.Когда у меня есть...
Это игрушечная программа Scala, которая читает 10 цифр с консоли и добавляет 1 к каждой их...
Я создал простое SBT-приложение scala в IntelliJ.У меня есть Scala 2.12.8 (самая новая) и SBT 1.2.7