Uses of Class
com.logicalclocks.hsfs.FeatureGroupBase

Packages that use FeatureGroupBase

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.metadata
com.logicalclocks.hsfs.spark
com.logicalclocks.hsfs.spark.constructor
com.logicalclocks.hsfs.spark.engine
com.logicalclocks.hsfs.spark.engine.hudi

Uses of FeatureGroupBase in com.logicalclocks.hsfs

Subclasses of FeatureGroupBase in com.logicalclocks.hsfs

Modifier and Type	Class	Description
class	StreamFeatureGroup<T>

Methods in com.logicalclocks.hsfs that return FeatureGroupBase

Modifier and Type	Method	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, DataSource dataSource)	Create a stream feature group object.
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)	Deprecated. Use FeatureStoreBase.createStreamFeatureGroup(String, Integer, String, Boolean, TimeTravelFormat, List, List, String, String, List, StatisticsConfig, DataSource) instead.
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, DataSource dataSource, OnlineConfig onlineConfig)	Get a stream feature group metadata object or create a new one if it doesn't exist.
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)	Deprecated. Use FeatureStoreBase.getOrCreateStreamFeatureGroup(String, Integer, String, Boolean, TimeTravelFormat, List, List, String, String, List, StatisticsConfig, DataSource, OnlineConfig) instead.

Constructors in com.logicalclocks.hsfs with parameters of type FeatureGroupBase

Modifier	Constructor	Description
	Feature(@NonNull String name, @NonNull FeatureGroupBase featureGroup)

Uses of FeatureGroupBase in com.logicalclocks.hsfs.beam

Subclasses of FeatureGroupBase in com.logicalclocks.hsfs.beam

Modifier and Type	Class	Description
class	StreamFeatureGroup

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

Methods in com.logicalclocks.hsfs.beam.engine with parameters of type FeatureGroupBase

Modifier and Type	Method	Description
Map<String,String>	BeamEngine.getKafkaConfig(FeatureGroupBase featureGroup, Map<String,String> writeOptions)

Uses of FeatureGroupBase in com.logicalclocks.hsfs.constructor

Classes in com.logicalclocks.hsfs.constructor with type parameters of type FeatureGroupBase

Modifier and Type	Class	Description
class	FeatureGroupAlias<T extends FeatureGroupBase>
class	FsQueryBase<T extends FeatureGroupBase,T2 extends FeatureGroupBase>
class	FsQueryBase<T extends FeatureGroupBase,T2 extends FeatureGroupBase>
class	QueryBase<T extends QueryBase<T,T2,T3>,T2 extends FeatureGroupBase,T3>

Fields in com.logicalclocks.hsfs.constructor declared as FeatureGroupBase

Modifier and Type	Field	Description
protected FeatureGroupBase	QueryBase.leftFeatureGroup

Constructors in com.logicalclocks.hsfs.constructor with parameters of type FeatureGroupBase

Modifier	Constructor	Description
	QueryBase(FeatureGroupBase leftFeatureGroup, List<Feature> leftFeatures)

Uses of FeatureGroupBase in com.logicalclocks.hsfs.engine

Classes in com.logicalclocks.hsfs.engine with type parameters of type FeatureGroupBase

Modifier and Type	Class	Description
class	FeatureViewEngineBase<T1 extends QueryBase<T1,T4,T5>,T2 extends FeatureViewBase<T2,T3,T1,T5>,T3 extends FeatureStoreBase<T1>,T4 extends FeatureGroupBase,T5>

Methods in com.logicalclocks.hsfs.engine with type parameters of type FeatureGroupBase

Modifier and Type	Method	Description
protected <T extends FeatureGroupBase> T	FeatureGroupEngineBase.saveExtennalFeatureGroupMetaData(T externalFeatureGroup, Class<T> fgClass)
<T extends FeatureGroupBase> void	FeatureGroupEngineBase.updateDeprecated(FeatureGroupBase featureGroup, Boolean deprecate, Class<T> fgClass)
<T extends FeatureGroupBase> void	FeatureGroupEngineBase.updateDescription(FeatureGroupBase featureGroup, String description, Class<T> fgClass)
<T extends FeatureGroupBase> void	FeatureGroupEngineBase.updateFeatures(FeatureGroupBase featureGroup, List<Feature> features, Class<T> fgClass)
<T extends FeatureGroupBase> void	FeatureGroupEngineBase.updateNotificationTopicName(FeatureGroupBase featureGroup, String notificationTopicName, Class<T> fgClass)
<T extends FeatureGroupBase> void	FeatureGroupEngineBase.updateStatisticsConfig(FeatureGroupBase featureGroup, Class<T> fgClass)

