Uses of Class
com.logicalclocks.hsfs.Storage

Packages that use Storage

Package	Description
com.logicalclocks.hsfs
com.logicalclocks.hsfs.constructor
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 and Description
static Storage	Storage.valueOf(String name) Returns the enum constant of this type with the specified name.
static Storage[]	Storage.values() Returns an array containing the constants of this enum type, 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 and Description
String	FsQueryBase.getStorageQuery(Storage storage)
<T2> String	QueryBase.sql(Storage storage, Class<T2> fsQueryType)

Uses of Storage in com.logicalclocks.hsfs.spark

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

Modifier and Type	Method and Description
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	StreamFeatureGroup.insert(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> featureData, Storage storage)
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, boolean overwrite) 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, boolean overwrite)
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, boolean overwrite, HudiOperationType operation, Map<String,String> writeOptions)

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 and 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 and Description
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, Map<String,String> onlineWriteOptions, Integer validationId)