Uses of Class
com.logicalclocks.hsfs.StreamFeatureGroup
Packages that use StreamFeatureGroup
Package
Description
-
Uses of StreamFeatureGroup in com.logicalclocks.hsfs
Methods in com.logicalclocks.hsfs that return StreamFeatureGroupModifier and TypeMethodDescriptionFeatureStore.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) 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) 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) 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) FeatureStore.getStreamFeatureGroup(@NonNull String name, @NonNull Integer version) Get a stream feature group object from the feature store.FeatureStore.getStreamFeatureGroup(String name) Get a stream feature group object from the feature store.Constructors in com.logicalclocks.hsfs with parameters of type StreamFeatureGroupModifierConstructorDescriptionTrainingDatasetFeature(StreamFeatureGroup featuregroup, String name, Boolean label) -
Uses of StreamFeatureGroup in com.logicalclocks.hsfs.constructor
Constructors in com.logicalclocks.hsfs.constructor with parameters of type StreamFeatureGroupModifierConstructorDescriptionQuery(StreamFeatureGroup leftFeatureGroup, List<Feature> leftFeatures) -
Uses of StreamFeatureGroup in com.logicalclocks.hsfs.engine
Methods in com.logicalclocks.hsfs.engine that return StreamFeatureGroupModifier and TypeMethodDescriptionFeatureGroupEngine.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) 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) FeatureGroupEngine.getStreamFeatureGroup(FeatureStore featureStore, String fgName, Integer fgVersion) Methods in com.logicalclocks.hsfs.engine that return types with arguments of type StreamFeatureGroupModifier and TypeMethodDescriptionFeatureGroupEngine.getStreamFeatureGroups(FeatureStore featureStore, String fgName) Methods in com.logicalclocks.hsfs.engine with parameters of type StreamFeatureGroupModifier and TypeMethodDescriptionFeatureGroupEngine.insertStream(StreamFeatureGroup streamFeatureGroup, List<T> featureData, Map<String, String> writeOptions) voidFeatureGroupEngine.save(StreamFeatureGroup featureGroup, List<String> partitionKeys, String precombineKeyName, Map<String, String> writeOptions, JobConfiguration materializationJobConfiguration) Engine.writeStream(StreamFeatureGroup streamFeatureGroup, List<T> featureData, Map<String, String> writeOptions)