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	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, DataSource dataSource)
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, DataSource dataSource, OnlineConfig onlineConfig)
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, 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	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, DataSource dataSource, OnlineConfig onlineConfig)
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, OnlineConfig onlineConfig)
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	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	Description
BeamProducer	BeamEngine.insertStream(StreamFeatureGroup streamFeatureGroup, Map<String,String> writeOptions)
BeamProducer	FeatureGroupEngine.insertStream(StreamFeatureGroup streamFeatureGroup, Map<String,String> writeOptions)
void	FeatureGroupEngine.save(StreamFeatureGroup featureGroup, List<String> partitionKeys, String precombineKeyName, Map<String,String> writeOptions, JobConfiguration materializationJobConfiguration)

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

Modifier	Constructor	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)