Package | Description |
---|---|
com.logicalclocks.hsfs.spark.engine | |
com.logicalclocks.hsfs.spark.engine.hudi |
Modifier and Type | Method and Description |
---|---|
void |
SparkEngine.registerHudiTemporaryTable(FeatureGroupAlias featureGroupAlias,
Map<String,String> readOptions) |
Modifier and Type | Method and Description |
---|---|
void |
HudiEngine.reconcileHudiSchema(org.apache.spark.sql.SparkSession sparkSession,
FeatureGroupAlias featureGroupAlias,
Map<String,String> hudiArgs) |
void |
HudiEngine.registerTemporaryTable(org.apache.spark.sql.SparkSession sparkSession,
FeatureGroupAlias featureGroupAlias,
Map<String,String> readOptions) |
Copyright © 2023. All rights reserved.