object DQContext
- Alphabetic
- By Inheritance
- DQContext
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
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
build(appConfig: String, referenceDate: Option[String], isLocal: Boolean = false, isShared: Boolean = false, doMigration: Boolean = false, extraVariables: Map[String, String] = Map.empty, logLvl: Level = Level.INFO): Result[DQContext]
Builds Checkita Data Quality context provided with path to an application-level configuration file and other required initialization parameters.
Builds Checkita Data Quality context provided with path to an application-level configuration file and other required initialization parameters.
- appConfig
Path to an application-level configuration file (HOCON)
- referenceDate
Reference date string
- isLocal
Boolean flag indicating whether spark application must be run locally.
- isShared
Boolean flag indicating whether spark application running within shared spark context.
- doMigration
Boolean flag indication whether DQ storage database migration needs to be run prior result saving.
- extraVariables
User-defined map of extra variables to be prepended to both application-level and job-level configuration files prior their parsing.
- logLvl
Application logging level
- returns
Either Data Quality context or a list of building errors.
- Note
This builder also collects system and java-runtime environment variables and looks for variables related to Checkita Data Quality Framework: following regex is used to find such variables:
^(?i)(DQ)[a-z0-9_-]+$
. These variables are combined with the ones provided in
extraVariablesargument and further used during configuration files parsing.
-
def
build(appConfig: AppConfig, referenceDate: Option[String], isLocal: Boolean, isShared: Boolean, doMigration: Boolean, prependVariables: String, logLvl: Level, versionInfo: VersionInfo): Result[DQContext]
Builds Checkita Data Quality context provided with application-level configuration and other required initialization parameters.
Builds Checkita Data Quality context provided with application-level configuration and other required initialization parameters.
- appConfig
Application-level configuration
- referenceDate
Reference date string
- isLocal
Boolean flag indicating whether spark application must be run locally.
- isShared
Boolean flag indicating whether spark application running within shared spark context.
- doMigration
Boolean flag indication whether DQ storage database migration needs to be run prior result saving.
- prependVariables
Collected variables that will be prepended to job configuration file (if one will be provided). These variables should already be transformed to a multiline HOCON string.
- logLvl
Application logging level.
- versionInfo
Information about application and configuration API versions.
- returns
Either Data Quality context or a list of building errors.
-
def
build(settings: AppSettings, spark: SparkSession): Result[DQContext]
Builds Checkita Data Quality context provided with application settings and existing spark session.
Builds Checkita Data Quality context provided with application settings and existing spark session.
- settings
Application settings object
- spark
Spark session object
- returns
Either Data Quality context or a list of building errors.
-
def
build(settings: AppSettings): Result[DQContext]
Builds Checkita Data Quality context provided only with application settings.
Builds Checkita Data Quality context provided only with application settings.
- settings
Application settings object
- returns
Either Data Quality context or a list of building errors.
- Note
This builder will create new spark session object or get one from shared spark context. If it is required to use already existing variable pointing to a spark session, then use other builder that have explicit argument to pass spark session object.
-
def
clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()
-
def
default: Result[DQContext]
Builds default Data Quality context using default application settings.
Builds default Data Quality context using default application settings.
- returns
Default DQ Context
-
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()