Packages

  • package root
    Definition Classes
    root
  • package org
    Definition Classes
    root
  • package checkita
    Definition Classes
    org
  • package dqf
    Definition Classes
    checkita
  • package connections
    Definition Classes
    dqf
  • package schemaregistry
    Definition Classes
    connections
  • case class SchemaRegistryConnection(config: RegistrySchemaConfig) extends Product with Serializable

    Schema registry connection used to obtain AVRO schemas from Confluent Kafka Schema Registry.

    Schema registry connection used to obtain AVRO schemas from Confluent Kafka Schema Registry. given either their ID or a subject. Also possible to fetch schema with explicit version. By default latest version is obtained.

    config

    Registry-kind schema configuration

    Definition Classes
    schemaregistry
    Note

    At this point only AVRO schemas are supported.

    ,

    This connection is not used to read any data, therefore, it does not extend DQConnection.

  • MapOps

implicit class MapOps extends AnyRef

Implicit conversion used to wrap map of properties into an option.

Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. MapOps
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new MapOps(value: Map[String, String])

    value

    Properties to wrap into an option.

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. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native()
  6. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  7. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  8. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  9. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  10. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  11. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  12. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  13. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  14. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  15. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  16. def toOptionMap: Option[Map[String, String]]
  17. def toString(): String
    Definition Classes
    AnyRef → Any
  18. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  19. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  20. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native()

Inherited from AnyRef

Inherited from Any

Ungrouped