| Package | Description |
|---|---|
| com.logicalclocks.hsfs.metadata | |
| com.logicalclocks.hsfs.spark.engine | |
| com.logicalclocks.hsfs.spark.engine.hudi |
| Modifier and Type | Method and Description |
|---|---|
FeatureGroupCommit |
FeatureGroupApi.featureGroupCommit(FeatureGroupBase featureGroup,
FeatureGroupCommit featureGroupCommit) |
| Modifier and Type | Method and Description |
|---|---|
List<FeatureGroupCommit> |
FeatureGroupApi.getCommitDetails(FeatureGroupBase featureGroupBase,
Long wallclockTimestamp,
Integer limit) |
| Modifier and Type | Method and Description |
|---|---|
FeatureGroupCommit |
FeatureGroupApi.featureGroupCommit(FeatureGroupBase featureGroup,
FeatureGroupCommit featureGroupCommit) |
| Modifier and Type | Method and Description |
|---|---|
FeatureGroupCommit |
FeatureGroupEngine.commitDelete(FeatureGroupBase featureGroupBase,
org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> genericDataset,
Map<String,String> writeOptions) |
| Modifier and Type | Method and 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) |
Copyright © 2025. All rights reserved.