Итак, я пытаюсь создать чрезвычайно простую записную книжку spark, используя блоки данных Azure, и...
У меня есть кадр данных, как показано ниже: ---------------------+------------------------ text |...
Я новичок в тестировании фреймворков, очень мало знаю о тестировании, но я хочу написать здесь...
Я пытаюсь настроить распределенный кеш, используя Apache Ignite с Scala. После настройки кэша я...
Я выполнил код Scala в IntelliJ IDEA для spark.streaming.kafka, где я использую scala версии 2.11,...
Моя цель - прочитать несколько строк из большого каталога hdfs, я использую spark2.2. Этот каталог...
Я использую Zeppelin, а df - это DataFrame искры.Я пытаюсь отфильтровать NaN, которые могут...
Эта проблема специфична для синтаксиса сопоставления с образцом в Scala.Допустим, у меня есть...
Я обнаружил очень странную проблему в Scala.Я пытался получить последний день прошлого месяца
Я пытаюсь создать пару ключ-значение из текстового ввода, где ключ будет String, а значение будет...
Мой серверный код получит следующее JSON { "signin-info":{ "email" :...
У меня есть CSV-файл из двух строковых столбцов (термин, код).Столбец кода имеет специальный формат...
У меня есть датафрейм df1, как показано ниже со схемой: scala> df1.printSchema root |--...
Мне нужно найти «Подтвердить» и нажать. <div class="sidebar-element-confirm">...
Я работаю с zeppelin в hdp 2.6. Я хочу прочитать коллекцию из mongodb, используя интерпретатор...
Я хочу ввести данные телеметрии, и на выходе получается многослойный вложенный файл JSON. Меня...
Я учусь делать юнит-тесты с Scatatest, но у меня есть несколько основных вопросов, так как я изучаю...
Я пытаюсь сделать цепочку неявных преобразований из Symbol -> A -> Option [A]. Но не удается...
Я использую 'Hive on Spark' с hive v2.3.3, а Spark v2.0.0 работает в автономном режиме с искрой без...
Я пытаюсь создать производителя Kafka, связанного с потребителем Spark. Производитель работает...
Я пытаюсь смоделировать универсальный интерфейс Java с перегруженным методом с различным...
Я новичок в Spark, и я хотел бы прочитать CSV-файл на Dataframe. Spark 1.3.0 / Scala 2.3.0 Это то,...
Нужна помощь в сортировке по ключу после вывода groupByKey: val skuRDD2:RDD[(String...
У меня есть следующий код: - case class event(imei: String, date: String, gpsdt: String,dt: String...
У меня небольшая проблема с созданием scala.scalajs.js.ThisFunction3 в следующем примере (с...