Я читаю книгу FP for Mortals, в которой есть следующая строка: Может быть только одна реализация...
Я только что скачал Scala и пытался использовать IntelliJ IDEA CE, и у меня возникли проблемы с...
Теперь я использую инкрементную контрольную точку в Flink с RocksDB, работающую в среде контейнера....
У меня есть файл CSV, содержащий несколько слов. Всего № слов в файле csv не будет превышать 50 тыс
У нас есть потоковое приложение, реализованное с использованием Spark Structured Streaming.который...
Я тестирую некоторый код, показанный ниже, который в основном определяет несколько неявных val s,...
Я пытаюсь записать файл в локальный FileSystem, используя библиотеку FileSystem org.apache.hadoop
когда я запускаю все эти 3 команды в оболочке / терминале Unix, все они работают нормально,...
У меня есть проект Scala, который я встроил в Fat JAR.Сегодня мне нужно было добавить несколько...
В настоящее время я работаю над заданием Spark Structured Streaming, и кажется, что на каждом...
Проблема: существует тема JMS, и у меня есть следующие сведения о соединении: URL: xyz Фабрика...
Я попытался разделить фрейм данных Spark по столбцу отметки времени update_database_time и записать...
Я пытаюсь внедрить ehcache через Play Framework.Я внедряю его в сопутствующий класс, но этот класс...
Я должен использовать foldByKey в Списке, чтобы найти максимальную цену каждого предмета. Я...
Я новичок в Скале.У меня есть функция, которая принимает строку и основана на различных логиках,...
Я пытаюсь показать различия между двумя различными наборами данных и эффективно. Мне нужно...
У меня есть СДР со следующим количеством элементов в каждом разделе (общее количество разделов val...
Я изучал и реализовывал функции spark mlib и не могу загрузить сохраненную модель lda. Я работаю с...
Попытка сделать простое преобразование с использованием unix_timestamp ведет себя иначе, чем Spark...
У меня есть три узла искрового кластера и три узла воспламеняющего кластера. Версия Spark: 2.3...
У меня есть такой фрейм данных, как scala> testDf.show()...
В настоящее время я перемещаю данные из базы данных в другую. Для этого я написал Scala-программу,...
Я пытаюсь использовать класс org.apache.hadoop.tools.DistCp, чтобы скопировать некоторые файлы в...
Я столкнулся с ошибкой, вызванной оконной функцией. Когда я применяю этот сценарий и сохраняю...
Я пытаюсь преобразовать набор данных искры в итератор, чтобы записать набор данных в influenxdb