c

org.checkita.dqf.config.jobconf.Sources

StreamSourcesConfig

final case class StreamSourcesConfig(kafka: Seq[KafkaSourceConfig] = Seq.empty, file: Seq[FileSourceConfig] = Seq.empty) extends Product with Serializable

Data Quality job configuration section describing streams

kafka

Sequence of streams based on Kafka topics

file

Sequence of streams based on file sources

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

Instance Constructors

  1. new StreamSourcesConfig(kafka: Seq[KafkaSourceConfig] = Seq.empty, file: Seq[FileSourceConfig] = Seq.empty)

    kafka

    Sequence of streams based on Kafka topics

    file

    Sequence of streams based on file sources

Value Members

  1. val file: Seq[FileSourceConfig]
  2. def getAllSources: Seq[SourceConfig]
  3. val kafka: Seq[KafkaSourceConfig]