Packages

c

org.checkita.dqf.config.jobconf.Schemas

RegistrySchemaConfig

final case class RegistrySchemaConfig(id: ID, description: Option[NonEmptyString], baseUrls: NonEmptyURISeq, schemaId: Option[Int], schemaSubject: Option[NonEmptyString], version: Option[Int], validateDefaults: Boolean = false, properties: Seq[SparkParam] = Seq.empty, headers: Seq[SparkParam] = Seq.empty, metadata: Seq[SparkParam] = Seq.empty, connectionTimeoutMs: Int = 60000, retryAttempts: Int = 3, retryIntervalMs: Int = 5000) extends SchemaConfig with Product with Serializable

Schema configuration that is used to read schema from Confluent Schema Registry.

id

Schema ID

description

Schema description

baseUrls

List of urls to connect to Schema Registry

schemaId

Schema ID to search in schema registry

schemaSubject

Schema subject to search in schema registry

version

Schema version (by default latest available version is fetched)

validateDefaults

Boolean flag enabling or disabling default values validation in Avro schema.

properties

List of additional connection properties: sequence of strings in format key=value.

headers

List of additional HTML headers: sequence of strings in format key=value.

metadata

List of metadata parameters specific to this schema

connectionTimeoutMs

Maximum time in milliseconds to wait for a response from the Schema Registry.

retryAttempts

Number of retry attempts in case of a failure.

retryIntervalMs

Delay in milliseconds between retry attempts.

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

Instance Constructors

  1. new RegistrySchemaConfig(id: ID, description: Option[NonEmptyString], baseUrls: NonEmptyURISeq, schemaId: Option[Int], schemaSubject: Option[NonEmptyString], version: Option[Int], validateDefaults: Boolean = false, properties: Seq[SparkParam] = Seq.empty, headers: Seq[SparkParam] = Seq.empty, metadata: Seq[SparkParam] = Seq.empty, connectionTimeoutMs: Int = 60000, retryAttempts: Int = 3, retryIntervalMs: Int = 5000)

    id

    Schema ID

    description

    Schema description

    baseUrls

    List of urls to connect to Schema Registry

    schemaId

    Schema ID to search in schema registry

    schemaSubject

    Schema subject to search in schema registry

    version

    Schema version (by default latest available version is fetched)

    validateDefaults

    Boolean flag enabling or disabling default values validation in Avro schema.

    properties

    List of additional connection properties: sequence of strings in format key=value.

    headers

    List of additional HTML headers: sequence of strings in format key=value.

    metadata

    List of metadata parameters specific to this schema

    connectionTimeoutMs

    Maximum time in milliseconds to wait for a response from the Schema Registry.

    retryAttempts

    Number of retry attempts in case of a failure.

    retryIntervalMs

    Delay in milliseconds between retry attempts.

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. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. val baseUrls: NonEmptyURISeq
  6. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native()
  7. val connectionTimeoutMs: Int
  8. val description: Option[NonEmptyString]
    Definition Classes
    RegistrySchemaConfig → JobConfigEntity
  9. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  10. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  11. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  12. val headers: Seq[SparkParam]
  13. val id: ID
    Definition Classes
    RegistrySchemaConfig → JobConfigEntity
  14. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  15. val metadata: Seq[SparkParam]
    Definition Classes
    RegistrySchemaConfig → JobConfigEntity
  16. val metadataString: Option[String]
    Definition Classes
    JobConfigEntity
  17. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  18. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  19. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  20. val properties: Seq[SparkParam]
  21. val retryAttempts: Int
  22. val retryIntervalMs: Int
  23. val schemaId: Option[Int]
  24. val schemaSubject: Option[NonEmptyString]
  25. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  26. val validateDefaults: Boolean
  27. val version: Option[Int]
  28. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  29. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  30. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native()

Inherited from Product

Inherited from Equals

Inherited from SchemaConfig

Inherited from JobConfigEntity

Inherited from Serializable

Inherited from Serializable

Inherited from AnyRef

Inherited from Any

Ungrouped