Uses of Class
com.dataai.etl.spark.core.DataAiPipeline

Uses of DataAiPipeline in com.dataai.etl.spark.core

Methods in com.dataai.etl.spark.core that return DataAiPipeline

Modifier and Type	Method	Description
static DataAiPipeline	DataAiPipeline.fromDataset(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> source)
static DataAiPipeline	DataAiPipeline.fromTable(org.apache.spark.sql.SparkSession spark, String table)
DataAiPipeline	DataAiPipeline.normalize()
DataAiPipeline	DataAiPipeline.profile()
DataAiPipeline	DataAiPipeline.recordKey(String... fields)
DataAiPipeline	DataAiPipeline.validate(com.dataai.etl.spark.api.RuleSpec... rules)
DataAiPipeline	DataAiPipeline.validate(List<com.dataai.etl.spark.api.RuleSpec> rules)