c

org.checkita.dqf.config.jobconf.Connections

IcebergConnectionConfig

final case class IcebergConnectionConfig(id: ID, description: Option[NonEmptyString], catalogName: NonEmptyString, catalogType: NonEmptyString, warehouse: Option[URI], catalogUri: Option[URI], parameters: Seq[SparkParam] = Seq.empty, metadata: Seq[SparkParam] = Seq.empty) extends ConnectionConfig with Product with Serializable

Connection configuration for Apache Iceberg tables

id

Connection Id

description

Connection description

catalogName

Spark catalog name used to register the Iceberg catalog

catalogType

Iceberg catalog type: hadoop, hive, rest, glue, nessie

warehouse

Warehouse location (path or URI)

catalogUri

Catalog service URI (for hive, rest, nessie catalog types)

parameters

Sequence of additional catalog parameters

metadata

List of metadata parameters specific to this connection

Linear Supertypes
Product, Equals, ConnectionConfig, JobConfigEntity, Serializable, Serializable, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. IcebergConnectionConfig
  2. Product
  3. Equals
  4. ConnectionConfig
  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 IcebergConnectionConfig(id: ID, description: Option[NonEmptyString], catalogName: NonEmptyString, catalogType: NonEmptyString, warehouse: Option[URI], catalogUri: Option[URI], parameters: Seq[SparkParam] = Seq.empty, metadata: Seq[SparkParam] = Seq.empty)

    id

    Connection Id

    description

    Connection description

    catalogName

    Spark catalog name used to register the Iceberg catalog

    catalogType

    Iceberg catalog type: hadoop, hive, rest, glue, nessie

    warehouse

    Warehouse location (path or URI)

    catalogUri

    Catalog service URI (for hive, rest, nessie catalog types)

    parameters

    Sequence of additional catalog parameters

    metadata

    List of metadata parameters specific to this connection

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 catalogName: NonEmptyString
  6. val catalogType: NonEmptyString
  7. val catalogUri: Option[URI]
  8. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native()
  9. val description: Option[NonEmptyString]
    Definition Classes
    IcebergConnectionConfig → JobConfigEntity
  10. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  11. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  12. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  13. val id: ID
    Definition Classes
    IcebergConnectionConfig → JobConfigEntity
  14. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  15. val metadata: Seq[SparkParam]
    Definition Classes
    IcebergConnectionConfig → 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 parameters: Seq[SparkParam]
    Definition Classes
    IcebergConnectionConfig → ConnectionConfig
  21. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  22. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  23. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  24. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native()
  25. val warehouse: Option[URI]

Inherited from Product

Inherited from Equals

Inherited from ConnectionConfig

Inherited from JobConfigEntity

Inherited from Serializable

Inherited from Serializable

Inherited from AnyRef

Inherited from Any

Ungrouped