Methods in com.logicalclocks.hsfs.engine with parameters of type FeatureGroupBase

Modifier and Type	Method	Description
void	FeatureGroupEngineBase.addTag(FeatureGroupBase featureGroupBase, String name, Object value)
void	FeatureGroupEngineBase.delete(FeatureGroupBase featureGroupBase)
void	FeatureGroupEngineBase.deleteTag(FeatureGroupBase featureGroupBase, String name)
Map<Long,Map<String,String>>	FeatureGroupUtils.getCommitDetails(FeatureGroupBase featureGroup, String wallclockTime, Integer limit)
String	FeatureGroupUtils.getFgName(FeatureGroupBase featureGroup)
static Map<String,byte[]>	FeatureGroupUtils.getHeaders(FeatureGroupBase featureGroup, Long numEntries)
static Map<String,byte[]>	FeatureGroupUtils.getHeaders(FeatureGroupBase featureGroup, Long numEntries, Map<String,String> options)
static Map<String,byte[]>	FeatureGroupUtils.getHeaders(FeatureGroupBase featureGroup, Long numEntries, Map<String,String> options, String operation)
static Map<String,byte[]>	FeatureGroupUtils.getHeaders(FeatureGroupBase featureGroup, Long numEntries, Map<String,String> options, String operation, Storage storage)	Kafka headers for the records of one write to the online topic.
String	FeatureGroupUtils.getHiveServerConnection(FeatureGroupBase featureGroup, String connectionString)
Map<String,String>	Engine.getKafkaConfig(FeatureGroupBase featureGroup, Map<String,String> writeOptions)
abstract Map<String,String>	EngineBase.getKafkaConfig(FeatureGroupBase featureGroup, Map<String,String> writeOptions)
scala.collection.Seq<String>	FeatureGroupUtils.getPartitionColumns(FeatureGroupBase offlineFeatureGroup)
scala.collection.Seq<String>	FeatureGroupUtils.getPrimaryColumns(FeatureGroupBase offlineFeatureGroup)
Subject	FeatureGroupUtils.getSubject(FeatureGroupBase featureGroup)
String	FeatureGroupUtils.getTableName(FeatureGroupBase offlineFeatureGroup)
Object	FeatureGroupEngineBase.getTag(FeatureGroupBase featureGroupBase, String name)
Map<String,Object>	FeatureGroupEngineBase.getTags(FeatureGroupBase featureGroupBase)
<T extends FeatureGroupBase> void	FeatureGroupEngineBase.updateDeprecated(FeatureGroupBase featureGroup, Boolean deprecate, Class<T> fgClass)
<T extends FeatureGroupBase> void	FeatureGroupEngineBase.updateDescription(FeatureGroupBase featureGroup, String description, Class<T> fgClass)
<T extends FeatureGroupBase> void	FeatureGroupEngineBase.updateFeatures(FeatureGroupBase featureGroup, List<Feature> features, Class<T> fgClass)
<T extends FeatureGroupBase> void	FeatureGroupEngineBase.updateNotificationTopicName(FeatureGroupBase featureGroup, String notificationTopicName, Class<T> fgClass)
<T extends FeatureGroupBase> void	FeatureGroupEngineBase.updateStatisticsConfig(FeatureGroupBase featureGroup, Class<T> fgClass)
void	FeatureGroupUtils.verifyAttributeKeyNames(FeatureGroupBase featureGroup, List<String> partitionKeyNames, String precombineKeyName)

Uses of FeatureGroupBase in com.logicalclocks.hsfs.flink

Subclasses of FeatureGroupBase in com.logicalclocks.hsfs.flink

Modifier and Type	Class	Description
class	StreamFeatureGroup

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

Methods in com.logicalclocks.hsfs.flink.engine with parameters of type FeatureGroupBase

Modifier and Type	Method	Description
Map<String,String>	FlinkEngine.getKafkaConfig(FeatureGroupBase featureGroup, Map<String,String> writeOptions)

Uses of FeatureGroupBase in com.logicalclocks.hsfs.metadata

Methods in com.logicalclocks.hsfs.metadata with type parameters of type FeatureGroupBase

