Uses of Class
com.logicalclocks.hsfs.Feature

Packages that use Feature

Package	Description
com.logicalclocks.hsfs
com.logicalclocks.hsfs.beam
com.logicalclocks.hsfs.beam.engine
com.logicalclocks.hsfs.constructor
com.logicalclocks.hsfs.engine
com.logicalclocks.hsfs.flink
com.logicalclocks.hsfs.flink.engine
com.logicalclocks.hsfs.spark
com.logicalclocks.hsfs.spark.constructor
com.logicalclocks.hsfs.spark.engine

Uses of Feature in com.logicalclocks.hsfs

Fields in com.logicalclocks.hsfs with type parameters of type Feature

Modifier and Type	Field and Description
protected List<Feature>	FeatureGroupBase.features

Methods in com.logicalclocks.hsfs that return Feature

Modifier and Type	Method and Description
Feature	FeatureGroupBase.getFeature(String name) Retrieve a feature of the feature group by name.

Methods in com.logicalclocks.hsfs with parameters of type Feature

Modifier and Type	Method and Description
Filter	Feature.eq(Feature value)
Filter	Feature.ge(Feature value)
Filter	Feature.gt(Feature value)
Filter	Feature.le(Feature value)
Filter	Feature.lt(Feature value)
Filter	Feature.ne(Feature value)

Method parameters in com.logicalclocks.hsfs with type arguments of type Feature

Modifier and Type	Method and Description
abstract FeatureGroupBase	FeatureStoreBase.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) Create a feature group object.
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)
abstract FeatureGroupBase	FeatureStoreBase.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) Get a feature group metadata object or create a new one if it doesn't exists.
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)
Query	StreamFeatureGroup.selectExceptFeatures(List<Feature> features) Select all features including primary key and event time feature of the feature group except provided `features` and return a query object.
Query	StreamFeatureGroup.selectFeatures(List<Feature> features) Select a subset of features of the feature group and return a query object.

Constructor parameters in com.logicalclocks.hsfs with type arguments of type Feature

Constructor and Description
StreamFeatureGroup(FeatureStoreBase featureStore, @NonNull String name, Integer version, String description, TimeTravelFormat timeTravelFormat, List<String> primaryKeys, List<String> partitionKeys, String hudiPrecombineKey, boolean onlineEnabled, List<Feature> features, StatisticsConfig statisticsConfig, String onlineTopicName, String eventTime, StorageConnector storageConnector, String path, OnlineConfig onlineConfig)
StreamFeatureGroup(Integer id, String description, List<Feature> features)

Uses of Feature in com.logicalclocks.hsfs.beam

Method parameters in com.logicalclocks.hsfs.beam with type arguments of type Feature

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, OnlineConfig onlineConfig)
com.logicalclocks.hsfs.beam.constructor.Query	StreamFeatureGroup.selectExceptFeatures(List<Feature> features) Select all features including primary key and event time feature of the feature group except provided `features` and return a query object.
com.logicalclocks.hsfs.beam.constructor.Query	StreamFeatureGroup.selectFeatures(List<Feature> features) Select a subset of features of the feature group and return a query object.

Constructor parameters in com.logicalclocks.hsfs.beam with type arguments of type Feature

Constructor and Description
StreamFeatureGroup(FeatureStore featureStore, @NonNull String name, Integer version, String description, List<String> primaryKeys, List<String> partitionKeys, String hudiPrecombineKey, boolean onlineEnabled, TimeTravelFormat timeTravelFormat, List<Feature> features, StatisticsConfig statisticsConfig, String onlineTopicName, String eventTime, OnlineConfig onlineConfig, StorageConnector storageConnector, String path)
StreamFeatureGroup(Integer id, String description, List<Feature> features)

Uses of Feature in com.logicalclocks.hsfs.beam.engine

Method parameters in com.logicalclocks.hsfs.beam.engine with type arguments of type Feature

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, OnlineConfig onlineConfig)

Uses of Feature in com.logicalclocks.hsfs.constructor

Fields in com.logicalclocks.hsfs.constructor with type parameters of type Feature

Modifier and Type	Field and Description
protected List<Feature>	QueryBase.leftFeatures

Methods in com.logicalclocks.hsfs.constructor with parameters of type Feature

Modifier and Type	Method and Description
T	QueryBase.appendFeature(Feature feature)

Method parameters in com.logicalclocks.hsfs.constructor with type arguments of type Feature

