| 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,
                  List<Feature> features,
                  TimeTravelFormat timeTravelFormat,
                  StatisticsConfig statisticsConfig,
                  String onlineTopicName,
                  String topicName,
                  String notificationTopicName,
                  String eventTime,
                  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) | 
| 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.