| Package | Description | 
|---|---|
| com.logicalclocks.hsfs | |
| com.logicalclocks.hsfs.flink | |
| com.logicalclocks.hsfs.spark | |
| com.logicalclocks.hsfs.spark.engine | 
| Modifier and Type | Field and Description | 
|---|---|
protected TimeTravelFormat | 
FeatureGroupBase.timeTravelFormat  | 
| Modifier and Type | Method and Description | 
|---|---|
static TimeTravelFormat | 
TimeTravelFormat.valueOf(String name)
Returns the enum constant of this type with the specified name. 
 | 
static TimeTravelFormat[] | 
TimeTravelFormat.values()
Returns an array containing the constants of this enum type, in
the order they are declared. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
abstract Object | 
FeatureStoreBase.getOrCreateFeatureGroup(String name,
                       Integer version,
                       String description,
                       List<String> primaryKeys,
                       List<String> partitionKeys,
                       String hudiPrecombineKey,
                       boolean onlineEnabled,
                       TimeTravelFormat timeTravelFormat,
                       StatisticsConfig statisticsConfig,
                       String eventTime)  | 
| Modifier and Type | Method and Description | 
|---|---|
Object | 
FeatureStore.getOrCreateFeatureGroup(String name,
                       Integer version,
                       String description,
                       List<String> primaryKeys,
                       List<String> partitionKeys,
                       String hudiPrecombineKey,
                       boolean onlineEnabled,
                       TimeTravelFormat timeTravelFormat,
                       StatisticsConfig statisticsConfig,
                       String eventTime)  | 
| Modifier and Type | Method and Description | 
|---|---|
FeatureGroup | 
FeatureStore.getOrCreateFeatureGroup(String name,
                       Integer version,
                       String description,
                       List<String> primaryKeys,
                       List<String> partitionKeys,
                       String hudiPrecombineKey,
                       boolean onlineEnabled,
                       TimeTravelFormat timeTravelFormat,
                       StatisticsConfig statisticsConfig,
                       String eventTime)
Get feature group metadata object or create a new one if it doesn't exist. 
 | 
| Constructor and Description | 
|---|
FeatureGroup(FeatureStore featureStore,
            @NonNull String name,
            Integer version,
            String description,
            List<String> primaryKeys,
            List<String> partitionKeys,
            String hudiPrecombineKey,
            boolean onlineEnabled,
            TimeTravelFormat timeTravelFormat,
            List<Feature> features,
            StatisticsConfig statisticsConfig,
            String onlineTopicName,
            String eventTime)  | 
| Modifier and Type | Method and Description | 
|---|---|
FeatureGroup | 
FeatureGroupEngine.getOrCreateFeatureGroup(FeatureStore featureStore,
                       String name,
                       Integer version,
                       String description,
                       List<String> primaryKeys,
                       List<String> partitionKeys,
                       String hudiPrecombineKey,
                       boolean onlineEnabled,
                       TimeTravelFormat timeTravelFormat,
                       StatisticsConfig statisticsConfig,
                       String eventTime)  | 
List<Feature> | 
SparkEngine.parseFeatureGroupSchema(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> dataset,
                       TimeTravelFormat timeTravelFormat)  | 
Copyright © 2023. All rights reserved.