В какой пакет входит Spark Streaming readStream? - PullRequest
Новая
       24

В какой пакет входит Spark Streaming readStream?

0 голосов
/ 04 июля 2019

Я пытаюсь создать потоковое приложение Spark, которое читает из Kafka.

Я смотрел на руководство здесь https://spark.apache.org/docs/2.4.0/structured-streaming-kafka-integration.html

Но когда я создаю свое собственное приложение, даже с: 

import org.apache.spark
import org.apache.spark.streaming._

import org.apache.spark.SparkConf
import org.apache.spark.sql._
import org.apache.spark.sql.kafka010
import org.apache.spark.sql.types.{DataTypes, StructType}

Я получаю: 

Error:(24, 8) object readStream is not a member of package org.apache.spark
possible cause: maybe a semicolon is missing before `object readStream'?
  .readStream

Какой импорт мне не хватает?

...