3
ответа

Получение строкового представления типа во времени выполнения в Scala

В Scala действительно ли возможно получить строковое представление типа во времени выполнения? Я пытаюсь сделать что-то вдоль этих строк: определение printTheNameOfThisType [T] () = {println (T.toString)}
вопрос задан: 10 October 2008 07:04
2
ответа

Как преобразовать scala. Список к java.util. Список?

Как преобразовать scala Scala. Список в java.util Java. Список?
вопрос задан: 31 March 2019 20:01
2
ответа

создание функции, которая принимает функцию в качестве параметра и вызывает ее для каждого элемента связанного списка

нам дан класс связанного списка, и нам нужно создать функцию в этом классе, которая принимает функцию в качестве параметра и вызывает эту функцию в каждом узле списка. мы можем сделать это рекурсивно или ...
вопрос задан: 28 March 2019 00:46
2
ответа

Scala: абстракция функции toString для классов case

Предположим, у меня есть класс case, определенный следующим образом: case case User (name: String, age: Int) Я хотел бы переопределить его метод toString следующим образом: case class User (name: String, age: Int) {...
вопрос задан: 21 March 2019 10:05
2
ответа

Свести последовательность карт для отображения с использованием полиморфизма типов в Scala, Spark UDF

У меня есть следующая функция, которая выравнивает последовательность отображений строки, чтобы удвоить. Как я могу сделать тип строки для двойного универсального? val flattenSeqOfMaps = udf {values: Seq [Map [String, Double]] = > ...
вопрос задан: 19 March 2019 17:35
2
ответа

Как определить перечисление с конкретными числовыми значениями в Scala

Как я могу определить перечисление с конкретными числовыми значениями в Scala и иметь возможность получить список значений из типа? Если я определяю перечисление, используя тип перечисления следующим образом: объект MyEnum расширяется ...
вопрос задан: 19 March 2019 12:06
2
ответа

java.io.IOException: нет файловой системы для схемы: maprfs. Добавление jar maprfs в bash_profile не работает

Я получаю следующую ошибку при запуске следующей команды через spark-shell. Я также добавил банку maprfs в свой bash_profile, как показано ниже. Я попробовал большинство решений из аналогичных постов, ...
вопрос задан: 18 March 2019 23:09
2
ответа

Добавление заголовков в Akka HTTP HttpRequest

У меня есть действующий HTTP-запрос Akka HttpRequest, и я хочу добавить к нему два заголовка. val req: HttpRequest = ??? val hs: Seq [HttpHeader] = Seq (RawHeader ("a", "b")) req.addHeaders (hs) Ожидаемый: новый ...
вопрос задан: 18 March 2019 10:25
2
ответа

Работа с необязательным полем с lihaoyi ujson

Я хочу использовать ujson из библиотеки upickle для извлечения необязательной строки из документа json. В некоторых документах поле json существует, в других нет. При доступе к полю и поле не ...
вопрос задан: 11 March 2019 15:48
2
ответа

Драйвер MySql не найден для программы Scala

Я новичок в Scala, пытаюсь использовать Spark для чтения из базы данных mysql. Я сталкиваюсь с исключением из класса, что бы я ни делал. Я пытался подключиться без Spark, используя Squeryl, Scalike и т. Д. Всегда ...
вопрос задан: 4 March 2019 14:47
2
ответа

Добавить новую запись перед другой в Spark

У меня есть датафрейм: | ID | TIMESTAMP | ЦЕННОСТЬ | 1 15:00:01 3 1 17:04:02 2 Я хочу добавить новую запись с помощью Spark-Scala раньше с тем же временем минус 1 секунда, когда значение равно 2. ...
вопрос задан: 4 March 2019 12:26
2
ответа

Ограничение параметра типа не учитывается при использовании универсального типа с неограниченным подстановочным знаком

В моем проекте у меня есть следующее созвездие: черта F черта X [A & lt ;: F] def test (x: X [_]): X [_ & lt ;: F] = x У черты X есть параметр типа с верхняя граница F. Насколько я понимаю, ...
вопрос задан: 2 March 2019 08:34
2
ответа

val против def производительности на Spark Dataframe

Следующий код и, следовательно, вопрос о производительности - представьте, конечно, в масштабе: import org.apache.spark.sql.types.StructType val df = sc.parallelize (Seq (("r1", 1, 1), ("r2 ", 6, 4), (" ...
вопрос задан: 25 February 2019 02:30
2
ответа

Как читать кадр данных построчно, не меняя порядок? в Spark Scala

У меня есть датафрейм, который содержит последовательность строк. Я хочу перебирать строки по очереди без изменения порядка. Я попытался ниже код. & GT Scala; val df = Seq (| (0, "Load", "employeeview", "...
вопрос задан: 22 February 2019 11:44
2
ответа

Ошибка Scala: java.sql.SQLException: не найден подходящий драйвер для jdbc: calcite:

Я создал флягу приложения Scala, используя maven-assembly-plugin. Теперь, когда я выполняю jar с java -jar path \ to \ jar \ myapp.jar, он выдает следующую ошибку: Исключение в потоке "main" Исключение ...
вопрос задан: 24 January 2019 11:03
2
ответа

Получить Seq сущностей из ответа akka http на основе массива json

Я пытаюсь использовать Flow как http-клиент Akka, и у меня возникли проблемы с получением Seq объектов класса case из массива json в ответе http. HTTP-ответ: {"bars": [], "foos": [{"id": ...
вопрос задан: 20 January 2019 16:23
2
ответа

Как проверить количество разделов в Spark DataFrame, не неся стоимости .rdd

Есть несколько вопросов о том, как получить количество разделов n RDD и / или DataFrame: ответы неизменно: rdd.getNumPartitions или df.rdd.getNumPartitions ...
вопрос задан: 19 January 2019 20:15
2
ответа

Как изменить значение для Tuple2 в Java

Я использую аккумулятор в функции сгиба. Я хотел бы изменить значение аккумулятора. Моя функция выглядит примерно так: public Tuple2 < String, Long > раза (Tuple2 & л; String, ...
вопрос задан: 19 January 2019 14:49
2
ответа

Может & ldquo; независимые от языка компиляторы & rdquo; существовать?

Следующий (странный) код является частью действительной программы Scala: / * simple-lang s0.3.35 * / block main () Для a = от 0 до 50 {display ("Hello World at" + a + "")} // конец простой-подобной программе ...
вопрос задан: 19 January 2019 12:45
2
ответа

Подсчитайте, сколько раз числа из списка встречаются в списке интервалов кортежей в Scala

Скажем, у меня есть список кортежей: диапазоны значений val = List ((1,4), (5,8), (9,10)) и список чисел val nums = List (2,2,3,7,8) , 9) Я хочу сделать карту из кортежа в диапазонах, сколько раз данное число ...
вопрос задан: 18 January 2019 14:19
2
ответа

Как объединить два DataFrame с объединенными столбцами в Spark?

Я не понимаю, как я могу объединить 2 таких DataFrame друг с другом. Первый DataFrame хранит информацию о времени запроса пользователя в сервисный центр. Давайте назовем этот DataFrame df1: + ----------- + --...
вопрос задан: 18 January 2019 13:34
2
ответа

Как рассчитать среднее значение в одной группе?

У меня есть такой фрейм данных: + ----- + --------- + --------- + | Категория | Amt | цена | + ----- + --------- + --------- + | | 100 | 1 | | | 180 | 2 | | | 250 | 3 | | ...
вопрос задан: 18 January 2019 09:20
2
ответа

Коллекция объектов с саморекурсивным типом в scala

Узел черты [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 ...
вопрос задан: 18 January 2019 07:16
2
ответа

Play framework (Scala) - Получение подмножества json, содержащего массивы

У меня есть много очень больших json-объектов, которые я возвращаю из Play Framework со Scala. В большинстве случаев пользователю не нужны все данные в объектах, только несколько полей. Поэтому я хочу пройти по путям, которые я ...
вопрос задан: 17 January 2019 12:32
2
ответа

Работа с микросекундными метками времени в PySpark

У меня есть фрейм данных pyspark со следующим форматом времени 20190111-08: 15: 45.275753. Я хочу преобразовать это в формат отметки времени, сохраняя детализацию микросекунды. Тем не менее, кажется, что это ...
вопрос задан: 17 January 2019 10:49
2
ответа

Как ускорить сборку sbt scala в докере?

У меня есть файл докера с: ИЗ 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 ...
вопрос задан: 17 January 2019 04:43
2
ответа

Как изменить атрибут базового класса класса дела

Возьмите следующий код: класс A (val i: Int) case класс B (str: String) расширяет A (1) val b = B («test») В моем сценарии я ограничен определением B, которое нельзя изменить , Я также хочу ...
вопрос задан: 16 January 2019 18:07
2
ответа

Можно ли указать, что тип будет иметь определенные параметры в своем конструкторе? Scala

Итак, у меня есть класс, который предполагает использование универсального типа, но этот тип должен иметь определенные характеристики. Он должен иметь определенный метод вычисления. Он должен иметь конструктор, который принимает Seq [Double] ...
вопрос задан: 16 January 2019 14:41
2
ответа

минимальное значение столбца типа структуры в кадре данных

У меня вопрос ниже файла JSON, где он содержит данные структурного типа для column3. Я могу извлечь строки, но не могу найти минимальное значение column3. Где column3 содержит динамический ...
вопрос задан: 16 January 2019 12:02
2
ответа

Соедините две строки в Scala с однозначным отображением

У меня есть две строки в Scala Вход 1: «a, c, e, g, i, k» Вход 2: «b, d, f, h, j, l» Как мне соединить две строки в Scala? Требуемый вывод = "ab, cd, ef, gh, ij, kl" Я пробовал что-то вроде: var ...
вопрос задан: 16 January 2019 04:28