Package | Description |
---|---|
com.logicalclocks.hsfs | |
com.logicalclocks.hsfs.engine |
Modifier and Type | Method and Description |
---|---|
StreamFeatureGroup |
FeatureStore.createStreamFeatureGroup(@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) |
StreamFeatureGroup |
FeatureStore.getOrCreateStreamFeatureGroup(@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) |
StreamFeatureGroup |
FeatureStore.getStreamFeatureGroup(String name)
Get a stream feature group object from the feature store.
|
StreamFeatureGroup |
FeatureStore.getStreamFeatureGroup(@NonNull String name,
@NonNull Integer version)
Get a stream feature group object from the feature store.
|
Constructor and Description |
---|
TrainingDatasetFeature(StreamFeatureGroup featuregroup,
String name,
Boolean label) |
Modifier and Type | Method and Description |
---|---|
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) |
StreamFeatureGroup |
FeatureGroupEngine.getStreamFeatureGroup(FeatureStore featureStore,
String fgName,
Integer fgVersion) |
Modifier and Type | Method and Description |
---|---|
List<StreamFeatureGroup> |
FeatureGroupEngine.getStreamFeatureGroups(FeatureStore featureStore,
String fgName) |
Modifier and Type | Method and Description |
---|---|
List<Object> |
FeatureGroupEngine.insertStream(StreamFeatureGroup streamFeatureGroup,
List<T> featureData,
Map<String,String> writeOptions) |
void |
FeatureGroupEngine.save(StreamFeatureGroup featureGroup,
List<String> partitionKeys,
String precombineKeyName,
Map<String,String> writeOptions,
JobConfiguration materializationJobConfiguration) |
List<T> |
Engine.writeStream(StreamFeatureGroup streamFeatureGroup,
List<T> featureData,
Map<String,String> writeOptions) |
Copyright © 2025. All rights reserved.