object Connections
- Alphabetic
- By Inheritance
- Connections
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Type Members
-
final
case class
ClickHouseConnectionConfig(id: ID, description: Option[NonEmptyString], url: URI, username: Option[NonEmptyString], password: Option[NonEmptyString], schema: Option[NonEmptyString], parameters: Seq[SparkParam] = Seq.empty, metadata: Seq[SparkParam] = Seq.empty) extends JdbcConnectionConfig with Product with Serializable
Connection configuration for ClickHouse
Connection configuration for ClickHouse
- id
Connection Id
- description
Connection description
- url
Url for connection to database
- username
Username used for connection
- password
Password used for connection
- schema
Optional schema to lookup tables from. If omitted, default schema is used.
- parameters
Sequence of additional connection parameters
- metadata
List of metadata parameters specific to this connection
-
sealed abstract
class
ConnectionConfig extends JobConfigEntity
Base class for all connection configurations.
Base class for all connection configurations. All connections are described as DQ entities that also might have a list of extra connection parameters (specific to Spark).
-
final
case class
ConnectionsConfig(kafka: Seq[KafkaConnectionConfig] = Seq.empty, postgres: Seq[PostgresConnectionConfig] = Seq.empty, oracle: Seq[OracleConnectionConfig] = Seq.empty, sqlite: Seq[SQLiteConnectionConfig] = Seq.empty, mysql: Seq[MySQLConnectionConfig] = Seq.empty, mssql: Seq[MSSQLConnectionConfig] = Seq.empty, h2: Seq[H2ConnectionConfig] = Seq.empty, greenplum: Seq[GreenplumConnectionConfig] = Seq.empty, clickhouse: Seq[ClickHouseConnectionConfig] = Seq.empty) extends Product with Serializable
Data Quality job configuration section describing connections to external systems.
Data Quality job configuration section describing connections to external systems.
- kafka
Sequence of Kafka connections
- postgres
Sequence of PostgresSQL connections
- oracle
Sequence of Oracle connection
- sqlite
Sequence of SQLite connections
- mysql
Sequence of MySQL connections
- mssql
Sequence of MS SQL connections
- h2
Sequence of H2 connections
- greenplum
Sequence of Greenplum connections
- clickhouse
Sequence of ClickHouse connections
-
final
case class
GreenplumConnectionConfig(id: ID, description: Option[NonEmptyString], url: URI, username: Option[NonEmptyString], password: Option[NonEmptyString], schema: Option[NonEmptyString], parameters: Seq[SparkParam] = Seq.empty, metadata: Seq[SparkParam] = Seq.empty) extends ConnectionConfig with Product with Serializable
Connection configuration for Greenplum database
Connection configuration for Greenplum database
- id
Connection Id
- description
Connection description
- url
Url for connection to database
- username
Username used for connection
- password
Password used for connection
- schema
Optional schema to lookup tables from. If omitted, default schema is used.
- parameters
Sequence of additional connection parameters
- metadata
List of metadata parameters specific to this connection
-
final
case class
H2ConnectionConfig(id: ID, description: Option[NonEmptyString], url: URI, parameters: Seq[SparkParam] = Seq.empty, metadata: Seq[SparkParam] = Seq.empty) extends JdbcConnectionConfig with Product with Serializable
Connection configuration for H2 database
Connection configuration for H2 database
- id
Connection Id
- description
Connection description
- url
Url for connection to database
- parameters
Sequence of additional connection parameters
- metadata
List of metadata parameters specific to this connection
-
sealed abstract
class
JdbcConnectionConfig extends ConnectionConfig
Base class for jdbc connection configurations.
Base class for jdbc connection configurations. Such connections must have and URL for connection to database and optional user/password combination
-
final
case class
KafkaConnectionConfig(id: ID, description: Option[NonEmptyString], servers: Refined[Seq[URI], NonEmpty], parameters: Seq[SparkParam] = Seq.empty, metadata: Seq[SparkParam] = Seq.empty) extends ConnectionConfig with Product with Serializable
Connection configuration for Kafka
Connection configuration for Kafka
- id
Connection Id
- description
Connection description
- servers
Kafka brokers
- parameters
Sequence of additional connection parameters
- metadata
List of metadata parameters specific to this connection
-
final
case class
MSSQLConnectionConfig(id: ID, description: Option[NonEmptyString], url: URI, username: Option[NonEmptyString], password: Option[NonEmptyString], schema: Option[NonEmptyString], parameters: Seq[SparkParam] = Seq.empty, metadata: Seq[SparkParam] = Seq.empty) extends JdbcConnectionConfig with Product with Serializable
Connection configuration for MS SQL database
Connection configuration for MS SQL database
- id
Connection Id
- description
Connection description
- url
Url for connection to database
- username
Username used for connection
- password
Password used for connection
- schema
Optional schema to lookup tables from. If omitted, default schema is used.
- parameters
Sequence of additional connection parameters
- metadata
List of metadata parameters specific to this connection
-
final
case class
MySQLConnectionConfig(id: ID, description: Option[NonEmptyString], url: URI, username: Option[NonEmptyString], password: Option[NonEmptyString], schema: Option[NonEmptyString], parameters: Seq[SparkParam] = Seq.empty, metadata: Seq[SparkParam] = Seq.empty) extends JdbcConnectionConfig with Product with Serializable
Connection configuration for MySQL database
Connection configuration for MySQL database
- id
Connection Id
- description
Connection description
- url
Url for connection to database
- username
Username used for connection
- password
Password used for connection
- schema
Optional schema to lookup tables from. If omitted, default schema is used.
- parameters
Sequence of additional connection parameters
- metadata
List of metadata parameters specific to this connection
-
final
case class
OracleConnectionConfig(id: ID, description: Option[NonEmptyString], url: URI, username: Option[NonEmptyString], password: Option[NonEmptyString], schema: Option[NonEmptyString], parameters: Seq[SparkParam] = Seq.empty, metadata: Seq[SparkParam] = Seq.empty) extends JdbcConnectionConfig with Product with Serializable
Connection configuration for Oracle database
Connection configuration for Oracle database
- id
Connection Id
- description
Connection description
- url
Url for connection to database
- username
Username used for connection
- password
Password used for connection
- schema
Optional schema to lookup tables from. If omitted, default schema is used.
- parameters
Sequence of additional connection parameters
- metadata
List of metadata parameters specific to this connection
-
final
case class
PostgresConnectionConfig(id: ID, description: Option[NonEmptyString], url: URI, username: Option[NonEmptyString], password: Option[NonEmptyString], schema: Option[NonEmptyString], parameters: Seq[SparkParam] = Seq.empty, metadata: Seq[SparkParam] = Seq.empty) extends JdbcConnectionConfig with Product with Serializable
Connection configuration for PostgreSQL database
Connection configuration for PostgreSQL database
- id
Connection Id
- description
Connection description
- url
Url for connection to database
- username
Username used for connection
- password
Password used for connection
- schema
Optional schema to lookup tables from. If omitted, default schema is used.
- parameters
Sequence of additional connection parameters
- metadata
List of metadata parameters specific to this connection
-
final
case class
SQLiteConnectionConfig(id: ID, description: Option[NonEmptyString], url: URI, parameters: Seq[SparkParam] = Seq.empty, metadata: Seq[SparkParam] = Seq.empty) extends JdbcConnectionConfig with Product with Serializable
Connection configuration for SQLite database
Connection configuration for SQLite database
- id
Connection Id
- description
Connection description
- url
Path to SQLite db-file
- parameters
Sequence of additional connection parameters
- metadata
List of metadata parameters specific to this connection
Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- AnyRef → Any
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()