Я новичок в Spark и Scala и хочу оптимизировать запрос, который я написал для Spark, который очень...

Я пытаюсь использовать scala реализацию IForest https://github.com/titicaca/spark-iforest,, но...

У меня есть следующий фрагмент кода: package org.test.test.datahelper import org.apache.spark.rdd

Я настроил метрики jmx в приложении Streaming Stream.Ниже приведен код: val sc = spark.sparkContext...

Я пришел на C с языка высокого уровня Scala и задал вопрос.В Scala мы обычно обрабатываем ошибки /...

Я создал пример проекта с интерфейсом Java, который реализуется классом Scala, а затем классом Java...

У меня есть таблица Cassandra из нескольких столбцов, и я хочу обновить один из них (а также что...

Учитывая два набора данных S и R, оба со столбцом времени (t), как описано ниже: //snapshot with id...

Я создаю 'RDD' newData, получая данные из REST API, используя 'Scala'.Содержимое RDD является...

Учитывая набор данных S, цель состоит в том, чтобы создать набор данных E, где S и E определены...

У меня есть (большой ~ 1 миллион) фрейм данных Scala Spark со следующими данными: id,score 1,0.956...

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

В Spark я установил все параметры Оценщика, используя сеттеры.Теперь я хочу скопировать все эти...

Я новичок в Apache Spark (и Scala) и хочу применить простой SQL-запрос сразу после чтения CSV-файла...

Из искрового документа load(): DataFrame load(path: String): DataFrame load(paths: String*):...

Я попытался передать DataFrame, который оказался больше spark.sql.autoBroadcastJoinThreshold, и...

У меня есть регулярное выражение (.*)?start((?!(foo|boo)).)* end test.*. Что он делает, так это...

В Scala 2.10 мы можем определить новый метод r с помощью StringContext следующим образом: implicit...

Попытка использовать поток твиттера с помощью Apache Flink и flatMap его в классе дел, как только...

Если у вас есть родитель: abstract class Parent { def something(arg: ???): Parent = ??? } и class...

Мне нужно выполнить обработку строк данных с сохранением состояния.Для этого мне нужно создать...

Я недавно начал использовать scala spark, в частности, я пытаюсь использовать GraphX ​​для создания...

Я пытаюсь объединить 2 DataFrames в Spark Framework. val final = mf1.join(mf2...

Мне нужна ваша помощь, потому что я новичок в Spark Framework. У меня есть папка с большим...

У меня есть скрипт, который я хочу запустить, чтобы просмотреть таблицу mysql, содержащую около 4M...