В Scala действительно ли возможно получить строковое представление типа во времени выполнения? Я пытаюсь сделать что-то вдоль этих строк: определение printTheNameOfThisType [T] () = {println (T.toString)}
нам дан класс связанного списка, и нам нужно создать функцию в этом классе, которая принимает функцию в качестве параметра и вызывает эту функцию в каждом узле списка. мы можем сделать это рекурсивно или ...
Предположим, у меня есть класс case, определенный следующим образом: case case User (name: String, age: Int) Я хотел бы переопределить его метод toString следующим образом: case class User (name: String, age: Int) {...
У меня есть следующая функция, которая выравнивает последовательность отображений строки, чтобы удвоить. Как я могу сделать тип строки для двойного универсального? val flattenSeqOfMaps = udf {values: Seq [Map [String, Double]] = > ...
Как я могу определить перечисление с конкретными числовыми значениями в Scala и иметь возможность получить список значений из типа? Если я определяю перечисление, используя тип перечисления следующим образом: объект MyEnum расширяется ...
Я получаю следующую ошибку при запуске следующей команды через spark-shell. Я также добавил банку maprfs в свой bash_profile, как показано ниже. Я попробовал большинство решений из аналогичных постов, ...
У меня есть действующий HTTP-запрос Akka HttpRequest, и я хочу добавить к нему два заголовка. val req: HttpRequest = ??? val hs: Seq [HttpHeader] = Seq (RawHeader ("a", "b")) req.addHeaders (hs) Ожидаемый: новый ...
Я хочу использовать ujson из библиотеки upickle для извлечения необязательной строки из документа json. В некоторых документах поле json существует, в других нет. При доступе к полю и поле не ...
Я новичок в Scala, пытаюсь использовать Spark для чтения из базы данных mysql. Я сталкиваюсь с исключением из класса, что бы я ни делал. Я пытался подключиться без Spark, используя Squeryl, Scalike и т. Д. Всегда ...
У меня есть датафрейм: | ID | TIMESTAMP | ЦЕННОСТЬ | 1 15:00:01 3 1 17:04:02 2 Я хочу добавить новую запись с помощью Spark-Scala раньше с тем же временем минус 1 секунда, когда значение равно 2. ...
В моем проекте у меня есть следующее созвездие: черта F черта X [A & lt ;: F] def test (x: X [_]): X [_ & lt ;: F] = x У черты X есть параметр типа с верхняя граница F. Насколько я понимаю, ...
Следующий код и, следовательно, вопрос о производительности - представьте, конечно, в масштабе: import org.apache.spark.sql.types.StructType val df = sc.parallelize (Seq (("r1", 1, 1), ("r2 ", 6, 4), (" ...
У меня есть датафрейм, который содержит последовательность строк. Я хочу перебирать строки по очереди без изменения порядка. Я попытался ниже код. & GT Scala; val df = Seq (| (0, "Load", "employeeview", "...
Я создал флягу приложения Scala, используя maven-assembly-plugin. Теперь, когда я выполняю jar с java -jar path \ to \ jar \ myapp.jar, он выдает следующую ошибку: Исключение в потоке "main" Исключение ...
Я пытаюсь использовать Flow как http-клиент Akka, и у меня возникли проблемы с получением Seq объектов класса case из массива json в ответе http. HTTP-ответ: {"bars": [], "foos": [{"id": ...
Есть несколько вопросов о том, как получить количество разделов n RDD и / или DataFrame: ответы неизменно: rdd.getNumPartitions или df.rdd.getNumPartitions ...
Я использую аккумулятор в функции сгиба. Я хотел бы изменить значение аккумулятора. Моя функция выглядит примерно так: public Tuple2 < String, Long > раза (Tuple2 & л; String, ...
Следующий (странный) код является частью действительной программы Scala: / * simple-lang s0.3.35 * / block main () Для a = от 0 до 50 {display ("Hello World at" + a + "")} // конец простой-подобной программе ...
Скажем, у меня есть список кортежей: диапазоны значений val = List ((1,4), (5,8), (9,10)) и список чисел val nums = List (2,2,3,7,8) , 9) Я хочу сделать карту из кортежа в диапазонах, сколько раз данное число ...
Я не понимаю, как я могу объединить 2 таких DataFrame друг с другом. Первый DataFrame хранит информацию о времени запроса пользователя в сервисный центр. Давайте назовем этот DataFrame df1: + ----------- + --...
Узел черты [N <: Узел [N]] {self: N = > } trait A расширяет Node [A] trait B {def list: List [Node [_]] def as: List [A] = list.collect {case x: A = > x}} У меня проблемы с использованием self ...
У меня есть много очень больших json-объектов, которые я возвращаю из Play Framework со Scala. В большинстве случаев пользователю не нужны все данные в объектах, только несколько полей. Поэтому я хочу пройти по путям, которые я ...
У меня есть фрейм данных pyspark со следующим форматом времени 20190111-08: 15: 45.275753. Я хочу преобразовать это в формат отметки времени, сохраняя детализацию микросекунды. Тем не менее, кажется, что это ...
У меня есть файл докера с: ИЗ amazonlinux: 2017.03 ENV SCALA_VERSION 2.11.8 ENV SBT_VERSION 0.13.13 # Установить Java8 RUN yum install -y java-1.8.0-openjdk-devel # Установить Scala и SBT RUN yum ...
Возьмите следующий код: класс A (val i: Int) case класс B (str: String) расширяет A (1) val b = B («test») В моем сценарии я ограничен определением B, которое нельзя изменить , Я также хочу ...
Итак, у меня есть класс, который предполагает использование универсального типа, но этот тип должен иметь определенные характеристики. Он должен иметь определенный метод вычисления. Он должен иметь конструктор, который принимает Seq [Double] ...
У меня вопрос ниже файла JSON, где он содержит данные структурного типа для column3. Я могу извлечь строки, но не могу найти минимальное значение column3. Где column3 содержит динамический ...
У меня есть две строки в Scala Вход 1: «a, c, e, g, i, k» Вход 2: «b, d, f, h, j, l» Как мне соединить две строки в Scala? Требуемый вывод = "ab, cd, ef, gh, ij, kl" Я пробовал что-то вроде: var ...