Modifier and Type	Method and Description
T	QueryBase.joinFeatures(T subquery, List<Feature> on)
T	QueryBase.joinFeatures(T subquery, List<Feature> on, JoinType joinType)
T	QueryBase.joinFeatures(T subquery, List<Feature> on, JoinType joinType, String prefix)
T	QueryBase.joinFeatures(T subquery, List<Feature> leftOn, List<Feature> rightOn)
T	QueryBase.joinFeatures(T subquery, List<Feature> leftOn, List<Feature> rightOn)
T	QueryBase.joinFeatures(T subquery, List<Feature> leftOn, List<Feature> rightOn, JoinType joinType)
T	QueryBase.joinFeatures(T subquery, List<Feature> leftOn, List<Feature> rightOn, JoinType joinType)
T	QueryBase.joinFeatures(T subquery, List<Feature> leftOn, List<Feature> rightOn, JoinType joinType, String prefix)
T	QueryBase.joinFeatures(T subquery, List<Feature> leftOn, List<Feature> rightOn, JoinType joinType, String prefix)
T	QueryBase.joinFeatures(T subquery, List<Feature> leftOn, List<Feature> rightOn, String prefix)
T	QueryBase.joinFeatures(T subquery, List<Feature> leftOn, List<Feature> rightOn, String prefix)
T	QueryBase.joinFeatures(T subquery, List<Feature> on, String prefix)

Constructor parameters in com.logicalclocks.hsfs.constructor with type arguments of type Feature

Constructor and Description
Join(T query, List<Feature> on, JoinType type, String prefix)
Join(T query, List<Feature> leftOn, List<Feature> rightOn, JoinType type, String prefix)
Join(T query, List<Feature> leftOn, List<Feature> rightOn, JoinType type, String prefix)
Query(StreamFeatureGroup leftFeatureGroup, List<Feature> leftFeatures)
QueryBase(FeatureGroupBase leftFeatureGroup, List<Feature> leftFeatures)

Uses of Feature in com.logicalclocks.hsfs.engine

Method parameters in com.logicalclocks.hsfs.engine with type arguments of type Feature

Modifier and Type	Method and Description
List<String>	FeatureGroupUtils.getComplexFeatures(List<Feature> features)
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)
<T extends FeatureGroupBase> void	FeatureGroupEngineBase.updateFeatures(FeatureGroupBase featureGroup, List<Feature> features, Class<T> fgClass)

Uses of Feature in com.logicalclocks.hsfs.flink

Method parameters in com.logicalclocks.hsfs.flink with type arguments of type Feature

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, OnlineConfig onlineConfig)
com.logicalclocks.hsfs.flink.constructor.Query	StreamFeatureGroup.selectExceptFeatures(List<Feature> features) Select all features including primary key and event time feature of the feature group except provided `features` and return a query object.
com.logicalclocks.hsfs.flink.constructor.Query	StreamFeatureGroup.selectFeatures(List<Feature> features) Select a subset of features of the feature group and return a query object.

Constructor parameters in com.logicalclocks.hsfs.flink with type arguments of type Feature

Constructor and Description
StreamFeatureGroup(FeatureStore featureStore, @NonNull String name, Integer version, String description, List<String> primaryKeys, List<String> partitionKeys, String hudiPrecombineKey, boolean onlineEnabled, TimeTravelFormat timeTravelFormat, List<Feature> features, StatisticsConfig statisticsConfig, String onlineTopicName, String topicName, String notificationTopicName, String eventTime, OnlineConfig onlineConfig, StorageConnector storageConnector, String path)
StreamFeatureGroup(Integer id, String description, List<Feature> features)

Uses of Feature in com.logicalclocks.hsfs.flink.engine

Method parameters in com.logicalclocks.hsfs.flink.engine with type arguments of type Feature

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, OnlineConfig onlineConfig)

Uses of Feature in com.logicalclocks.hsfs.spark

Methods in com.logicalclocks.hsfs.spark with parameters of type Feature

Modifier and Type	Method and Description
void	ExternalFeatureGroup.appendFeatures(Feature features)
void	FeatureGroup.appendFeatures(Feature features) Append a single feature to the schema of the feature group.
void	StreamFeatureGroup.appendFeatures(Feature features) Append a single feature to the schema of the stream feature group.
void	ExternalFeatureGroup.updateFeatures(Feature feature)
void	FeatureGroup.updateFeatures(Feature feature) Update the metadata of feature.
void	StreamFeatureGroup.updateFeatures(Feature feature) Update the metadata of feature.

Method parameters in com.logicalclocks.hsfs.spark with type arguments of type Feature

