Это должно загрузить учебный набор данных. val trainData = new...
У меня есть этот исходный DF и некоторые переменные: val sourceDF = Seq( ("123",...
Я настраиваю пакет Spark, целью которого является фильтрация некоторых полей, которые необходимо...
Я использую библиотеку Spotify Scio для написания конвейеров Apache Beam в Scala. Я хочу рекурсивно...
Из того, что я вижу, каждый драйвер занимает как минимум 1 процессор. Поэтому я хотел бы оставить...
Slick поднимает нормальных типов скалы, например, Rep[Long], но это означает, что вы не можете...
Код здесь: https://github
Я создаю потоковую аналитику, для которой требуется ~ 50 ГБ исходного состояния в памяти для одной...
/ Что я пытаюсь / Я хочу выполнить преобразование Spark UDF для нескольких блоков HDFS, содержащих...
Я испытываю очень странную ошибку при вводе кода ниже. Цель этого кода - создать класс, который...
У меня есть некоторый код, подобный этому import java.time.Instant val tstamp = 1546344620.1877 val...
Я пытаюсь реализовать функцию, которая загружает около 40 миллионов записей в базу данных MySQL,...
Многие виды оптики имеют представление Ван Ларховена. Например, Lens типа Lens s t a b может быть...
У меня есть выражение соответствия, подобное этому: i match { case x if x == 0 ⇒ romanNumeral case...
У меня было рабочее игровое приложение. Я попытался включить поддержку эволюции базы данных в...
Scala: обнаружение и извлечение чего-то более конкретного из коллекции Any значений. (Мотивация:...
Предположим, у меня есть следующие данные XML: <students>...
Я пытаюсь использовать Sqoop для экспорта данных из моего озера данных в таблицу, которую я...
Я пытаюсь повторить учебник TicTacToe для React с использованием Slinky . В какой-то момент игра...
Я только что столкнулся с очень странным поведением в модификациях стека Scala. Давайте посмотрим...
Я пытаюсь реализовать преобразователь Stream, описанный в разделе «Функциональное программирование...
У меня есть два кода Scala - MyMain.scala и MyFunction.scala, построенные отдельно, а встроенная...
Это код для создания единственного сообщения для Кафки, указанный в документе https://doc.akka
Я использую скрипт для CDC Merge в потоковой передаче. Я хочу передать значения столбца в...
У меня есть файл со следующими данными ####$ cat products.csv 1,tv,sony,hd,699 2,tv,sony,uhd,799 3...