package quality
- Alphabetic
- By Inheritance
- quality
- RuleProcessingConstants
- CollectRunnerImports
- VariableProcessIfMissing
- VersionSpecificSerializingImports
- ExpressionRunnerImports
- ViewLoading
- RuleFolderRunnerImports
- RuleEngineRunnerImports
- LambdaFunctionsImports
- AddDataFunctionsImports
- SerializingImports
- MapLookupImportsShared
- Serializable
- RuleRunnerImports
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Package Members
Type Members
- trait BloomLookup extends AnyRef
Simple does it contain function to test a bloom
- 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
- trait ClassicOnly extends Annotation
- Annotations
- @Retention()
- trait DefaultProcessor extends HasRuleText with HasOutputExpression
Configuration of what should be evaluated when no trigger passes for Folder and Collector
- class EmptyForAPICompilation extends AnyRef
- trait ExpressionRule extends Serializable
A trigger rule
- trait HasOutputExpression extends Serializable
- trait HasRuleText extends Serializable
- 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()
- type IdTriple = (Id, Id, Id)
- Definition Classes
- LambdaFunctionsImports
- trait LambdaFunction extends HasRuleText
A user defined SQL function
- 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()
- 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()
- trait LazyRuleSuiteResult extends Serializable
A lazy proxy for RuleSuiteResult
- type MapCreator = () => (DataFrame, Column, Column)
- Definition Classes
- MapLookupImportsShared
- type MapLookups = String
- Definition Classes
- MapLookupImportsShared
- trait OutputExpression extends AnyRef
Used as a result of serializing
- sealed trait ResultStatisticsProvider[T, R] extends Serializable
- sealed trait ResultStatisticsProviderImpl[T <: ResultStatistics[_]] extends Serializable
- 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()
- case class RuleSet(id: Id, rules: Seq[Rule]) extends Serializable with Product
- Annotations
- @SerialVersionUID()
- 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()
- trait RunOnPassProcessor extends HasRuleText with HasOutputExpression
Configuration of what should be evaluated when a trigger passes and salience matches
- case class SparkBloomFilter(bloom: BloomFilter) extends BloomLookup with Product with Serializable
- 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
Concrete Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- Any
- final def ##: Int
- Definition Classes
- Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- Any
- val DefaultRuleInt: Int
- Definition Classes
- RuleRunnerImports
- val DefaultRuleSalience: Int
- Definition Classes
- RuleRunnerImports
- val DisabledRuleInt: Int
- Definition Classes
- RuleRunnerImports
- val FailedInt: Int
- Definition Classes
- RuleRunnerImports
- val IgnoredRuleInt: Int
- Definition Classes
- RuleRunnerImports
- val PassedInt: Int
- Definition Classes
- RuleRunnerImports
- val SoftFailedInt: Int
- Definition Classes
- RuleRunnerImports
- val UnevaluatedRuleInt: Int
- Definition Classes
- RuleRunnerImports
- def addDataQuality(dataFrame: DataFrame, rules: RuleSuite, name: String): DataFrame
- Definition Classes
- AddDataFunctionsImports
- def addDataQualityF(rules: RuleSuite, name: String): (DataFrame) => DataFrame
- Definition Classes
- AddDataFunctionsImports
- def addExpressionRunner(dataFrame: DataFrame, ruleSuite: RuleSuite, name: String, renderOptions: Map[String, String], ddlType: String, stripDDL: Boolean, postProcess: (DataFrame) => DataFrame): DataFrame
- Definition Classes
- AddDataFunctionsImports
- 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
- def addOverallResultsAndDetails(dataFrame: DataFrame, rules: RuleSuite, overallResult: String, resultDetails: String): DataFrame
- Definition Classes
- AddDataFunctionsImports
- def addOverallResultsAndDetailsF(rules: RuleSuite, overallResult: String, resultDetails: String): (DataFrame) => DataFrame
- Definition Classes
- AddDataFunctionsImports
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- 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
- 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
- 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
- def combine(ruleRows: Dataset[RuleRow], lambdaFunctionRows: Dataset[LambdaFunctionRow], outputExpressionRows: Dataset[OutputExpressionRow], ruleSuites: Dataset[RuleSuiteRow])(implicit encoder: Encoder[CombinedRuleSuiteRows]): Dataset[CombinedRuleSuiteRows]
- Definition Classes
- VersionSpecificSerializingImports
- def combine(ruleRows: Dataset[RuleRow])(implicit encoder: Encoder[CombinedRuleSuiteRows]): Dataset[CombinedRuleSuiteRows]
- Definition Classes
- VersionSpecificSerializingImports
- def combine(ruleRows: Dataset[RuleRow], lambdaFunctionRows: Dataset[LambdaFunctionRow])(implicit encoder: Encoder[CombinedRuleSuiteRows]): Dataset[CombinedRuleSuiteRows]
- Definition Classes
- VersionSpecificSerializingImports
- def combine(ruleRows: Dataset[RuleRow], lambdaFunctionRows: Dataset[LambdaFunctionRow], outputExpressionRows: Dataset[OutputExpressionRow])(implicit encoder: Encoder[CombinedRuleSuiteRows]): Dataset[CombinedRuleSuiteRows]
- Definition Classes
- VersionSpecificSerializingImports
- 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
- def combined_rows(ruleSuite: RuleSuite): Dataset[CombinedRuleSuiteRows]
- Definition Classes
- VersionSpecificSerializingImports
- def dqRuleRunner(ruleSuite: RuleSuite, variablesPerFunc: Int, variableFuncGroup: Int, extraConfig: Map[String, String]): Column
- Definition Classes
- RuleRunnerImports
- def equals(arg0: Any): Boolean
- Definition Classes
- Any
- def expressionRunner(ruleSuite: RuleSuite, name: String, renderOptions: Map[String, String], extraConfig: Map[String, String]): Column
- Definition Classes
- ExpressionRunnerImports
- 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
- 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
- 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
- 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
- def getConfig(name: String, default: String): String
- val groupProcessorAuditBucketStep: String
- Definition Classes
- RuleProcessingConstants
- val groupProcessorAuditLocation: String
- Definition Classes
- RuleProcessingConstants
- val groupProcessorAuditMaxBucket: String
- Definition Classes
- RuleProcessingConstants
- val groupProcessorAuditMinBucket: String
- Definition Classes
- RuleProcessingConstants
- val groupProcessorAuditName: String
- Definition Classes
- RuleProcessingConstants
- val groupProcessorBucketSizeKey: String
- Definition Classes
- RuleProcessingConstants
- val groupProcessorDumpAuditKey: String
- Definition Classes
- RuleProcessingConstants
- val groupProcessorKey: String
- Definition Classes
- RuleProcessingConstants
- val groupProcessorPercentFilter: String
- Definition Classes
- RuleProcessingConstants
- def hashCode(): Int
- Definition Classes
- Any
- def integrateLambdas(ruleSuiteMap: RuleSuiteMap, lambdas: Map[Id, Seq[LambdaFunction]], globalLibrary: Option[Id]): RuleSuiteMap
- Definition Classes
- SerializingImports
- def integrateMetaRuleSets(dataFrame: DataFrame, ruleSuiteMap: RuleSuiteMap, metaRuleSetMap: Map[Id, Seq[MetaRuleSetRow]], stablePosition: (String) => Int, transform: (DataFrame) => DataFrame): RuleSuiteMap
- Definition Classes
- SerializingImports
- def integrateOutputExpressions(ruleSuiteMap: RuleSuiteMap, outputs: Map[Id, Seq[OutputExpressionRow]], globalLibrary: Option[Id]): (RuleSuiteMap, Map[Id, Set[Rule]])
- Definition Classes
- SerializingImports
- def integrateRuleSuites(ruleSuiteMap: RuleSuiteMap, ruleSuites: Map[Id, RuleSuiteRow]): RuleSuiteMap
- Definition Classes
- SerializingImports
- def isAMissingRuleSuiteRule(rule: Rule): Boolean
- Definition Classes
- SerializingImports
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- 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
- def loadMapConfigs(loader: DataFrameLoader, viewDF: DataFrame, ruleSuiteId: Id, mapConfig: MapConfigColumns): (Seq[MapConfig], Set[String])
- Definition Classes
- MapLookupImportsShared
- 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
- def loadMaps(configs: Seq[MapConfig]): MapLookups
- Definition Classes
- MapLookupImportsShared
- def loadViewConfigs(loader: DataFrameLoader, viewDF: DataFrame, name: Column, token: Column, filter: Column, sql: Column): (Seq[ViewConfig], Set[String])
- Definition Classes
- ViewLoading
- def loadViewConfigs(loader: DataFrameLoader, viewDF: DataFrame, ruleSuiteId: Id, viewColumns: ViewConfigColumns): (Seq[ViewConfig], Set[String])
- Definition Classes
- ViewLoading
- 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
- def loadViews(viewConfigs: Seq[ViewConfig]): ViewLoadResults
- Definition Classes
- ViewLoading
- def mapLookupsFromDFs(creators: Map[String, MapCreator]): MapLookups
- Definition Classes
- MapLookupImportsShared
- def process_if_attribute_missing(ruleSuite: Column): String
- Definition Classes
- VariableProcessIfMissing
- def process_if_attribute_missing(ruleSuite: Column, schema: StructType): String
- Definition Classes
- VariableProcessIfMissing
- def process_if_attribute_missing(ruleSuite: Column, schema: StructType, stableName: String): String
- Definition Classes
- VariableProcessIfMissing
- def process_if_attribute_missing_col(ruleSuite: Column, schema: StructType, stableName: String): Column
- Definition Classes
- VariableProcessIfMissing
- def readLambdaRowsFromDF(lambdaFunctionDF: DataFrame, lambdaFunctionName: Column, lambdaFunctionExpression: Column, lambdaFunctionId: Column, lambdaFunctionVersion: Column, lambdaFunctionRuleSuiteId: Column, lambdaFunctionRuleSuiteVersion: Column): Dataset[LambdaFunctionRow]
- Definition Classes
- SerializingImports
- def readLambdasFromDF(lambdaFunctionDF: DataFrame, lambdaFunctionName: Column, lambdaFunctionExpression: Column, lambdaFunctionId: Column, lambdaFunctionVersion: Column, lambdaFunctionRuleSuiteId: Column, lambdaFunctionRuleSuiteVersion: Column): Map[Id, Seq[LambdaFunction]]
- Definition Classes
- SerializingImports
- def readMetaRuleSetsFromDF(metaRuleSetDF: DataFrame, columnSelectionExpression: Column, lambdaFunctionExpression: Column, metaRuleSetId: Column, metaRuleSetVersion: Column, metaRuleSuiteId: Column, metaRuleSuiteVersion: Column): Map[Id, Seq[MetaRuleSetRow]]
- Definition Classes
- SerializingImports
- def readOutputExpressionRowsFromDF(outputExpressionDF: DataFrame, outputExpression: Column, outputExpressionId: Column, outputExpressionVersion: Column, outputExpressionRuleSuiteId: Column, outputExpressionRuleSuiteVersion: Column): Dataset[OutputExpressionRow]
- Definition Classes
- SerializingImports
- def readOutputExpressionsFromDF(outputExpressionDF: DataFrame, outputExpression: Column, outputExpressionId: Column, outputExpressionVersion: Column, outputExpressionRuleSuiteId: Column, outputExpressionRuleSuiteVersion: Column): Map[Id, Seq[OutputExpressionRow]]
- Definition Classes
- SerializingImports
- 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
- 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
- def readRuleSuitesFromDF(ruleSuites: Dataset[RuleSuiteRow]): Map[Id, RuleSuiteRow]
- Definition Classes
- SerializingImports
- 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
- def readRulesFromDF(df: DataFrame, ruleSuiteId: Column, ruleSuiteVersion: Column, ruleSetId: Column, ruleSetVersion: Column, ruleId: Column, ruleVersion: Column, ruleExpr: Column): RuleSuiteMap
- Definition Classes
- SerializingImports
- def registerLambdaFunctions(functions: Seq[LambdaFunction]): Unit
- Definition Classes
- LambdaFunctionsImports
- def registerQualityFunctions(): Unit
- def registerTempViewNameFromDS[T](lambdaFunctionRows: Option[Dataset[T]]): String
- Attributes
- protected
- Definition Classes
- VersionSpecificSerializingImports
- def register_rule_suite(ruleSuite: RuleSuite): String
- Definition Classes
- VersionSpecificSerializingImports
- def register_rule_suite(ruleSuite: RuleSuite, stableName: String): String
- Definition Classes
- VersionSpecificSerializingImports
- def register_rule_suite_group(group: RuleSuiteGroup, stableName: String): String
- Definition Classes
- VersionSpecificSerializingImports
- def register_rule_suite_group(group: RuleSuiteGroup): String
- Definition Classes
- VersionSpecificSerializingImports
- def register_rule_suite_group_variable(ds: Dataset[CombinedRuleSuiteRows], stableName: String): String
- Definition Classes
- VersionSpecificSerializingImports
- def register_rule_suite_group_variable(ds: Dataset[CombinedRuleSuiteRows]): String
- Definition Classes
- VersionSpecificSerializingImports
- def register_rule_suite_variable(ds: Dataset[CombinedRuleSuiteRows], id: VersionedId, stableName: String): String
- Definition Classes
- VersionSpecificSerializingImports
- def register_rule_suite_variable(ds: Dataset[CombinedRuleSuiteRows], id: VersionedId): String
- Definition Classes
- VersionSpecificSerializingImports
- def ruleEngineRunner(ruleSuite: RuleSuite, resultDataType: DataType): Column
- Definition Classes
- RuleEngineRunnerImports
- def ruleEngineRunner(ruleSuite: RuleSuite, resultDataType: DataType, debugMode: Boolean): Column
- Definition Classes
- RuleEngineRunnerImports
- 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
- def ruleEngineWithStruct(dataFrame: DataFrame, rules: RuleSuite, outputType: DataType, ruleEngineFieldName: String, alias: String, debugMode: Boolean): DataFrame
- Definition Classes
- AddDataFunctionsImports
- def ruleEngineWithStructF[P[R] >: Dataset[R]](rules: RuleSuite, outputType: DataType, ruleEngineFieldName: String, alias: String, debugMode: Boolean): (P[Row]) => P[Row]
- Definition Classes
- AddDataFunctionsImports
- def ruleEngineWithStructFOT[P[R] >: Dataset[R]](rules: RuleSuite, outputType: Option[DataType], ruleEngineFieldName: String, alias: String, debugMode: Boolean): (P[Row]) => P[Row]
- Definition Classes
- AddDataFunctionsImports
- def ruleEngineWithStructOT(dataFrame: DataFrame, rules: RuleSuite, outputType: Option[DataType], ruleEngineFieldName: String, alias: String, debugMode: Boolean): DataFrame
- Definition Classes
- AddDataFunctionsImports
- def ruleFolderRunner(ruleSuite: RuleSuite, startingStruct: Column, debugMode: Boolean, variablesPerFunc: Int, variableFuncGroup: Int, useType: Option[StructType], extraConfig: Map[String, String]): Column
- Definition Classes
- RuleFolderRunnerImports
- def ruleRunner(ruleSuite: RuleSuite, variablesPerFunc: Int, variableFuncGroup: Int, extraConfig: Map[String, String]): Column
- Definition Classes
- RuleRunnerImports
- def rule_suite(ds: Dataset[CombinedRuleSuiteRows], id: VersionedId): Option[RuleSuite]
- Definition Classes
- VersionSpecificSerializingImports
- def rule_suite(row: CombinedRuleSuiteRows): RuleSuite
- Definition Classes
- VersionSpecificSerializingImports
- def rule_suite_from(ruleSuiteGroupName: String, ruleSuiteId: Int, ruleSuiteVersion: Int): Column
- Definition Classes
- VersionSpecificSerializingImports
- def rule_suite_from(ruleSuiteGroupName: String, ruleSuiteId: Int): Column
- Definition Classes
- VersionSpecificSerializingImports
- def rule_suite_group(ds: Dataset[CombinedRuleSuiteRows]): RuleSuiteGroup
- Definition Classes
- VersionSpecificSerializingImports
- def rule_suite_group(combined: Seq[CombinedRuleSuiteRows]): RuleSuiteGroup
- Definition Classes
- VersionSpecificSerializingImports
- val showGroupingTime: String
- Definition Classes
- RuleProcessingConstants
- val showSplitCompilationTime: String
- Definition Classes
- RuleProcessingConstants
- def toDS(ruleSuite: RuleSuite): Dataset[RuleRow]
- Definition Classes
- SerializingImports
- def toLambdaDS(ruleSuite: RuleSuite): Dataset[LambdaFunctionRow]
- Definition Classes
- SerializingImports
- def toOutputExpressionDS(ruleSuite: RuleSuite): Dataset[OutputExpressionRow]
- Definition Classes
- SerializingImports
- def toRuleSuiteDF(ruleSuite: RuleSuite): DataFrame
- Definition Classes
- SerializingImports
- def toRuleSuiteRow(ruleSuite: RuleSuite): (RuleSuiteRow, Option[OutputExpressionRow])
- Definition Classes
- SerializingImports
- def toString(): String
- Definition Classes
- Any
- val topLevelBooleanGrouper: String
- Definition Classes
- RuleProcessingConstants
- def typedExpressionRunner(ruleSuite: RuleSuite, ddlType: String, name: String, extraConfig: Map[String, String]): Column
- Definition Classes
- ExpressionRunnerImports
- val useEmptyRuleSetResults: String
- Definition Classes
- RuleProcessingConstants
- val useEvaluatedOnlyRuleSetResults: String
- Definition Classes
- RuleProcessingConstants
- object BloomModel extends Serializable
- object DefaultProcessor extends Serializable
- object ExpressionRule extends Serializable
- object LambdaFunction extends Serializable
- object NoOpDefaultProcessor
- object NoOpRunOnPassProcessor
- object OutputExpression
- object RegistrationFunction
- object ResultStatisticsProvider extends Serializable
- object RuleSuite extends Serializable
- object RunOnPassProcessor extends Serializable