Это моя схема root |-- tags: array (nullable = true) | |-- element: array (containsNull = true) | |...

Это снимок, который делается после добавления столбца, но не содержит сумму всех значений одного...

В Scala Spark есть несколько методов, которые могут привести к разделению / перераспределению...

Весь мой интерес к PostgreSQL обусловлен его мощной системой ACL. Чтобы получить доступ к данным в...

У меня есть файл Json, который выглядит следующим образом { "tags": [ { "1":...

Я пытаюсь создать новый фрейм искровых данных, используя скалярную основу для вложенного JSON. Я...

Я пытаюсь преобразовать общий ввод в java.sqlTimestamp, используя Java 8 time API,...

Я пытаюсь проанализировать время смещения, используя Java 8 DateTimeFormatter. Я живу в EST время,...

Я думаю, что приведенный ниже код лучше всего описывает мою проблему: import scala.collection

У меня есть датафрейм, который представляет график.Он имеет следующую структуру: a, b b, c b, d...

Я пытаюсь настроить zeppelin-0.8.0 на моей операционной системе windos 8 r2.У меня уже есть спарк...

Я пытаюсь перейти на Spark 2.2 с версии Spark 1.6. Существующие модульные тесты зависят от...

У меня есть типизированная запечатанная черта sealed trait PropertyValue[T <: Property] Мне...

Я определил приложение Spark для потребителей и производителей Kafka. Однако сообщения не попадают...

У меня есть датафрейм df1. Я планирую разделить его на два кадра данных - df2 и df3. Существующий...

Допустим, у меня есть n значений в Scala с именем v 1 , v 2 ,. .., v i , ..., v n типов T ij ,...

Я использую библиотеку lift json в scala, чтобы десериализовать некоторые конфигурации json для...

У меня есть программа структурированного потокового вещания на основе scala, которая должна...

Недавно мы обновили пакет сборки CF (Cloud Foundry) с cflinuxfs2 до cflinuxfs3.Это происходит с...

Моя программа spark не работает, и ни планировщик, ни драйвер, ни исполнители не предоставляют...

Я создаю HTTP-пост для регистрации источника данных в каталоге данных Azure. Код генерирует...

Scala затрудняет мне создание регулярного выражения, которое легко работает с "текстовым...

Я ищу решение для добавления значения временной метки kafka в мою схему структурированной потоковой...

Учитывая case class: case class ScoringSummary(MatchMethod: String="", TP: Double=0, FP:...

Я пытаюсь создать trait и abstract class для подтипа по сообщениям (в среде воспроизведения Akka),...