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.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(@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.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.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	FeatureGroupEngine.insertStream(StreamFeatureGroup streamFeatureGroup, Map<String,String> writeOptions)
BeamProducer	BeamEngine.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

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)