def main(args: Array[String]) { val session = SparkSession.builder()

Я использую Spark Streaming 1.6 для чтения сообщений из Tibco, и я выполняю некоторые...

Я использую огурец со скалой и использую баночки ниже cucumber-junit-1.2.0.jar cucumber-core-1.2.0

Я предположил так (как указано @ https://docs.oracle.com/javase/7/docs/api/java/util/zip/Deflater

Я использую Spark 2.4.0 с Scala 2.11 на 4 процессорных ядрах и 8 потоках. Я написал следующее...

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

Я использую игровую инфраструктуру для создания объекта json, после этого я должен сохранить эти...

scala> val a = jsonMap.get("L2_ID") a: Option[Any] = Some(List(24493, 22774, 23609,...

Я хотел бы определить State, который создает конкретный подтип черты, согласно decodeFoo: sealed...

Я не уверен, как это сделать, то, что я пытаюсь сделать, это: output1 <- step1(...) output2...

Я запускаю этот код в spark-shell, spark 2.3.0: val lineitem=spark.read

Я заметил, что большинство (или все) черты Spark ML, расширяющие Params, подобно HasRegParam или...

Я читаю документацию Doobie и пытаюсь выполнить простое получение или создание внутри транзакции.Я...

У меня есть IO[Throwable, Seq[IO[Nothing, String]]], и я хотел бы превратить его в IO[Throwable,...

Это может быть открытым вопросом, но я начну с языка scala.Scala поддерживает асинхронное...

У меня есть массив строк: EmpArray = Array(emp_id,emp_name,city) Вместо того, чтобы вручную...

В spark есть конфигурация spark.sql.parquet.output.committer.class.Требуется тот тип коммиттера,...

Я пытаюсь создать макрос, чтобы получить список значений val для определенного класса дел. object...

В Scala, я вижу, есть 2 способа создания контекста spark: Создание sparkContext в начале выполнения...

Я определил следующий тип псевдонима: type PartiallyAppliedEither[A] = Either[String, A] Я вижу,...

Я пытаюсь использовать потоковую передачу по искру при чтении данных из одного расположения HDFS в...

Учитывая appplication.config, который содержит фиксированные значения и необязательные перезаписи,...

Я следую этому руководству для развертывания контракта https://www.youtube.com/watch

Я пытаюсь найти право libraryDependencies из sbt .Моя версия Scala scalaVersion := "2.12

Я обновил DSE 5.1 ​​до DSE 6.7.Мы используем аналитический узел с поддержкой spark для заданий...