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

Packages that use StreamFeatureGroup

Package	Description
com.logicalclocks.hsfs.beam
com.logicalclocks.hsfs.beam.engine

Uses of StreamFeatureGroup in com.logicalclocks.hsfs.beam

Methods in com.logicalclocks.hsfs.beam 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, TimeTravelFormat timeTravelFormat, StatisticsConfig statisticsConfig, String eventTime, OnlineConfig onlineConfig)
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.beam.engine

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

Modifier and Type	Method and Description
StreamFeatureGroup	FeatureGroupEngine.getStreamFeatureGroup(FeatureStore featureStore, String fgName, Integer fgVersion)

Methods in com.logicalclocks.hsfs.beam.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.beam.engine with parameters of type StreamFeatureGroup

Modifier and Type	Method and Description
BeamProducer	BeamEngine.insertStream(StreamFeatureGroup streamFeatureGroup, Map<String,String> writeOptions)
BeamProducer	FeatureGroupEngine.insertStream(StreamFeatureGroup streamFeatureGroup, Map<String,String> writeOptions)

Constructors in com.logicalclocks.hsfs.beam.engine with parameters of type StreamFeatureGroup

Constructor and Description
BeamProducer(String topic, Map<String,String> properties, org.apache.avro.Schema schema, org.apache.avro.Schema encodedSchema, Map<String,org.apache.avro.Schema> deserializedComplexFeatureSchemas, List<String> primaryKeys, StreamFeatureGroup streamFeatureGroup)