Class DataQualityRule.DataQualityRuleBuilder<C extends DataQualityRule,B extends DataQualityRule.DataQualityRuleBuilder<C,B>>

Enclosing class:
DataQualityRule

public abstract static class DataQualityRule.DataQualityRuleBuilder<C extends DataQualityRule,B extends DataQualityRule.DataQualityRuleBuilder<C,B>> extends Asset.AssetBuilder<C,B>
  • Constructor Details

    • DataQualityRuleBuilder

      public DataQualityRuleBuilder()
  • Method Details

    • $fillValuesFrom

      protected B $fillValuesFrom(C instance)
      Overrides:
      $fillValuesFrom in class Asset.AssetBuilder<C extends DataQualityRule,B extends DataQualityRule.DataQualityRuleBuilder<C,B>>
    • typeName

      public B typeName(String typeName)
      Fixed typeName for DataQualityRules.
      Overrides:
      typeName in class Reference.ReferenceBuilder<C extends DataQualityRule,B extends DataQualityRule.DataQualityRuleBuilder<C,B>>
      Returns:
      this.
    • dqIsPartOfContract

      public B dqIsPartOfContract(Boolean dqIsPartOfContract)
      Whether this data quality is part of contract (true) or not (false).
      Returns:
      this.
    • dqRuleAlertPriority

      public B dqRuleAlertPriority(DataQualityRuleAlertPriority dqRuleAlertPriority)
      Default priority level for alerts involving this rule.
      Returns:
      this.
    • dqRuleBaseColumn

      public B dqRuleBaseColumn(IColumn dqRuleBaseColumn)
      Base column attached to this rule.
      Returns:
      this.
    • dqRuleBaseColumnQualifiedName

      public B dqRuleBaseColumnQualifiedName(String dqRuleBaseColumnQualifiedName)
      Base column qualified name that attached to this rule.
      Returns:
      this.
    • dqRuleBaseDataset

      public B dqRuleBaseDataset(IAsset dqRuleBaseDataset)
      Base dataset attached to this rule.
      Returns:
      this.
    • dqRuleBaseDatasetQualifiedName

      public B dqRuleBaseDatasetQualifiedName(String dqRuleBaseDatasetQualifiedName)
      Base dataset qualified name that attached to this rule.
      Returns:
      this.
    • dqRuleConfigArguments

      public B dqRuleConfigArguments(DataQualityRuleConfigArguments dqRuleConfigArguments)
      Json string of the rule config that contains the rule definitions.
      Returns:
      this.
    • dqRuleCustomSQL

      public B dqRuleCustomSQL(String dqRuleCustomSQL)
      SQL code for custom SQL rules.
      Returns:
      this.
    • dqRuleDimension

      public B dqRuleDimension(DataQualityDimension dqRuleDimension)
      Dimension of the data quality rule.
      Returns:
      this.
    • dqRuleLatestMetricValue

      public B dqRuleLatestMetricValue(String dqRuleLatestMetricValue)
      Last result metrics value of the rule.
      Returns:
      this.
    • dqRuleLatestMetricValueComputedAt

      public B dqRuleLatestMetricValueComputedAt(Long dqRuleLatestMetricValueComputedAt)
      Time (epoch) at which the latest metric value was evaluated in the source.
      Returns:
      this.
    • dqRuleLatestResult

      public B dqRuleLatestResult(DataQualityResult dqRuleLatestResult)
      Latest result of the rule.
      Returns:
      this.
    • dqRuleLatestResultComputedAt

      public B dqRuleLatestResultComputedAt(Long dqRuleLatestResultComputedAt)
      Time (epoch) at which the latest rule result was evaluated.
      Returns:
      this.
    • dqRuleLatestResultFetchedAt

      public B dqRuleLatestResultFetchedAt(Long dqRuleLatestResultFetchedAt)
      Time (epoch) at which the latest rule result was fetched.
      Returns:
      this.
    • dqRuleReferenceColumnQualifiedName

      public B dqRuleReferenceColumnQualifiedName(String dqRuleReferenceColumnQualifiedName)
    • dqRuleReferenceColumnQualifiedNames

      public B dqRuleReferenceColumnQualifiedNames(Collection<? extends String> dqRuleReferenceColumnQualifiedNames)
    • clearDqRuleReferenceColumnQualifiedNames

      public B clearDqRuleReferenceColumnQualifiedNames()
    • dqRuleReferenceColumn

      public B dqRuleReferenceColumn(IColumn dqRuleReferenceColumn)
    • dqRuleReferenceColumns

      public B dqRuleReferenceColumns(Collection<? extends IColumn> dqRuleReferenceColumns)
    • clearDqRuleReferenceColumns

      public B clearDqRuleReferenceColumns()
    • dqRuleReferenceDatasetQualifiedName

      public B dqRuleReferenceDatasetQualifiedName(String dqRuleReferenceDatasetQualifiedName)
    • dqRuleReferenceDatasetQualifiedNames

      public B dqRuleReferenceDatasetQualifiedNames(Collection<? extends String> dqRuleReferenceDatasetQualifiedNames)
    • clearDqRuleReferenceDatasetQualifiedNames

      public B clearDqRuleReferenceDatasetQualifiedNames()
    • dqRuleReferenceDataset

      public B dqRuleReferenceDataset(IAsset dqRuleReferenceDataset)
    • dqRuleReferenceDatasets

      public B dqRuleReferenceDatasets(Collection<? extends IAsset> dqRuleReferenceDatasets)
    • clearDqRuleReferenceDatasets

      public B clearDqRuleReferenceDatasets()
    • dqRuleRowScopeFilteringEnabled

      public B dqRuleRowScopeFilteringEnabled(Boolean dqRuleRowScopeFilteringEnabled)
      Whether row scope filtering is enabled for this data quality rule (true) or not (false).
      Returns:
      this.
    • dqRuleSourceSyncErrorCode

      public B dqRuleSourceSyncErrorCode(String dqRuleSourceSyncErrorCode)
      Error code in the case of state being "failure".
      Returns:
      this.
    • dqRuleSourceSyncErrorMessage

      public B dqRuleSourceSyncErrorMessage(String dqRuleSourceSyncErrorMessage)
      Error message in the case of state being "error".
      Returns:
      this.
    • dqRuleSourceSyncRawError

      public B dqRuleSourceSyncRawError(String dqRuleSourceSyncRawError)
      Raw error message from the source.
      Returns:
      this.
    • dqRuleSourceSyncStatus

      public B dqRuleSourceSyncStatus(DataQualitySourceSyncStatus dqRuleSourceSyncStatus)
      Latest sync status of the rule to the source.
      Returns:
      this.
    • dqRuleSourceSyncedAt

      public B dqRuleSourceSyncedAt(Long dqRuleSourceSyncedAt)
      Time (epoch) at which the rule synced to the source.
      Returns:
      this.
    • dqRuleStatus

      public B dqRuleStatus(DataQualityRuleStatus dqRuleStatus)
      Status of the rule.
      Returns:
      this.
    • dqRuleTemplate

      public B dqRuleTemplate(IDataQualityRuleTemplate dqRuleTemplate)
      Template used to create this rule.
      Returns:
      this.
    • dqRuleTemplateName

      public B dqRuleTemplateName(String dqRuleTemplateName)
      Name of the rule template corresponding to the rule.
      Returns:
      this.
    • inputToAirflowTask

      public B inputToAirflowTask(IAirflowTask inputToAirflowTask)
    • inputToAirflowTasks

      public B inputToAirflowTasks(Collection<? extends IAirflowTask> inputToAirflowTasks)
    • clearInputToAirflowTasks

      public B clearInputToAirflowTasks()
    • inputToProcess

      public B inputToProcess(ILineageProcess inputToProcess)
    • inputToProcesses

      public B inputToProcesses(Collection<? extends ILineageProcess> inputToProcesses)
    • clearInputToProcesses

      public B clearInputToProcesses()
    • inputToSparkJob

      public B inputToSparkJob(ISparkJob inputToSparkJob)
    • inputToSparkJobs

      public B inputToSparkJobs(Collection<? extends ISparkJob> inputToSparkJobs)
    • clearInputToSparkJobs

      public B clearInputToSparkJobs()
    • modelImplementedAttribute

      public B modelImplementedAttribute(IModelAttribute modelImplementedAttribute)
    • modelImplementedAttributes

      public B modelImplementedAttributes(Collection<? extends IModelAttribute> modelImplementedAttributes)
    • clearModelImplementedAttributes

      public B clearModelImplementedAttributes()
    • modelImplementedEntity

      public B modelImplementedEntity(IModelEntity modelImplementedEntity)
    • modelImplementedEntities

      public B modelImplementedEntities(Collection<? extends IModelEntity> modelImplementedEntities)
    • clearModelImplementedEntities

      public B clearModelImplementedEntities()
    • outputFromAirflowTask

      public B outputFromAirflowTask(IAirflowTask outputFromAirflowTask)
    • outputFromAirflowTasks

      public B outputFromAirflowTasks(Collection<? extends IAirflowTask> outputFromAirflowTasks)
    • clearOutputFromAirflowTasks

      public B clearOutputFromAirflowTasks()
    • outputFromProcess

      public B outputFromProcess(ILineageProcess outputFromProcess)
    • outputFromProcesses

      public B outputFromProcesses(Collection<? extends ILineageProcess> outputFromProcesses)
    • clearOutputFromProcesses

      public B clearOutputFromProcesses()
    • outputFromSparkJob

      public B outputFromSparkJob(ISparkJob outputFromSparkJob)
    • outputFromSparkJobs

      public B outputFromSparkJobs(Collection<? extends ISparkJob> outputFromSparkJobs)
    • clearOutputFromSparkJobs

      public B clearOutputFromSparkJobs()
    • self

      protected abstract B self()
      Specified by:
      self in class Asset.AssetBuilder<C extends DataQualityRule,B extends DataQualityRule.DataQualityRuleBuilder<C,B>>
    • build

      public abstract C build()
      Specified by:
      build in class Asset.AssetBuilder<C extends DataQualityRule,B extends DataQualityRule.DataQualityRuleBuilder<C,B>>
    • toString

      public String toString()
      Overrides:
      toString in class Asset.AssetBuilder<C extends DataQualityRule,B extends DataQualityRule.DataQualityRuleBuilder<C,B>>