Modifier and Type	Method	Description
<T extends FeatureGroupBase> T[]	FeatureGroupApi.getInternal(FeatureStoreBase featureStoreBase, String fgName, Integer fgVersion, Class<T[]> fgType)
<U extends FeatureGroupBase> FeatureGroupBase	FeatureGroupApi.save(FeatureGroupBase featureGroup, Class<U> fgType)
<U extends FeatureGroupBase> FeatureGroupBase	FeatureGroupApi.saveFeatureGroupMetaData(FeatureGroupBase featureGroup, List<String> partitionKeys, String hudiPrecombineKey, Map<String,String> writeOptions, JobConfiguration jobConfiguration, Class<U> fgType)
<U extends FeatureGroupBase> FeatureGroupBase	FeatureGroupApi.saveInternal(FeatureGroupBase featureGroupBase, org.apache.http.entity.StringEntity entity, Class<U> fgType)
<T extends FeatureGroupBase> T	FeatureGroupApi.updateMetadata(FeatureGroupBase featureGroup, String queryParameter, Class<T> fgType)
<T extends FeatureGroupBase> T	FeatureGroupApi.updateMetadata(FeatureGroupBase featureGroup, String queryParameter, Object value, Class<T> fgType)

Methods in com.logicalclocks.hsfs.metadata that return FeatureGroupBase

Modifier and Type	Method	Description
<T extends FeatureGroupBase> T[]	FeatureGroupApi.getInternal(FeatureStoreBase featureStoreBase, String fgName, Integer fgVersion, Class<T[]> fgType)
<U extends FeatureGroupBase> FeatureGroupBase	FeatureGroupApi.save(FeatureGroupBase featureGroup, Class<U> fgType)
<U extends FeatureGroupBase> FeatureGroupBase	FeatureGroupApi.saveFeatureGroupMetaData(FeatureGroupBase featureGroup, List<String> partitionKeys, String hudiPrecombineKey, Map<String,String> writeOptions, JobConfiguration jobConfiguration, Class<U> fgType)
<U extends FeatureGroupBase> FeatureGroupBase	FeatureGroupApi.saveInternal(FeatureGroupBase featureGroupBase, org.apache.http.entity.StringEntity entity, Class<U> fgType)

Methods in com.logicalclocks.hsfs.metadata with parameters of type FeatureGroupBase

Modifier and Type	Method	Description
void	TagsApi.add(FeatureGroupBase featureGroupBase, String name, Object value)
OnlineIngestion	OnlineIngestionApi.createOnlineIngestion(FeatureGroupBase featureGroup, OnlineIngestion onlineIngestion)
void	FeatureGroupApi.delete(FeatureGroupBase featureGroupBase)
void	FeatureGroupApi.deleteContent(FeatureGroupBase featureGroup)
void	TagsApi.deleteTag(FeatureGroupBase featureGroup, String name)
FeatureGroupCommit	FeatureGroupApi.featureGroupCommit(FeatureGroupBase featureGroup, FeatureGroupCommit featureGroupCommit)
Statistics	StatisticsApi.get(FeatureGroupBase featureGroup, String commitTime)
Map<String,Object>	TagsApi.get(FeatureGroupBase featureGroupBase)
Object	TagsApi.get(FeatureGroupBase featureGroupBase, String name)
List<FeatureGroupCommit>	FeatureGroupApi.getCommitDetails(FeatureGroupBase featureGroupBase, Long wallclockTimestamp, Integer limit)
Statistics	StatisticsApi.getLast(FeatureGroupBase featureGroup)
List<OnlineIngestion>	OnlineIngestionApi.getOnlineIngestion(FeatureGroupBase featureGroup, String queryParameters)
Statistics	StatisticsApi.post(FeatureGroupBase featureGroup, Statistics statistics)
<U extends FeatureGroupBase> FeatureGroupBase	FeatureGroupApi.save(FeatureGroupBase featureGroup, Class<U> fgType)
<U extends FeatureGroupBase> FeatureGroupBase	FeatureGroupApi.saveFeatureGroupMetaData(FeatureGroupBase featureGroup, List<String> partitionKeys, String hudiPrecombineKey, Map<String,String> writeOptions, JobConfiguration jobConfiguration, Class<U> fgType)
<U extends FeatureGroupBase> FeatureGroupBase	FeatureGroupApi.saveInternal(FeatureGroupBase featureGroupBase, org.apache.http.entity.StringEntity entity, Class<U> fgType)
<T extends FeatureGroupBase> T	FeatureGroupApi.updateMetadata(FeatureGroupBase featureGroup, String queryParameter, Class<T> fgType)
<T extends FeatureGroupBase> T	FeatureGroupApi.updateMetadata(FeatureGroupBase featureGroup, String queryParameter, Object value, Class<T> fgType)