Modifier and Type	Method and Description
void	ExternalFeatureGroup.appendFeatures(List<Feature> features)
void	FeatureGroup.appendFeatures(List<Feature> features) Append features to the schema of the feature group.
void	StreamFeatureGroup.appendFeatures(List<Feature> features) Append features to the schema of the stream feature group.
StreamFeatureGroup	FeatureStore.createStreamFeatureGroup(@NonNull String name, Integer version, String description, Boolean onlineEnabled, TimeTravelFormat timeTravelFormat, List<String> primaryKey, List<String> partitionKey, 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, OnlineConfig onlineConfig) Get stream feature group metadata object or create a new one if it doesn't exist.
Query	ExternalFeatureGroup.selectExceptFeatures(List<Feature> features)
Query	FeatureGroup.selectExceptFeatures(List<Feature> features) Select all features including primary key and event time feature of the feature group except provided `features` and return a query object.
Query	StreamFeatureGroup.selectExceptFeatures(List<Feature> features) Select all features including primary key and event time feature of the feature group except provided `features` and return a query object.
Query	ExternalFeatureGroup.selectFeatures(List<Feature> features)
Query	FeatureGroup.selectFeatures(List<Feature> features) Select a subset of features of the feature group and return a query object.
Query	StreamFeatureGroup.selectFeatures(List<Feature> features) Select a subset of features of the feature group and return a query object.
void	ExternalFeatureGroup.updateFeatures(List<Feature> features)
void	FeatureGroup.updateFeatures(List<Feature> features) Update the metadata of multiple features.
void	StreamFeatureGroup.updateFeatures(List<Feature> features) Update the metadata of multiple features.

Constructor parameters in com.logicalclocks.hsfs.spark with type arguments of type Feature

Constructor and Description
ExternalFeatureGroup(FeatureStore featureStore, @NonNull String name, Integer version, String query, ExternalDataFormat dataFormat, String path, Map<String,String> options, @NonNull StorageConnector storageConnector, String description, List<String> primaryKeys, List<Feature> features, StatisticsConfig statisticsConfig, String eventTime, boolean onlineEnabled, String onlineTopicName, String topicName, String notificationTopicName, OnlineConfig onlineConfig)
FeatureGroup(FeatureStore featureStore, @NonNull String name, Integer version, String description, List<String> primaryKeys, List<String> partitionKeys, String hudiPrecombineKey, boolean onlineEnabled, TimeTravelFormat timeTravelFormat, List<Feature> features, StatisticsConfig statisticsConfig, String onlineTopicName, String topicName, String notificationTopicName, String eventTime, OnlineConfig onlineConfig, StorageConnector storageConnector, String path)
FeatureGroup(Integer id, String description, List<Feature> features)
StreamFeatureGroup(FeatureStore featureStore, @NonNull String name, Integer version, String description, List<String> primaryKeys, List<String> partitionKeys, String hudiPrecombineKey, boolean onlineEnabled, TimeTravelFormat timeTravelFormat, List<Feature> features, StatisticsConfig statisticsConfig, String onlineTopicName, String topicName, String notificationTopicName, String eventTime, OnlineConfig onlineConfig, StorageConnector storageConnector, String path)
StreamFeatureGroup(Integer id, String description, List<Feature> features)

Uses of Feature in com.logicalclocks.hsfs.spark.constructor

Constructor parameters in com.logicalclocks.hsfs.spark.constructor with type arguments of type Feature

Constructor and Description
Query(FeatureGroupBase leftFeatureGroup, List<Feature> leftFeatures)

Uses of Feature in com.logicalclocks.hsfs.spark.engine

Methods in com.logicalclocks.hsfs.spark.engine that return types with arguments of type Feature

Modifier and Type	Method and Description
List<Feature>	SparkEngine.parseFeatureGroupSchema(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> dataset, TimeTravelFormat timeTravelFormat)

Method parameters in com.logicalclocks.hsfs.spark.engine with type arguments of type Feature

Modifier and Type	Method and Description
<T extends FeatureGroupBase> void	FeatureGroupEngine.appendFeatures(FeatureGroupBase featureGroup, List<Feature> features, Class<T> fgClass)
StreamFeatureGroup	FeatureGroupEngine.getOrCreateStreamFeatureGroup(FeatureStore featureStore, String name, Integer version, String description, List<String> primaryKeys, List<String> partitionKeys, String hudiPrecombineKey, boolean onlineEnabled, StatisticsConfig statisticsConfig, String eventTime, TimeTravelFormat timeTravelFormat, List<Feature> features, StorageConnector storageConnector, String path, OnlineConfig onlineConfig)