| Package | Description | 
|---|---|
| com.logicalclocks.hsfs | |
| com.logicalclocks.hsfs.constructor | |
| com.logicalclocks.hsfs.spark | |
| com.logicalclocks.hsfs.spark.constructor | |
| com.logicalclocks.hsfs.spark.engine | 
| Modifier and Type | Method and Description | 
|---|---|
static Storage | 
Storage.valueOf(String name)
Returns the enum constant of this type with the specified name. 
 | 
static Storage[] | 
Storage.values()
Returns an array containing the constants of this enum type, in
the order they are declared. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
String | 
FsQueryBase.getStorageQuery(Storage storage)  | 
<T2> String | 
QueryBase.sql(Storage storage,
   Class<T2> fsQueryType)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
ExternalFeatureGroup.insert(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> featureData,
      Storage storage)  | 
void | 
FeatureGroup.insert(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> featureData,
      Storage storage)
Incrementally insert data to a feature group or overwrite all data contained in the feature group. 
 | 
void | 
StreamFeatureGroup.insert(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> featureData,
      Storage storage)  | 
void | 
FeatureGroup.insert(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> featureData,
      Storage storage,
      boolean overwrite)
Incrementally insert data to a feature group or overwrite all  data contained in the feature group. 
 | 
void | 
StreamFeatureGroup.insert(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> featureData,
      Storage storage,
      boolean overwrite)  | 
void | 
FeatureGroup.insert(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> featureData,
      Storage storage,
      boolean overwrite,
      HudiOperationType operation,
      Map<String,String> writeOptions)
Incrementally insert data to a feature group or overwrite all  data contained in the feature group. 
 | 
void | 
StreamFeatureGroup.insert(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> featureData,
      Storage storage,
      boolean overwrite,
      HudiOperationType operation,
      Map<String,String> writeOptions)  | 
| Modifier and Type | Method and Description | 
|---|---|
String | 
Query.sql(Storage storage)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
FeatureGroupEngine.insert(FeatureGroup featureGroup,
      org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> featureData,
      Storage storage,
      HudiOperationType operation,
      org.apache.spark.sql.SaveMode saveMode,
      List<String> partitionKeys,
      String hudiPrecombineKey,
      Map<String,String> writeOptions)  | 
void | 
FeatureGroupEngine.saveDataframe(FeatureGroup featureGroup,
             org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> dataset,
             Storage storage,
             HudiOperationType operation,
             Map<String,String> offlineWriteOptions,
             Map<String,String> onlineWriteOptions,
             Integer validationId)  | 
Copyright © 2025. All rights reserved.