package quality

Linear Supertypes
RuleProcessingConstants, CollectRunnerImports, VariableProcessIfMissing, VersionSpecificSerializingImports, ExpressionRunnerImports, ViewLoading, RuleFolderRunnerImports, RuleEngineRunnerImports, LambdaFunctionsImports, AddDataFunctionsImports, SerializingImports, MapLookupImportsShared, Serializable, RuleRunnerImports, AnyRef, Any
Content Hierarchy
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. quality
  2. RuleProcessingConstants
  3. CollectRunnerImports
  4. VariableProcessIfMissing
  5. VersionSpecificSerializingImports
  6. ExpressionRunnerImports
  7. ViewLoading
  8. RuleFolderRunnerImports
  9. RuleEngineRunnerImports
  10. LambdaFunctionsImports
  11. AddDataFunctionsImports
  12. SerializingImports
  13. MapLookupImportsShared
  14. Serializable
  15. RuleRunnerImports
  16. AnyRef
  17. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Package Members

  1. package classicFunctions

    Collection of the Quality Spark Expressions for use in select( Column * )

  2. package impl
  3. package sparkless

Type Members

  1. trait BloomLookup extends AnyRef

    Simple does it contain function to test a bloom

  2. case class BloomModel(rootDir: String, fpp: Double, numBuckets: Int) extends Serializable with Product

    Represents the shared file location of a bucked bloom filter.

    Represents the shared file location of a bucked bloom filter. There should be files with names 0..numBuckets containing the same number of bytes representing each bucket.

    rootDir

    The directory which contains each bucket

    fpp

    The fpp for this bloom - note it is informational only and will not be used in further processing

    numBuckets

    The number of buckets within this bloom

  3. trait ClassicOnly extends Annotation
    Annotations
    @Retention()
  4. trait DefaultProcessor extends HasRuleText with HasOutputExpression

    Configuration of what should be evaluated when no trigger passes for Folder and Collector

  5. class EmptyForAPICompilation extends AnyRef
  6. trait ExpressionRule extends Serializable

    A trigger rule

  7. trait HasOutputExpression extends Serializable
  8. trait HasRuleText extends Serializable
  9. case class Id(id: Int, version: Int) extends VersionedId with Product with Serializable

    A versioned rule ID - note the name is never persisted in results, the id and version are sufficient to retrieve the name

    A versioned rule ID - note the name is never persisted in results, the id and version are sufficient to retrieve the name

    id

    a unique ID to identify this rule

    version

    the version of the rule - again tied to ID

    Annotations
    @SerialVersionUID()
  10. type IdTriple = (Id, Id, Id)
    Definition Classes
    LambdaFunctionsImports
  11. trait LambdaFunction extends HasRuleText

    A user defined SQL function

  12. case class LazyRuleEngineResult[T](lazyRuleSuiteResults: LazyRuleSuiteResult, salientRule: Option[SalientRule], result: Option[T]) extends Serializable with Product

    Results for all rules run against a DataFrame, the RuleSuiteResult is lazily evaluated.

    Results for all rules run against a DataFrame, the RuleSuiteResult is lazily evaluated. Note in debug mode the type of T must be Seq[(Int, ActualType)]

    lazyRuleSuiteResults

    Overall results from applying the engine, evealuated lazily

    salientRule

    if it's None there is no rule which matched for this row or it's in Debug mode which will return all results.

    result

    The result type for this row, if no rule matched this will be None, if a rule matched but the outputexpression returned null this will also be None

    Annotations
    @SerialVersionUID()
  13. case class LazyRuleFolderResult[T](lazyRuleSuiteResults: LazyRuleSuiteResult, result: Option[T]) extends Serializable with Product

    Results for all rules run against a DataFrame, the RuleSuiteResult is lazily evaluated.

    Results for all rules run against a DataFrame, the RuleSuiteResult is lazily evaluated. Note in debug mode the type of T must be Seq[(Int, ActualType)]

    lazyRuleSuiteResults

    Overall results from applying the engine, evaluated lazily

    result

    The result type for this row, if no rule matched this will be None, if a rule matched but the outputexpression returned null this will also be None

    Annotations
    @SerialVersionUID()
  14. trait LazyRuleSuiteResult extends Serializable

    A lazy proxy for RuleSuiteResult

  15. type MapCreator = () => (DataFrame, Column, Column)
    Definition Classes
    MapLookupImportsShared
  16. type MapLookups = String
    Definition Classes
    MapLookupImportsShared
  17. trait OutputExpression extends AnyRef

    Used as a result of serializing

  18. sealed trait ResultStatisticsProvider[T, R] extends Serializable
  19. sealed trait ResultStatisticsProviderImpl[T <: ResultStatistics[_]] extends Serializable
  20. case class Rule(id: Id, expression: ExpressionRule, runOnPassProcessor: RunOnPassProcessor = NoOpRunOnPassProcessor.noOp) extends Serializable with Product

    A rule to run over a row

    A rule to run over a row

    Annotations
    @SerialVersionUID()
  21. case class RuleSet(id: Id, rules: Seq[Rule]) extends Serializable with Product
    Annotations
    @SerialVersionUID()
  22. case class RuleSuite(id: Id, ruleSets: Seq[RuleSet], lambdaFunctions: Seq[LambdaFunction] = Seq.empty, probablePass: Double = defaultProbablePass, defaultProcessor: DefaultProcessor = NoOpDefaultProcessor.noOp) extends Serializable with Product

    Represents a versioned collection of RuleSet's

    Represents a versioned collection of RuleSet's

    probablePass

    override to specify a different percentage for treating probability results as passes - defaults to 80% (0.8)

    defaultProcessor

    when using folder or collector this output expression will be used when no rules are triggered

    Annotations
    @SerialVersionUID()
  23. trait RunOnPassProcessor extends HasRuleText with HasOutputExpression

    Configuration of what should be evaluated when a trigger passes and salience matches

  24. case class SparkBloomFilter(bloom: BloomFilter) extends BloomLookup with Product with Serializable
  25. sealed trait VersionedId extends Serializable

    base for storage of rule or ruleset ids, must be a trait to force frameless to use lookup and stop any accidental auto product treatment

