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.getOrCreateStreamFeatureGroup(String name, Integer version)
StreamFeatureGroup	FeatureStore.getOrCreateStreamFeatureGroup(String name, Integer version, List<String> primaryKeys, boolean onlineEnabled, String eventTime)
StreamFeatureGroup	FeatureStore.getOrCreateStreamFeatureGroup(String name, Integer version, List<String> primaryKeys, List<String> partitionKeys, boolean onlineEnabled, String eventTime)
StreamFeatureGroup	FeatureStore.getOrCreateStreamFeatureGroup(String name, Integer version, String description, List<String> primaryKeys, List<String> partitionKeys, String hudiPrecombineKey, boolean onlineEnabled, StatisticsConfig statisticsConfig, String eventTime)
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.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)
org.apache.flink.streaming.api.datastream.DataStreamSink<?>	FlinkEngine.writeDataStream(StreamFeatureGroup streamFeatureGroup, org.apache.flink.streaming.api.datastream.DataStream<?> dataStream, Map<String,String> writeOptions)