Packages

class KafkaDataLoader extends StreamDataLoader

This is used to load Kafka data source into a DataFrame

Linear Supertypes
StreamDataLoader, DataLoader, Serializable, Serializable, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. KafkaDataLoader
  2. StreamDataLoader
  3. DataLoader
  4. Serializable
  5. Serializable
  6. AnyRef
  7. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new KafkaDataLoader(ss: SparkSession, input: KafkaEndpoint)

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. lazy val _ss: SparkSession
    Definition Classes
    StreamDataLoader
  5. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  6. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native()
  7. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  8. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  9. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  10. val format: String
  11. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  12. def getDFReader(kafkaOptions: Map[String, String]): DataStreamReader
    Definition Classes
    KafkaDataLoader → StreamDataLoader
  13. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  14. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  15. val kafkaSaslConfig: String
  16. def loadDataFrame(): DataFrame

    load the source data as dataframe.

    load the source data as dataframe.

    returns

    an dataframe

    Definition Classes
    KafkaDataLoader → DataLoader
  17. def loadSchema(): Schema

    get the schema of the source.

    get the schema of the source. It's only used in the deprecated DataSource.getDataSetAndSchema

    returns

    an Avro Schema

    Definition Classes
    KafkaDataLoader → DataLoader
  18. lazy val log: Logger
    Definition Classes
    DataLoader
    Annotations
    @transient()
  19. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  20. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  21. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  22. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  23. def toString(): String
    Definition Classes
    AnyRef → Any
  24. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  25. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  26. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native()

Inherited from StreamDataLoader

Inherited from DataLoader

Inherited from Serializable

Inherited from Serializable

Inherited from AnyRef

Inherited from Any

Ungrouped