Abstract Value Members

  1. abstract def getClass(): Class[_ <: AnyRef]
    Definition Classes
    Any

Concrete Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    Any
  2. final def ##: Int
    Definition Classes
    Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    Any
  4. val DefaultRuleInt: Int
    Definition Classes
    RuleRunnerImports
  5. val DefaultRuleSalience: Int
    Definition Classes
    RuleRunnerImports
  6. val DisabledRuleInt: Int
    Definition Classes
    RuleRunnerImports
  7. val FailedInt: Int
    Definition Classes
    RuleRunnerImports
  8. val IgnoredRuleInt: Int
    Definition Classes
    RuleRunnerImports
  9. val PassedInt: Int
    Definition Classes
    RuleRunnerImports
  10. val SoftFailedInt: Int
    Definition Classes
    RuleRunnerImports
  11. val UnevaluatedRuleInt: Int
    Definition Classes
    RuleRunnerImports
  12. def addDataQuality(dataFrame: DataFrame, rules: RuleSuite, name: String): DataFrame
    Definition Classes
    AddDataFunctionsImports
  13. def addDataQualityF(rules: RuleSuite, name: String): (DataFrame) => DataFrame
    Definition Classes
    AddDataFunctionsImports
  14. def addExpressionRunner(dataFrame: DataFrame, ruleSuite: RuleSuite, name: String, renderOptions: Map[String, String], ddlType: String, stripDDL: Boolean, postProcess: (DataFrame) => DataFrame): DataFrame
    Definition Classes
    AddDataFunctionsImports
  15. def addExpressionRunnerF[P[R] >: Dataset[R]](ruleSuite: RuleSuite, name: String, renderOptions: Map[String, String], ddlType: String, stripDDL: Boolean, postProcess: (DataFrame) => DataFrame): (P[Row]) => P[Row]
    Definition Classes
    AddDataFunctionsImports
  16. def addOverallResultsAndDetails(dataFrame: DataFrame, rules: RuleSuite, overallResult: String, resultDetails: String): DataFrame
    Definition Classes
    AddDataFunctionsImports
  17. def addOverallResultsAndDetailsF(rules: RuleSuite, overallResult: String, resultDetails: String): (DataFrame) => DataFrame
    Definition Classes
    AddDataFunctionsImports
  18. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  19. def collectRunner(ruleSuite: RuleSuite, resultDataType: Option[DataType], variablesPerFunc: Int, variableFuncGroup: Int, flatten: Boolean, includeNulls: Boolean, useInPlaceArray: Boolean, unrollInPlaceArray: Boolean, unrollOutputArraySize: Int, extraConfig: Map[String, String]): Column
    Definition Classes
    CollectRunnerImports
  20. def combine(ruleRows: Dataset[RuleRow], lambdaFunctionRows: Dataset[LambdaFunctionRow], outputExpressionRows: Dataset[OutputExpressionRow], globalLambdaSuites: Dataset[Id], ruleSuites: Dataset[RuleSuiteRow])(implicit encoder: Encoder[CombinedRuleSuiteRows]): Dataset[CombinedRuleSuiteRows]
    Definition Classes
    VersionSpecificSerializingImports
  21. def combine(ruleRows: Dataset[RuleRow], lambdaFunctionRows: Dataset[LambdaFunctionRow], outputExpressionRows: Dataset[OutputExpressionRow], globalLambdaSuites: Dataset[Id], globalOutputExpressionSuites: Dataset[Id], ruleSuites: Dataset[RuleSuiteRow])(implicit encoder: Encoder[CombinedRuleSuiteRows]): Dataset[CombinedRuleSuiteRows]
    Definition Classes
    VersionSpecificSerializingImports
  22. def combine(ruleRows: Dataset[RuleRow], lambdaFunctionRows: Dataset[LambdaFunctionRow], outputExpressionRows: Dataset[OutputExpressionRow], ruleSuites: Dataset[RuleSuiteRow])(implicit encoder: Encoder[CombinedRuleSuiteRows]): Dataset[CombinedRuleSuiteRows]
    Definition Classes
    VersionSpecificSerializingImports
  23. def combine(ruleRows: Dataset[RuleRow])(implicit encoder: Encoder[CombinedRuleSuiteRows]): Dataset[CombinedRuleSuiteRows]
    Definition Classes
    VersionSpecificSerializingImports
  24. def combine(ruleRows: Dataset[RuleRow], lambdaFunctionRows: Dataset[LambdaFunctionRow])(implicit encoder: Encoder[CombinedRuleSuiteRows]): Dataset[CombinedRuleSuiteRows]
    Definition Classes
    VersionSpecificSerializingImports
  25. def combine(ruleRows: Dataset[RuleRow], lambdaFunctionRows: Dataset[LambdaFunctionRow], outputExpressionRows: Dataset[OutputExpressionRow])(implicit encoder: Encoder[CombinedRuleSuiteRows]): Dataset[CombinedRuleSuiteRows]
    Definition Classes
    VersionSpecificSerializingImports
  26. def combine(ruleRows: Dataset[RuleRow], lambdaFunctionRows: Option[Dataset[LambdaFunctionRow]], outputExpressionRows: Option[Dataset[OutputExpressionRow]], globalLambdaSuites: Option[Dataset[Id]], globalOutputExpressionSuites: Option[Dataset[Id]], ruleSuites: Option[Dataset[RuleSuiteRow]])(implicit encoder: Encoder[CombinedRuleSuiteRows]): Dataset[CombinedRuleSuiteRows]
    Definition Classes
    VersionSpecificSerializingImports
  27. def combined_rows(ruleSuite: RuleSuite): Dataset[CombinedRuleSuiteRows]
    Definition Classes
    VersionSpecificSerializingImports
  28. def dqRuleRunner(ruleSuite: RuleSuite, variablesPerFunc: Int, variableFuncGroup: Int, extraConfig: Map[String, String]): Column
    Definition Classes
    RuleRunnerImports
  29. def equals(arg0: Any): Boolean
    Definition Classes
    Any
  30. def expressionRunner(ruleSuite: RuleSuite, name: String, renderOptions: Map[String, String], extraConfig: Map[String, String]): Column
    Definition Classes
    ExpressionRunnerImports
  31. def foldAndReplaceFieldPairs[P[R] >: Dataset[R]](rules: RuleSuite, fields: Seq[(String, Column)], foldFieldName: String, debugMode: Boolean, tempFoldDebugName: String, maintainOrder: Boolean, alias: String): (P[Row]) => P[Row]
    Definition Classes
    AddDataFunctionsImports
  32. def foldAndReplaceFieldPairsWithStruct[P[R] >: Dataset[R]](rules: RuleSuite, fields: Seq[(String, Column)], struct: StructType, foldFieldName: String, debugMode: Boolean, tempFoldDebugName: String, maintainOrder: Boolean, alias: String): (P[Row]) => P[Row]
    Definition Classes
    AddDataFunctionsImports
  33. def foldAndReplaceFields[P[R] >: Dataset[R]](rules: RuleSuite, fields: Seq[String], foldFieldName: String, debugMode: Boolean, tempFoldDebugName: String, maintainOrder: Boolean, alias: String): (P[Row]) => P[Row]
    Definition Classes
    AddDataFunctionsImports
  34. def foldAndReplaceFieldsWithStruct[P[R] >: Dataset[R]](rules: RuleSuite, struct: StructType, foldFieldName: String, debugMode: Boolean, tempFoldDebugName: String, maintainOrder: Boolean, alias: String): (P[Row]) => P[Row]
    Definition Classes
    AddDataFunctionsImports
  35. def getConfig(name: String, default: String): String
  36. val groupProcessorAuditBucketStep: String
    Definition Classes
    RuleProcessingConstants
  37. val groupProcessorAuditLocation: String
    Definition Classes
    RuleProcessingConstants
  38. val groupProcessorAuditMaxBucket: String
    Definition Classes
    RuleProcessingConstants
  39. val groupProcessorAuditMinBucket: String
    Definition Classes
    RuleProcessingConstants
  40. val groupProcessorAuditName: String
    Definition Classes
    RuleProcessingConstants
  41. val groupProcessorBucketSizeKey: String
    Definition Classes
    RuleProcessingConstants
  42. val groupProcessorDumpAuditKey: String
    Definition Classes
    RuleProcessingConstants
  43. val groupProcessorKey: String
    Definition Classes
    RuleProcessingConstants
  44. val groupProcessorPercentFilter: String
    Definition Classes
    RuleProcessingConstants
  45. def hashCode(): Int
    Definition Classes
    Any
  46. def integrateLambdas(ruleSuiteMap: RuleSuiteMap, lambdas: Map[Id, Seq[LambdaFunction]], globalLibrary: Option[Id]): RuleSuiteMap
    Definition Classes
    SerializingImports
  47. def integrateMetaRuleSets(dataFrame: DataFrame, ruleSuiteMap: RuleSuiteMap, metaRuleSetMap: Map[Id, Seq[MetaRuleSetRow]], stablePosition: (String) => Int, transform: (DataFrame) => DataFrame): RuleSuiteMap
    Definition Classes
    SerializingImports
  48. def integrateOutputExpressions(ruleSuiteMap: RuleSuiteMap, outputs: Map[Id, Seq[OutputExpressionRow]], globalLibrary: Option[Id]): (RuleSuiteMap, Map[Id, Set[Rule]])
    Definition Classes
    SerializingImports
  49. def integrateRuleSuites(ruleSuiteMap: RuleSuiteMap, ruleSuites: Map[Id, RuleSuiteRow]): RuleSuiteMap
    Definition Classes
    SerializingImports
  50. def isAMissingRuleSuiteRule(rule: Rule): Boolean
    Definition Classes
    SerializingImports
  51. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  52. def loadMapConfigs(loader: DataFrameLoader, viewDF: DataFrame, name: Column, token: Column, filter: Column, sql: Column, key: Column, value: Column): (Seq[MapConfig], Set[String])
    Definition Classes
    MapLookupImportsShared
  53. def loadMapConfigs(loader: DataFrameLoader, viewDF: DataFrame, ruleSuiteId: Id, mapConfig: MapConfigColumns): (Seq[MapConfig], Set[String])
    Definition Classes
    MapLookupImportsShared
  54. def loadMapConfigs(loader: DataFrameLoader, viewDF: DataFrame, ruleSuiteIdColumn: Column, ruleSuiteVersionColumn: Column, ruleSuiteId: Id, name: Column, token: Column, filter: Column, sql: Column, key: Column, value: Column): (Seq[MapConfig], Set[String])
    Definition Classes
    MapLookupImportsShared
  55. def loadMaps(configs: Seq[MapConfig]): MapLookups
    Definition Classes
    MapLookupImportsShared
  56. def loadViewConfigs(loader: DataFrameLoader, viewDF: DataFrame, name: Column, token: Column, filter: Column, sql: Column): (Seq[ViewConfig], Set[String])
    Definition Classes
    ViewLoading
  57. def loadViewConfigs(loader: DataFrameLoader, viewDF: DataFrame, ruleSuiteId: Id, viewColumns: ViewConfigColumns): (Seq[ViewConfig], Set[String])
    Definition Classes
    ViewLoading
  58. def loadViewConfigs(loader: DataFrameLoader, viewDF: DataFrame, ruleSuiteIdColumn: Column, ruleSuiteVersionColumn: Column, ruleSuiteId: Id, name: Column, token: Column, filter: Column, sql: Column): (Seq[ViewConfig], Set[String])
    Definition Classes
    ViewLoading
  59. def loadViews(viewConfigs: Seq[ViewConfig]): ViewLoadResults
    Definition Classes
    ViewLoading
  60. def mapLookupsFromDFs(creators: Map[String, MapCreator]): MapLookups
    Definition Classes
    MapLookupImportsShared
  61. def process_if_attribute_missing(ruleSuite: Column): String
    Definition Classes
    VariableProcessIfMissing
  62. def process_if_attribute_missing(ruleSuite: Column, schema: StructType): String
    Definition Classes
    VariableProcessIfMissing
  63. def process_if_attribute_missing(ruleSuite: Column, schema: StructType, stableName: String): String
    Definition Classes
    VariableProcessIfMissing
  64. def process_if_attribute_missing_col(ruleSuite: Column, schema: StructType, stableName: String): Column
    Definition Classes
    VariableProcessIfMissing
  65. def readLambdaRowsFromDF(lambdaFunctionDF: DataFrame, lambdaFunctionName: Column, lambdaFunctionExpression: Column, lambdaFunctionId: Column, lambdaFunctionVersion: Column, lambdaFunctionRuleSuiteId: Column, lambdaFunctionRuleSuiteVersion: Column): Dataset[LambdaFunctionRow]
    Definition Classes
    SerializingImports
  66. def readLambdasFromDF(lambdaFunctionDF: DataFrame, lambdaFunctionName: Column, lambdaFunctionExpression: Column, lambdaFunctionId: Column, lambdaFunctionVersion: Column, lambdaFunctionRuleSuiteId: Column, lambdaFunctionRuleSuiteVersion: Column): Map[Id, Seq[LambdaFunction]]
    Definition Classes
    SerializingImports
  67. def readMetaRuleSetsFromDF(metaRuleSetDF: DataFrame, columnSelectionExpression: Column, lambdaFunctionExpression: Column, metaRuleSetId: Column, metaRuleSetVersion: Column, metaRuleSuiteId: Column, metaRuleSuiteVersion: Column): Map[Id, Seq[MetaRuleSetRow]]
    Definition Classes
    SerializingImports
  68. def readOutputExpressionRowsFromDF(outputExpressionDF: DataFrame, outputExpression: Column, outputExpressionId: Column, outputExpressionVersion: Column, outputExpressionRuleSuiteId: Column, outputExpressionRuleSuiteVersion: Column): Dataset[OutputExpressionRow]
    Definition Classes
    SerializingImports
  69. def readOutputExpressionsFromDF(outputExpressionDF: DataFrame, outputExpression: Column, outputExpressionId: Column, outputExpressionVersion: Column, outputExpressionRuleSuiteId: Column, outputExpressionRuleSuiteVersion: Column): Map[Id, Seq[OutputExpressionRow]]
    Definition Classes
    SerializingImports
  70. def readRuleRowsFromDF(df: DataFrame, ruleSuiteId: Column, ruleSuiteVersion: Column, ruleSetId: Column, ruleSetVersion: Column, ruleId: Column, ruleVersion: Column, ruleExpr: Column, outputExpressionSalience: Column, outputExpressionId: Column, outputExpressionVersion: Column): Dataset[RuleRow]
    Definition Classes
    SerializingImports
  71. def readRuleRowsFromDF(df: DataFrame, ruleSuiteId: Column, ruleSuiteVersion: Column, ruleSetId: Column, ruleSetVersion: Column, ruleId: Column, ruleVersion: Column, ruleExpr: Column, ruleEngine: Option[(Column, Column, Column)]): Dataset[RuleRow]
    Definition Classes
    SerializingImports
  72. def readRuleSuitesFromDF(ruleSuites: Dataset[RuleSuiteRow]): Map[Id, RuleSuiteRow]
    Definition Classes
    SerializingImports
  73. def readRulesFromDF(df: DataFrame, ruleSuiteId: Column, ruleSuiteVersion: Column, ruleSetId: Column, ruleSetVersion: Column, ruleId: Column, ruleVersion: Column, ruleExpr: Column, ruleEngineSalience: Column, ruleEngineId: Column, ruleEngineVersion: Column): RuleSuiteMap
    Definition Classes
    SerializingImports
  74. def readRulesFromDF(df: DataFrame, ruleSuiteId: Column, ruleSuiteVersion: Column, ruleSetId: Column, ruleSetVersion: Column, ruleId: Column, ruleVersion: Column, ruleExpr: Column): RuleSuiteMap
    Definition Classes
    SerializingImports
  75. def registerLambdaFunctions(functions: Seq[LambdaFunction]): Unit
    Definition Classes
    LambdaFunctionsImports
  76. def registerQualityFunctions(): Unit
  77. def registerTempViewNameFromDS[T](lambdaFunctionRows: Option[Dataset[T]]): String
    Attributes
    protected
    Definition Classes
    VersionSpecificSerializingImports
  78. def register_rule_suite(ruleSuite: RuleSuite): String
    Definition Classes
    VersionSpecificSerializingImports
  79. def register_rule_suite(ruleSuite: RuleSuite, stableName: String): String
    Definition Classes
    VersionSpecificSerializingImports
  80. def register_rule_suite_group(group: RuleSuiteGroup, stableName: String): String
    Definition Classes
    VersionSpecificSerializingImports
  81. def register_rule_suite_group(group: RuleSuiteGroup): String
    Definition Classes
    VersionSpecificSerializingImports
  82. def register_rule_suite_group_variable(ds: Dataset[CombinedRuleSuiteRows], stableName: String): String
    Definition Classes
    VersionSpecificSerializingImports
  83. def register_rule_suite_group_variable(ds: Dataset[CombinedRuleSuiteRows]): String
    Definition Classes
    VersionSpecificSerializingImports
  84. def register_rule_suite_variable(ds: Dataset[CombinedRuleSuiteRows], id: VersionedId, stableName: String): String
    Definition Classes
    VersionSpecificSerializingImports
  85. def register_rule_suite_variable(ds: Dataset[CombinedRuleSuiteRows], id: VersionedId): String
    Definition Classes
    VersionSpecificSerializingImports
  86. def ruleEngineRunner(ruleSuite: RuleSuite, resultDataType: DataType): Column
    Definition Classes
    RuleEngineRunnerImports
  87. def ruleEngineRunner(ruleSuite: RuleSuite, resultDataType: DataType, debugMode: Boolean): Column
    Definition Classes
    RuleEngineRunnerImports
  88. def ruleEngineRunner(ruleSuite: RuleSuite, resultDataType: Option[DataType], debugMode: Boolean, variablesPerFunc: Int, variableFuncGroup: Int, forceRunnerEval: Boolean, forceTriggerEval: Boolean, extraConfig: Map[String, String]): Column
    Definition Classes
    RuleEngineRunnerImports
  89. def ruleEngineWithStruct(dataFrame: DataFrame, rules: RuleSuite, outputType: DataType, ruleEngineFieldName: String, alias: String, debugMode: Boolean): DataFrame
    Definition Classes
    AddDataFunctionsImports
  90. def ruleEngineWithStructF[P[R] >: Dataset[R]](rules: RuleSuite, outputType: DataType, ruleEngineFieldName: String, alias: String, debugMode: Boolean): (P[Row]) => P[Row]
    Definition Classes
    AddDataFunctionsImports
  91. def ruleEngineWithStructFOT[P[R] >: Dataset[R]](rules: RuleSuite, outputType: Option[DataType], ruleEngineFieldName: String, alias: String, debugMode: Boolean): (P[Row]) => P[Row]
    Definition Classes
    AddDataFunctionsImports
  92. def ruleEngineWithStructOT(dataFrame: DataFrame, rules: RuleSuite, outputType: Option[DataType], ruleEngineFieldName: String, alias: String, debugMode: Boolean): DataFrame
    Definition Classes
    AddDataFunctionsImports
  93. def ruleFolderRunner(ruleSuite: RuleSuite, startingStruct: Column, debugMode: Boolean, variablesPerFunc: Int, variableFuncGroup: Int, useType: Option[StructType], extraConfig: Map[String, String]): Column
    Definition Classes
    RuleFolderRunnerImports
  94. def ruleRunner(ruleSuite: RuleSuite, variablesPerFunc: Int, variableFuncGroup: Int, extraConfig: Map[String, String]): Column
    Definition Classes
    RuleRunnerImports
  95. def rule_suite(ds: Dataset[CombinedRuleSuiteRows], id: VersionedId): Option[RuleSuite]
    Definition Classes
    VersionSpecificSerializingImports
  96. def rule_suite(row: CombinedRuleSuiteRows): RuleSuite
    Definition Classes
    VersionSpecificSerializingImports
  97. def rule_suite_from(ruleSuiteGroupName: String, ruleSuiteId: Int, ruleSuiteVersion: Int): Column
    Definition Classes
    VersionSpecificSerializingImports
  98. def rule_suite_from(ruleSuiteGroupName: String, ruleSuiteId: Int): Column
    Definition Classes
    VersionSpecificSerializingImports
  99. def rule_suite_group(ds: Dataset[CombinedRuleSuiteRows]): RuleSuiteGroup
    Definition Classes
    VersionSpecificSerializingImports
  100. def rule_suite_group(combined: Seq[CombinedRuleSuiteRows]): RuleSuiteGroup
    Definition Classes
    VersionSpecificSerializingImports
  101. val showGroupingTime: String
    Definition Classes
    RuleProcessingConstants
  102. val showSplitCompilationTime: String
    Definition Classes
    RuleProcessingConstants
  103. def toDS(ruleSuite: RuleSuite): Dataset[RuleRow]
    Definition Classes
    SerializingImports
  104. def toLambdaDS(ruleSuite: RuleSuite): Dataset[LambdaFunctionRow]
    Definition Classes
    SerializingImports
  105. def toOutputExpressionDS(ruleSuite: RuleSuite): Dataset[OutputExpressionRow]
    Definition Classes
    SerializingImports
  106. def toRuleSuiteDF(ruleSuite: RuleSuite): DataFrame
    Definition Classes
    SerializingImports
  107. def toRuleSuiteRow(ruleSuite: RuleSuite): (RuleSuiteRow, Option[OutputExpressionRow])
    Definition Classes
    SerializingImports
  108. def toString(): String
    Definition Classes
    Any
  109. val topLevelBooleanGrouper: String
    Definition Classes
    RuleProcessingConstants
  110. def typedExpressionRunner(ruleSuite: RuleSuite, ddlType: String, name: String, extraConfig: Map[String, String]): Column
    Definition Classes
    ExpressionRunnerImports
  111. val useEmptyRuleSetResults: String
    Definition Classes
    RuleProcessingConstants
  112. val useEvaluatedOnlyRuleSetResults: String
    Definition Classes
    RuleProcessingConstants
  113. object BloomModel extends Serializable
  114. object DefaultProcessor extends Serializable
  115. object ExpressionRule extends Serializable
  116. object LambdaFunction extends Serializable
  117. object NoOpDefaultProcessor
  118. object NoOpRunOnPassProcessor
  119. object OutputExpression
  120. object RegistrationFunction
  121. object ResultStatisticsProvider extends Serializable
  122. object RuleSuite extends Serializable
  123. object RunOnPassProcessor extends Serializable

Inherited from RuleProcessingConstants

Inherited from CollectRunnerImports

Inherited from VariableProcessIfMissing

Inherited from VersionSpecificSerializingImports

Inherited from ExpressionRunnerImports

Inherited from ViewLoading

Inherited from RuleFolderRunnerImports

Inherited from RuleEngineRunnerImports

Inherited from LambdaFunctionsImports

Inherited from AddDataFunctionsImports

Inherited from SerializingImports

Inherited from MapLookupImportsShared

Inherited from Serializable

Inherited from RuleRunnerImports

Inherited from AnyRef

Inherited from Any

Ungrouped