Результаты поиска по запросу "scala"

1 ответ

, как показано ниже:

вая приведенный ниже код, как мне добавить столбец подсчета? (например, .count ("*"). as ("count")) Окончательный вывод будет выглядеть примерно так: +---+------+------+-----------------------------+------ | id|sum(d)|max(b)|concat_ws(,, ...

1 ответ

 который, по-видимому, остается открытым.

бую следующее: class ClientActor (stockActor: ActorSelection, paymentsActor: ActorSelection) extends PersistentActor with AtLeastOnceDelivery with akka.actor.ActorLogging with RequiresMessageQueue[akka.custom.CustomMailbox]{ //actor ...

5 ответов

Обратная функция в Scala

ТОП публикаций

2 ответа

с простым sql это невозможно

ел бы отсортировать DataFrame на основе столбца с моим собственным компаратором. Это можно сделать в Spark SQL? Например, предположим, что у меня есть DataFrame, зарегистрированный как таблица «MyTable» со столбцом «Day», тип которого ...

0 ответов

Мой код для файла данных newfile1.csv и json file (схема) работает отлично, я просто пропускаю последний бит кода, где я могу динамически распределять заголовки и типы данных из файла json в файл csv.

ваша помощь в определении динамической схемы с полями и типами данных из файла JSon входных метаданных для данных в файле csv в Databricks. Я хочу определить схему, которая отображает имя поля с соответствующим типом данных из JSON для ввода ...

1 ответ

 абсолютно разумно

приведен мой случай использования Я используюкоты [https://typelevel.org/cats/]для проверки моего конфига. Мой конфигурационный файл находится в формате json.Я десериализовал мой конфигурационный файл в мой класс делConfig с помощьюподъемная ...

3 ответа

Можете ли вы попробовать это, основываясь на том, что вы сказали, это разбор UTC времени, так что у меня есть это в качестве образца.

у, чтобы UNIX Epoch Time (Posix Time, Unix Time) строки в некоторыхpatternстрока в обычном формате (поэтому UTC). Пожалуйста, используйте Java 8, а не Joda или старую Java. (За миллисекунды смотритеКак преобразовать строку даты и времени в ...

0 ответов

({Exec Stream Pumper} RemoteInterpreterManagedProcess.java [processLine]: 298) - Когда это было неожиданно в это время. ({Exec Default Executor} RemoteInterpreterManagedProcess.java [onProcessFailed]: 250) - Сбой процесса интерпретатора {} org.apache.commons.exec.ExecuteException: процесс завершился с ошибкой: 255 (значение выхода: 255) в org.apache.commons .exec.DefaultExecutor.executeInternal (DefaultExecutor.java:404) ({pool-2-thread-2} Job.java [run]: 190) - Задание не выполнено

аюсь настроить zeppelin-0.8.0 на моей операционной системе windos 8 r2. У меня уже есть спарк на моей консоли, т.е. SPARK_HOME и JAVA_HOME, HADOOP_HOME настроены и работают нормально. Но в то время как я пытаюсь выполнить printl ("привет") в ...

1 ответ

Поэтому я думаю, что лучше всего использовать одно из двух решений выше.

людаю интересное поведение. У меня есть существующий проект, в котором я создал папку и создалScala Сценарий в этой папке. Чтобы запустить это я сделал Напишите скрипт Scala, например, MyScript.scalaВ меню выберите: Run -> Edit Configurations ...

1 ответ

Мне пришлось добавить эту строку непосредственно перед вызовом опроса, кажется, что теперь все работает: kafkaConsumer.seekToBeginning (kafkaConsumer.assignment ())

денный ниже клиент Scala kafka не возвращает никаких событий изpoll вызов. Тем не менее, тема правильная, и я вижу события, отправляемые в тему с помощью консоли: /opt/kafka_2.11-0.10.1.0/bin/kafka-console-consumer.sh ...