| 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. 
 | 
| Constructor and Description | 
|---|
FeatureView(@NonNull String name,
           Integer version,
           @NonNull com.logicalclocks.hsfs.flink.constructor.Query query,
           String description,
           @NonNull FeatureStore featureStore,
           List<String> labels)  | 
FeatureViewBuilder(FeatureStore featureStore)  | 
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,
                  TimeTravelFormat timeTravelFormat,
                  List<Feature> features,
                  StatisticsConfig statisticsConfig,
                  String onlineTopicName,
                  String topicName,
                  String notificationTopicName,
                  String eventTime,
                  OnlineConfig onlineConfig,
                  StorageConnector storageConnector,
                  String path)  | 
| Modifier and Type | Method and Description | 
|---|---|
FeatureView | 
FeatureViewEngine.get(FeatureStore featureStore,
   String name,
   Integer version)  | 
StreamFeatureGroup | 
FeatureGroupEngine.getOrCreateFeatureGroup(FeatureStore featureStore,
                       @NonNull String name,
                       Integer version,
                       String description,
                       Boolean onlineEnabled,
                       TimeTravelFormat timeTravelFormat,
                       List<String> primaryKeys,
                       List<String> partitionKeys,
                       String eventTime,
                       String hudiPrecombineKey,
                       List<Feature> features,
                       StatisticsConfig statisticsConfig,
                       StorageConnector storageConnector,
                       String path,
                       OnlineConfig onlineConfig)  | 
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 © 2025. All rights reserved.