Uses of Enum Class
com.logicalclocks.hsfs.Storage

Packages that use Storage

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

Uses of Storage in com.logicalclocks.hsfs

Methods in com.logicalclocks.hsfs that return Storage

Modifier and Type	Method	Description
static Storage	Storage.valueOf(String name)	Returns the enum constant of this class with the specified name.
static Storage[]	Storage.values()	Returns an array containing the constants of this enum class, in the order they are declared.

Uses of Storage in com.logicalclocks.hsfs.constructor

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

Modifier and Type	Method	Description
String	FsQueryBase.getStorageQuery(Storage storage)
<T2> String	QueryBase.sql(Storage storage, Class<T2> fsQueryType)

Uses of Storage in com.logicalclocks.hsfs.engine

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

Modifier and Type	Method	Description
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.

Uses of Storage in com.logicalclocks.hsfs.spark

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

Modifier and Type	Method	Description
void	ExternalFeatureGroup.insert(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> featureData, Storage storage)
void	FeatureGroup.insert(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> featureData, Storage storage)	Incrementally insert data to a feature group or overwrite all data contained in the feature group.
void	FeatureGroup.insert(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> featureData, Storage storage, boolean overwrite)	Incrementally insert data to a feature group or overwrite all data contained in the feature group.
void	FeatureGroup.insert(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> featureData, Storage storage, boolean overwrite, HudiOperationType operation, Map<String,String> writeOptions)	Incrementally insert data to a feature group or overwrite all data contained in the feature group.
void	StreamFeatureGroup.insert(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> featureData, Storage storage)
void	StreamFeatureGroup.insert(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> featureData, Storage storage, boolean overwrite)
void	StreamFeatureGroup.insert(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> featureData, Storage storage, boolean overwrite, HudiOperationType operation, Map<String,String> writeOptions)
void	FeatureGroup.removeRows(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> featureData, Storage storage)	Drops records present in the provided DataFrame from the offline table, and optionally from the online store of an online-enabled feature group.
void	FeatureGroup.removeRows(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> featureData, Map<String,String> writeOptions, Storage storage)	Drops records present in the provided DataFrame from the offline table, and optionally from the online store of an online-enabled feature group.
void	StreamFeatureGroup.removeRows(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> featureData, Storage storage)	Drops records present in the provided DataFrame from the offline table, and optionally from the online store of an online-enabled feature group.
void	StreamFeatureGroup.removeRows(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> featureData, Map<String,String> writeOptions, Storage storage)	Drops records present in the provided DataFrame from the offline table, and optionally from the online store of an online-enabled feature group.

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

Methods in com.logicalclocks.hsfs.spark.constructor with parameters of type Storage

Modifier and Type	Method	Description
String	Query.sql(Storage storage)

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

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

Modifier and Type	Method	Description
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.
void	FeatureGroupEngine.insert(FeatureGroup featureGroup, org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> featureData, Storage storage, HudiOperationType operation, org.apache.spark.sql.SaveMode saveMode, List<String> partitionKeys, String hudiPrecombineKey, Map<String,String> writeOptions)
void	FeatureGroupEngine.saveDataframe(FeatureGroup featureGroup, org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> dataset, Storage storage, HudiOperationType operation, Map<String,String> offlineWriteOptions, Integer validationId)
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.