Uses of FeatureGroupBase in com.logicalclocks.hsfs.spark

Subclasses of FeatureGroupBase in com.logicalclocks.hsfs.spark

Modifier and Type	Class	Description
class	ExternalFeatureGroup
class	FeatureGroup
class	StreamFeatureGroup

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

Constructors in com.logicalclocks.hsfs.spark.constructor with parameters of type FeatureGroupBase

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

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

Methods in com.logicalclocks.hsfs.spark.engine with type parameters of type FeatureGroupBase

Modifier and Type	Method	Description
<T extends FeatureGroupBase> void	FeatureGroupEngine.appendFeatures(FeatureGroupBase featureGroup, List<Feature> features, Class<T> fgClass)

Methods in com.logicalclocks.hsfs.spark.engine with parameters of type FeatureGroupBase

Modifier and Type	Method	Description
<T extends FeatureGroupBase> void	FeatureGroupEngine.appendFeatures(FeatureGroupBase featureGroup, List<Feature> features, Class<T> fgClass)
FeatureGroupCommit	FeatureGroupEngine.commitDelete(FeatureGroupBase featureGroupBase, org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> genericDataset, Map<String,String> writeOptions)
FeatureGroupCommit	FeatureGroupEngine.commitDelete(FeatureGroupBase featureGroupBase, org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> genericDataset, Map<String,String> writeOptions, Storage storage)	Deletes the records in genericDataset from the storage named by storage.
Map<Long,Map<String,String>>	FeatureGroupEngine.commitDetails(FeatureGroupBase featureGroupBase, Integer limit)
Map<Long,Map<String,String>>	FeatureGroupEngine.commitDetailsByWallclockTime(FeatureGroupBase featureGroup, String wallclockTime, Integer limit)
Statistics	StatisticsEngine.computeStatistics(FeatureGroupBase featureGroup, org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> dataFrame, Long commitId)
String	SparkEngine.constructCheckpointPath(FeatureGroupBase featureGroup, String queryName, String queryPrefix)
void	SparkEngine.deleteOnlineDataframe(FeatureGroupBase featureGroupBase, org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> dataset, Map<String,String> writeOptions)	Produces an online delete tombstone for every row in the dataset.
org.apache.spark.sql.Dataset<org.apache.spark.sql.Row>	SparkEngine.encodeComplexFeatures(FeatureGroupBase featureGroupBase, org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> dataset)	Encodes all complex type features to binary using their avro type as schema.
Statistics	StatisticsEngine.get(FeatureGroupBase featureGroup, String commitTime)
Map<String,String>	SparkEngine.getKafkaConfig(FeatureGroupBase featureGroup, Map<String,String> writeOptions)
Statistics	StatisticsEngine.getLast(FeatureGroupBase featureGroup)
protected String	SparkEngine.makeQueryName(String queryName, FeatureGroupBase featureGroup)
void	SparkEngine.writeEmptyDataframe(FeatureGroupBase featureGroup)
void	SparkEngine.writeOfflineDataframe(FeatureGroupBase featureGroup, org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> dataset, HudiOperationType operation, Map<String,String> writeOptions, Integer validationId)
void	SparkEngine.writeOnlineDataframe(FeatureGroupBase featureGroupBase, org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> dataset, Map<String,String> writeOptions)	Writes feature group dataframe to kafka for online-fs ingestion.
void	SparkEngine.writeOnlineDataframe(FeatureGroupBase featureGroupBase, org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> dataset, Map<String,String> writeOptions, Storage storage)	Writes feature group dataframe to kafka for online-fs ingestion.
<S> org.apache.spark.sql.streaming.StreamingQuery	SparkEngine.writeStreamDataframe(FeatureGroupBase featureGroupBase, org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> dataset, String queryName, String outputMode, boolean awaitTermination, Long timeout, String checkpointLocation, Map<String,String> writeOptions)

Uses of FeatureGroupBase in com.logicalclocks.hsfs.spark.engine.hudi

Methods in com.logicalclocks.hsfs.spark.engine.hudi with parameters of type FeatureGroupBase

Modifier and Type	Method	Description
FeatureGroupCommit	HudiEngine.deleteRecord(org.apache.spark.sql.SparkSession sparkSession, FeatureGroupBase featureGroup, org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> deleteDF, Map<String,String> writeOptions)
void	HudiEngine.saveHudiFeatureGroup(org.apache.spark.sql.SparkSession sparkSession, FeatureGroupBase featureGroup, org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> dataset, HudiOperationType operation, Map<String,String> writeOptions, Integer validationId)