Uses of Class
com.logicalclocks.hsfs.Storage

Packages that use Storage

Package	Description
com.logicalclocks.hsfs
com.logicalclocks.hsfs.constructor
com.logicalclocks.hsfs.flink
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.

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

Modifier and Type	Method and Description
String	TrainingDatasetBase.getQuery(Storage storage)
abstract String	TrainingDatasetBase.getQuery(Storage storage, boolean withLabel)
void	FeatureGroupBaseForApi.insert(FeatureGroupBaseForApi featureData, Storage storage)
void	FeatureGroupBaseForApi.insert(FeatureGroupBaseForApi featureData, Storage storage, boolean overwrite)
void	FeatureGroupBaseForApi.insert(FeatureGroupBaseForApi featureData, Storage storage, boolean overwrite, HudiOperationType operation, Map<String,String> writeOptions)
abstract void	FeatureGroupBase.insert(T featureData, Storage storage)
abstract void	FeatureGroupBase.insert(T featureData, Storage storage, boolean overwrite)
abstract void	FeatureGroupBase.insert(T featureData, Storage storage, boolean overwrite, HudiOperationType operation, Map<String,String> writeOptions)

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)
abstract String	QueryBase.sql(Storage storage)
<T2> String	QueryBase.sql(Storage storage, Class<T2> fsQueryType)

Uses of Storage in com.logicalclocks.hsfs.flink

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

Modifier and Type	Method and Description
void	StreamFeatureGroup.insert(org.apache.flink.streaming.api.datastream.DataStream<?> featureData, Storage storage)
void	StreamFeatureGroup.insert(org.apache.flink.streaming.api.datastream.DataStream<?> featureData, Storage storage, boolean overwrite)
void	StreamFeatureGroup.insert(org.apache.flink.streaming.api.datastream.DataStream<?> featureData, Storage storage, boolean online, HudiOperationType hudiOperationType, Map<String,String> writeOptions)

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
String	TrainingDataset.getQuery(Storage storage, boolean withLabel)
void	ExternalFeatureGroup.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)
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	ExternalFeatureGroup.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)
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	ExternalFeatureGroup.insert(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> featureData, Storage storage, boolean overwrite, HudiOperationType operation, Map<String,String> writeOptions)
void	StreamFeatureGroup.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 stream 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.

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
String	TrainingDatasetEngine.getQuery(TrainingDataset trainingDataset, Storage storage, boolean withLabel, boolean isHiveQuery)
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)