| Package | Description | 
|---|---|
| com.logicalclocks.hsfs.flink | |
| com.logicalclocks.hsfs.flink.engine | 
| Modifier and Type | Method and Description | 
|---|---|
FeatureStore | 
HopsworksConnection.getFeatureStore()
Retrieve the project feature store. 
 | 
FeatureStore | 
HopsworksConnection.getFeatureStore(String name)
Retrieve a feature store based on name. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
FeatureView.clean(FeatureStore featureStore,
     String s,
     Integer integer)  | 
| Constructor and Description | 
|---|
StreamFeatureGroup(FeatureStore featureStore,
                  int id)  | 
StreamFeatureGroup(FeatureStore featureStore,
                  @NonNull String name,
                  Integer version,
                  String description,
                  List<String> primaryKeys,
                  List<String> partitionKeys,
                  String hudiPrecombineKey,
                  boolean onlineEnabled,
                  List<Feature> features,
                  StatisticsConfig statisticsConfig,
                  String onlineTopicName,
                  String eventTime)  | 
| Modifier and Type | Method and Description | 
|---|---|
FeatureView | 
FeatureViewEngine.get(FeatureStore featureStore,
   String name,
   Integer version)  | 
FeatureView | 
FeatureViewEngine.getOrCreateFeatureView(FeatureStore featureStore,
                      String name,
                      Integer version,
                      com.logicalclocks.hsfs.flink.constructor.Query query,
                      String description,
                      List<String> labels)  | 
StreamFeatureGroup | 
FeatureGroupEngine.getStreamFeatureGroup(FeatureStore featureStore,
                     String fgName,
                     Integer fgVersion)  | 
List<StreamFeatureGroup> | 
FeatureGroupEngine.getStreamFeatureGroups(FeatureStore featureStore,
                      String fgName)  | 
Copyright © 2023. All rights reserved.