Coursier - это инструмент загрузки Scala. В инструкциях говорится, что нужно использовать -Dhttps
Я пытаюсь перевести SQL-запрос на спарк-лэнг. Вот запрос sql: %sql select...
Я хочу прочитать текстовый файл из hdf, используя spark rdd, и записать в kafka по foreach.Code...
У меня есть следующий класс дел, определенный в Scala case class BitmexTradeData( foreignNotional:...
В моем проекте sbt scala я хочу использовать эту https://github.com/akka/akka/pull/25317/files...
Напишите функцию, которая на входе принимает два параметра: список целых чисел и число. Выход...
Я пытаюсь разбить изображения ниже на столбцы. Если разделить, то Dataframe всегда меняется на...
Используя флаг -Xprint в scalac, мы получаем выходные данные фаз компилятора , например, с учетом...
У меня есть такая строка ввода val input =...
Я хочу сохранить вывод консоли в файле паркета, потому что вывод состоит из 13849 строк. Выход для...
У меня в фрейме 1.6 есть фрейм данных, в котором я хотел бы выбрать все строки больше текущего...
В моем потоковом приложении Scala (2.11) я потребляю данные из одной очереди в IBM MQ и записываю...
Я пытаюсь создать универсальную функцию для чтения yaml-файлов с той же вложенной структурой, но с...
Функция scanFolder() работала, но иногда выдается исключение ниже object MyClass{ // ... etc val fs...
Я пытаюсь добавить метод установки в объект: object Foo { def foo_=(s: String) = println(s) } Foo
Я изучаю схему реестра, используя слияние. Кажется, я не могу загрузить 'kafka avro serializer'. Я...
Я студент, я впервые изучаю spark. Когда я настраиваю среду на intellj и запускаю spark, возникает...
Почему возможно / разрешено иметь отрицательную продолжительность в scala? scala> import scala
Я пытаюсь создать сценарий, который будет работать каждый раз, но я не знаю, как обращаться с...
Как это сделать? val (a,b) = spark.sql("SELECT 1,2").first Примечания и мотивы Мне нужно...
scala.collection.Iterator и List являются подклассами scala.collection.IterableOnce. Почему бы...
У меня есть датафрейм (dateds1), который выглядит следующим образом,...
Я новичок в Scala и изо всех сил пытаюсь разыграть Array(Vector) до Array(Array[Double]). Я думал,...
Я хотел бы использовать оператор match case, используя списки. Вот мой пример использования: val...
В Треугольнике Паскаля все числа на краю треугольника равны 1, и каждое число внутри треугольника...