Uses of Class
com.logicalclocks.hsfs.FeatureGroupCommit

Packages that use FeatureGroupCommit

Package	Description
com.logicalclocks.hsfs.metadata
com.logicalclocks.hsfs.spark.engine
com.logicalclocks.hsfs.spark.engine.hudi

Uses of FeatureGroupCommit in com.logicalclocks.hsfs.metadata

Methods in com.logicalclocks.hsfs.metadata that return FeatureGroupCommit

Modifier and Type	Method	Description
FeatureGroupCommit	FeatureGroupApi.featureGroupCommit(FeatureGroupBase featureGroup, FeatureGroupCommit featureGroupCommit)

Methods in com.logicalclocks.hsfs.metadata that return types with arguments of type FeatureGroupCommit

Modifier and Type	Method	Description
List<FeatureGroupCommit>	FeatureGroupApi.getCommitDetails(FeatureGroupBase featureGroupBase, Long wallclockTimestamp, Integer limit)

Methods in com.logicalclocks.hsfs.metadata with parameters of type FeatureGroupCommit

Modifier and Type	Method	Description
FeatureGroupCommit	FeatureGroupApi.featureGroupCommit(FeatureGroupBase featureGroup, FeatureGroupCommit featureGroupCommit)

Uses of FeatureGroupCommit in com.logicalclocks.hsfs.spark.engine

Methods in com.logicalclocks.hsfs.spark.engine that return FeatureGroupCommit

Modifier and Type	Method	Description
FeatureGroupCommit	FeatureGroupEngine.commitDelete(FeatureGroupBase featureGroupBase, org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> genericDataset, Map<String,String> writeOptions)
FeatureGroupCommit	FeatureGroupEngine.commitDelete(FeatureGroupBase featureGroupBase, org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> genericDataset, Map<String,String> writeOptions, Storage storage)	Deletes the records in genericDataset from the storage named by storage.

Uses of FeatureGroupCommit in com.logicalclocks.hsfs.spark.engine.hudi

Methods in com.logicalclocks.hsfs.spark.engine.hudi that return FeatureGroupCommit

Modifier and Type	Method	Description
FeatureGroupCommit	HudiEngine.deleteRecord(org.apache.spark.sql.SparkSession sparkSession, FeatureGroupBase featureGroup, org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> deleteDF, Map<String,String> writeOptions)