Результаты поиска по запросу "scala"
, как показано ниже:
вая приведенный ниже код, как мне добавить столбец подсчета? (например, .count ("*"). as ("count")) Окончательный вывод будет выглядеть примерно так: +---+------+------+-----------------------------+------ | id|sum(d)|max(b)|concat_ws(,, ...
который, по-видимому, остается открытым.
бую следующее: class ClientActor (stockActor: ActorSelection, paymentsActor: ActorSelection) extends PersistentActor with AtLeastOnceDelivery with akka.actor.ActorLogging with RequiresMessageQueue[akka.custom.CustomMailbox]{ //actor ...
с простым sql это невозможно
ел бы отсортировать DataFrame на основе столбца с моим собственным компаратором. Это можно сделать в Spark SQL? Например, предположим, что у меня есть DataFrame, зарегистрированный как таблица «MyTable» со столбцом «Day», тип которого ...
Мой код для файла данных newfile1.csv и json file (схема) работает отлично, я просто пропускаю последний бит кода, где я могу динамически распределять заголовки и типы данных из файла json в файл csv.
ваша помощь в определении динамической схемы с полями и типами данных из файла JSon входных метаданных для данных в файле csv в Databricks. Я хочу определить схему, которая отображает имя поля с соответствующим типом данных из JSON для ввода ...
абсолютно разумно
приведен мой случай использования Я используюкоты [https://typelevel.org/cats/]для проверки моего конфига. Мой конфигурационный файл находится в формате json.Я десериализовал мой конфигурационный файл в мой класс делConfig с помощьюподъемная ...
Можете ли вы попробовать это, основываясь на том, что вы сказали, это разбор UTC времени, так что у меня есть это в качестве образца.
у, чтобы UNIX Epoch Time (Posix Time, Unix Time) строки в некоторыхpatternстрока в обычном формате (поэтому UTC). Пожалуйста, используйте Java 8, а не Joda или старую Java. (За миллисекунды смотритеКак преобразовать строку даты и времени в ...
({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 ("привет") в ...
Поэтому я думаю, что лучше всего использовать одно из двух решений выше.
людаю интересное поведение. У меня есть существующий проект, в котором я создал папку и создалScala Сценарий в этой папке. Чтобы запустить это я сделал Напишите скрипт Scala, например, MyScript.scalaВ меню выберите: Run -> Edit Configurations ...
Мне пришлось добавить эту строку непосредственно перед вызовом опроса, кажется, что теперь все работает: kafkaConsumer.seekToBeginning (kafkaConsumer.assignment ())
денный ниже клиент Scala kafka не возвращает никаких событий изpoll вызов. Тем не менее, тема правильная, и я вижу события, отправляемые в тему с помощью консоли: /opt/kafka_2.11-0.10.1.0/bin/kafka-console-consumer.sh ...