Uses of Class
com.logicalclocks.hsfs.flink.StreamFeatureGroup

Packages that use StreamFeatureGroup

Package	Description
com.logicalclocks.hsfs.flink
com.logicalclocks.hsfs.flink.engine

Uses of StreamFeatureGroup in com.logicalclocks.hsfs.flink

Methods in com.logicalclocks.hsfs.flink that return StreamFeatureGroup

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.

Uses of StreamFeatureGroup in com.logicalclocks.hsfs.flink.engine

Methods in com.logicalclocks.hsfs.flink.engine that return StreamFeatureGroup

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)

Methods in com.logicalclocks.hsfs.flink.engine that return types with arguments of type StreamFeatureGroup

Modifier and Type	Method and Description
List<StreamFeatureGroup>	FeatureGroupEngine.getStreamFeatureGroups(FeatureStore featureStore, String fgName)

Methods in com.logicalclocks.hsfs.flink.engine with parameters of type StreamFeatureGroup

Modifier and Type	Method and Description
org.apache.flink.streaming.api.datastream.DataStreamSink<?>	FeatureGroupEngine.insertStream(StreamFeatureGroup streamFeatureGroup, org.apache.flink.streaming.api.datastream.DataStream<?> featureData, Map<String,String> writeOptions)
void	FeatureGroupEngine.save(StreamFeatureGroup featureGroup, List<String> partitionKeys, String precombineKeyName, Map<String,String> writeOptions, JobConfiguration materializationJobConfiguration)
org.apache.flink.streaming.api.datastream.DataStreamSink<?>	FlinkEngine.writeDataStream(StreamFeatureGroup streamFeatureGroup, org.apache.flink.streaming.api.datastream.DataStream<?> dataStream, Map<String,String> writeOptions)