Index (hsfs-parent 3.3.0-RC2 API)

A B C D E F G H I J K L M N O P Q R S T U V W

A

accessKey - Variable in class com.logicalclocks.hsfs.StorageConnector.S3Connector
account() - Method in class com.logicalclocks.hsfs.StorageConnector.SnowflakeConnector
accountName - Variable in class com.logicalclocks.hsfs.StorageConnector.AdlsConnector
add(FeatureGroupBase, String, Object) - Method in class com.logicalclocks.hsfs.metadata.TagsApi
add(TrainingDatasetBase, String, Object) - Method in class com.logicalclocks.hsfs.metadata.TagsApi
add(FeatureViewBase, String, Object) - Method in class com.logicalclocks.hsfs.metadata.TagsApi
add(FeatureViewBase, Integer, String, Object) - Method in class com.logicalclocks.hsfs.metadata.TagsApi
addFeatureGroupToFeatures(FeatureGroupBase, List<Feature>) - Method in class com.logicalclocks.hsfs.constructor.QueryBase
addFile(String) - Method in class com.logicalclocks.hsfs.spark.engine.SparkEngine
addTag(FeatureGroupBase, String, Object) - Method in class com.logicalclocks.hsfs.engine.FeatureGroupEngineBase
addTag(FeatureViewBase, String, Object) - Method in class com.logicalclocks.hsfs.engine.FeatureViewEngineBase
addTag(FeatureViewBase, String, Object, Integer) - Method in class com.logicalclocks.hsfs.engine.FeatureViewEngineBase
addTag(String, Object) - Method in class com.logicalclocks.hsfs.FeatureGroupBase: Add name/value tag to the feature group.
addTag(String, Object) - Method in class com.logicalclocks.hsfs.FeatureViewBase: Add name/value tag to the feature view.
addTag(String, Object) - Method in class com.logicalclocks.hsfs.flink.FeatureView
addTag(TrainingDataset, String, Object) - Method in class com.logicalclocks.hsfs.spark.engine.TrainingDatasetEngine
addTag(String, Object) - Method in class com.logicalclocks.hsfs.spark.FeatureView: Add name/value tag to the feature view.
addTag(String, Object) - Method in class com.logicalclocks.hsfs.spark.TrainingDataset: Add name/value tag to the training dataset.
addTag(String, Object) - Method in class com.logicalclocks.hsfs.TrainingDatasetBase: Add name/value tag to the training dataset.
addTrainingDatasetTag(Integer, String, Object) - Method in class com.logicalclocks.hsfs.FeatureViewBase: Add name/value tag to the training dataset.
addTrainingDatasetTag(Integer, String, Object) - Method in class com.logicalclocks.hsfs.flink.FeatureView
addTrainingDatasetTag(Integer, String, Object) - Method in class com.logicalclocks.hsfs.spark.FeatureView: Add name/value tag to the training dataset.
AdlsConnector() - Constructor for class com.logicalclocks.hsfs.StorageConnector.AdlsConnector
algorithm - Variable in class com.logicalclocks.hsfs.StorageConnector.GcsConnector
AMBIGUOUS_LABEL_ERROR - Static variable in class com.logicalclocks.hsfs.engine.FeatureViewEngineBase
and(Filter) - Method in class com.logicalclocks.hsfs.constructor.Filter
and(FilterLogic) - Method in class com.logicalclocks.hsfs.constructor.Filter
and(Filter) - Method in class com.logicalclocks.hsfs.constructor.FilterLogic
and(FilterLogic) - Method in class com.logicalclocks.hsfs.constructor.FilterLogic
API_PATH - Static variable in class com.logicalclocks.hsfs.metadata.HopsworksClient
apiKey - Variable in class com.logicalclocks.hsfs.metadata.HopsworksExternalClient
apiKeyFilePath - Variable in class com.logicalclocks.hsfs.HopsworksConnectionBase
apiKeyValue - Variable in class com.logicalclocks.hsfs.HopsworksConnectionBase
appendFeature(Feature) - Method in class com.logicalclocks.hsfs.constructor.QueryBase
appendFeatures(List<Feature>) - Method in class com.logicalclocks.hsfs.FeatureGroupBase: Append features to the schema of the feature group.
appendFeatures(Feature) - Method in class com.logicalclocks.hsfs.FeatureGroupBase: Append a single feature to the schema of the feature group.
appendFeatures(List<Feature>) - Method in class com.logicalclocks.hsfs.FeatureGroupBaseForApi
appendFeatures(Feature) - Method in class com.logicalclocks.hsfs.FeatureGroupBaseForApi
appendFeatures(List<Feature>) - Method in class com.logicalclocks.hsfs.flink.StreamFeatureGroup
appendFeatures(Feature) - Method in class com.logicalclocks.hsfs.flink.StreamFeatureGroup
appendFeatures(FeatureGroupBase, List<Feature>, Class<T>) - Method in class com.logicalclocks.hsfs.spark.engine.FeatureGroupEngine
appendFeatures(List<Feature>) - Method in class com.logicalclocks.hsfs.spark.ExternalFeatureGroup
appendFeatures(Feature) - Method in class com.logicalclocks.hsfs.spark.ExternalFeatureGroup
appendFeatures(List<Feature>) - Method in class com.logicalclocks.hsfs.spark.FeatureGroup: Append features to the schema of the feature group.
appendFeatures(Feature) - Method in class com.logicalclocks.hsfs.spark.FeatureGroup: Append a single feature to the schema of the feature group.
appendFeatures(List<Feature>) - Method in class com.logicalclocks.hsfs.spark.StreamFeatureGroup: Append features to the schema of the stream feature group.
appendFeatures(Feature) - Method in class com.logicalclocks.hsfs.spark.StreamFeatureGroup: Append a single feature to the schema of the stream feature group.
application - Variable in class com.logicalclocks.hsfs.StorageConnector.SnowflakeConnector
applicationId - Variable in class com.logicalclocks.hsfs.StorageConnector.AdlsConnector
apply(JavaSparkContext, SparkSession, Dataset<Row>, TypedProperties) - Method in class com.logicalclocks.hsfs.spark.engine.hudi.DeltaStreamerTransformer
arguments - Variable in class com.logicalclocks.hsfs.StorageConnector.BigqueryConnector
arguments - Variable in class com.logicalclocks.hsfs.StorageConnector.JdbcConnector
arguments - Variable in class com.logicalclocks.hsfs.StorageConnector.RedshiftConnector
arguments - Variable in class com.logicalclocks.hsfs.StorageConnector.S3Connector
asOf(String) - Method in class com.logicalclocks.hsfs.constructor.QueryBase: Perform time travel on the given Query.
asOf(String, String) - Method in class com.logicalclocks.hsfs.constructor.QueryBase: Perform time travel on the given Query.
asOf(String) - Method in class com.logicalclocks.hsfs.FeatureGroupBase
asOf(String, String) - Method in class com.logicalclocks.hsfs.FeatureGroupBase
asOf(String) - Method in class com.logicalclocks.hsfs.FeatureGroupBaseForApi
asOf(String, String) - Method in class com.logicalclocks.hsfs.FeatureGroupBaseForApi
asOf(String) - Method in class com.logicalclocks.hsfs.flink.StreamFeatureGroup
asOf(String, String) - Method in class com.logicalclocks.hsfs.flink.StreamFeatureGroup
asOf(String) - Method in class com.logicalclocks.hsfs.spark.ExternalFeatureGroup
asOf(String, String) - Method in class com.logicalclocks.hsfs.spark.ExternalFeatureGroup
asOf(String) - Method in class com.logicalclocks.hsfs.spark.FeatureGroup: Get Query object to retrieve all features of the group at a point in the past.
asOf(String, String) - Method in class com.logicalclocks.hsfs.spark.FeatureGroup: Get Query object to retrieve all features of the group at a point in the past.
asOf(String) - Method in class com.logicalclocks.hsfs.spark.StreamFeatureGroup: Get Query object to retrieve all features of the group at a point in the past.
asOf(String, String) - Method in class com.logicalclocks.hsfs.spark.StreamFeatureGroup: Get Query object to retrieve all features of the group at a point in the past.
AuthorizationHandler<T> - Class in com.logicalclocks.hsfs.metadata
autoCreate - Variable in class com.logicalclocks.hsfs.StorageConnector.RedshiftConnector

B

BaseHandler(Class<T>, ObjectMapper) - Constructor for class com.logicalclocks.hsfs.metadata.HopsworksClient.BaseHandler
BIGQ_CREDENTIALS - Static variable in class com.logicalclocks.hsfs.util.Constants
BIGQ_DATASET - Static variable in class com.logicalclocks.hsfs.util.Constants
BIGQ_MATERIAL_DATASET - Static variable in class com.logicalclocks.hsfs.util.Constants
BIGQ_PARENT_PROJECT - Static variable in class com.logicalclocks.hsfs.util.Constants
BIGQ_PROJECT - Static variable in class com.logicalclocks.hsfs.util.Constants
BIGQ_VIEWS_ENABLED - Static variable in class com.logicalclocks.hsfs.util.Constants
BIGQUERY_FORMAT - Static variable in class com.logicalclocks.hsfs.util.Constants
BigqueryConnector() - Constructor for class com.logicalclocks.hsfs.StorageConnector.BigqueryConnector
bootstrapServers - Variable in class com.logicalclocks.hsfs.StorageConnector.KafkaConnector
bucket - Variable in class com.logicalclocks.hsfs.StorageConnector.GcsConnector
bucket - Variable in class com.logicalclocks.hsfs.StorageConnector.S3Connector
build() - Method in class com.logicalclocks.hsfs.spark.FeatureView.FeatureViewBuilder
buildStringEntity(Object) - Method in class com.logicalclocks.hsfs.metadata.HopsworksClient

C

castColumnType(Dataset<Row>, List<TrainingDatasetFeature>) - Method in class com.logicalclocks.hsfs.spark.engine.SparkEngine
certKey - Variable in class com.logicalclocks.hsfs.metadata.HopsworksExternalClient
certPath - Variable in class com.logicalclocks.hsfs.HopsworksConnectionBase
checkpointDirPath(String, String) - Method in class com.logicalclocks.hsfs.spark.engine.SparkEngine
clean(T3, String, Integer) - Method in class com.logicalclocks.hsfs.FeatureViewBase
clean(FeatureStore, String, Integer) - Method in class com.logicalclocks.hsfs.flink.FeatureView
clean(FeatureStore, String, Integer) - Method in class com.logicalclocks.hsfs.spark.FeatureView: Delete the feature view and all associated metadata and training data.
close() - Method in class com.logicalclocks.hsfs.HopsworksConnectionBase: Close the connection and clean up the certificates.
close() - Method in class com.logicalclocks.hsfs.spark.engine.hudi.DeltaStreamerAvroDeserializer
clusterIdentifier - Variable in class com.logicalclocks.hsfs.StorageConnector.RedshiftConnector
coalesce - Variable in class com.logicalclocks.hsfs.TrainingDatasetBase
Code - Class in com.logicalclocks.hsfs.metadata
Code(Long, String) - Constructor for class com.logicalclocks.hsfs.metadata.Code
Code.RunType - Enum in com.logicalclocks.hsfs.metadata
CODE_PATH - Static variable in class com.logicalclocks.hsfs.metadata.CodeApi
CodeApi - Class in com.logicalclocks.hsfs.metadata
CodeApi(EntityEndpointType) - Constructor for class com.logicalclocks.hsfs.metadata.CodeApi
CodeEngine - Class in com.logicalclocks.hsfs.engine
CodeEngine(EntityEndpointType) - Constructor for class com.logicalclocks.hsfs.engine.CodeEngine
com.logicalclocks.hsfs - package com.logicalclocks.hsfs
com.logicalclocks.hsfs.constructor - package com.logicalclocks.hsfs.constructor
com.logicalclocks.hsfs.engine - package com.logicalclocks.hsfs.engine
com.logicalclocks.hsfs.flink - package com.logicalclocks.hsfs.flink
com.logicalclocks.hsfs.flink.engine - package com.logicalclocks.hsfs.flink.engine
com.logicalclocks.hsfs.metadata - package com.logicalclocks.hsfs.metadata
com.logicalclocks.hsfs.spark - package com.logicalclocks.hsfs.spark
com.logicalclocks.hsfs.spark.constructor - package com.logicalclocks.hsfs.spark.constructor
com.logicalclocks.hsfs.spark.engine - package com.logicalclocks.hsfs.spark.engine
com.logicalclocks.hsfs.spark.engine.hudi - package com.logicalclocks.hsfs.spark.engine.hudi
com.logicalclocks.hsfs.spark.util - package com.logicalclocks.hsfs.spark.util
com.logicalclocks.hsfs.util - package com.logicalclocks.hsfs.util
COMMIT_METADATA_KEYPREFIX_OPT_KEY - Static variable in class com.logicalclocks.hsfs.spark.engine.hudi.HudiEngine
commitDelete(FeatureGroupBase, Dataset<Row>, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.engine.FeatureGroupEngine
commitDeleteRecord(T) - Method in class com.logicalclocks.hsfs.FeatureGroupBase
commitDeleteRecord(T, Map<String, String>) - Method in class com.logicalclocks.hsfs.FeatureGroupBase
commitDeleteRecord(FeatureGroupBaseForApi) - Method in class com.logicalclocks.hsfs.FeatureGroupBaseForApi
commitDeleteRecord(FeatureGroupBaseForApi, Map<String, String>) - Method in class com.logicalclocks.hsfs.FeatureGroupBaseForApi
commitDeleteRecord(DataStream<?>) - Method in class com.logicalclocks.hsfs.flink.StreamFeatureGroup
commitDeleteRecord(DataStream<?>, Map<String, String>) - Method in class com.logicalclocks.hsfs.flink.StreamFeatureGroup
commitDeleteRecord(Dataset<Row>) - Method in class com.logicalclocks.hsfs.spark.ExternalFeatureGroup
commitDeleteRecord(Dataset<Row>, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.ExternalFeatureGroup
commitDeleteRecord(Dataset<Row>) - Method in class com.logicalclocks.hsfs.spark.FeatureGroup: Drops records present in the provided DataFrame and commits it as update to this Feature group.
commitDeleteRecord(Dataset<Row>, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.FeatureGroup: Drops records present in the provided DataFrame and commits it as update to this Feature group.
commitDeleteRecord(Dataset<Row>) - Method in class com.logicalclocks.hsfs.spark.StreamFeatureGroup: Drops records present in the provided DataFrame and commits it as update to this Stream Feature group.
commitDeleteRecord(Dataset<Row>, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.StreamFeatureGroup: Drops records present in the provided DataFrame and commits it as update to this Stream Feature group.
commitDetails() - Method in class com.logicalclocks.hsfs.FeatureGroupBase
commitDetails(Integer) - Method in class com.logicalclocks.hsfs.FeatureGroupBase
commitDetails(String) - Method in class com.logicalclocks.hsfs.FeatureGroupBase
commitDetails(String, Integer) - Method in class com.logicalclocks.hsfs.FeatureGroupBase
commitDetails() - Method in class com.logicalclocks.hsfs.FeatureGroupBaseForApi
commitDetails(Integer) - Method in class com.logicalclocks.hsfs.FeatureGroupBaseForApi
commitDetails(String) - Method in class com.logicalclocks.hsfs.FeatureGroupBaseForApi
commitDetails(String, Integer) - Method in class com.logicalclocks.hsfs.FeatureGroupBaseForApi
commitDetails() - Method in class com.logicalclocks.hsfs.flink.StreamFeatureGroup
commitDetails(Integer) - Method in class com.logicalclocks.hsfs.flink.StreamFeatureGroup
commitDetails(String) - Method in class com.logicalclocks.hsfs.flink.StreamFeatureGroup
commitDetails(String, Integer) - Method in class com.logicalclocks.hsfs.flink.StreamFeatureGroup
commitDetails(FeatureGroupBase, Integer) - Method in class com.logicalclocks.hsfs.spark.engine.FeatureGroupEngine
commitDetails() - Method in class com.logicalclocks.hsfs.spark.ExternalFeatureGroup
commitDetails(Integer) - Method in class com.logicalclocks.hsfs.spark.ExternalFeatureGroup
commitDetails(String) - Method in class com.logicalclocks.hsfs.spark.ExternalFeatureGroup
commitDetails(String, Integer) - Method in class com.logicalclocks.hsfs.spark.ExternalFeatureGroup
commitDetails() - Method in class com.logicalclocks.hsfs.spark.FeatureGroup: Retrieves commit timeline for this feature group.
commitDetails(Integer) - Method in class com.logicalclocks.hsfs.spark.FeatureGroup: Retrieves commit timeline for this feature group.
commitDetails(String) - Method in class com.logicalclocks.hsfs.spark.FeatureGroup: Return commit details as of specific point in time.
commitDetails(String, Integer) - Method in class com.logicalclocks.hsfs.spark.FeatureGroup: Return commit details as of specific point in time.
commitDetails() - Method in class com.logicalclocks.hsfs.spark.StreamFeatureGroup: Retrieves commit timeline for this stream feature group.
commitDetails(Integer) - Method in class com.logicalclocks.hsfs.spark.StreamFeatureGroup: /** Retrieves commit timeline for this stream feature group.
commitDetails(String) - Method in class com.logicalclocks.hsfs.spark.StreamFeatureGroup: Return commit details as of specific point in time.
commitDetails(String, Integer) - Method in class com.logicalclocks.hsfs.spark.StreamFeatureGroup: Return commit details as of specific point in time.
commitDetailsByWallclockTime(FeatureGroupBase, String, Integer) - Method in class com.logicalclocks.hsfs.spark.engine.FeatureGroupEngine
COMPLEX_FEATURE_TYPES - Static variable in class com.logicalclocks.hsfs.util.Constants
computeStatistics() - Method in class com.logicalclocks.hsfs.FeatureGroupBase: Recompute the statistics for the feature group and save them to the feature store.
computeStatistics(String) - Method in class com.logicalclocks.hsfs.FeatureGroupBase
computeStatistics() - Method in class com.logicalclocks.hsfs.FeatureGroupBaseForApi
computeStatistics(String) - Method in class com.logicalclocks.hsfs.FeatureGroupBaseForApi
computeStatistics() - Method in class com.logicalclocks.hsfs.flink.StreamFeatureGroup
computeStatistics(String) - Method in class com.logicalclocks.hsfs.flink.StreamFeatureGroup
computeStatistics(FeatureView, TrainingDataset, Dataset<Row>[]) - Method in class com.logicalclocks.hsfs.spark.engine.FeatureViewEngine
computeStatistics(TrainingDataset, Dataset<Row>) - Method in class com.logicalclocks.hsfs.spark.engine.StatisticsEngine
computeStatistics(FeatureView, TrainingDataset, Dataset<Row>) - Method in class com.logicalclocks.hsfs.spark.engine.StatisticsEngine
computeStatistics(FeatureGroupBase, Dataset<Row>, Long) - Method in class com.logicalclocks.hsfs.spark.engine.StatisticsEngine
computeStatistics() - Method in class com.logicalclocks.hsfs.spark.ExternalFeatureGroup
computeStatistics(String) - Method in class com.logicalclocks.hsfs.spark.ExternalFeatureGroup
computeStatistics() - Method in class com.logicalclocks.hsfs.spark.FeatureGroup: Recompute the statistics for the feature group and save them to the feature store.
computeStatistics(String) - Method in class com.logicalclocks.hsfs.spark.FeatureGroup: Recompute the statistics for the feature group and save them to the feature store.
computeStatistics() - Method in class com.logicalclocks.hsfs.spark.StreamFeatureGroup: Recompute the statistics for the stream feature group and save them to the feature store.
computeStatistics(String) - Method in class com.logicalclocks.hsfs.spark.StreamFeatureGroup: Recompute the statistics for the feature group and save them to the feature store.
computeStatistics() - Method in class com.logicalclocks.hsfs.spark.TrainingDataset: Recompute the statistics for the entire training dataset and save them to the feature store.
computeStatistics() - Method in class com.logicalclocks.hsfs.TrainingDatasetBase: Recompute the statistics for the entire training dataset and save them to the feature store.
configure(Map<String, ?>, boolean) - Method in class com.logicalclocks.hsfs.spark.engine.hudi.DeltaStreamerAvroDeserializer
connectionPool - Variable in class com.logicalclocks.hsfs.metadata.HopsworksExternalClient
connectionString - Variable in class com.logicalclocks.hsfs.StorageConnector.JdbcConnector
Constants - Class in com.logicalclocks.hsfs.util
Constants() - Constructor for class com.logicalclocks.hsfs.util.Constants
constructCheckpointPath(FeatureGroupBase, String, String) - Method in class com.logicalclocks.hsfs.spark.engine.SparkEngine
constructQuery(FeatureStoreBase, QueryBase, Class<T>) - Method in class com.logicalclocks.hsfs.metadata.QueryConstructorApi
containerName - Variable in class com.logicalclocks.hsfs.StorageConnector.AdlsConnector
convertSplitDatasetsToMap(List<Split>, Dataset<Row>[]) - Method in class com.logicalclocks.hsfs.spark.engine.FeatureViewEngine
convertToDefaultDataframe(Dataset<Row>) - Method in class com.logicalclocks.hsfs.spark.engine.SparkEngine
count - Variable in class com.logicalclocks.hsfs.metadata.RestDto
createConnectionFactory(HttpHost, boolean, String) - Method in class com.logicalclocks.hsfs.metadata.HopsworksExternalClient
created - Variable in class com.logicalclocks.hsfs.FeatureGroupBase
createEmptyDataFrame(S) - Method in class com.logicalclocks.hsfs.spark.engine.SparkEngine
createExternalFeatureGroup() - Method in class com.logicalclocks.hsfs.FeatureStoreBase
createExternalFeatureGroup() - Method in class com.logicalclocks.hsfs.flink.FeatureStore
createExternalFeatureGroup() - Method in class com.logicalclocks.hsfs.spark.FeatureStore: Create external feature group builder object.
createFeatureGroup() - Method in class com.logicalclocks.hsfs.FeatureStoreBase
createFeatureGroup() - Method in class com.logicalclocks.hsfs.flink.FeatureStore
createFeatureGroup() - Method in class com.logicalclocks.hsfs.spark.FeatureStore: Create feature group builder object.
createFeatureView() - Method in class com.logicalclocks.hsfs.FeatureStoreBase
createFeatureView() - Method in class com.logicalclocks.hsfs.flink.FeatureStore
createFeatureView() - Method in class com.logicalclocks.hsfs.spark.FeatureStore
createOnDemandFeatureGroup() - Method in class com.logicalclocks.hsfs.spark.FeatureStore: Deprecated.
createStreamFeatureGroup() - Method in class com.logicalclocks.hsfs.FeatureStoreBase
createStreamFeatureGroup() - Method in class com.logicalclocks.hsfs.flink.FeatureStore
createStreamFeatureGroup() - Method in class com.logicalclocks.hsfs.spark.FeatureStore: Create stream feature group builder object.
createTrainingData(String, Integer, TrainingDatasetBase, Class<T>) - Method in class com.logicalclocks.hsfs.metadata.FeatureViewApi
createTrainingData(String, String, String, DataFormat) - Method in class com.logicalclocks.hsfs.spark.FeatureView: Create the metadata for a training dataset and save the corresponding training data into `location`.
createTrainingData(String, String, String, DataFormat, Boolean, StorageConnector, String, Long, StatisticsConfig, Map<String, String>, FilterLogic, Filter) - Method in class com.logicalclocks.hsfs.spark.FeatureView: Create the metadata for a training dataset and save the corresponding training data into `location`.
createTrainingDataset(TrainingDatasetBase) - Method in class com.logicalclocks.hsfs.metadata.TrainingDatasetApi
createTrainingDataset(FeatureView, TrainingDataset, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.engine.FeatureViewEngine
createTrainingDataset() - Method in class com.logicalclocks.hsfs.spark.FeatureStore: Deprecated.
createTrainTestSplit(Float, String, String, String, String, String, DataFormat) - Method in class com.logicalclocks.hsfs.spark.FeatureView: Create the metadata for a training dataset and save the corresponding training data into `location`.
createTrainTestSplit(Float, String, String, String, String, String, DataFormat, Boolean, StorageConnector, String, Long, StatisticsConfig, Map<String, String>, FilterLogic, Filter) - Method in class com.logicalclocks.hsfs.spark.FeatureView: Create the metadata for a training dataset and save the corresponding training data into `location`.
createTrainValidationTestSplit(Float, Float, String, String, String, String, String, String, String, DataFormat) - Method in class com.logicalclocks.hsfs.spark.FeatureView: Create the metadata for a training dataset and save the corresponding training data into `location`.
createTrainValidationTestSplit(Float, Float, String, String, String, String, String, String, String, DataFormat, Boolean, StorageConnector, String, Long, StatisticsConfig, Map<String, String>, FilterLogic, Filter) - Method in class com.logicalclocks.hsfs.spark.FeatureView: Create the metadata for a training dataset and save the corresponding training data into `location`.
creator - Variable in class com.logicalclocks.hsfs.FeatureGroupBase
Credentials - Class in com.logicalclocks.hsfs.metadata
Credentials() - Constructor for class com.logicalclocks.hsfs.metadata.Credentials

D

database - Variable in class com.logicalclocks.hsfs.StorageConnector.SnowflakeConnector
databaseDriver - Variable in class com.logicalclocks.hsfs.StorageConnector.RedshiftConnector
databaseEndpoint - Variable in class com.logicalclocks.hsfs.StorageConnector.RedshiftConnector
databaseGroup - Variable in class com.logicalclocks.hsfs.StorageConnector.RedshiftConnector
databaseName - Variable in class com.logicalclocks.hsfs.StorageConnector.RedshiftConnector
databasePassword - Variable in class com.logicalclocks.hsfs.StorageConnector.RedshiftConnector
databasePort - Variable in class com.logicalclocks.hsfs.StorageConnector.RedshiftConnector
databaseUserName - Variable in class com.logicalclocks.hsfs.StorageConnector.RedshiftConnector
DataFormat - Enum in com.logicalclocks.hsfs
dataFormat - Variable in class com.logicalclocks.hsfs.TrainingDatasetBase
dataset - Variable in class com.logicalclocks.hsfs.StorageConnector.BigqueryConnector
datasetName - Variable in class com.logicalclocks.hsfs.StorageConnector.HopsFsConnector
DEFAULT_HIVE_PARTITION_EXTRACTOR_CLASS_OPT_VAL - Static variable in class com.logicalclocks.hsfs.spark.engine.hudi.HudiEngine
DEFAULT_VERSION - Static variable in class com.logicalclocks.hsfs.FeatureStoreBase
delete(FeatureGroupBase) - Method in class com.logicalclocks.hsfs.engine.FeatureGroupEngineBase
delete(T3, String) - Method in class com.logicalclocks.hsfs.engine.FeatureViewEngineBase
delete(T3, String, Integer) - Method in class com.logicalclocks.hsfs.engine.FeatureViewEngineBase
delete() - Method in class com.logicalclocks.hsfs.FeatureGroupBase
delete() - Method in class com.logicalclocks.hsfs.FeatureViewBase
delete() - Method in class com.logicalclocks.hsfs.flink.FeatureView
delete(FeatureGroupBase) - Method in class com.logicalclocks.hsfs.metadata.FeatureGroupApi
delete(FeatureStoreBase, String, Integer) - Method in class com.logicalclocks.hsfs.metadata.FeatureViewApi
delete(FeatureStoreBase, String) - Method in class com.logicalclocks.hsfs.metadata.FeatureViewApi
delete(TrainingDatasetBase) - Method in class com.logicalclocks.hsfs.metadata.TrainingDatasetApi
delete(TrainingDataset) - Method in class com.logicalclocks.hsfs.spark.engine.TrainingDatasetEngine
delete() - Method in class com.logicalclocks.hsfs.spark.FeatureView: Delete current feature view, all associated metadata and training data.
delete() - Method in class com.logicalclocks.hsfs.spark.TrainingDataset: Delete training dataset and all associated metadata.
delete() - Method in class com.logicalclocks.hsfs.TrainingDatasetBase: Delete training dataset and all associated metadata.
deleteAllTrainingDatasets() - Method in class com.logicalclocks.hsfs.FeatureViewBase
deleteAllTrainingDatasets() - Method in class com.logicalclocks.hsfs.flink.FeatureView
deleteAllTrainingDatasets() - Method in class com.logicalclocks.hsfs.spark.FeatureView: Delete all training datasets.
deleteContent(FeatureGroupBase) - Method in class com.logicalclocks.hsfs.metadata.FeatureGroupApi
deleteRecord(SparkSession, FeatureGroupBase, Dataset<Row>, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.engine.hudi.HudiEngine
deleteTag(FeatureGroupBase, String) - Method in class com.logicalclocks.hsfs.engine.FeatureGroupEngineBase
deleteTag(FeatureViewBase, String) - Method in class com.logicalclocks.hsfs.engine.FeatureViewEngineBase
deleteTag(FeatureViewBase, String, Integer) - Method in class com.logicalclocks.hsfs.engine.FeatureViewEngineBase
deleteTag(String) - Method in class com.logicalclocks.hsfs.FeatureGroupBase: Delete a tag of the feature group.
deleteTag(String) - Method in class com.logicalclocks.hsfs.FeatureViewBase: Delete a tag of the feature view.
deleteTag(String) - Method in class com.logicalclocks.hsfs.flink.FeatureView
deleteTag(FeatureViewBase, String) - Method in class com.logicalclocks.hsfs.metadata.TagsApi
deleteTag(FeatureViewBase, Integer, String) - Method in class com.logicalclocks.hsfs.metadata.TagsApi
deleteTag(FeatureGroupBase, String) - Method in class com.logicalclocks.hsfs.metadata.TagsApi
deleteTag(TrainingDatasetBase, String) - Method in class com.logicalclocks.hsfs.metadata.TagsApi
deleteTag(TrainingDataset, String) - Method in class com.logicalclocks.hsfs.spark.engine.TrainingDatasetEngine
deleteTag(String) - Method in class com.logicalclocks.hsfs.spark.FeatureView: Delete a tag of the feature view.
deleteTag(String) - Method in class com.logicalclocks.hsfs.spark.TrainingDataset: Delete a tag of the training dataset.
deleteTag(String) - Method in class com.logicalclocks.hsfs.TrainingDatasetBase: Delete a tag of the training dataset.
deleteTrainingData(T2, Integer) - Method in class com.logicalclocks.hsfs.engine.FeatureViewEngineBase
deleteTrainingData(T2) - Method in class com.logicalclocks.hsfs.engine.FeatureViewEngineBase
deleteTrainingData(FeatureStoreBase, String, Integer, Integer) - Method in class com.logicalclocks.hsfs.metadata.FeatureViewApi
deleteTrainingData(FeatureStoreBase, String, Integer) - Method in class com.logicalclocks.hsfs.metadata.FeatureViewApi
deleteTrainingDataset(Integer) - Method in class com.logicalclocks.hsfs.FeatureViewBase
deleteTrainingDataset(Integer) - Method in class com.logicalclocks.hsfs.flink.FeatureView
deleteTrainingDataset(Integer) - Method in class com.logicalclocks.hsfs.spark.FeatureView: Delete a training dataset.
deleteTrainingDatasetOnly(T2, Integer) - Method in class com.logicalclocks.hsfs.engine.FeatureViewEngineBase
deleteTrainingDatasetOnly(T2) - Method in class com.logicalclocks.hsfs.engine.FeatureViewEngineBase
deleteTrainingDatasetOnly(FeatureStoreBase, String, Integer, Integer) - Method in class com.logicalclocks.hsfs.metadata.FeatureViewApi
deleteTrainingDatasetOnly(FeatureStoreBase, String, Integer) - Method in class com.logicalclocks.hsfs.metadata.FeatureViewApi
deleteTrainingDatasetTag(Integer, String) - Method in class com.logicalclocks.hsfs.FeatureViewBase: Delete a tag of the training dataset.
deleteTrainingDatasetTag(Integer, String) - Method in class com.logicalclocks.hsfs.flink.FeatureView
deleteTrainingDatasetTag(Integer, String) - Method in class com.logicalclocks.hsfs.spark.FeatureView: Delete a tag of the training dataset.
DELIMITER - Static variable in class com.logicalclocks.hsfs.util.Constants
DELTA_SOURCE_ORDERING_FIELD_OPT_KEY - Static variable in class com.logicalclocks.hsfs.spark.engine.hudi.HudiEngine
DELTA_STREAMER_TRANSFORMER - Static variable in class com.logicalclocks.hsfs.spark.engine.hudi.HudiEngine
DELTASTREAMER_CHECKPOINT_KEY - Static variable in class com.logicalclocks.hsfs.spark.engine.hudi.HudiEngine
DeltaStreamerAvroDeserializer - Class in com.logicalclocks.hsfs.spark.engine.hudi
DeltaStreamerAvroDeserializer() - Constructor for class com.logicalclocks.hsfs.spark.engine.hudi.DeltaStreamerAvroDeserializer
DeltaStreamerConfig - Class in com.logicalclocks.hsfs.spark.engine.hudi
DeltaStreamerConfig() - Constructor for class com.logicalclocks.hsfs.spark.engine.hudi.DeltaStreamerConfig
DeltaStreamerJobConf - Class in com.logicalclocks.hsfs
DeltaStreamerJobConf() - Constructor for class com.logicalclocks.hsfs.DeltaStreamerJobConf
deltaStreamerJobConf - Variable in class com.logicalclocks.hsfs.FeatureGroupBase
DeltaStreamerKafkaSource - Class in com.logicalclocks.hsfs.spark.engine.hudi
DeltaStreamerKafkaSource(TypedProperties, JavaSparkContext, SparkSession, SchemaProvider) - Constructor for class com.logicalclocks.hsfs.spark.engine.hudi.DeltaStreamerKafkaSource
DeltaStreamerSchemaProvider - Class in com.logicalclocks.hsfs.spark.engine.hudi
DeltaStreamerSchemaProvider(TypedProperties, JavaSparkContext) - Constructor for class com.logicalclocks.hsfs.spark.engine.hudi.DeltaStreamerSchemaProvider
DeltaStreamerTransformer - Class in com.logicalclocks.hsfs.spark.engine.hudi
DeltaStreamerTransformer() - Constructor for class com.logicalclocks.hsfs.spark.engine.hudi.DeltaStreamerTransformer
description - Variable in class com.logicalclocks.hsfs.FeatureGroupBase
description - Variable in class com.logicalclocks.hsfs.FeatureViewBase
description(String) - Method in class com.logicalclocks.hsfs.spark.FeatureView.FeatureViewBuilder
description - Variable in class com.logicalclocks.hsfs.StorageConnector
description - Variable in class com.logicalclocks.hsfs.TrainingDatasetBase
deserialize(String, byte[]) - Method in class com.logicalclocks.hsfs.spark.engine.hudi.DeltaStreamerAvroDeserializer
directoryId - Variable in class com.logicalclocks.hsfs.StorageConnector.AdlsConnector

E

encodeComplexFeatures(FeatureGroupBase, Dataset<Row>) - Method in class com.logicalclocks.hsfs.spark.engine.SparkEngine: Encodes all complex type features to binary using their avro type as schema.
encryptionKey - Variable in class com.logicalclocks.hsfs.StorageConnector.GcsConnector
encryptionKeyHash - Variable in class com.logicalclocks.hsfs.StorageConnector.GcsConnector
ENTITY_ID_PATH - Static variable in class com.logicalclocks.hsfs.metadata.CodeApi
ENTITY_ID_PATH - Static variable in class com.logicalclocks.hsfs.metadata.TagsApi
ENTITY_ROOT_PATH - Static variable in class com.logicalclocks.hsfs.metadata.CodeApi
ENTITY_ROOT_PATH - Static variable in class com.logicalclocks.hsfs.metadata.TagsApi
EntityEndpointType - Enum in com.logicalclocks.hsfs
eq(Object) - Method in class com.logicalclocks.hsfs.Feature
eq(Feature) - Method in class com.logicalclocks.hsfs.Feature
eventEndTime - Variable in class com.logicalclocks.hsfs.TrainingDatasetBase
eventStartTime - Variable in class com.logicalclocks.hsfs.TrainingDatasetBase
eventTime - Variable in class com.logicalclocks.hsfs.FeatureGroupBase
expectationsNames - Variable in class com.logicalclocks.hsfs.FeatureGroupBase
expiration - Variable in class com.logicalclocks.hsfs.StorageConnector.RedshiftConnector
ExternalDataFormat - Enum in com.logicalclocks.hsfs
ExternalFeatureGroup - Class in com.logicalclocks.hsfs.spark
ExternalFeatureGroup(FeatureStore, String, Integer, String, ExternalDataFormat, String, Map<String, String>, StorageConnector, String, List<String>, List<Feature>, StatisticsConfig, String, boolean, String) - Constructor for class com.logicalclocks.hsfs.spark.ExternalFeatureGroup
ExternalFeatureGroup() - Constructor for class com.logicalclocks.hsfs.spark.ExternalFeatureGroup
ExternalFeatureGroup(FeatureStore, int) - Constructor for class com.logicalclocks.hsfs.spark.ExternalFeatureGroup
extraFilter - Variable in class com.logicalclocks.hsfs.TrainingDatasetBase
extraFilterVersion - Variable in class com.logicalclocks.hsfs.FeatureViewBase

F

Feature - Class in com.logicalclocks.hsfs
Feature(String) - Constructor for class com.logicalclocks.hsfs.Feature
Feature(String, FeatureGroupBase) - Constructor for class com.logicalclocks.hsfs.Feature
Feature(String, int) - Constructor for class com.logicalclocks.hsfs.Feature
Feature(String, String) - Constructor for class com.logicalclocks.hsfs.Feature
Feature(String, String, String) - Constructor for class com.logicalclocks.hsfs.Feature
Feature(String, String, Boolean, Boolean) - Constructor for class com.logicalclocks.hsfs.Feature
Feature(String, String, String, Boolean, Boolean, String, String) - Constructor for class com.logicalclocks.hsfs.Feature
FEATURE_GROUP_CLEAR_PATH - Static variable in class com.logicalclocks.hsfs.metadata.FeatureGroupApi
FEATURE_GROUP_COMMIT_PATH - Static variable in class com.logicalclocks.hsfs.metadata.FeatureGroupApi
FEATURE_GROUP_COMPLEX_FEATURES - Static variable in class com.logicalclocks.hsfs.spark.engine.hudi.HudiEngine
FEATURE_GROUP_ENCODED_SCHEMA - Static variable in class com.logicalclocks.hsfs.spark.engine.hudi.HudiEngine
FEATURE_GROUP_ID_PATH - Static variable in class com.logicalclocks.hsfs.metadata.FeatureGroupApi
FEATURE_GROUP_KAFKA_OFFSET_RESET - Static variable in class com.logicalclocks.hsfs.spark.engine.hudi.HudiEngine
FEATURE_GROUP_NAME - Static variable in class com.logicalclocks.hsfs.spark.engine.hudi.HudiEngine
FEATURE_GROUP_PATH - Static variable in class com.logicalclocks.hsfs.metadata.FeatureGroupApi
FEATURE_GROUP_ROOT_PATH - Static variable in class com.logicalclocks.hsfs.metadata.FeatureGroupApi
FEATURE_GROUP_SCHEMA - Static variable in class com.logicalclocks.hsfs.spark.engine.hudi.HudiEngine
FEATURE_GROUP_VERSION - Static variable in class com.logicalclocks.hsfs.spark.engine.hudi.HudiEngine
FEATURE_STORE_NAME - Static variable in class com.logicalclocks.hsfs.spark.engine.hudi.HudiEngine
FEATURE_STORE_NAME_PATH - Static variable in class com.logicalclocks.hsfs.metadata.FeatureStoreApi
FEATURE_STORE_PATH - Static variable in class com.logicalclocks.hsfs.metadata.FeatureStoreApi
FEATURE_STORE_SERVICE_PATH - Static variable in class com.logicalclocks.hsfs.metadata.FeatureStoreApi
FeatureGroup - Class in com.logicalclocks.hsfs.spark
FeatureGroup(FeatureStore, String, Integer, String, List<String>, List<String>, String, boolean, TimeTravelFormat, List<Feature>, StatisticsConfig, String, String) - Constructor for class com.logicalclocks.hsfs.spark.FeatureGroup
FeatureGroup() - Constructor for class com.logicalclocks.hsfs.spark.FeatureGroup
FeatureGroup(FeatureStore, Integer) - Constructor for class com.logicalclocks.hsfs.spark.FeatureGroup
FeatureGroup(Integer, String, List<Feature>) - Constructor for class com.logicalclocks.hsfs.spark.FeatureGroup
FeatureGroup(FeatureStore, int) - Constructor for class com.logicalclocks.hsfs.spark.FeatureGroup
FeatureGroupAlias<T extends FeatureGroupBase> - Class in com.logicalclocks.hsfs.constructor
FeatureGroupAlias() - Constructor for class com.logicalclocks.hsfs.constructor.FeatureGroupAlias
featureGroupApi - Variable in class com.logicalclocks.hsfs.engine.FeatureGroupEngineBase
featureGroupApi - Variable in class com.logicalclocks.hsfs.FeatureStoreBase
FeatureGroupApi - Class in com.logicalclocks.hsfs.metadata
FeatureGroupApi() - Constructor for class com.logicalclocks.hsfs.metadata.FeatureGroupApi
FeatureGroupBase<T> - Class in com.logicalclocks.hsfs
FeatureGroupBase() - Constructor for class com.logicalclocks.hsfs.FeatureGroupBase
FeatureGroupBaseForApi - Class in com.logicalclocks.hsfs
FeatureGroupBaseForApi(FeatureStoreBase, Integer) - Constructor for class com.logicalclocks.hsfs.FeatureGroupBaseForApi
FeatureGroupCommit - Class in com.logicalclocks.hsfs
FeatureGroupCommit() - Constructor for class com.logicalclocks.hsfs.FeatureGroupCommit
featureGroupCommit(FeatureGroupBase, FeatureGroupCommit) - Method in class com.logicalclocks.hsfs.metadata.FeatureGroupApi
FeatureGroupEngine - Class in com.logicalclocks.hsfs.flink.engine
FeatureGroupEngine() - Constructor for class com.logicalclocks.hsfs.flink.engine.FeatureGroupEngine
featureGroupEngine - Variable in class com.logicalclocks.hsfs.flink.StreamFeatureGroup
FeatureGroupEngine - Class in com.logicalclocks.hsfs.spark.engine
FeatureGroupEngine() - Constructor for class com.logicalclocks.hsfs.spark.engine.FeatureGroupEngine
featureGroupEngine - Variable in class com.logicalclocks.hsfs.spark.StreamFeatureGroup
FeatureGroupEngineBase - Class in com.logicalclocks.hsfs.engine
FeatureGroupEngineBase() - Constructor for class com.logicalclocks.hsfs.engine.FeatureGroupEngineBase
FeatureGroupEngineBase(FeatureGroupApi, TagsApi) - Constructor for class com.logicalclocks.hsfs.engine.FeatureGroupEngineBase
featureGroupEngineBase - Variable in class com.logicalclocks.hsfs.FeatureGroupBase
FeatureGroupUtils - Class in com.logicalclocks.hsfs.engine
FeatureGroupUtils() - Constructor for class com.logicalclocks.hsfs.engine.FeatureGroupUtils
features - Variable in class com.logicalclocks.hsfs.FeatureGroupBase
features - Variable in class com.logicalclocks.hsfs.FeatureViewBase
features - Variable in class com.logicalclocks.hsfs.TrainingDatasetBase
featureStore - Variable in class com.logicalclocks.hsfs.FeatureGroupBase
featureStore - Variable in class com.logicalclocks.hsfs.FeatureViewBase
FeatureStore - Class in com.logicalclocks.hsfs.flink
FeatureStore() - Constructor for class com.logicalclocks.hsfs.flink.FeatureStore
FeatureStore - Class in com.logicalclocks.hsfs.spark
FeatureStore() - Constructor for class com.logicalclocks.hsfs.spark.FeatureStore
featureStore - Variable in class com.logicalclocks.hsfs.TrainingDatasetBase
FEATURESTORE_SUFFIX - Static variable in class com.logicalclocks.hsfs.util.Constants
featureStoreApi - Variable in class com.logicalclocks.hsfs.HopsworksConnectionBase
FeatureStoreApi - Class in com.logicalclocks.hsfs.metadata
FeatureStoreApi() - Constructor for class com.logicalclocks.hsfs.metadata.FeatureStoreApi
FeatureStoreBase<T2 extends QueryBase> - Class in com.logicalclocks.hsfs
FeatureStoreBase() - Constructor for class com.logicalclocks.hsfs.FeatureStoreBase
FeatureStoreException - Exception in com.logicalclocks.hsfs
FeatureStoreException(String) - Constructor for exception com.logicalclocks.hsfs.FeatureStoreException
FeatureStoreException(String, Throwable) - Constructor for exception com.logicalclocks.hsfs.FeatureStoreException
featurestoreId - Variable in class com.logicalclocks.hsfs.StorageConnector
FeatureType - Enum in com.logicalclocks.hsfs
FeatureView - Class in com.logicalclocks.hsfs.flink
FeatureView() - Constructor for class com.logicalclocks.hsfs.flink.FeatureView
FeatureView - Class in com.logicalclocks.hsfs.spark
FeatureView(String, Integer, Query, String, FeatureStore, List<String>) - Constructor for class com.logicalclocks.hsfs.spark.FeatureView
FeatureView.FeatureViewBuilder - Class in com.logicalclocks.hsfs.spark
featureViewApi - Variable in class com.logicalclocks.hsfs.engine.FeatureViewEngineBase
FeatureViewApi - Class in com.logicalclocks.hsfs.metadata
FeatureViewApi() - Constructor for class com.logicalclocks.hsfs.metadata.FeatureViewApi
FeatureViewBase<T extends FeatureViewBase,T3 extends FeatureStoreBase<T4>,T4 extends QueryBase,T5> - Class in com.logicalclocks.hsfs
FeatureViewBase() - Constructor for class com.logicalclocks.hsfs.FeatureViewBase
FeatureViewBuilder(FeatureStore) - Constructor for class com.logicalclocks.hsfs.spark.FeatureView.FeatureViewBuilder
FeatureViewEngine - Class in com.logicalclocks.hsfs.flink.engine
FeatureViewEngine() - Constructor for class com.logicalclocks.hsfs.flink.engine.FeatureViewEngine
FeatureViewEngine - Class in com.logicalclocks.hsfs.spark.engine
FeatureViewEngine() - Constructor for class com.logicalclocks.hsfs.spark.engine.FeatureViewEngine
FeatureViewEngineBase<T1 extends QueryBase<T1,T4,T5>,T2 extends FeatureViewBase<T2,T3,T1,T5>,T3 extends FeatureStoreBase<T1>,T4 extends FeatureGroupBase,T5> - Class in com.logicalclocks.hsfs.engine
FeatureViewEngineBase() - Constructor for class com.logicalclocks.hsfs.engine.FeatureViewEngineBase
fetchNewData(Option<String>, long) - Method in class com.logicalclocks.hsfs.spark.engine.hudi.DeltaStreamerKafkaSource
Filter - Class in com.logicalclocks.hsfs.constructor
Filter() - Constructor for class com.logicalclocks.hsfs.constructor.Filter
filter - Variable in class com.logicalclocks.hsfs.constructor.QueryBase
filter(Filter) - Method in class com.logicalclocks.hsfs.constructor.QueryBase
filter(FilterLogic) - Method in class com.logicalclocks.hsfs.constructor.QueryBase
FilterLogic - Class in com.logicalclocks.hsfs.constructor
FilterLogic(Filter) - Constructor for class com.logicalclocks.hsfs.constructor.FilterLogic
FilterLogic(SqlFilterLogic, Filter, Filter) - Constructor for class com.logicalclocks.hsfs.constructor.FilterLogic
FilterLogic(SqlFilterLogic, Filter, FilterLogic) - Constructor for class com.logicalclocks.hsfs.constructor.FilterLogic
FilterLogic(SqlFilterLogic, FilterLogic, Filter) - Constructor for class com.logicalclocks.hsfs.constructor.FilterLogic
FilterLogic(SqlFilterLogic, FilterLogic, FilterLogic) - Constructor for class com.logicalclocks.hsfs.constructor.FilterLogic
FlinkEngine - Class in com.logicalclocks.hsfs.flink.engine
fromString(String) - Static method in enum com.logicalclocks.hsfs.SslEndpointIdentificationAlgorithm
FsQuery - Class in com.logicalclocks.hsfs.spark.constructor
FsQuery() - Constructor for class com.logicalclocks.hsfs.spark.constructor.FsQuery
FsQueryBase<T extends FeatureGroupBase,T2 extends FeatureGroupBase> - Class in com.logicalclocks.hsfs.constructor
FsQueryBase() - Constructor for class com.logicalclocks.hsfs.constructor.FsQueryBase
FUNCTION_TYPE - Static variable in class com.logicalclocks.hsfs.spark.engine.hudi.HudiEngine
FV_TAGS_PATH - Static variable in class com.logicalclocks.hsfs.metadata.TagsApi
FV_TD_TAGS_PATH - Static variable in class com.logicalclocks.hsfs.metadata.TagsApi

G

GcsConnector() - Constructor for class com.logicalclocks.hsfs.StorageConnector.GcsConnector
ge(Object) - Method in class com.logicalclocks.hsfs.Feature
ge(Feature) - Method in class com.logicalclocks.hsfs.Feature
generation - Variable in class com.logicalclocks.hsfs.StorageConnector.AdlsConnector
GenericRecordAvroSerializer - Class in com.logicalclocks.hsfs.flink.engine
GenericRecordAvroSerializer() - Constructor for class com.logicalclocks.hsfs.flink.engine.GenericRecordAvroSerializer
get(T3, String, Integer) - Method in class com.logicalclocks.hsfs.engine.FeatureViewEngineBase
get(T3, String, Integer, Class<T2>) - Method in class com.logicalclocks.hsfs.engine.FeatureViewEngineBase
get(T3, String) - Method in class com.logicalclocks.hsfs.engine.FeatureViewEngineBase
get(FeatureStore, String, Integer) - Method in class com.logicalclocks.hsfs.flink.engine.FeatureViewEngine
get(int, String, Class<T>) - Method in class com.logicalclocks.hsfs.metadata.FeatureStoreApi
get(FeatureStoreBase, String, Integer, Class<T>) - Method in class com.logicalclocks.hsfs.metadata.FeatureViewApi
get(FeatureStoreBase, String) - Method in class com.logicalclocks.hsfs.metadata.FeatureViewApi
get(String) - Method in class com.logicalclocks.hsfs.metadata.ProjectApi
get(FeatureGroupBase, String) - Method in class com.logicalclocks.hsfs.metadata.StatisticsApi
get(TrainingDatasetBase, String) - Method in class com.logicalclocks.hsfs.metadata.StatisticsApi
get(Integer, String, Class<U>) - Method in class com.logicalclocks.hsfs.metadata.StorageConnectorApi
get(FeatureViewBase) - Method in class com.logicalclocks.hsfs.metadata.TagsApi
get(FeatureViewBase, Integer) - Method in class com.logicalclocks.hsfs.metadata.TagsApi
get(FeatureViewBase, String) - Method in class com.logicalclocks.hsfs.metadata.TagsApi
get(FeatureViewBase, Integer, String) - Method in class com.logicalclocks.hsfs.metadata.TagsApi
get(FeatureGroupBase, String) - Method in class com.logicalclocks.hsfs.metadata.TagsApi
get(TrainingDatasetBase, String) - Method in class com.logicalclocks.hsfs.metadata.TagsApi
get(FeatureGroupBase) - Method in class com.logicalclocks.hsfs.metadata.TagsApi
get(TrainingDatasetBase) - Method in class com.logicalclocks.hsfs.metadata.TagsApi
get(FeatureStoreBase, String, Integer) - Method in class com.logicalclocks.hsfs.metadata.TrainingDatasetApi
get(String) - Method in class com.logicalclocks.hsfs.metadata.VariablesApi
get(FeatureStore, String, Integer) - Method in class com.logicalclocks.hsfs.spark.engine.FeatureViewEngine
get(FeatureGroupBase, String) - Method in class com.logicalclocks.hsfs.spark.engine.StatisticsEngine
get(TrainingDataset, String) - Method in class com.logicalclocks.hsfs.spark.engine.StatisticsEngine
getAdlsConnector(String) - Method in class com.logicalclocks.hsfs.FeatureStoreBase
getAdlsConnector(String) - Method in class com.logicalclocks.hsfs.flink.FeatureStore
getAdlsConnector(String) - Method in class com.logicalclocks.hsfs.spark.FeatureStore: Get a previously created Adls compliant storage connector from the feature store.
getAssumedRole() - Method in class com.logicalclocks.hsfs.metadata.HopsworksExternalClient
getAvroSchema(FeatureGroupBase, FeatureStoreBase) - Method in class com.logicalclocks.hsfs.engine.FeatureGroupUtils
getAvroSchema() - Method in class com.logicalclocks.hsfs.FeatureGroupBase
getBatchData(T2, Date, Date, Map<String, String>, Integer) - Method in class com.logicalclocks.hsfs.engine.FeatureViewEngineBase
getBatchData() - Method in class com.logicalclocks.hsfs.FeatureViewBase
getBatchData(String, String) - Method in class com.logicalclocks.hsfs.FeatureViewBase
getBatchData(String, String, Map<String, String>) - Method in class com.logicalclocks.hsfs.FeatureViewBase
getBatchData(FeatureView, Date, Date, Map<String, String>, Integer) - Method in class com.logicalclocks.hsfs.flink.engine.FeatureViewEngine
getBatchData() - Method in class com.logicalclocks.hsfs.flink.FeatureView
getBatchData(String, String) - Method in class com.logicalclocks.hsfs.flink.FeatureView
getBatchData(String, String, Map<String, String>) - Method in class com.logicalclocks.hsfs.flink.FeatureView
getBatchData(FeatureView, Date, Date, Map<String, String>, Integer) - Method in class com.logicalclocks.hsfs.spark.engine.FeatureViewEngine
getBatchData() - Method in class com.logicalclocks.hsfs.spark.FeatureView: Get all data from the feature view as a batch from the offline feature store.
getBatchData(String, String) - Method in class com.logicalclocks.hsfs.spark.FeatureView: Get a batch of data from an event time interval from the offline feature store.
getBatchData(String, String, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.FeatureView: Get a batch of data from an event time interval from the offline feature store.
getBatchQuery(T2, Date, Date, Boolean, Integer) - Method in class com.logicalclocks.hsfs.engine.FeatureViewEngineBase
getBatchQuery(T2, Date, Date, Boolean, Integer, Class<T1>) - Method in class com.logicalclocks.hsfs.engine.FeatureViewEngineBase
getBatchQuery() - Method in class com.logicalclocks.hsfs.FeatureViewBase
getBatchQuery(String, String) - Method in class com.logicalclocks.hsfs.FeatureViewBase
getBatchQuery(FeatureView, Date, Date, Boolean, Integer) - Method in class com.logicalclocks.hsfs.flink.engine.FeatureViewEngine
getBatchQuery() - Method in class com.logicalclocks.hsfs.flink.FeatureView
getBatchQuery(String, String) - Method in class com.logicalclocks.hsfs.flink.FeatureView
getBatchQuery(FeatureStoreBase, String, Integer, Long, Long, Boolean, Integer, Class<T>) - Method in class com.logicalclocks.hsfs.metadata.FeatureViewApi
getBatchQuery(FeatureView, Date, Date, Boolean, Integer) - Method in class com.logicalclocks.hsfs.spark.engine.FeatureViewEngine
getBatchQuery() - Method in class com.logicalclocks.hsfs.spark.FeatureView: Get a query string of the batch query.
getBatchQuery(String, String) - Method in class com.logicalclocks.hsfs.spark.FeatureView: Get a query string of the batch query.
getBatchQueryString(T2, Date, Date, Integer) - Method in class com.logicalclocks.hsfs.engine.FeatureViewEngineBase
getBatchQueryString(FeatureView, Date, Date, Integer) - Method in class com.logicalclocks.hsfs.flink.engine.FeatureViewEngine
getBatchQueryString(FeatureView, Date, Date, Integer) - Method in class com.logicalclocks.hsfs.spark.engine.FeatureViewEngine
getBigqueryConnector(String) - Method in class com.logicalclocks.hsfs.FeatureStoreBase
getBigqueryConnector(String) - Method in class com.logicalclocks.hsfs.flink.FeatureStore
getBigqueryConnector(String) - Method in class com.logicalclocks.hsfs.spark.FeatureStore: Get a previously created BigQuery compliant storage connector from the feature store.
getBrokerEndpoints(FeatureStoreBase) - Method in class com.logicalclocks.hsfs.metadata.KafkaApi
getBrokerEndpoints(FeatureStoreBase, boolean) - Method in class com.logicalclocks.hsfs.metadata.KafkaApi
getByName(FeatureStoreBase, String, Class<T>) - Method in class com.logicalclocks.hsfs.metadata.StorageConnectorApi
getCertKey() - Method in class com.logicalclocks.hsfs.flink.engine.FlinkEngine
getCertKey() - Method in interface com.logicalclocks.hsfs.metadata.HopsworksHttpClient
getCertKey() - Method in class com.logicalclocks.hsfs.spark.engine.SparkEngine
getCommitDetails(FeatureGroupBase, String, Integer) - Method in class com.logicalclocks.hsfs.engine.FeatureGroupUtils
getCommitDetails(FeatureGroupBase, Long, Integer) - Method in class com.logicalclocks.hsfs.metadata.FeatureGroupApi
getComplexFeatures(List<Feature>) - Method in class com.logicalclocks.hsfs.engine.FeatureGroupUtils
getComplexFeatures() - Method in class com.logicalclocks.hsfs.FeatureGroupBase
getCount() - Method in class com.logicalclocks.hsfs.metadata.RestDto
getCredentials(Project) - Method in class com.logicalclocks.hsfs.metadata.HopsworksClient
getDataset(Boolean) - Method in class com.logicalclocks.hsfs.spark.TrainingDatasetBundle
getDataset(String, Boolean) - Method in class com.logicalclocks.hsfs.spark.TrainingDatasetBundle
getDateFromDateString(String) - Static method in class com.logicalclocks.hsfs.engine.FeatureGroupUtils
getDeserializedAvroSchema(String) - Method in class com.logicalclocks.hsfs.engine.FeatureGroupUtils
getDeserializedAvroSchema() - Method in class com.logicalclocks.hsfs.FeatureGroupBase
getDeserializedEncodedAvroSchema(Schema, List<String>) - Method in class com.logicalclocks.hsfs.engine.FeatureGroupUtils
getDeserializedEncodedAvroSchema() - Method in class com.logicalclocks.hsfs.FeatureGroupBase
getEncodedAvroSchema(Schema, List<String>) - Method in class com.logicalclocks.hsfs.engine.FeatureGroupUtils
getEncodedAvroSchema() - Method in class com.logicalclocks.hsfs.FeatureGroupBase
getEndTime() - Method in class com.logicalclocks.hsfs.engine.FeatureViewEngineBase
getExternalFeatureGroup(String, Integer) - Method in class com.logicalclocks.hsfs.FeatureStoreBase: Get a external feature group object from the feature store.
getExternalFeatureGroup(String) - Method in class com.logicalclocks.hsfs.FeatureStoreBase: Get a external feature group object with default version `1` from the feature store.
getExternalFeatureGroup(String, Integer) - Method in class com.logicalclocks.hsfs.flink.FeatureStore
getExternalFeatureGroup(String) - Method in class com.logicalclocks.hsfs.flink.FeatureStore
getExternalFeatureGroup(FeatureStore, String, Integer) - Method in class com.logicalclocks.hsfs.spark.engine.FeatureGroupEngine
getExternalFeatureGroup(String, Integer) - Method in class com.logicalclocks.hsfs.spark.FeatureStore: Get an external feature group object from the feature store.
getExternalFeatureGroup(String) - Method in class com.logicalclocks.hsfs.spark.FeatureStore: Get an external feature group object with default version `1` from the feature store.
getExternalFeatureGroups(String) - Method in class com.logicalclocks.hsfs.FeatureStoreBase
getExternalFeatureGroups(String) - Method in class com.logicalclocks.hsfs.flink.FeatureStore
getExternalFeatureGroups(FeatureStore, String) - Method in class com.logicalclocks.hsfs.spark.engine.FeatureGroupEngine
getExternalFeatureGroups(String) - Method in class com.logicalclocks.hsfs.spark.FeatureStore: Get a list of all versions of an external feature group from the feature store.
getFeature(String) - Method in class com.logicalclocks.hsfs.FeatureGroupBase: Retrieve a feature of the feature group by name.
getFeatureAvroSchema(String, Schema) - Method in class com.logicalclocks.hsfs.engine.FeatureGroupUtils
getFeatureAvroSchema(String) - Method in class com.logicalclocks.hsfs.FeatureGroupBase
getFeatureGroup(FeatureStore, String, Integer) - Method in class com.logicalclocks.hsfs.spark.engine.FeatureGroupEngine
getFeatureGroup(String, Integer) - Method in class com.logicalclocks.hsfs.spark.FeatureStore: Get a feature group object from the feature store.
getFeatureGroup(String) - Method in class com.logicalclocks.hsfs.spark.FeatureStore: Get a feature group object with default version `1` from the feature store.
getFeatureGroups(String) - Method in class com.logicalclocks.hsfs.FeatureStoreBase
getFeatureGroups(String) - Method in class com.logicalclocks.hsfs.flink.FeatureStore
getFeatureGroups(FeatureStore, String) - Method in class com.logicalclocks.hsfs.spark.engine.FeatureGroupEngine
getFeatureGroups(String) - Method in class com.logicalclocks.hsfs.spark.FeatureStore: Get a list of all versions of a feature group from the feature store.
getFeatureStore() - Method in class com.logicalclocks.hsfs.flink.HopsworksConnection: Retrieve the project feature store.
getFeatureStore(String) - Method in class com.logicalclocks.hsfs.flink.HopsworksConnection: Retrieve a feature store based on name.
getFeatureStore() - Method in class com.logicalclocks.hsfs.HopsworksConnectionBase
getFeatureStore(String) - Method in class com.logicalclocks.hsfs.HopsworksConnectionBase
getFeatureStore() - Method in class com.logicalclocks.hsfs.spark.HopsworksConnection: Retrieve the project feature store.
getFeatureStore(String) - Method in class com.logicalclocks.hsfs.spark.HopsworksConnection: Retrieve a feature store based on name.
getFeatureVector(TrainingDatasetBase, Map<String, Object>) - Method in class com.logicalclocks.hsfs.engine.VectorServer
getFeatureVector(TrainingDatasetBase, Map<String, Object>, boolean) - Method in class com.logicalclocks.hsfs.engine.VectorServer
getFeatureVector(FeatureViewBase, Map<String, Object>) - Method in class com.logicalclocks.hsfs.engine.VectorServer
getFeatureVector(FeatureViewBase, Map<String, Object>, boolean) - Method in class com.logicalclocks.hsfs.engine.VectorServer
getFeatureVector(Map<String, Object>) - Method in class com.logicalclocks.hsfs.FeatureViewBase: Returns assembled feature vector from online feature store.
getFeatureVector(Map<String, Object>, boolean) - Method in class com.logicalclocks.hsfs.FeatureViewBase: Returns assembled feature vector from online feature store.
getFeatureVectors(TrainingDatasetBase, Map<String, List<Object>>) - Method in class com.logicalclocks.hsfs.engine.VectorServer
getFeatureVectors(TrainingDatasetBase, Map<String, List<Object>>, boolean) - Method in class com.logicalclocks.hsfs.engine.VectorServer
getFeatureVectors(FeatureViewBase, Map<String, List<Object>>) - Method in class com.logicalclocks.hsfs.engine.VectorServer
getFeatureVectors(FeatureViewBase, Map<String, List<Object>>, boolean) - Method in class com.logicalclocks.hsfs.engine.VectorServer
getFeatureVectors(Map<String, List<Object>>) - Method in class com.logicalclocks.hsfs.FeatureViewBase: Returns assembled feature vectors in batches from online feature store.
getFeatureVectors(Map<String, List<Object>>, boolean) - Method in class com.logicalclocks.hsfs.FeatureViewBase: Returns assembled feature vectors in batches from online feature store.
getFeatureView(String) - Method in class com.logicalclocks.hsfs.FeatureStoreBase
getFeatureView(String, Integer) - Method in class com.logicalclocks.hsfs.FeatureStoreBase
getFeatureView(String, Integer) - Method in class com.logicalclocks.hsfs.flink.FeatureStore: Get a feature view object from the selected feature store.
getFeatureView(String) - Method in class com.logicalclocks.hsfs.flink.FeatureStore: Get a feature view object from the selected feature store.
getFeatureView(String, Integer) - Method in class com.logicalclocks.hsfs.spark.FeatureStore: Get a feature view object from the selected feature store.
getFeatureView(String) - Method in class com.logicalclocks.hsfs.spark.FeatureStore: Get a feature view object with the default version `1` from the selected feature store.
getFgName(FeatureGroupBase) - Method in class com.logicalclocks.hsfs.engine.FeatureGroupUtils
getGcsConnector(String) - Method in class com.logicalclocks.hsfs.FeatureStoreBase
getGcsConnector(String) - Method in class com.logicalclocks.hsfs.flink.FeatureStore
getGcsConnector(String) - Method in class com.logicalclocks.hsfs.spark.FeatureStore: Get a previously created Gcs compliant storage connector from the feature store.
getHiveServerConnection(FeatureGroupBase, String) - Method in class com.logicalclocks.hsfs.engine.FeatureGroupUtils
getHopsFsConnector(String) - Method in class com.logicalclocks.hsfs.FeatureStoreBase
getHopsFsConnector(String) - Method in class com.logicalclocks.hsfs.flink.FeatureStore
getHopsFsConnector(String) - Method in class com.logicalclocks.hsfs.spark.FeatureStore: Get a previously created HopsFs compliant storage connector from the feature store.
getInstance() - Static method in class com.logicalclocks.hsfs.flink.engine.FlinkEngine
getInstance() - Static method in class com.logicalclocks.hsfs.metadata.HopsworksClient
getInstance() - Static method in class com.logicalclocks.hsfs.spark.engine.SparkEngine
getInternal(FeatureStoreBase, String, Integer, Class<T>) - Method in class com.logicalclocks.hsfs.metadata.FeatureGroupApi
getItems() - Method in class com.logicalclocks.hsfs.metadata.RestDto
getJdbcConnector(String) - Method in class com.logicalclocks.hsfs.FeatureStoreBase
getJdbcConnector(String) - Method in class com.logicalclocks.hsfs.flink.FeatureStore
getJdbcConnector(String) - Method in class com.logicalclocks.hsfs.spark.FeatureStore: Get a previously created JDBC compliant storage connector from the feature store.
getKafkaConfig(FeatureGroupBase, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.engine.SparkEngine
getKafkaConnector(String) - Method in class com.logicalclocks.hsfs.FeatureStoreBase
getKafkaConnector(String) - Method in class com.logicalclocks.hsfs.flink.FeatureStore
getKafkaConnector(String) - Method in class com.logicalclocks.hsfs.spark.FeatureStore: Get a previously created Kafka compliant storage connector from the feature store.
getKeyStorePath() - Method in class com.logicalclocks.hsfs.flink.engine.FlinkEngine
getKeyStorePath() - Method in interface com.logicalclocks.hsfs.metadata.HopsworksHttpClient
getKeyStorePath() - Method in class com.logicalclocks.hsfs.spark.engine.SparkEngine
getkStore() - Method in class com.logicalclocks.hsfs.metadata.Credentials
getLabel() - Method in class com.logicalclocks.hsfs.TrainingDatasetBase
getLast(FeatureGroupBase) - Method in class com.logicalclocks.hsfs.metadata.StatisticsApi
getLast(TrainingDatasetBase) - Method in class com.logicalclocks.hsfs.metadata.StatisticsApi
getLast(FeatureGroupBase) - Method in class com.logicalclocks.hsfs.spark.engine.StatisticsEngine
getLast(TrainingDataset) - Method in class com.logicalclocks.hsfs.spark.engine.StatisticsEngine
getOnDemandFeatureGroup(String, Integer) - Method in class com.logicalclocks.hsfs.spark.FeatureStore: Deprecated.
getOnDemandFeatureGroup(String) - Method in class com.logicalclocks.hsfs.spark.FeatureStore: Deprecated.
getOnDemandFeatureGroups(String) - Method in class com.logicalclocks.hsfs.spark.FeatureStore: Deprecated.
getOnlineStorageConnector() - Method in class com.logicalclocks.hsfs.FeatureStoreBase
getOnlineStorageConnector() - Method in class com.logicalclocks.hsfs.flink.FeatureStore
getOnlineStorageConnector(FeatureStoreBase, Class<T>) - Method in class com.logicalclocks.hsfs.metadata.StorageConnectorApi
getOnlineStorageConnector() - Method in class com.logicalclocks.hsfs.spark.FeatureStore: Get a previously created JDBC compliant storage connector from the feature store to connect to the online feature store.
getOnlineTableName(FeatureGroupBase) - Method in class com.logicalclocks.hsfs.engine.FeatureGroupUtils
getOrCreateFeatureGroup(String, Integer) - Method in class com.logicalclocks.hsfs.FeatureStoreBase
getOrCreateFeatureGroup(String, Integer, List<String>, List<String>, boolean, String) - Method in class com.logicalclocks.hsfs.FeatureStoreBase
getOrCreateFeatureGroup(String, Integer, List<String>, boolean, String) - Method in class com.logicalclocks.hsfs.FeatureStoreBase
getOrCreateFeatureGroup(String, Integer, String, List<String>, List<String>, String, boolean, TimeTravelFormat, StatisticsConfig, String) - Method in class com.logicalclocks.hsfs.FeatureStoreBase
getOrCreateFeatureGroup(String, Integer) - Method in class com.logicalclocks.hsfs.flink.FeatureStore
getOrCreateFeatureGroup(String, Integer, List<String>, boolean, String) - Method in class com.logicalclocks.hsfs.flink.FeatureStore
getOrCreateFeatureGroup(String, Integer, List<String>, List<String>, boolean, String) - Method in class com.logicalclocks.hsfs.flink.FeatureStore
getOrCreateFeatureGroup(String, Integer, String, List<String>, List<String>, String, boolean, TimeTravelFormat, StatisticsConfig, String) - Method in class com.logicalclocks.hsfs.flink.FeatureStore
getOrCreateFeatureGroup(FeatureStore, String, Integer, String, List<String>, List<String>, String, boolean, TimeTravelFormat, StatisticsConfig, String) - Method in class com.logicalclocks.hsfs.spark.engine.FeatureGroupEngine
getOrCreateFeatureGroup(String, Integer) - Method in class com.logicalclocks.hsfs.spark.FeatureStore: Get feature group metadata object or create a new one if it doesn't exist.
getOrCreateFeatureGroup(String, Integer, List<String>, boolean, String) - Method in class com.logicalclocks.hsfs.spark.FeatureStore: Get feature group metadata object or create a new one if it doesn't exist.
getOrCreateFeatureGroup(String, Integer, List<String>, List<String>, boolean, String) - Method in class com.logicalclocks.hsfs.spark.FeatureStore: Get feature group metadata object or create a new one if it doesn't exist.
getOrCreateFeatureGroup(String, Integer, String, List<String>, List<String>, String, boolean, TimeTravelFormat, StatisticsConfig, String) - Method in class com.logicalclocks.hsfs.spark.FeatureStore: Get feature group metadata object or create a new one if it doesn't exist.
getOrCreateFeatureView(T3, String, Integer, T1, String, List<String>) - Method in class com.logicalclocks.hsfs.engine.FeatureViewEngineBase
getOrCreateFeatureView(String, T2, Integer) - Method in class com.logicalclocks.hsfs.FeatureStoreBase
getOrCreateFeatureView(String, T2, Integer, String, List<String>) - Method in class com.logicalclocks.hsfs.FeatureStoreBase
getOrCreateFeatureView(FeatureStore, String, Integer, Query, String, List<String>) - Method in class com.logicalclocks.hsfs.flink.engine.FeatureViewEngine
getOrCreateFeatureView(String, Query, Integer) - Method in class com.logicalclocks.hsfs.flink.FeatureStore
getOrCreateFeatureView(String, Query, Integer, String, List<String>) - Method in class com.logicalclocks.hsfs.flink.FeatureStore
getOrCreateFeatureView(FeatureStore, String, Integer, Query, String, List<String>) - Method in class com.logicalclocks.hsfs.spark.engine.FeatureViewEngine
getOrCreateFeatureView(String, Query, Integer) - Method in class com.logicalclocks.hsfs.spark.FeatureStore: Get feature view metadata object or create a new one if it doesn't exist.
getOrCreateFeatureView(String, Query, Integer, String, List<String>) - Method in class com.logicalclocks.hsfs.spark.FeatureStore: Get feature view metadata object or create a new one if it doesn't exist.
getOrCreateStreamFeatureGroup(String, Integer) - Method in class com.logicalclocks.hsfs.FeatureStoreBase
getOrCreateStreamFeatureGroup(String, Integer, List<String>, boolean, String) - Method in class com.logicalclocks.hsfs.FeatureStoreBase
getOrCreateStreamFeatureGroup(String, Integer, List<String>, List<String>, boolean, String) - Method in class com.logicalclocks.hsfs.FeatureStoreBase
getOrCreateStreamFeatureGroup(String, Integer, String, List<String>, List<String>, String, boolean, StatisticsConfig, String) - Method in class com.logicalclocks.hsfs.FeatureStoreBase
getOrCreateStreamFeatureGroup(String, Integer) - Method in class com.logicalclocks.hsfs.flink.FeatureStore
getOrCreateStreamFeatureGroup(String, Integer, List<String>, boolean, String) - Method in class com.logicalclocks.hsfs.flink.FeatureStore
getOrCreateStreamFeatureGroup(String, Integer, List<String>, List<String>, boolean, String) - Method in class com.logicalclocks.hsfs.flink.FeatureStore
getOrCreateStreamFeatureGroup(String, Integer, String, List<String>, List<String>, String, boolean, StatisticsConfig, String) - Method in class com.logicalclocks.hsfs.flink.FeatureStore
getOrCreateStreamFeatureGroup(FeatureStore, String, Integer, String, List<String>, List<String>, String, boolean, StatisticsConfig, String) - Method in class com.logicalclocks.hsfs.spark.engine.FeatureGroupEngine
getOrCreateStreamFeatureGroup(String, Integer) - Method in class com.logicalclocks.hsfs.spark.FeatureStore: Get stream feature group metadata object or create a new one if it doesn't exist.
getOrCreateStreamFeatureGroup(String, Integer, List<String>, boolean, String) - Method in class com.logicalclocks.hsfs.spark.FeatureStore: Get stream feature group metadata object or create a new one if it doesn't exist.
getOrCreateStreamFeatureGroup(String, Integer, List<String>, List<String>, boolean, String) - Method in class com.logicalclocks.hsfs.spark.FeatureStore: Get stream feature group metadata object or create a new one if it doesn't exist.
getOrCreateStreamFeatureGroup(String, Integer, String, List<String>, List<String>, String, boolean, StatisticsConfig, String) - Method in class com.logicalclocks.hsfs.spark.FeatureStore: Get stream feature group metadata object or create a new one if it doesn't exist.
getPartitionColumns(FeatureGroupBase) - Method in class com.logicalclocks.hsfs.engine.FeatureGroupUtils
getPassword() - Method in class com.logicalclocks.hsfs.metadata.Credentials
getPath(String) - Method in class com.logicalclocks.hsfs.StorageConnector.AdlsConnector
getPath(String) - Method in class com.logicalclocks.hsfs.StorageConnector.BigqueryConnector
getPath(String) - Method in class com.logicalclocks.hsfs.StorageConnector.GcsConnector
getPath(String) - Method in class com.logicalclocks.hsfs.StorageConnector
getPath(String) - Method in class com.logicalclocks.hsfs.StorageConnector.HopsFsConnector
getPath(String) - Method in class com.logicalclocks.hsfs.StorageConnector.JdbcConnector
getPath(String) - Method in class com.logicalclocks.hsfs.StorageConnector.KafkaConnector
getPath(String) - Method in class com.logicalclocks.hsfs.StorageConnector.RedshiftConnector
getPath(String) - Method in class com.logicalclocks.hsfs.StorageConnector.S3Connector
getPath(String) - Method in class com.logicalclocks.hsfs.StorageConnector.SnowflakeConnector
getPrimaryColumns(FeatureGroupBase) - Method in class com.logicalclocks.hsfs.engine.FeatureGroupUtils
getPrimaryKeys() - Method in class com.logicalclocks.hsfs.FeatureGroupBase
getPrimaryKeys() - Method in class com.logicalclocks.hsfs.FeatureViewBase: Set of primary key names that is used as keys in input dict object for `get_serving_vector` method.
getPrimaryKeys() - Method in class com.logicalclocks.hsfs.spark.FeatureView: Get set of primary key names that is used as keys in input dict object for `getServingVector` method.
getProducedType() - Method in class com.logicalclocks.hsfs.flink.engine.PojoToAvroRecord
getProject() - Method in class com.logicalclocks.hsfs.HopsworksConnectionBase
getProjectName(String) - Method in class com.logicalclocks.hsfs.HopsworksConnectionBase
getQuery(TrainingDatasetBase, boolean, boolean) - Method in class com.logicalclocks.hsfs.metadata.TrainingDatasetApi
getQuery(TrainingDataset, Storage, boolean, boolean) - Method in class com.logicalclocks.hsfs.spark.engine.TrainingDatasetEngine
getQuery(Storage, boolean) - Method in class com.logicalclocks.hsfs.spark.TrainingDataset
getQuery() - Method in class com.logicalclocks.hsfs.TrainingDatasetBase
getQuery(boolean) - Method in class com.logicalclocks.hsfs.TrainingDatasetBase
getQuery(Storage) - Method in class com.logicalclocks.hsfs.TrainingDatasetBase
getQuery(Storage, boolean) - Method in class com.logicalclocks.hsfs.TrainingDatasetBase
getReadOptions(Map<String, String>, DataFormat) - Method in class com.logicalclocks.hsfs.spark.engine.SparkEngine
getRedshiftConnector(String) - Method in class com.logicalclocks.hsfs.FeatureStoreBase
getRedshiftConnector(String) - Method in class com.logicalclocks.hsfs.flink.FeatureStore
getRedshiftConnector(String) - Method in class com.logicalclocks.hsfs.spark.FeatureStore: Get a previously created Redshift compliant storage connector from the feature store.
getS3Connector(String) - Method in class com.logicalclocks.hsfs.FeatureStoreBase
getS3Connector(String) - Method in class com.logicalclocks.hsfs.flink.FeatureStore
getS3Connector(String) - Method in class com.logicalclocks.hsfs.spark.FeatureStore: Get a previously created S3 compliant storage connector from the feature store.
getServingKeys() - Method in class com.logicalclocks.hsfs.TrainingDatasetBase: Set of primary key names that is used as keys in input dict object for `get_serving_vector` method.
getServingPreparedStatement(FeatureViewBase, boolean) - Method in class com.logicalclocks.hsfs.metadata.FeatureViewApi
getServingPreparedStatement(TrainingDatasetBase, boolean) - Method in class com.logicalclocks.hsfs.metadata.TrainingDatasetApi
getServingVector(Map<String, Object>) - Method in class com.logicalclocks.hsfs.spark.TrainingDataset: Retrieve feature vector from online feature store.
getServingVector(Map<String, Object>) - Method in class com.logicalclocks.hsfs.TrainingDatasetBase: Retrieve feature vector from online feature store.
getServingVector(Map<String, Object>, boolean) - Method in class com.logicalclocks.hsfs.TrainingDatasetBase: Retrieve feature vector from online feature store.
getServingVectors(Map<String, List<Object>>) - Method in class com.logicalclocks.hsfs.TrainingDatasetBase
getServingVectors(Map<String, List<Object>>, boolean) - Method in class com.logicalclocks.hsfs.TrainingDatasetBase
getSnowflakeConnector(String) - Method in class com.logicalclocks.hsfs.FeatureStoreBase
getSnowflakeConnector(String) - Method in class com.logicalclocks.hsfs.flink.FeatureStore
getSnowflakeConnector(String) - Method in class com.logicalclocks.hsfs.spark.FeatureStore: Get a previously created Snowflake compliant storage connector from the feature store.
getSourceSchema() - Method in class com.logicalclocks.hsfs.spark.engine.hudi.DeltaStreamerSchemaProvider
getSplitStatistics(TrainingDataset) - Method in class com.logicalclocks.hsfs.spark.engine.StatisticsEngine
getSplitStatistics(TrainingDataset, Map<String, Dataset<Row>>) - Method in class com.logicalclocks.hsfs.spark.engine.StatisticsEngine
getStartTime() - Method in class com.logicalclocks.hsfs.engine.FeatureViewEngineBase
getStatistics() - Method in class com.logicalclocks.hsfs.FeatureGroupBase: Get the last statistics commit for the feature group.
getStatistics() - Method in class com.logicalclocks.hsfs.FeatureGroupBaseForApi
getStatistics() - Method in class com.logicalclocks.hsfs.flink.StreamFeatureGroup
getStatistics() - Method in class com.logicalclocks.hsfs.spark.ExternalFeatureGroup
getStatistics() - Method in class com.logicalclocks.hsfs.spark.FeatureGroup: Get the last statistics commit for the feature group.
getStatistics() - Method in class com.logicalclocks.hsfs.spark.StreamFeatureGroup
getStatistics() - Method in class com.logicalclocks.hsfs.spark.TrainingDataset: Get the last statistics commit for the training dataset.
getStatistics(String) - Method in class com.logicalclocks.hsfs.spark.TrainingDataset: Get the statistics of a specific commit time for the training dataset.
getStatistics() - Method in class com.logicalclocks.hsfs.TrainingDatasetBase: Get the last statistics commit for the training dataset.
getStatistics(String) - Method in class com.logicalclocks.hsfs.TrainingDatasetBase: Get the statistics of a specific commit time for the training dataset.
getStorageConnector(String) - Method in class com.logicalclocks.hsfs.FeatureStoreBase: Get a list of all versions of an external feature group from the feature store.
getStorageConnector(String) - Method in class com.logicalclocks.hsfs.flink.FeatureStore
getStorageConnector(String) - Method in class com.logicalclocks.hsfs.spark.FeatureStore: Get a previously created storage connector from the feature store.
getStorageQuery(Storage) - Method in class com.logicalclocks.hsfs.constructor.FsQueryBase
getStreamFeatureGroup(String, Integer) - Method in class com.logicalclocks.hsfs.FeatureStoreBase: Get a feature group object from the feature store.
getStreamFeatureGroup(String) - Method in class com.logicalclocks.hsfs.FeatureStoreBase: Get a feature group object with default version `1` from the feature store.
getStreamFeatureGroup(FeatureStore, String, Integer) - Method in class com.logicalclocks.hsfs.flink.engine.FeatureGroupEngine
getStreamFeatureGroup(String) - Method in class com.logicalclocks.hsfs.flink.FeatureStore: Get a stream feature group object from the feature store.
getStreamFeatureGroup(String, Integer) - Method in class com.logicalclocks.hsfs.flink.FeatureStore: Get a stream feature group object from the feature store.
getStreamFeatureGroup(FeatureStore, String, Integer) - Method in class com.logicalclocks.hsfs.spark.engine.FeatureGroupEngine
getStreamFeatureGroup(String) - Method in class com.logicalclocks.hsfs.spark.FeatureStore: Get a stream feature group object with default version `1` from the feature store.
getStreamFeatureGroup(String, Integer) - Method in class com.logicalclocks.hsfs.spark.FeatureStore: Get a stream feature group object from the feature store.
getStreamFeatureGroups(FeatureStore, String) - Method in class com.logicalclocks.hsfs.flink.engine.FeatureGroupEngine
getStreamFeatureGroups(FeatureStore, String) - Method in class com.logicalclocks.hsfs.spark.engine.FeatureGroupEngine
getSubject(FeatureGroupBase) - Method in class com.logicalclocks.hsfs.engine.FeatureGroupUtils
getSubject() - Method in class com.logicalclocks.hsfs.FeatureGroupBase
getTableName(FeatureGroupBase) - Method in class com.logicalclocks.hsfs.engine.FeatureGroupUtils
getTag(FeatureGroupBase, String) - Method in class com.logicalclocks.hsfs.engine.FeatureGroupEngineBase
getTag(FeatureViewBase, String) - Method in class com.logicalclocks.hsfs.engine.FeatureViewEngineBase
getTag(FeatureViewBase, String, Integer) - Method in class com.logicalclocks.hsfs.engine.FeatureViewEngineBase
getTag(String) - Method in class com.logicalclocks.hsfs.FeatureGroupBase: Get a single tag value of the feature group.
getTag(String) - Method in class com.logicalclocks.hsfs.FeatureViewBase: Get a single tag value of the feature view.
getTag(String) - Method in class com.logicalclocks.hsfs.flink.FeatureView
getTag(TrainingDataset, String) - Method in class com.logicalclocks.hsfs.spark.engine.TrainingDatasetEngine
getTag(String) - Method in class com.logicalclocks.hsfs.spark.FeatureView: Get a single tag value of the feature view.
getTag(String) - Method in class com.logicalclocks.hsfs.spark.TrainingDataset: Get a single tag value of the training dataset.
getTag(String) - Method in class com.logicalclocks.hsfs.TrainingDatasetBase: Get a single tag value of the training dataset.
getTags(FeatureGroupBase) - Method in class com.logicalclocks.hsfs.engine.FeatureGroupEngineBase
getTags(FeatureViewBase) - Method in class com.logicalclocks.hsfs.engine.FeatureViewEngineBase
getTags(FeatureViewBase, Integer) - Method in class com.logicalclocks.hsfs.engine.FeatureViewEngineBase
getTags() - Method in class com.logicalclocks.hsfs.FeatureGroupBase: Get all tags of the feature group.
getTags() - Method in class com.logicalclocks.hsfs.FeatureViewBase: Get all tags of the feature view.
getTags() - Method in class com.logicalclocks.hsfs.flink.FeatureView
getTags(TrainingDataset) - Method in class com.logicalclocks.hsfs.spark.engine.TrainingDatasetEngine
getTags() - Method in class com.logicalclocks.hsfs.spark.FeatureView: Get all tags of the feature view.
getTags() - Method in class com.logicalclocks.hsfs.spark.TrainingDataset: Get all tags of the training dataset.
getTags() - Method in class com.logicalclocks.hsfs.TrainingDatasetBase: Get all tags of the training dataset.
getTimeStampFromDateString(String) - Static method in class com.logicalclocks.hsfs.engine.FeatureGroupUtils
getTopicDetails(FeatureStoreBase, String) - Method in class com.logicalclocks.hsfs.metadata.KafkaApi
getTopicSubject(FeatureStoreBase, String) - Method in class com.logicalclocks.hsfs.metadata.KafkaApi
getTrainingData(Integer, Map<String, String>) - Method in class com.logicalclocks.hsfs.FeatureViewBase
getTrainingData(Integer, Map<String, String>) - Method in class com.logicalclocks.hsfs.flink.FeatureView
getTrainingData(FeatureStoreBase, String, Integer, Integer, Class<T>) - Method in class com.logicalclocks.hsfs.metadata.FeatureViewApi
getTrainingData(Integer) - Method in class com.logicalclocks.hsfs.spark.FeatureView: Get training data created by `featureView.createTrainingData` or `featureView.trainingData`.
getTrainingData(Integer, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.FeatureView: Get training data created by `featureView.createTrainingData` or `featureView.trainingData`.
getTrainingDataset(String, Integer) - Method in class com.logicalclocks.hsfs.FeatureStoreBase: Get a training dataset object from the selected feature store.
getTrainingDataset(String) - Method in class com.logicalclocks.hsfs.FeatureStoreBase: Get a training dataset object with the default version `1` from the selected feature store.
getTrainingDataset(String, Integer) - Method in class com.logicalclocks.hsfs.flink.FeatureStore
getTrainingDataset(String) - Method in class com.logicalclocks.hsfs.flink.FeatureStore
getTrainingDataset(FeatureStoreBase, String, Integer) - Method in class com.logicalclocks.hsfs.metadata.TrainingDatasetApi
getTrainingDataset(FeatureView, Integer, List<String>, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.engine.FeatureViewEngine
getTrainingDataset(FeatureView, TrainingDataset, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.engine.FeatureViewEngine
getTrainingDataset(FeatureView, TrainingDataset, List<String>, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.engine.FeatureViewEngine
getTrainingDataset(String, Integer) - Method in class com.logicalclocks.hsfs.spark.FeatureStore: Deprecated.
getTrainingDataset(String) - Method in class com.logicalclocks.hsfs.spark.FeatureStore: Deprecated.
getTrainingDatasets(String) - Method in class com.logicalclocks.hsfs.FeatureStoreBase: Get all versions of a training dataset object from the selected feature store.
getTrainingDatasets(String) - Method in class com.logicalclocks.hsfs.flink.FeatureStore
getTrainingDatasets(String) - Method in class com.logicalclocks.hsfs.spark.FeatureStore: Deprecated.
getTrainingDatasetTag(Integer, String) - Method in class com.logicalclocks.hsfs.FeatureViewBase: Get a single tag value of the training dataset.
getTrainingDatasetTag(Integer, String) - Method in class com.logicalclocks.hsfs.flink.FeatureView
getTrainingDatasetTag(Integer, String) - Method in class com.logicalclocks.hsfs.spark.FeatureView: Get a single tag value of the training dataset.
getTrainingDatasetTags(Integer) - Method in class com.logicalclocks.hsfs.FeatureViewBase: Get all tags of the training dataset.
getTrainingDatasetTags(Integer) - Method in class com.logicalclocks.hsfs.flink.FeatureView
getTrainingDatasetTags(Integer) - Method in class com.logicalclocks.hsfs.spark.FeatureView: Get all tags of the training dataset.
getTrainingDatasetType(StorageConnector) - Method in class com.logicalclocks.hsfs.TrainingDatasetBase
getTrainTestSplit(Integer, Map<String, String>) - Method in class com.logicalclocks.hsfs.FeatureViewBase
getTrainTestSplit(Integer, Map<String, String>) - Method in class com.logicalclocks.hsfs.flink.FeatureView
getTrainTestSplit(Integer) - Method in class com.logicalclocks.hsfs.spark.FeatureView: Get training data created by `featureView.createTrainTestSplit` or `featureView.trainTestSplit`.
getTrainTestSplit(Integer, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.FeatureView: Get training data created by `featureView.createTrainTestSplit` or `featureView.trainTestSplit`.
getTrainValidationTestSplit(Integer, Map<String, String>) - Method in class com.logicalclocks.hsfs.FeatureViewBase
getTrainValidationTestSplit(Integer, Map<String, String>) - Method in class com.logicalclocks.hsfs.flink.FeatureView
getTrainValidationTestSplit(Integer) - Method in class com.logicalclocks.hsfs.spark.FeatureView: Get training data created by `featureView.createTrainValidationTestSplit` or featureView.trainValidationTestSplit`.
getTrainValidationTestSplit(Integer, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.FeatureView: Get training data created by `featureView.createTrainValidationTestSplit` or featureView.trainValidationTestSplit`.
getTransformationFunctions(FeatureViewBase) - Method in class com.logicalclocks.hsfs.metadata.FeatureViewApi
getTransformationFunctions(TrainingDatasetBase) - Method in class com.logicalclocks.hsfs.metadata.TrainingDatasetApi
getTrustStorePath() - Method in class com.logicalclocks.hsfs.flink.engine.FlinkEngine
getTrustStorePath() - Method in interface com.logicalclocks.hsfs.metadata.HopsworksHttpClient
getTrustStorePath() - Method in class com.logicalclocks.hsfs.spark.engine.SparkEngine
gettStore() - Method in class com.logicalclocks.hsfs.metadata.Credentials
getValue() - Method in enum com.logicalclocks.hsfs.EntityEndpointType
getValue() - Method in enum com.logicalclocks.hsfs.HudiOperationType
getValue() - Method in enum com.logicalclocks.hsfs.SslEndpointIdentificationAlgorithm
getWriteOptions(Map<String, String>, DataFormat) - Method in class com.logicalclocks.hsfs.spark.engine.SparkEngine
gt(Object) - Method in class com.logicalclocks.hsfs.Feature
gt(Feature) - Method in class com.logicalclocks.hsfs.Feature

H

handleRequest(HttpRequest, ResponseHandler<T>) - Method in class com.logicalclocks.hsfs.metadata.HopsworksClient
handleRequest(HttpRequest, Class<T>) - Method in class com.logicalclocks.hsfs.metadata.HopsworksClient
handleRequest(HttpRequest) - Method in class com.logicalclocks.hsfs.metadata.HopsworksClient
handleRequest(HttpRequest, ResponseHandler<T>) - Method in class com.logicalclocks.hsfs.metadata.HopsworksExternalClient
handleRequest(HttpRequest, ResponseHandler<T>) - Method in interface com.logicalclocks.hsfs.metadata.HopsworksHttpClient
handleRequest(HttpRequest, ResponseHandler<T>) - Method in class com.logicalclocks.hsfs.metadata.HopsworksInternalClient
handleResponse(HttpResponse) - Method in class com.logicalclocks.hsfs.metadata.AuthorizationHandler
handleResponse(HttpResponse) - Method in class com.logicalclocks.hsfs.metadata.HopsworksClient.BaseHandler
HEADER - Static variable in class com.logicalclocks.hsfs.util.Constants
HIVE_AUTO_CREATE_DATABASE_OPT_KEY - Static variable in class com.logicalclocks.hsfs.spark.engine.hudi.HudiEngine
HIVE_AUTO_CREATE_DATABASE_OPT_VAL - Static variable in class com.logicalclocks.hsfs.spark.engine.hudi.HudiEngine
HIVE_FORMAT - Static variable in class com.logicalclocks.hsfs.util.Constants
HIVE_NON_PARTITION_EXTRACTOR_CLASS_OPT_VAL - Static variable in class com.logicalclocks.hsfs.spark.engine.hudi.HudiEngine
HIVE_PARTITION_EXTRACTOR_CLASS_OPT_KEY - Static variable in class com.logicalclocks.hsfs.spark.engine.hudi.HudiEngine
hiveEngine - Variable in class com.logicalclocks.hsfs.constructor.QueryBase
HopsFsConnector() - Constructor for class com.logicalclocks.hsfs.StorageConnector.HopsFsConnector
hopsfsPath - Variable in class com.logicalclocks.hsfs.StorageConnector.HopsFsConnector
HopsworksClient - Class in com.logicalclocks.hsfs.metadata
HopsworksClient(HopsworksHttpClient, String) - Constructor for class com.logicalclocks.hsfs.metadata.HopsworksClient
HopsworksClient.BaseHandler<T> - Class in com.logicalclocks.hsfs.metadata
HopsworksClient.HopsworksErrorClass - Class in com.logicalclocks.hsfs.metadata
hopsworksClientInstance - Static variable in class com.logicalclocks.hsfs.metadata.HopsworksClient
HopsworksConnection - Class in com.logicalclocks.hsfs.flink
HopsworksConnection(String, int, String, Region, SecretStore, boolean, String, String, String, String) - Constructor for class com.logicalclocks.hsfs.flink.HopsworksConnection
HopsworksConnection - Class in com.logicalclocks.hsfs.spark
HopsworksConnection(String, int, String, Region, SecretStore, boolean, String, String, String, String) - Constructor for class com.logicalclocks.hsfs.spark.HopsworksConnection
HopsworksConnectionBase - Class in com.logicalclocks.hsfs
HopsworksConnectionBase() - Constructor for class com.logicalclocks.hsfs.HopsworksConnectionBase
HopsworksErrorClass() - Constructor for class com.logicalclocks.hsfs.metadata.HopsworksClient.HopsworksErrorClass
HopsworksExternalClient - Class in com.logicalclocks.hsfs.metadata
HopsworksExternalClient(CloseableHttpClient, HttpHost) - Constructor for class com.logicalclocks.hsfs.metadata.HopsworksExternalClient
HopsworksHostnameVerifier - Class in com.logicalclocks.hsfs.metadata
HopsworksHostnameVerifier(boolean, String) - Constructor for class com.logicalclocks.hsfs.metadata.HopsworksHostnameVerifier
hopsworksHttpClient - Variable in class com.logicalclocks.hsfs.metadata.HopsworksClient
HopsworksHttpClient - Interface in com.logicalclocks.hsfs.metadata
HopsworksInternalClient - Class in com.logicalclocks.hsfs.metadata
HopsworksInternalClient() - Constructor for class com.logicalclocks.hsfs.metadata.HopsworksInternalClient
host - Variable in class com.logicalclocks.hsfs.HopsworksConnectionBase
host - Variable in class com.logicalclocks.hsfs.metadata.HopsworksClient
hostnameVerification - Variable in class com.logicalclocks.hsfs.HopsworksConnectionBase
httpClient - Variable in class com.logicalclocks.hsfs.metadata.HopsworksExternalClient
httpHost - Variable in class com.logicalclocks.hsfs.metadata.HopsworksExternalClient
HUDI_BASE_PATH - Static variable in class com.logicalclocks.hsfs.spark.engine.hudi.HudiEngine
HUDI_BEGIN_INSTANTTIME_OPT_KEY - Static variable in class com.logicalclocks.hsfs.spark.engine.hudi.HudiEngine
HUDI_COMPLEX_KEY_GENERATOR_OPT_VAL - Static variable in class com.logicalclocks.hsfs.spark.engine.hudi.HudiEngine
HUDI_COPY_ON_WRITE - Static variable in class com.logicalclocks.hsfs.spark.engine.hudi.HudiEngine
HUDI_END_INSTANTTIME_OPT_KEY - Static variable in class com.logicalclocks.hsfs.spark.engine.hudi.HudiEngine
HUDI_HIVE_SYNC_DB - Static variable in class com.logicalclocks.hsfs.spark.engine.hudi.HudiEngine
HUDI_HIVE_SYNC_ENABLE - Static variable in class com.logicalclocks.hsfs.spark.engine.hudi.HudiEngine
HUDI_HIVE_SYNC_MODE - Static variable in class com.logicalclocks.hsfs.spark.engine.hudi.HudiEngine
HUDI_HIVE_SYNC_MODE_VAL - Static variable in class com.logicalclocks.hsfs.spark.engine.hudi.HudiEngine
HUDI_HIVE_SYNC_PARTITION_FIELDS - Static variable in class com.logicalclocks.hsfs.spark.engine.hudi.HudiEngine
HUDI_HIVE_SYNC_TABLE - Static variable in class com.logicalclocks.hsfs.spark.engine.hudi.HudiEngine
HUDI_KAFKA_TOPIC - Static variable in class com.logicalclocks.hsfs.spark.engine.hudi.HudiEngine
HUDI_KEY_GENERATOR_OPT_KEY - Static variable in class com.logicalclocks.hsfs.spark.engine.hudi.HudiEngine
HUDI_PARTITION_FIELD - Static variable in class com.logicalclocks.hsfs.spark.engine.hudi.HudiEngine
HUDI_PRECOMBINE_FIELD - Static variable in class com.logicalclocks.hsfs.spark.engine.hudi.HudiEngine
HUDI_QUERY_TIME_TRAVEL_AS_OF_INSTANT - Static variable in class com.logicalclocks.hsfs.spark.engine.hudi.HudiEngine
HUDI_QUERY_TYPE_INCREMENTAL_OPT_VAL - Static variable in class com.logicalclocks.hsfs.spark.engine.hudi.HudiEngine
HUDI_QUERY_TYPE_OPT_KEY - Static variable in class com.logicalclocks.hsfs.spark.engine.hudi.HudiEngine
HUDI_QUERY_TYPE_SNAPSHOT_OPT_VAL - Static variable in class com.logicalclocks.hsfs.spark.engine.hudi.HudiEngine
HUDI_RECORD_KEY - Static variable in class com.logicalclocks.hsfs.spark.engine.hudi.HudiEngine
HUDI_SPARK_FORMAT - Static variable in class com.logicalclocks.hsfs.spark.engine.hudi.HudiEngine
HUDI_TABLE_NAME - Static variable in class com.logicalclocks.hsfs.spark.engine.hudi.HudiEngine
HUDI_TABLE_OPERATION - Static variable in class com.logicalclocks.hsfs.spark.engine.hudi.HudiEngine
HUDI_TABLE_STORAGE_TYPE - Static variable in class com.logicalclocks.hsfs.spark.engine.hudi.HudiEngine
HUDI_WRITE_INSERT_DROP_DUPLICATES - Static variable in class com.logicalclocks.hsfs.spark.engine.hudi.HudiEngine
HudiEngine - Class in com.logicalclocks.hsfs.spark.engine.hudi
HudiEngine() - Constructor for class com.logicalclocks.hsfs.spark.engine.hudi.HudiEngine
HudiOperationType - Enum in com.logicalclocks.hsfs
hudiPrecombineKey - Variable in class com.logicalclocks.hsfs.FeatureGroupBase

I

iamRole - Variable in class com.logicalclocks.hsfs.StorageConnector.RedshiftConnector
iamRole - Variable in class com.logicalclocks.hsfs.StorageConnector.S3Connector
id - Variable in class com.logicalclocks.hsfs.FeatureGroupBase
id - Variable in class com.logicalclocks.hsfs.FeatureViewBase
id - Variable in class com.logicalclocks.hsfs.StorageConnector
id - Variable in class com.logicalclocks.hsfs.TrainingDatasetBase
in(Collection<?>) - Method in class com.logicalclocks.hsfs.Feature: Deprecated.
`in` method is deprecated. Use `isin` instead.
INFER_SCHEMA - Static variable in class com.logicalclocks.hsfs.util.Constants
initBatchScoring(Integer) - Method in class com.logicalclocks.hsfs.FeatureViewBase: Initialise feature view to retrieve feature vector from offline feature store.
INITIAL_CHECKPOINT_STRING - Static variable in class com.logicalclocks.hsfs.spark.engine.hudi.HudiEngine
initPreparedStatement(TrainingDatasetBase, boolean) - Method in class com.logicalclocks.hsfs.engine.VectorServer
initPreparedStatement(TrainingDatasetBase, boolean, boolean) - Method in class com.logicalclocks.hsfs.engine.VectorServer
initPreparedStatement(FeatureViewBase, boolean) - Method in class com.logicalclocks.hsfs.engine.VectorServer
initPreparedStatement(FeatureViewBase, boolean, boolean) - Method in class com.logicalclocks.hsfs.engine.VectorServer
initPreparedStatement() - Method in class com.logicalclocks.hsfs.TrainingDatasetBase: Initialise and cache parametrised prepared statement to retrieve feature vector from online feature store.
initPreparedStatement(boolean) - Method in class com.logicalclocks.hsfs.TrainingDatasetBase: Initialise and cache parametrised prepared statement to retrieve feature vector from online feature store.
initPreparedStatement(boolean, boolean) - Method in class com.logicalclocks.hsfs.TrainingDatasetBase: Initialise and cache parametrised prepared statement to retrieve batch feature vectors from online feature store.
initServing(TrainingDatasetBase, boolean) - Method in class com.logicalclocks.hsfs.engine.VectorServer
initServing(FeatureViewBase, boolean) - Method in class com.logicalclocks.hsfs.engine.VectorServer
initServing(FeatureViewBase, boolean, boolean) - Method in class com.logicalclocks.hsfs.engine.VectorServer
initServing() - Method in class com.logicalclocks.hsfs.FeatureViewBase: Initialise feature view to retrieve feature vector from online feature store.
initServing(Boolean, Boolean) - Method in class com.logicalclocks.hsfs.FeatureViewBase: Deprecated.
insert(T) - Method in class com.logicalclocks.hsfs.FeatureGroupBase
insert(T, Map<String, String>) - Method in class com.logicalclocks.hsfs.FeatureGroupBase
insert(T, Storage) - Method in class com.logicalclocks.hsfs.FeatureGroupBase
insert(T, boolean) - Method in class com.logicalclocks.hsfs.FeatureGroupBase
insert(T, Storage, boolean) - Method in class com.logicalclocks.hsfs.FeatureGroupBase
insert(T, boolean, Map<String, String>) - Method in class com.logicalclocks.hsfs.FeatureGroupBase
insert(T, HudiOperationType) - Method in class com.logicalclocks.hsfs.FeatureGroupBase
insert(T, Storage, boolean, HudiOperationType, Map<String, String>) - Method in class com.logicalclocks.hsfs.FeatureGroupBase
insert(T, JobConfiguration) - Method in class com.logicalclocks.hsfs.FeatureGroupBase
insert(T, boolean, Map<String, String>, JobConfiguration) - Method in class com.logicalclocks.hsfs.FeatureGroupBase
insert(FeatureGroupBaseForApi) - Method in class com.logicalclocks.hsfs.FeatureGroupBaseForApi
insert(FeatureGroupBaseForApi, Map<String, String>) - Method in class com.logicalclocks.hsfs.FeatureGroupBaseForApi
insert(FeatureGroupBaseForApi, Storage) - Method in class com.logicalclocks.hsfs.FeatureGroupBaseForApi
insert(FeatureGroupBaseForApi, boolean) - Method in class com.logicalclocks.hsfs.FeatureGroupBaseForApi
insert(FeatureGroupBaseForApi, Storage, boolean) - Method in class com.logicalclocks.hsfs.FeatureGroupBaseForApi
insert(FeatureGroupBaseForApi, boolean, Map<String, String>) - Method in class com.logicalclocks.hsfs.FeatureGroupBaseForApi
insert(FeatureGroupBaseForApi, HudiOperationType) - Method in class com.logicalclocks.hsfs.FeatureGroupBaseForApi
insert(FeatureGroupBaseForApi, Storage, boolean, HudiOperationType, Map<String, String>) - Method in class com.logicalclocks.hsfs.FeatureGroupBaseForApi
insert(FeatureGroupBaseForApi, JobConfiguration) - Method in class com.logicalclocks.hsfs.FeatureGroupBaseForApi
insert(FeatureGroupBaseForApi, boolean, Map<String, String>, JobConfiguration) - Method in class com.logicalclocks.hsfs.FeatureGroupBaseForApi
insert(DataStream<?>) - Method in class com.logicalclocks.hsfs.flink.StreamFeatureGroup
insert(DataStream<?>, Map<String, String>) - Method in class com.logicalclocks.hsfs.flink.StreamFeatureGroup
insert(DataStream<?>, Storage) - Method in class com.logicalclocks.hsfs.flink.StreamFeatureGroup
insert(DataStream<?>, boolean) - Method in class com.logicalclocks.hsfs.flink.StreamFeatureGroup
insert(DataStream<?>, Storage, boolean) - Method in class com.logicalclocks.hsfs.flink.StreamFeatureGroup
insert(DataStream<?>, boolean, Map<String, String>) - Method in class com.logicalclocks.hsfs.flink.StreamFeatureGroup
insert(DataStream<?>, HudiOperationType) - Method in class com.logicalclocks.hsfs.flink.StreamFeatureGroup
insert(DataStream<?>, Storage, boolean, HudiOperationType, Map<String, String>) - Method in class com.logicalclocks.hsfs.flink.StreamFeatureGroup
insert(DataStream<?>, JobConfiguration) - Method in class com.logicalclocks.hsfs.flink.StreamFeatureGroup
insert(DataStream<?>, boolean, Map<String, String>, JobConfiguration) - Method in class com.logicalclocks.hsfs.flink.StreamFeatureGroup
insert(FeatureGroup, Dataset<Row>, Storage, HudiOperationType, SaveMode, List<String>, String, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.engine.FeatureGroupEngine
insert(StreamFeatureGroup, Dataset<Row>, SaveMode, List<String>, String, Map<String, String>, JobConfiguration) - Method in class com.logicalclocks.hsfs.spark.engine.FeatureGroupEngine
insert(ExternalFeatureGroup, Dataset<Row>, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.engine.FeatureGroupEngine
insert(Dataset<Row>, Storage) - Method in class com.logicalclocks.hsfs.spark.ExternalFeatureGroup
insert(Dataset<Row>, boolean) - Method in class com.logicalclocks.hsfs.spark.ExternalFeatureGroup
insert(Dataset<Row>, Storage, boolean) - Method in class com.logicalclocks.hsfs.spark.ExternalFeatureGroup
insert(Dataset<Row>, boolean, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.ExternalFeatureGroup
insert(Dataset<Row>, HudiOperationType) - Method in class com.logicalclocks.hsfs.spark.ExternalFeatureGroup
insert(Dataset<Row>, Storage, boolean, HudiOperationType, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.ExternalFeatureGroup
insert(Dataset<Row>, JobConfiguration) - Method in class com.logicalclocks.hsfs.spark.ExternalFeatureGroup
insert(Dataset<Row>, boolean, Map<String, String>, JobConfiguration) - Method in class com.logicalclocks.hsfs.spark.ExternalFeatureGroup
insert(Dataset<Row>) - Method in class com.logicalclocks.hsfs.spark.ExternalFeatureGroup: Incrementally insert data to the online storage of an external feature group.
insert(Dataset<Row>, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.ExternalFeatureGroup: Incrementally insert data to the online storage of an external feature group.
insert(Dataset<Row>) - Method in class com.logicalclocks.hsfs.spark.FeatureGroup: Incrementally insert data to a feature group or overwrite all data contained in the feature group.
insert(Dataset<Row>, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.FeatureGroup: Incrementally insert data to a feature group or overwrite all data contained in the feature group.
insert(Dataset<Row>, Storage) - Method in class com.logicalclocks.hsfs.spark.FeatureGroup: Incrementally insert data to a feature group or overwrite all data contained in the feature group.
insert(Dataset<Row>, boolean) - Method in class com.logicalclocks.hsfs.spark.FeatureGroup: Incrementally insert data to a feature group or overwrite all data contained in the feature group.
insert(Dataset<Row>, Storage, boolean) - Method in class com.logicalclocks.hsfs.spark.FeatureGroup: Incrementally insert data to a feature group or overwrite all data contained in the feature group.
insert(Dataset<Row>, boolean, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.FeatureGroup: Incrementally insert data to a feature group or overwrite all data contained in the feature group.
insert(Dataset<Row>, HudiOperationType) - Method in class com.logicalclocks.hsfs.spark.FeatureGroup: Incrementally insert data to a feature group or overwrite all data contained in the feature group.
insert(Dataset<Row>, Storage, boolean, HudiOperationType, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.FeatureGroup: Incrementally insert data to a feature group or overwrite all data contained in the feature group.
insert(Dataset<Row>, JobConfiguration) - Method in class com.logicalclocks.hsfs.spark.FeatureGroup
insert(Dataset<Row>, boolean, Map<String, String>, JobConfiguration) - Method in class com.logicalclocks.hsfs.spark.FeatureGroup
insert(Dataset<Row>) - Method in class com.logicalclocks.hsfs.spark.StreamFeatureGroup: Incrementally insert data to a stream feature group or overwrite all data contained in the feature group.
insert(Dataset<Row>, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.StreamFeatureGroup: Incrementally insert data to a stream feature group or overwrite all data contained in the feature group.
insert(Dataset<Row>, Storage) - Method in class com.logicalclocks.hsfs.spark.StreamFeatureGroup
insert(Dataset<Row>, boolean) - Method in class com.logicalclocks.hsfs.spark.StreamFeatureGroup: Incrementally insert data to a stream feature group or overwrite all data contained in the feature group.
insert(Dataset<Row>, Storage, boolean) - Method in class com.logicalclocks.hsfs.spark.StreamFeatureGroup
insert(Dataset<Row>, boolean, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.StreamFeatureGroup: Incrementally insert data to a stream feature group or overwrite all data contained in the feature group.
insert(Dataset<Row>, HudiOperationType) - Method in class com.logicalclocks.hsfs.spark.StreamFeatureGroup
insert(Dataset<Row>, Storage, boolean, HudiOperationType, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.StreamFeatureGroup: Incrementally insert data to a stream feature group or overwrite all data contained in the feature group.
insert(Dataset<Row>, JobConfiguration) - Method in class com.logicalclocks.hsfs.spark.StreamFeatureGroup: Incrementally insert data to a stream feature group or overwrite all data contained in the feature group.
insert(Dataset<Row>, boolean, Map<String, String>, JobConfiguration) - Method in class com.logicalclocks.hsfs.spark.StreamFeatureGroup: Incrementally insert data to a stream feature group or overwrite all data contained in the feature group.
insertStream(T) - Method in class com.logicalclocks.hsfs.FeatureGroupBase
insertStream(T, String) - Method in class com.logicalclocks.hsfs.FeatureGroupBase
insertStream(T, Map<String, String>) - Method in class com.logicalclocks.hsfs.FeatureGroupBase
insertStream(T, String, Map<String, String>) - Method in class com.logicalclocks.hsfs.FeatureGroupBase
insertStream(T, String, String) - Method in class com.logicalclocks.hsfs.FeatureGroupBase
insertStream(T, String, String, String) - Method in class com.logicalclocks.hsfs.FeatureGroupBase
insertStream(T, String, String, boolean, Long) - Method in class com.logicalclocks.hsfs.FeatureGroupBase
insertStream(T, String, String, boolean, Long, String) - Method in class com.logicalclocks.hsfs.FeatureGroupBase
insertStream(T, String, String, boolean, Long, String, Map<String, String>) - Method in class com.logicalclocks.hsfs.FeatureGroupBase
insertStream(T, String, String, boolean, String) - Method in class com.logicalclocks.hsfs.FeatureGroupBase
insertStream(T, String, String, boolean, Long, String, Map<String, String>, JobConfiguration) - Method in class com.logicalclocks.hsfs.FeatureGroupBase
insertStream(FeatureGroupBaseForApi) - Method in class com.logicalclocks.hsfs.FeatureGroupBaseForApi
insertStream(FeatureGroupBaseForApi, String) - Method in class com.logicalclocks.hsfs.FeatureGroupBaseForApi
insertStream(FeatureGroupBaseForApi, Map<String, String>) - Method in class com.logicalclocks.hsfs.FeatureGroupBaseForApi
insertStream(FeatureGroupBaseForApi, String, Map<String, String>) - Method in class com.logicalclocks.hsfs.FeatureGroupBaseForApi
insertStream(FeatureGroupBaseForApi, String, String) - Method in class com.logicalclocks.hsfs.FeatureGroupBaseForApi
insertStream(FeatureGroupBaseForApi, String, String, String) - Method in class com.logicalclocks.hsfs.FeatureGroupBaseForApi
insertStream(FeatureGroupBaseForApi, String, String, boolean, Long) - Method in class com.logicalclocks.hsfs.FeatureGroupBaseForApi
insertStream(FeatureGroupBaseForApi, String, String, boolean, Long, String) - Method in class com.logicalclocks.hsfs.FeatureGroupBaseForApi
insertStream(FeatureGroupBaseForApi, String, String, boolean, Long, String, Map<String, String>) - Method in class com.logicalclocks.hsfs.FeatureGroupBaseForApi
insertStream(FeatureGroupBaseForApi, String, String, boolean, String) - Method in class com.logicalclocks.hsfs.FeatureGroupBaseForApi
insertStream(FeatureGroupBaseForApi, String, String, boolean, Long, String, Map<String, String>, JobConfiguration) - Method in class com.logicalclocks.hsfs.FeatureGroupBaseForApi
insertStream(StreamFeatureGroup, DataStream<?>, Map<String, String>) - Method in class com.logicalclocks.hsfs.flink.engine.FeatureGroupEngine
insertStream(DataStream<?>) - Method in class com.logicalclocks.hsfs.flink.StreamFeatureGroup: Ingest a feature data to the online feature store using Flink DataStream API.
insertStream(DataStream<?>, Map<String, String>) - Method in class com.logicalclocks.hsfs.flink.StreamFeatureGroup
insertStream(DataStream<?>, String) - Method in class com.logicalclocks.hsfs.flink.StreamFeatureGroup
insertStream(DataStream<?>, String, Map<String, String>) - Method in class com.logicalclocks.hsfs.flink.StreamFeatureGroup
insertStream(DataStream<?>, String, String) - Method in class com.logicalclocks.hsfs.flink.StreamFeatureGroup
insertStream(DataStream<?>, String, String, String) - Method in class com.logicalclocks.hsfs.flink.StreamFeatureGroup
insertStream(DataStream<?>, String, String, boolean, Long) - Method in class com.logicalclocks.hsfs.flink.StreamFeatureGroup
insertStream(DataStream<?>, String, String, boolean, Long, String) - Method in class com.logicalclocks.hsfs.flink.StreamFeatureGroup
insertStream(DataStream<?>, String, String, boolean, Long, String, Map<String, String>) - Method in class com.logicalclocks.hsfs.flink.StreamFeatureGroup
insertStream(DataStream<?>, String, String, boolean, String) - Method in class com.logicalclocks.hsfs.flink.StreamFeatureGroup
insertStream(DataStream<?>, String, String, boolean, Long, String, Map<String, String>, JobConfiguration) - Method in class com.logicalclocks.hsfs.flink.StreamFeatureGroup
insertStream(FeatureGroup, Dataset<Row>, String, String, boolean, Long, String, List<String>, String, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.engine.FeatureGroupEngine: Deprecated.
insertStream(StreamFeatureGroup, Dataset<Row>, String, String, boolean, Long, String, List<String>, String, Map<String, String>, JobConfiguration) - Method in class com.logicalclocks.hsfs.spark.engine.FeatureGroupEngine
insertStream(Dataset<Row>) - Method in class com.logicalclocks.hsfs.spark.ExternalFeatureGroup
insertStream(Dataset<Row>, String) - Method in class com.logicalclocks.hsfs.spark.ExternalFeatureGroup
insertStream(Dataset<Row>, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.ExternalFeatureGroup
insertStream(Dataset<Row>, String, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.ExternalFeatureGroup
insertStream(Dataset<Row>, String, String) - Method in class com.logicalclocks.hsfs.spark.ExternalFeatureGroup
insertStream(Dataset<Row>, String, String, String) - Method in class com.logicalclocks.hsfs.spark.ExternalFeatureGroup
insertStream(Dataset<Row>, String, String, boolean, Long) - Method in class com.logicalclocks.hsfs.spark.ExternalFeatureGroup
insertStream(Dataset<Row>, String, String, boolean, Long, String) - Method in class com.logicalclocks.hsfs.spark.ExternalFeatureGroup
insertStream(Dataset<Row>, String, String, boolean, Long, String, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.ExternalFeatureGroup
insertStream(Dataset<Row>, String, String, boolean, String) - Method in class com.logicalclocks.hsfs.spark.ExternalFeatureGroup
insertStream(Dataset<Row>, String, String, boolean, Long, String, Map<String, String>, JobConfiguration) - Method in class com.logicalclocks.hsfs.spark.ExternalFeatureGroup
insertStream(Dataset<Row>) - Method in class com.logicalclocks.hsfs.spark.FeatureGroup: Deprecated.
insertStream method is deprecated FeatureGroups. Full capability insertStream is available for StreamFeatureGroups.
insertStream(Dataset<Row>, String) - Method in class com.logicalclocks.hsfs.spark.FeatureGroup: Deprecated.
insertStream(Dataset<Row>, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.FeatureGroup: Deprecated.
insertStream(Dataset<Row>, String, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.FeatureGroup
insertStream(Dataset<Row>, String, String) - Method in class com.logicalclocks.hsfs.spark.FeatureGroup: Deprecated.
insertStream(Dataset<Row>, String, String, String) - Method in class com.logicalclocks.hsfs.spark.FeatureGroup: Deprecated.
insertStream(Dataset<Row>, String, String, boolean, Long) - Method in class com.logicalclocks.hsfs.spark.FeatureGroup: Deprecated.
insertStream method is deprecated FeatureGroups. Full capability insertStream is available for StreamFeatureGroups.
insertStream(Dataset<Row>, String, String, boolean, Long, String) - Method in class com.logicalclocks.hsfs.spark.FeatureGroup: Deprecated.
insertStream(Dataset<Row>, String, String, boolean, String) - Method in class com.logicalclocks.hsfs.spark.FeatureGroup: Deprecated.
insertStream method is deprecated FeatureGroups. Full capability insertStream is available for StreamFeatureGroups.
insertStream(Dataset<Row>, String, String, boolean, Long, String, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.FeatureGroup: Deprecated.
insertStream(Dataset<Row>, String, String, boolean, Long, String, Map<String, String>, JobConfiguration) - Method in class com.logicalclocks.hsfs.spark.FeatureGroup
insertStream(Dataset<Row>) - Method in class com.logicalclocks.hsfs.spark.StreamFeatureGroup: Ingest a Spark Structured Streaming Dataframe to the online feature store.
insertStream(Dataset<Row>, String) - Method in class com.logicalclocks.hsfs.spark.StreamFeatureGroup: Ingest a Spark Structured Streaming Dataframe to the online feature store.
insertStream(Dataset<Row>, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.StreamFeatureGroup: Ingest a Spark Structured Streaming Dataframe to the online feature store.
insertStream(Dataset<Row>, String, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.StreamFeatureGroup: Ingest a Spark Structured Streaming Dataframe to the online feature store.
insertStream(Dataset<Row>, String, String) - Method in class com.logicalclocks.hsfs.spark.StreamFeatureGroup: Ingest a Spark Structured Streaming Dataframe to the online feature store.
insertStream(Dataset<Row>, String, String, String) - Method in class com.logicalclocks.hsfs.spark.StreamFeatureGroup: Ingest a Spark Structured Streaming Dataframe to the online feature store.
insertStream(Dataset<Row>, String, String, boolean, Long) - Method in class com.logicalclocks.hsfs.spark.StreamFeatureGroup: Ingest a Spark Structured Streaming Dataframe to the online feature store.
insertStream(Dataset<Row>, String, String, boolean, Long, String) - Method in class com.logicalclocks.hsfs.spark.StreamFeatureGroup: Ingest a Spark Structured Streaming Dataframe to the online feature store.
insertStream(Dataset<Row>, String, String, boolean, Long, String, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.StreamFeatureGroup: Ingest a Spark Structured Streaming Dataframe to the online feature store.
insertStream(Dataset<Row>, String, String, boolean, String) - Method in class com.logicalclocks.hsfs.spark.StreamFeatureGroup
insertStream(Dataset<Row>, String, String, boolean, Long, String, Map<String, String>, JobConfiguration) - Method in class com.logicalclocks.hsfs.spark.StreamFeatureGroup: Ingest a Spark Structured Streaming Dataframe to the online feature store.
InternalException - Exception in com.logicalclocks.hsfs.metadata
InternalException(String) - Constructor for exception com.logicalclocks.hsfs.metadata.InternalException
isComplex() - Method in class com.logicalclocks.hsfs.Feature: Returns true if the feature has a complex type.
isComplex() - Method in class com.logicalclocks.hsfs.TrainingDatasetFeature
isin(Collection<?>) - Method in class com.logicalclocks.hsfs.Feature
isTimeTravel() - Method in class com.logicalclocks.hsfs.constructor.QueryBase
items - Variable in class com.logicalclocks.hsfs.metadata.RestDto

J

JDBC_DRIVER - Static variable in class com.logicalclocks.hsfs.util.Constants
JDBC_FORMAT - Static variable in class com.logicalclocks.hsfs.util.Constants
JDBC_PWD - Static variable in class com.logicalclocks.hsfs.util.Constants
JDBC_TABLE - Static variable in class com.logicalclocks.hsfs.util.Constants
JDBC_URL - Static variable in class com.logicalclocks.hsfs.util.Constants
JDBC_USER - Static variable in class com.logicalclocks.hsfs.util.Constants
JdbcConnector() - Constructor for class com.logicalclocks.hsfs.StorageConnector.JdbcConnector
JobConfiguration - Class in com.logicalclocks.hsfs
JobConfiguration() - Constructor for class com.logicalclocks.hsfs.JobConfiguration
Join<T extends QueryBase> - Class in com.logicalclocks.hsfs.constructor
Join(T, JoinType, String) - Constructor for class com.logicalclocks.hsfs.constructor.Join
Join(T, List<Feature>, JoinType, String) - Constructor for class com.logicalclocks.hsfs.constructor.Join
Join(T, List<Feature>, List<Feature>, JoinType, String) - Constructor for class com.logicalclocks.hsfs.constructor.Join
join(T) - Method in class com.logicalclocks.hsfs.constructor.QueryBase
join(T, String) - Method in class com.logicalclocks.hsfs.constructor.QueryBase
join(T, List<String>) - Method in class com.logicalclocks.hsfs.constructor.QueryBase
join(T, List<String>, List<String>) - Method in class com.logicalclocks.hsfs.constructor.QueryBase
join(T, List<String>, List<String>, String) - Method in class com.logicalclocks.hsfs.constructor.QueryBase
join(T, JoinType) - Method in class com.logicalclocks.hsfs.constructor.QueryBase
join(T, JoinType, String) - Method in class com.logicalclocks.hsfs.constructor.QueryBase
join(T, List<String>, JoinType) - Method in class com.logicalclocks.hsfs.constructor.QueryBase
join(T, List<String>, JoinType, String) - Method in class com.logicalclocks.hsfs.constructor.QueryBase
join(T, List<String>, List<String>, JoinType) - Method in class com.logicalclocks.hsfs.constructor.QueryBase
join(T, List<String>, List<String>, JoinType, String) - Method in class com.logicalclocks.hsfs.constructor.QueryBase
joinFeatures(T, List<Feature>) - Method in class com.logicalclocks.hsfs.constructor.QueryBase
joinFeatures(T, List<Feature>, String) - Method in class com.logicalclocks.hsfs.constructor.QueryBase
joinFeatures(T, List<Feature>, List<Feature>) - Method in class com.logicalclocks.hsfs.constructor.QueryBase
joinFeatures(T, List<Feature>, List<Feature>, String) - Method in class com.logicalclocks.hsfs.constructor.QueryBase
joinFeatures(T, List<Feature>, JoinType) - Method in class com.logicalclocks.hsfs.constructor.QueryBase
joinFeatures(T, List<Feature>, JoinType, String) - Method in class com.logicalclocks.hsfs.constructor.QueryBase
joinFeatures(T, List<Feature>, List<Feature>, JoinType) - Method in class com.logicalclocks.hsfs.constructor.QueryBase
joinFeatures(T, List<Feature>, List<Feature>, JoinType, String) - Method in class com.logicalclocks.hsfs.constructor.QueryBase
joins - Variable in class com.logicalclocks.hsfs.constructor.QueryBase
JoinType - Enum in com.logicalclocks.hsfs.constructor

K

K_CERTIFICATE - Static variable in class com.logicalclocks.hsfs.metadata.HopsworksExternalClient
KAFKA_BOOTSTRAP_SERVERS - Static variable in class com.logicalclocks.hsfs.util.Constants
KAFKA_FORMAT - Static variable in class com.logicalclocks.hsfs.util.Constants
KAFKA_SECURITY_PROTOCOL - Static variable in class com.logicalclocks.hsfs.util.Constants
KAFKA_SOURCE - Static variable in class com.logicalclocks.hsfs.spark.engine.hudi.HudiEngine
KAFKA_SSL_ENDPOINT_IDENTIFICATION_ALGORITHM - Static variable in class com.logicalclocks.hsfs.util.Constants
KAFKA_SSL_KEY_PASSWORD - Static variable in class com.logicalclocks.hsfs.util.Constants
KAFKA_SSL_KEYSTORE_LOCATION - Static variable in class com.logicalclocks.hsfs.util.Constants
KAFKA_SSL_KEYSTORE_PASSWORD - Static variable in class com.logicalclocks.hsfs.util.Constants
KAFKA_SSL_TRUSTSTORE_LOCATION - Static variable in class com.logicalclocks.hsfs.util.Constants
KAFKA_SSL_TRUSTSTORE_PASSWORD - Static variable in class com.logicalclocks.hsfs.util.Constants
KafkaApi - Class in com.logicalclocks.hsfs.metadata
KafkaApi() - Constructor for class com.logicalclocks.hsfs.metadata.KafkaApi
KafkaClusterInfo - Class in com.logicalclocks.hsfs.metadata
KafkaClusterInfo() - Constructor for class com.logicalclocks.hsfs.metadata.KafkaClusterInfo
KafkaConnector() - Constructor for class com.logicalclocks.hsfs.StorageConnector.KafkaConnector
keyPath - Variable in class com.logicalclocks.hsfs.StorageConnector.BigqueryConnector
keyPath - Variable in class com.logicalclocks.hsfs.StorageConnector.GcsConnector
KeySerializationSchema - Class in com.logicalclocks.hsfs.flink.engine
KeySerializationSchema(List<String>) - Constructor for class com.logicalclocks.hsfs.flink.engine.KeySerializationSchema
keyStorePath - Variable in class com.logicalclocks.hsfs.HopsworksConnectionBase
keyStorePath - Variable in class com.logicalclocks.hsfs.metadata.HopsworksExternalClient

L

label - Variable in class com.logicalclocks.hsfs.TrainingDatasetBase
LABEL_NOT_EXIST_ERROR - Static variable in class com.logicalclocks.hsfs.engine.FeatureViewEngineBase
labels - Variable in class com.logicalclocks.hsfs.FeatureViewBase
labels(List<String>) - Method in class com.logicalclocks.hsfs.spark.FeatureView.FeatureViewBuilder
le(Object) - Method in class com.logicalclocks.hsfs.Feature
le(Feature) - Method in class com.logicalclocks.hsfs.Feature
leftFeatureGroup - Variable in class com.logicalclocks.hsfs.constructor.QueryBase
leftFeatureGroupEndTime - Variable in class com.logicalclocks.hsfs.constructor.QueryBase
leftFeatureGroupStartTime - Variable in class com.logicalclocks.hsfs.constructor.QueryBase
leftFeatures - Variable in class com.logicalclocks.hsfs.constructor.QueryBase
like(Object) - Method in class com.logicalclocks.hsfs.Feature
LOADBALANCER_EXTERNAL_DOMAIN - Static variable in class com.logicalclocks.hsfs.metadata.VariablesApi
location - Variable in class com.logicalclocks.hsfs.FeatureGroupBase
location - Variable in class com.logicalclocks.hsfs.TrainingDatasetBase
LOGGER - Static variable in class com.logicalclocks.hsfs.constructor.QueryBase
LOGGER - Static variable in class com.logicalclocks.hsfs.engine.FeatureGroupEngineBase
LOGGER - Static variable in class com.logicalclocks.hsfs.engine.FeatureViewEngineBase
LOGGER - Static variable in class com.logicalclocks.hsfs.FeatureGroupBase
LOGGER - Static variable in class com.logicalclocks.hsfs.FeatureStoreBase
LOGGER - Static variable in class com.logicalclocks.hsfs.FeatureViewBase
LOGGER - Static variable in class com.logicalclocks.hsfs.metadata.HopsworksClient
LOGGER - Static variable in class com.logicalclocks.hsfs.metadata.HopsworksExternalClient
LOGGER - Static variable in interface com.logicalclocks.hsfs.metadata.HopsworksHttpClient
LOGGER - Static variable in class com.logicalclocks.hsfs.TrainingDatasetBase
lt(Object) - Method in class com.logicalclocks.hsfs.Feature
lt(Feature) - Method in class com.logicalclocks.hsfs.Feature

M

makeLabelFeatures(QueryBase, List<String>) - Static method in class com.logicalclocks.hsfs.engine.FeatureViewEngineBase
map(T) - Method in class com.logicalclocks.hsfs.flink.engine.PojoToAvroRecord
MATERIAL_PASSWD - Static variable in class com.logicalclocks.hsfs.metadata.HopsworksExternalClient
materializationDataset - Variable in class com.logicalclocks.hsfs.StorageConnector.BigqueryConnector
MIN_SYNC_INTERVAL_SECONDS - Static variable in class com.logicalclocks.hsfs.spark.engine.hudi.HudiEngine

N

name - Variable in class com.logicalclocks.hsfs.FeatureGroupBase
name - Variable in class com.logicalclocks.hsfs.FeatureViewBase
name(String) - Method in class com.logicalclocks.hsfs.spark.FeatureView.FeatureViewBuilder
name - Variable in class com.logicalclocks.hsfs.StorageConnector
name - Variable in class com.logicalclocks.hsfs.TrainingDatasetBase
ne(Object) - Method in class com.logicalclocks.hsfs.Feature
ne(Feature) - Method in class com.logicalclocks.hsfs.Feature

O

objectMapper - Variable in class com.logicalclocks.hsfs.metadata.HopsworksClient
objectToDataset(Object) - Method in class com.logicalclocks.hsfs.spark.engine.SparkEngine
onCommit(String) - Method in class com.logicalclocks.hsfs.spark.engine.hudi.DeltaStreamerKafkaSource
OnDemandOptions - Class in com.logicalclocks.hsfs.metadata
OnDemandOptions() - Constructor for class com.logicalclocks.hsfs.metadata.OnDemandOptions
onlineEnabled - Variable in class com.logicalclocks.hsfs.FeatureGroupBase
onlineTopicName - Variable in class com.logicalclocks.hsfs.FeatureGroupBase
open(Configuration) - Method in class com.logicalclocks.hsfs.flink.engine.PojoToAvroRecord
Option - Class in com.logicalclocks.hsfs.metadata
Option() - Constructor for class com.logicalclocks.hsfs.metadata.Option
options - Variable in class com.logicalclocks.hsfs.StorageConnector.KafkaConnector
or(Filter) - Method in class com.logicalclocks.hsfs.constructor.Filter
or(FilterLogic) - Method in class com.logicalclocks.hsfs.constructor.Filter
or(Filter) - Method in class com.logicalclocks.hsfs.constructor.FilterLogic
or(FilterLogic) - Method in class com.logicalclocks.hsfs.constructor.FilterLogic

P

PARAM_NAME_PARAMETER_STORE - Static variable in class com.logicalclocks.hsfs.metadata.HopsworksExternalClient
PARAM_NAME_SECRET_STORE - Static variable in class com.logicalclocks.hsfs.metadata.HopsworksExternalClient
parentProject - Variable in class com.logicalclocks.hsfs.StorageConnector.BigqueryConnector
parseFeatureGroupSchema(Dataset<Row>, TimeTravelFormat) - Method in class com.logicalclocks.hsfs.spark.engine.SparkEngine
parseTagValue(ObjectMapper, Object) - Method in class com.logicalclocks.hsfs.metadata.TagsApi
parseTrainingDatasetSchema(Dataset<Row>) - Method in class com.logicalclocks.hsfs.spark.engine.TrainingDatasetUtils
PartitionDetails - Class in com.logicalclocks.hsfs.metadata
PartitionDetails() - Constructor for class com.logicalclocks.hsfs.metadata.PartitionDetails
partitionKeys - Variable in class com.logicalclocks.hsfs.FeatureGroupBase
password - Variable in class com.logicalclocks.hsfs.StorageConnector.SnowflakeConnector
PAYLOAD_CLASS_OPT_KEY - Static variable in class com.logicalclocks.hsfs.spark.engine.hudi.HudiEngine
PAYLOAD_CLASS_OPT_VAL - Static variable in class com.logicalclocks.hsfs.spark.engine.hudi.HudiEngine
PojoToAvroRecord<T> - Class in com.logicalclocks.hsfs.flink.engine
PojoToAvroRecord(Schema, Schema, Map<String, String>) - Constructor for class com.logicalclocks.hsfs.flink.engine.PojoToAvroRecord
port - Variable in class com.logicalclocks.hsfs.HopsworksConnectionBase
post(FeatureGroupBase, Code, String, Code.RunType, String) - Method in class com.logicalclocks.hsfs.metadata.CodeApi
post(TrainingDatasetBase, Code, String, Code.RunType, String) - Method in class com.logicalclocks.hsfs.metadata.CodeApi
post(FeatureGroupBase, Statistics) - Method in class com.logicalclocks.hsfs.metadata.StatisticsApi
post(TrainingDatasetBase, Statistics) - Method in class com.logicalclocks.hsfs.metadata.StatisticsApi
post(FeatureViewBase, Integer, Statistics) - Method in class com.logicalclocks.hsfs.metadata.StatisticsApi
PreparedStatementParameter - Class in com.logicalclocks.hsfs.constructor
PreparedStatementParameter() - Constructor for class com.logicalclocks.hsfs.constructor.PreparedStatementParameter
primaryKeys - Variable in class com.logicalclocks.hsfs.FeatureGroupBase
profile(Dataset<Row>, List<String>, Boolean, Boolean, Boolean) - Method in class com.logicalclocks.hsfs.spark.engine.SparkEngine
profile(Dataset<Row>, List<String>, Boolean, Boolean) - Method in class com.logicalclocks.hsfs.spark.engine.SparkEngine
profile(Dataset<Row>, List<String>) - Method in class com.logicalclocks.hsfs.spark.engine.SparkEngine
profile(Dataset<Row>, boolean, boolean) - Method in class com.logicalclocks.hsfs.spark.engine.SparkEngine
profile(Dataset<Row>) - Method in class com.logicalclocks.hsfs.spark.engine.SparkEngine
project - Variable in class com.logicalclocks.hsfs.HopsworksConnectionBase
project - Variable in class com.logicalclocks.hsfs.metadata.HopsworksClient
Project - Class in com.logicalclocks.hsfs
Project(Integer) - Constructor for class com.logicalclocks.hsfs.Project
PROJECT_ID - Static variable in class com.logicalclocks.hsfs.spark.engine.hudi.HudiEngine
PROJECT_PATH - Static variable in class com.logicalclocks.hsfs.metadata.HopsworksClient
projectApi - Variable in class com.logicalclocks.hsfs.HopsworksConnectionBase
ProjectApi - Class in com.logicalclocks.hsfs.metadata
ProjectApi() - Constructor for class com.logicalclocks.hsfs.metadata.ProjectApi
PROJECTNAME_ENV - Static variable in class com.logicalclocks.hsfs.util.Constants
projectObj - Variable in class com.logicalclocks.hsfs.HopsworksConnectionBase
PROPERTY_ALGORITHM - Static variable in class com.logicalclocks.hsfs.util.Constants
PROPERTY_ENCRYPTION_HASH - Static variable in class com.logicalclocks.hsfs.util.Constants
PROPERTY_ENCRYPTION_KEY - Static variable in class com.logicalclocks.hsfs.util.Constants
PROPERTY_GCS_ACCOUNT_EMAIL - Static variable in class com.logicalclocks.hsfs.util.Constants
PROPERTY_GCS_ACCOUNT_ENABLE - Static variable in class com.logicalclocks.hsfs.util.Constants
PROPERTY_GCS_ACCOUNT_KEY - Static variable in class com.logicalclocks.hsfs.util.Constants
PROPERTY_GCS_ACCOUNT_KEY_ID - Static variable in class com.logicalclocks.hsfs.util.Constants
PROPERTY_GCS_FS_KEY - Static variable in class com.logicalclocks.hsfs.util.Constants
PROPERTY_GCS_FS_VALUE - Static variable in class com.logicalclocks.hsfs.util.Constants
PROPERTY_KEY_FILE - Static variable in class com.logicalclocks.hsfs.util.Constants
pullChanges(String, String) - Method in class com.logicalclocks.hsfs.constructor.QueryBase: Deprecated.
use asOf(wallclockEndTime, wallclockStartTime) instead
purgeAllTrainingData() - Method in class com.logicalclocks.hsfs.FeatureViewBase
purgeAllTrainingData() - Method in class com.logicalclocks.hsfs.flink.FeatureView
purgeAllTrainingData() - Method in class com.logicalclocks.hsfs.spark.FeatureView: Delete all training datasets in this feature view (data only).
purgeTrainingData(Integer) - Method in class com.logicalclocks.hsfs.FeatureViewBase
purgeTrainingData(Integer) - Method in class com.logicalclocks.hsfs.flink.FeatureView
purgeTrainingData(Integer) - Method in class com.logicalclocks.hsfs.spark.FeatureView: Delete a training dataset (data only).

Q

query - Variable in class com.logicalclocks.hsfs.FeatureViewBase
Query - Class in com.logicalclocks.hsfs.spark.constructor
Query(FeatureGroupBase, List<Feature>) - Constructor for class com.logicalclocks.hsfs.spark.constructor.Query
query(Query) - Method in class com.logicalclocks.hsfs.spark.FeatureView.FeatureViewBuilder: Query of a feature view.
QUERY_CONSTRUCTOR_PATH - Static variable in class com.logicalclocks.hsfs.metadata.QueryConstructorApi
QueryBase<T extends QueryBase<T,T2,T3>,T2 extends FeatureGroupBase,T3> - Class in com.logicalclocks.hsfs.constructor
QueryBase(T2, List<Feature>) - Constructor for class com.logicalclocks.hsfs.constructor.QueryBase
queryConstructorApi - Variable in class com.logicalclocks.hsfs.constructor.QueryBase
QueryConstructorApi - Class in com.logicalclocks.hsfs.metadata
QueryConstructorApi() - Constructor for class com.logicalclocks.hsfs.metadata.QueryConstructorApi
queryProject - Variable in class com.logicalclocks.hsfs.StorageConnector.BigqueryConnector
queryTable - Variable in class com.logicalclocks.hsfs.StorageConnector.BigqueryConnector

R

read() - Method in class com.logicalclocks.hsfs.constructor.QueryBase
read(boolean) - Method in class com.logicalclocks.hsfs.constructor.QueryBase
read(boolean, Map<String, String>) - Method in class com.logicalclocks.hsfs.constructor.QueryBase
read() - Method in class com.logicalclocks.hsfs.FeatureGroupBase
read(boolean) - Method in class com.logicalclocks.hsfs.FeatureGroupBase
read(Map<String, String>) - Method in class com.logicalclocks.hsfs.FeatureGroupBase
read(boolean, Map<String, String>) - Method in class com.logicalclocks.hsfs.FeatureGroupBase
read(String) - Method in class com.logicalclocks.hsfs.FeatureGroupBase
read(String, Map<String, String>) - Method in class com.logicalclocks.hsfs.FeatureGroupBase
read() - Method in class com.logicalclocks.hsfs.FeatureGroupBaseForApi
read(boolean) - Method in class com.logicalclocks.hsfs.FeatureGroupBaseForApi
read(Map<String, String>) - Method in class com.logicalclocks.hsfs.FeatureGroupBaseForApi
read(boolean, Map<String, String>) - Method in class com.logicalclocks.hsfs.FeatureGroupBaseForApi
read(String) - Method in class com.logicalclocks.hsfs.FeatureGroupBaseForApi
read(String, Map<String, String>) - Method in class com.logicalclocks.hsfs.FeatureGroupBaseForApi
read() - Method in class com.logicalclocks.hsfs.flink.StreamFeatureGroup
read(boolean) - Method in class com.logicalclocks.hsfs.flink.StreamFeatureGroup
read(Map<String, String>) - Method in class com.logicalclocks.hsfs.flink.StreamFeatureGroup
read(boolean, Map<String, String>) - Method in class com.logicalclocks.hsfs.flink.StreamFeatureGroup
read(String) - Method in class com.logicalclocks.hsfs.flink.StreamFeatureGroup
read(String, Map<String, String>) - Method in class com.logicalclocks.hsfs.flink.StreamFeatureGroup
read() - Method in class com.logicalclocks.hsfs.spark.constructor.Query
read(boolean) - Method in class com.logicalclocks.hsfs.spark.constructor.Query
read(boolean, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.constructor.Query
read(StorageConnector, String, Map<String, String>, String) - Method in class com.logicalclocks.hsfs.spark.engine.SparkEngine
read(TrainingDataset, String, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.engine.TrainingDatasetEngine
read() - Method in class com.logicalclocks.hsfs.spark.ExternalFeatureGroup
read(boolean) - Method in class com.logicalclocks.hsfs.spark.ExternalFeatureGroup
read(Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.ExternalFeatureGroup
read(boolean, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.ExternalFeatureGroup
read(String) - Method in class com.logicalclocks.hsfs.spark.ExternalFeatureGroup
read(String, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.ExternalFeatureGroup
read() - Method in class com.logicalclocks.hsfs.spark.FeatureGroup: Reads the feature group from the offline storage as Spark DataFrame.
read(boolean) - Method in class com.logicalclocks.hsfs.spark.FeatureGroup: Reads the feature group from the offline or online storage as Spark DataFrame.
read(Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.FeatureGroup: Reads the feature group from the offline storage as Spark DataFrame.
read(boolean, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.FeatureGroup: Reads the feature group from the offline or online storage as Spark DataFrame.
read(String) - Method in class com.logicalclocks.hsfs.spark.FeatureGroup: Reads Feature group into a dataframe at a specific point in time.
read(String, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.FeatureGroup: Reads Feature group into a dataframe at a specific point in time.
read() - Method in class com.logicalclocks.hsfs.spark.StreamFeatureGroup: Reads the feature group from the offline storage as Spark DataFrame.
read(boolean) - Method in class com.logicalclocks.hsfs.spark.StreamFeatureGroup: Reads the stream feature group from the offline or online storage as Spark DataFrame.
read(Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.StreamFeatureGroup: Reads the stream feature group from the offline storage as Spark DataFrame.
read(boolean, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.StreamFeatureGroup: Reads the stream feature group from the offline or online storage as Spark DataFrame.
read(String) - Method in class com.logicalclocks.hsfs.spark.StreamFeatureGroup: Reads stream Feature group into a dataframe at a specific point in time.
read(String, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.StreamFeatureGroup: Reads stream Feature group into a dataframe at a specific point in time.
read() - Method in class com.logicalclocks.hsfs.spark.TrainingDataset: Read the content of the training dataset.
read(Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.TrainingDataset: Read the content of the training dataset.
read(String) - Method in class com.logicalclocks.hsfs.spark.TrainingDataset: Read all a single split from the training dataset.
read(String, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.TrainingDataset: Read a single split from the training dataset.
read(StorageConnector.HopsFsConnector, String, Map<String, String>, String) - Method in class com.logicalclocks.hsfs.spark.util.StorageConnectorUtils: Reads path into a spark dataframe using the HopsFsConnector.
read(StorageConnector.S3Connector, String, Map<String, String>, String) - Method in class com.logicalclocks.hsfs.spark.util.StorageConnectorUtils: Reads path into a spark dataframe using the S3Connector.
read(StorageConnector.RedshiftConnector, String) - Method in class com.logicalclocks.hsfs.spark.util.StorageConnectorUtils: Reads query into a spark dataframe using the RedshiftConnector.
read(StorageConnector.AdlsConnector, String, Map<String, String>, String) - Method in class com.logicalclocks.hsfs.spark.util.StorageConnectorUtils: Reads path into a spark dataframe using the AdlsConnector.
read(StorageConnector.SnowflakeConnector, String) - Method in class com.logicalclocks.hsfs.spark.util.StorageConnectorUtils: Reads query into a spark dataframe using the SnowflakeConnector.
read(StorageConnector.JdbcConnector, String) - Method in class com.logicalclocks.hsfs.spark.util.StorageConnectorUtils: Reads query into a spark dataframe using the JdbcConnector.
read(StorageConnector.GcsConnector, String, Map<String, String>, String) - Method in class com.logicalclocks.hsfs.spark.util.StorageConnectorUtils: Reads a path into a spark dataframe using the GcsConnector.
read(StorageConnector.BigqueryConnector, String, Map<String, String>, String) - Method in class com.logicalclocks.hsfs.spark.util.StorageConnectorUtils: Reads a query or a path into a spark dataframe using the sBigqueryConnector.
read(StorageConnector, String, String, Map<String, String>, String) - Method in class com.logicalclocks.hsfs.spark.util.StorageConnectorUtils: Reads a query or a path into a spark dataframe using the storage connector.
read() - Method in class com.logicalclocks.hsfs.TrainingDatasetBase: Read the content of the training dataset.
read(String, Map<String, String>) - Method in class com.logicalclocks.hsfs.TrainingDatasetBase: Read a single split from the training dataset.
readApiKey(SecretStore, Region, String) - Method in class com.logicalclocks.hsfs.metadata.HopsworksExternalClient: Read API key.
readApiKeyParamStore(Region, String) - Method in class com.logicalclocks.hsfs.metadata.HopsworksExternalClient
readApiKeySecretManager(Region, String) - Method in class com.logicalclocks.hsfs.metadata.HopsworksExternalClient
readCertKey(String) - Static method in class com.logicalclocks.hsfs.metadata.HopsworksExternalClient
readCertKey(String) - Static method in interface com.logicalclocks.hsfs.metadata.HopsworksHttpClient
readChanges(String, String) - Method in class com.logicalclocks.hsfs.spark.FeatureGroup: Deprecated.
readChanges(String, String, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.FeatureGroup: Deprecated.
readChanges(String, String) - Method in class com.logicalclocks.hsfs.spark.StreamFeatureGroup: Deprecated.
`readChanges` method is deprecated. Use `asOf(wallclockEndTime, wallclockStartTime).read()` instead.
readChanges(String, String, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.StreamFeatureGroup: Deprecated.
readStream(StorageConnector, String, String, String, Map<String, String>, boolean) - Method in class com.logicalclocks.hsfs.spark.engine.SparkEngine
readStream(StorageConnector.KafkaConnector, String, boolean, String, String, Map<String, String>, boolean) - Method in class com.logicalclocks.hsfs.spark.util.StorageConnectorUtils: Reads stream into a spark dataframe using the kafka storage connector.
reconcileHudiSchema(SparkSession, FeatureGroupAlias, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.engine.hudi.HudiEngine
recreateTrainingDataset(FeatureView, Integer, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.engine.FeatureViewEngine
recreateTrainingDataset(Integer, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.FeatureView: Recreate a training dataset.
RedshiftConnector() - Constructor for class com.logicalclocks.hsfs.StorageConnector.RedshiftConnector
refetch() - Method in class com.logicalclocks.hsfs.StorageConnector
refreshJwt() - Method in class com.logicalclocks.hsfs.metadata.HopsworksInternalClient
region - Variable in class com.logicalclocks.hsfs.HopsworksConnectionBase
registerHudiFeatureGroups(Map<String, String>) - Method in class com.logicalclocks.hsfs.constructor.FsQueryBase
registerHudiFeatureGroups(Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.constructor.FsQuery
registerHudiTemporaryTable(FeatureGroupAlias, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.engine.SparkEngine
registerOnDemandFeatureGroups() - Method in class com.logicalclocks.hsfs.constructor.FsQueryBase
registerOnDemandFeatureGroups() - Method in class com.logicalclocks.hsfs.spark.constructor.FsQuery
registerOnDemandTemporaryTable(ExternalFeatureGroup, String) - Method in class com.logicalclocks.hsfs.spark.engine.SparkEngine
registerSplitStatistics(TrainingDataset) - Method in class com.logicalclocks.hsfs.spark.engine.StatisticsEngine
registerSplitStatistics(FeatureView, TrainingDataset, Map<String, Dataset<Row>>) - Method in class com.logicalclocks.hsfs.spark.engine.StatisticsEngine
registerTemporaryTable(SparkSession, FeatureGroupAlias, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.engine.hudi.HudiEngine
removeNewLines() - Method in class com.logicalclocks.hsfs.constructor.FsQueryBase
REST_ENDPOINT_SYS - Static variable in class com.logicalclocks.hsfs.metadata.HopsworksInternalClient
RestDto<D> - Class in com.logicalclocks.hsfs.metadata
RestDto() - Constructor for class com.logicalclocks.hsfs.metadata.RestDto
rewriteFeatureStoreName(String) - Method in class com.logicalclocks.hsfs.HopsworksConnectionBase
role - Variable in class com.logicalclocks.hsfs.StorageConnector.SnowflakeConnector

S

S3_ACCESS_KEY_ENV - Static variable in class com.logicalclocks.hsfs.util.Constants
S3_CREDENTIAL_PROVIDER_ENV - Static variable in class com.logicalclocks.hsfs.util.Constants
S3_ENCRYPTION_ALGO - Static variable in class com.logicalclocks.hsfs.util.Constants
S3_ENCRYPTION_KEY - Static variable in class com.logicalclocks.hsfs.util.Constants
S3_ENDPOINT - Static variable in class com.logicalclocks.hsfs.util.Constants
S3_SCHEME - Static variable in class com.logicalclocks.hsfs.util.Constants
S3_SECRET_KEY_ENV - Static variable in class com.logicalclocks.hsfs.util.Constants
S3_SESSION_KEY_ENV - Static variable in class com.logicalclocks.hsfs.util.Constants
S3_SPARK_SCHEME - Static variable in class com.logicalclocks.hsfs.util.Constants
S3_TEMPORARY_CREDENTIAL_PROVIDER - Static variable in class com.logicalclocks.hsfs.util.Constants
S3Connector() - Constructor for class com.logicalclocks.hsfs.StorageConnector.S3Connector
sanitizeFeatureNames(Dataset<Row>) - Method in class com.logicalclocks.hsfs.spark.engine.SparkEngine
save(T2, Class<T2>) - Method in class com.logicalclocks.hsfs.engine.FeatureViewEngineBase
save(FeatureGroupBase, Class<U>) - Method in class com.logicalclocks.hsfs.metadata.FeatureGroupApi
save(FeatureViewBase, Class<T>) - Method in class com.logicalclocks.hsfs.metadata.FeatureViewApi
save(FeatureGroup, Dataset<Row>, List<String>, String, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.engine.FeatureGroupEngine: Create the metadata and write the data to the online/offline feature store.
save(StreamFeatureGroup, Dataset<Row>, List<String>, String, Map<String, String>, JobConfiguration) - Method in class com.logicalclocks.hsfs.spark.engine.FeatureGroupEngine: Create the metadata and write the data to the online/offline feature store.
save(TrainingDataset, Query, Map<String, String>, List<String>) - Method in class com.logicalclocks.hsfs.spark.engine.TrainingDatasetEngine: Make a REST call to Hopsworks to create the metadata and write the data on the File System.
save() - Method in class com.logicalclocks.hsfs.spark.ExternalFeatureGroup
save(Dataset<Row>) - Method in class com.logicalclocks.hsfs.spark.FeatureGroup: Deprecated.
save(Dataset<Row>, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.FeatureGroup: Deprecated.
save(Dataset<Row>, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.StreamFeatureGroup: Deprecated.
save(Dataset<Row>, Map<String, String>, JobConfiguration) - Method in class com.logicalclocks.hsfs.spark.StreamFeatureGroup: Deprecated.
save(Query) - Method in class com.logicalclocks.hsfs.spark.TrainingDataset
save(Query, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.TrainingDataset: Create the training dataset based on the content of the feature store query.
saveCode(TrainingDatasetBase) - Method in class com.logicalclocks.hsfs.engine.CodeEngine
saveCode(FeatureGroupBase) - Method in class com.logicalclocks.hsfs.engine.CodeEngine
saveDataframe(FeatureGroup, Dataset<Row>, Storage, HudiOperationType, Map<String, String>, Map<String, String>, Integer) - Method in class com.logicalclocks.hsfs.spark.engine.FeatureGroupEngine
saveExtennalFeatureGroupMetaData(T, Class<T>) - Method in class com.logicalclocks.hsfs.engine.FeatureGroupEngineBase
saveExternalFeatureGroup(ExternalFeatureGroup) - Method in class com.logicalclocks.hsfs.spark.engine.FeatureGroupEngine
saveFeatureGroupMetaData(FeatureGroupBase, List<String>, String, Map<String, String>, JobConfiguration, Class<U>) - Method in class com.logicalclocks.hsfs.metadata.FeatureGroupApi
saveFeatureGroupMetaData(FeatureGroup, List<String>, String, Dataset<Row>, boolean) - Method in class com.logicalclocks.hsfs.spark.engine.FeatureGroupEngine
saveFeatureGroupMetaData(StreamFeatureGroup, List<String>, String, Map<String, String>, JobConfiguration, Dataset<Row>) - Method in class com.logicalclocks.hsfs.spark.engine.FeatureGroupEngine
saveHudiFeatureGroup(SparkSession, FeatureGroupBase, Dataset<Row>, HudiOperationType, Map<String, String>, Integer) - Method in class com.logicalclocks.hsfs.spark.engine.hudi.HudiEngine
saveInternal(FeatureGroupBase, StringEntity, Class<U>) - Method in class com.logicalclocks.hsfs.metadata.FeatureGroupApi
schema - Variable in class com.logicalclocks.hsfs.StorageConnector.SnowflakeConnector
SCHEMA_PROVIDER - Static variable in class com.logicalclocks.hsfs.spark.engine.hudi.HudiEngine
secretKey - Variable in class com.logicalclocks.hsfs.StorageConnector.S3Connector
secretStore - Variable in class com.logicalclocks.hsfs.HopsworksConnectionBase
SecretStore - Enum in com.logicalclocks.hsfs
SecurityProtocol - Enum in com.logicalclocks.hsfs
securityProtocol - Variable in class com.logicalclocks.hsfs.StorageConnector.KafkaConnector
seed - Variable in class com.logicalclocks.hsfs.TrainingDatasetBase
select(List<String>) - Method in class com.logicalclocks.hsfs.FeatureGroupBase
select(List<String>) - Method in class com.logicalclocks.hsfs.FeatureGroupBaseForApi
select(List<String>) - Method in class com.logicalclocks.hsfs.flink.StreamFeatureGroup
select(List<String>) - Method in class com.logicalclocks.hsfs.spark.ExternalFeatureGroup
select(List<String>) - Method in class com.logicalclocks.hsfs.spark.FeatureGroup: Select a subset of features of the feature group and return a query object.
select(List<String>) - Method in class com.logicalclocks.hsfs.spark.StreamFeatureGroup: Select a subset of features of the feature group and return a query object.
selectAll() - Method in class com.logicalclocks.hsfs.FeatureGroupBase
selectAll() - Method in class com.logicalclocks.hsfs.FeatureGroupBaseForApi
selectAll() - Method in class com.logicalclocks.hsfs.flink.StreamFeatureGroup
selectAll() - Method in class com.logicalclocks.hsfs.spark.ExternalFeatureGroup
selectAll() - Method in class com.logicalclocks.hsfs.spark.FeatureGroup: Select all features of the feature group and return a query object.
selectAll() - Method in class com.logicalclocks.hsfs.spark.StreamFeatureGroup: Select all features of the feature group and return a query object.
selectExcept(List<String>) - Method in class com.logicalclocks.hsfs.FeatureGroupBase
selectExcept(List<String>) - Method in class com.logicalclocks.hsfs.FeatureGroupBaseForApi
selectExcept(List<String>) - Method in class com.logicalclocks.hsfs.flink.StreamFeatureGroup
selectExcept(List<String>) - Method in class com.logicalclocks.hsfs.spark.ExternalFeatureGroup
selectExcept(List<String>) - Method in class com.logicalclocks.hsfs.spark.FeatureGroup: Select all features including primary key and event time feature of the feature group except provided `features` and return a query object.
selectExcept(List<String>) - Method in class com.logicalclocks.hsfs.spark.StreamFeatureGroup: Select all features including primary key and event time feature of the feature group except provided `features` and return a query object.
selectExceptFeatures(List<Feature>) - Method in class com.logicalclocks.hsfs.FeatureGroupBase
selectExceptFeatures(List<Feature>) - Method in class com.logicalclocks.hsfs.FeatureGroupBaseForApi
selectExceptFeatures(List<Feature>) - Method in class com.logicalclocks.hsfs.flink.StreamFeatureGroup
selectExceptFeatures(List<Feature>) - Method in class com.logicalclocks.hsfs.spark.ExternalFeatureGroup
selectExceptFeatures(List<Feature>) - Method in class com.logicalclocks.hsfs.spark.FeatureGroup: Select all features including primary key and event time feature of the feature group except provided `features` and return a query object.
selectExceptFeatures(List<Feature>) - Method in class com.logicalclocks.hsfs.spark.StreamFeatureGroup: Select all features including primary key and event time feature of the feature group except provided `features` and return a query object.
selectFeatures(List<Feature>) - Method in class com.logicalclocks.hsfs.FeatureGroupBase
selectFeatures(List<Feature>) - Method in class com.logicalclocks.hsfs.FeatureGroupBaseForApi
selectFeatures(List<Feature>) - Method in class com.logicalclocks.hsfs.flink.StreamFeatureGroup
selectFeatures(List<Feature>) - Method in class com.logicalclocks.hsfs.spark.ExternalFeatureGroup
selectFeatures(List<Feature>) - Method in class com.logicalclocks.hsfs.spark.FeatureGroup: Select a subset of features of the feature group and return a query object.
selectFeatures(List<Feature>) - Method in class com.logicalclocks.hsfs.spark.StreamFeatureGroup: Select a subset of features of the feature group and return a query object.
serialize(GenericRecord) - Method in class com.logicalclocks.hsfs.flink.engine.GenericRecordAvroSerializer
serialize(GenericRecord) - Method in class com.logicalclocks.hsfs.flink.engine.KeySerializationSchema
serverEncryptionAlgorithm - Variable in class com.logicalclocks.hsfs.StorageConnector.S3Connector
serverEncryptionKey - Variable in class com.logicalclocks.hsfs.StorageConnector.S3Connector
serviceCredential - Variable in class com.logicalclocks.hsfs.StorageConnector.AdlsConnector
ServingPreparedStatement - Class in com.logicalclocks.hsfs.constructor
ServingPreparedStatement() - Constructor for class com.logicalclocks.hsfs.constructor.ServingPreparedStatement
sessionToken - Variable in class com.logicalclocks.hsfs.StorageConnector.S3Connector
setCertKey(String) - Method in interface com.logicalclocks.hsfs.metadata.HopsworksHttpClient
setCount(Integer) - Method in class com.logicalclocks.hsfs.metadata.RestDto
setEventTime(FeatureViewBase, TrainingDatasetBase) - Method in class com.logicalclocks.hsfs.engine.FeatureViewEngineBase
setInstance(HopsworksClient) - Static method in class com.logicalclocks.hsfs.metadata.HopsworksClient
setInstance(SparkEngine) - Static method in class com.logicalclocks.hsfs.spark.engine.SparkEngine
setItems(List<D>) - Method in class com.logicalclocks.hsfs.metadata.RestDto
setKeyStorePath(String) - Method in interface com.logicalclocks.hsfs.metadata.HopsworksHttpClient
setkStore(String) - Method in class com.logicalclocks.hsfs.metadata.Credentials
setLabel(List<String>) - Method in class com.logicalclocks.hsfs.TrainingDatasetBase
setLabelFeature(List<TrainingDatasetFeature>, List<String>) - Static method in class com.logicalclocks.hsfs.spark.engine.TrainingDatasetUtils
setLeftFeatureGroup(T2) - Method in class com.logicalclocks.hsfs.constructor.QueryBase
setName(String) - Method in class com.logicalclocks.hsfs.Feature
setName(String) - Method in class com.logicalclocks.hsfs.TrainingDatasetFeature
setPassword(String) - Method in class com.logicalclocks.hsfs.metadata.Credentials
setTimeSeriesSplits(Integer, String, String, String, String, String, String) - Method in class com.logicalclocks.hsfs.TrainingDatasetBase
setTrustStorePath(String) - Method in interface com.logicalclocks.hsfs.metadata.HopsworksHttpClient
settStore(String) - Method in class com.logicalclocks.hsfs.metadata.Credentials
setupConnectorHadoopConf(StorageConnector) - Method in class com.logicalclocks.hsfs.spark.engine.SparkEngine
setupHopsworksClient(String, int, Region, SecretStore, boolean, String, String, String) - Static method in class com.logicalclocks.hsfs.metadata.HopsworksClient
setupHudiReadOpts(Long, Long, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.engine.hudi.HudiEngine
setValTestSplit(Float, Float) - Method in class com.logicalclocks.hsfs.TrainingDatasetBase
setValue(String) - Method in enum com.logicalclocks.hsfs.SslEndpointIdentificationAlgorithm
sfOptions - Variable in class com.logicalclocks.hsfs.StorageConnector.SnowflakeConnector
show(int) - Method in class com.logicalclocks.hsfs.constructor.QueryBase
show(boolean, int) - Method in class com.logicalclocks.hsfs.constructor.QueryBase
show(int) - Method in class com.logicalclocks.hsfs.FeatureGroupBase
show(int, boolean) - Method in class com.logicalclocks.hsfs.FeatureGroupBase
show(int) - Method in class com.logicalclocks.hsfs.FeatureGroupBaseForApi
show(int, boolean) - Method in class com.logicalclocks.hsfs.FeatureGroupBaseForApi
show(int) - Method in class com.logicalclocks.hsfs.flink.StreamFeatureGroup
show(int, boolean) - Method in class com.logicalclocks.hsfs.flink.StreamFeatureGroup
show(int) - Method in class com.logicalclocks.hsfs.spark.constructor.Query
show(boolean, int) - Method in class com.logicalclocks.hsfs.spark.constructor.Query
show(int) - Method in class com.logicalclocks.hsfs.spark.ExternalFeatureGroup
show(int, boolean) - Method in class com.logicalclocks.hsfs.spark.ExternalFeatureGroup
show(int) - Method in class com.logicalclocks.hsfs.spark.FeatureGroup: Show the first `n` rows of the feature group.
show(int, boolean) - Method in class com.logicalclocks.hsfs.spark.FeatureGroup: Show the first `n` rows of the feature group.
show(int) - Method in class com.logicalclocks.hsfs.spark.StreamFeatureGroup: Show the first `n` rows of the feature group.
show(int, boolean) - Method in class com.logicalclocks.hsfs.spark.StreamFeatureGroup: Show the first `n` rows of the feature group.
show(int) - Method in class com.logicalclocks.hsfs.spark.TrainingDataset: Show numRows from the training dataset (across all splits).
show(int) - Method in class com.logicalclocks.hsfs.TrainingDatasetBase: Show numRows from the training dataset (across all splits).
SNOWFLAKE_APPLICATION - Static variable in class com.logicalclocks.hsfs.util.Constants
SNOWFLAKE_AUTH - Static variable in class com.logicalclocks.hsfs.util.Constants
SNOWFLAKE_DB - Static variable in class com.logicalclocks.hsfs.util.Constants
SNOWFLAKE_FORMAT - Static variable in class com.logicalclocks.hsfs.util.Constants
SNOWFLAKE_PWD - Static variable in class com.logicalclocks.hsfs.util.Constants
SNOWFLAKE_ROLE - Static variable in class com.logicalclocks.hsfs.util.Constants
SNOWFLAKE_SCHEMA - Static variable in class com.logicalclocks.hsfs.util.Constants
SNOWFLAKE_TABLE - Static variable in class com.logicalclocks.hsfs.util.Constants
SNOWFLAKE_TOKEN - Static variable in class com.logicalclocks.hsfs.util.Constants
SNOWFLAKE_URL - Static variable in class com.logicalclocks.hsfs.util.Constants
SNOWFLAKE_USER - Static variable in class com.logicalclocks.hsfs.util.Constants
SNOWFLAKE_WAREHOUSE - Static variable in class com.logicalclocks.hsfs.util.Constants
SnowflakeConnector() - Constructor for class com.logicalclocks.hsfs.StorageConnector.SnowflakeConnector
SPARK_MASTER - Static variable in class com.logicalclocks.hsfs.spark.engine.hudi.HudiEngine
SparkEngine - Class in com.logicalclocks.hsfs.spark.engine
sparkFormat - Static variable in class com.logicalclocks.hsfs.StorageConnector.KafkaConnector
sparkOptions - Variable in class com.logicalclocks.hsfs.StorageConnector.AdlsConnector
sparkOptions() - Method in class com.logicalclocks.hsfs.StorageConnector.AdlsConnector
sparkOptions() - Method in class com.logicalclocks.hsfs.StorageConnector.BigqueryConnector: Set spark options specific to BigQuery.
sparkOptions() - Method in class com.logicalclocks.hsfs.StorageConnector.GcsConnector
sparkOptions() - Method in class com.logicalclocks.hsfs.StorageConnector.HopsFsConnector
sparkOptions() - Method in class com.logicalclocks.hsfs.StorageConnector.JdbcConnector
sparkOptions() - Method in class com.logicalclocks.hsfs.StorageConnector.KafkaConnector
sparkOptions() - Method in class com.logicalclocks.hsfs.StorageConnector.RedshiftConnector
sparkOptions() - Method in class com.logicalclocks.hsfs.StorageConnector.S3Connector
sparkOptions() - Method in class com.logicalclocks.hsfs.StorageConnector.SnowflakeConnector
sparkOptions() - Method in class com.logicalclocks.hsfs.StorageConnector
sparkPath(String) - Static method in class com.logicalclocks.hsfs.spark.engine.SparkEngine
sparkSchemasMatch(String[], String[]) - Method in class com.logicalclocks.hsfs.spark.engine.hudi.HudiEngine
Split - Class in com.logicalclocks.hsfs
Split(String, Float) - Constructor for class com.logicalclocks.hsfs.Split
Split(String, Date, Date) - Constructor for class com.logicalclocks.hsfs.Split
Split.SplitType - Enum in com.logicalclocks.hsfs
splitDataset(TrainingDataset, Query, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.engine.SparkEngine
splitLabels(Dataset<Row>, List<String>) - Static method in class com.logicalclocks.hsfs.spark.engine.SparkEngine
splits - Variable in class com.logicalclocks.hsfs.TrainingDatasetBase
SplitStatistics - Class in com.logicalclocks.hsfs.metadata
SplitStatistics() - Constructor for class com.logicalclocks.hsfs.metadata.SplitStatistics
sql() - Method in class com.logicalclocks.hsfs.constructor.QueryBase
sql(Storage) - Method in class com.logicalclocks.hsfs.constructor.QueryBase
sql(Storage, Class<T2>) - Method in class com.logicalclocks.hsfs.constructor.QueryBase
sql(String) - Method in class com.logicalclocks.hsfs.FeatureStoreBase
sql(String) - Method in class com.logicalclocks.hsfs.flink.FeatureStore
sql() - Method in class com.logicalclocks.hsfs.spark.constructor.Query
sql(Storage) - Method in class com.logicalclocks.hsfs.spark.constructor.Query
sql(String) - Method in class com.logicalclocks.hsfs.spark.engine.SparkEngine
sql(String) - Method in class com.logicalclocks.hsfs.spark.FeatureStore
SqlFilterCondition - Enum in com.logicalclocks.hsfs.constructor
SqlFilterLogic - Enum in com.logicalclocks.hsfs.constructor
SslEndpointIdentificationAlgorithm - Enum in com.logicalclocks.hsfs
sslEndpointIdentificationAlgorithm - Variable in class com.logicalclocks.hsfs.StorageConnector.KafkaConnector
sslKeyPassword - Variable in class com.logicalclocks.hsfs.StorageConnector.KafkaConnector
sslKeystoreLocation - Variable in class com.logicalclocks.hsfs.StorageConnector.KafkaConnector
sslKeystorePassword - Variable in class com.logicalclocks.hsfs.StorageConnector.KafkaConnector
sslTruststoreLocation - Variable in class com.logicalclocks.hsfs.StorageConnector.KafkaConnector
sslTruststorePassword - Variable in class com.logicalclocks.hsfs.StorageConnector.KafkaConnector
statisticColumns - Variable in class com.logicalclocks.hsfs.FeatureGroupBase
Statistics - Class in com.logicalclocks.hsfs.metadata
Statistics() - Constructor for class com.logicalclocks.hsfs.metadata.Statistics
StatisticsApi - Class in com.logicalclocks.hsfs.metadata
StatisticsApi(EntityEndpointType) - Constructor for class com.logicalclocks.hsfs.metadata.StatisticsApi
statisticsConfig - Variable in class com.logicalclocks.hsfs.FeatureGroupBase
StatisticsConfig - Class in com.logicalclocks.hsfs
StatisticsConfig(Boolean, Boolean, Boolean, Boolean) - Constructor for class com.logicalclocks.hsfs.StatisticsConfig
statisticsConfig - Variable in class com.logicalclocks.hsfs.TrainingDatasetBase
StatisticsEngine - Class in com.logicalclocks.hsfs.spark.engine
StatisticsEngine(EntityEndpointType) - Constructor for class com.logicalclocks.hsfs.spark.engine.StatisticsEngine
statisticsEngine - Variable in class com.logicalclocks.hsfs.spark.FeatureGroup
Storage - Enum in com.logicalclocks.hsfs
StorageConnector - Class in com.logicalclocks.hsfs
StorageConnector() - Constructor for class com.logicalclocks.hsfs.StorageConnector
storageConnector - Variable in class com.logicalclocks.hsfs.TrainingDatasetBase
StorageConnector.AdlsConnector - Class in com.logicalclocks.hsfs
StorageConnector.BigqueryConnector - Class in com.logicalclocks.hsfs
StorageConnector.GcsConnector - Class in com.logicalclocks.hsfs
StorageConnector.HopsFsConnector - Class in com.logicalclocks.hsfs
StorageConnector.JdbcConnector - Class in com.logicalclocks.hsfs
StorageConnector.KafkaConnector - Class in com.logicalclocks.hsfs
StorageConnector.RedshiftConnector - Class in com.logicalclocks.hsfs
StorageConnector.S3Connector - Class in com.logicalclocks.hsfs
StorageConnector.SnowflakeConnector - Class in com.logicalclocks.hsfs
storageConnectorApi - Variable in class com.logicalclocks.hsfs.constructor.QueryBase
storageConnectorApi - Variable in class com.logicalclocks.hsfs.FeatureStoreBase
StorageConnectorApi - Class in com.logicalclocks.hsfs.metadata
StorageConnectorApi() - Constructor for class com.logicalclocks.hsfs.metadata.StorageConnectorApi
storageConnectorApi - Variable in class com.logicalclocks.hsfs.StorageConnector
storageConnectorType - Variable in class com.logicalclocks.hsfs.StorageConnector
StorageConnectorType - Enum in com.logicalclocks.hsfs
StorageConnectorUtils - Class in com.logicalclocks.hsfs.spark.util
StorageConnectorUtils() - Constructor for class com.logicalclocks.hsfs.spark.util.StorageConnectorUtils
StreamFeatureGroup - Class in com.logicalclocks.hsfs.flink
StreamFeatureGroup(FeatureStore, String, Integer, String, List<String>, List<String>, String, boolean, List<Feature>, StatisticsConfig, String, String) - Constructor for class com.logicalclocks.hsfs.flink.StreamFeatureGroup
StreamFeatureGroup() - Constructor for class com.logicalclocks.hsfs.flink.StreamFeatureGroup
StreamFeatureGroup(Integer, String, List<Feature>) - Constructor for class com.logicalclocks.hsfs.flink.StreamFeatureGroup
StreamFeatureGroup(FeatureStore, int) - Constructor for class com.logicalclocks.hsfs.flink.StreamFeatureGroup
StreamFeatureGroup - Class in com.logicalclocks.hsfs.spark
StreamFeatureGroup(FeatureStore, String, Integer, String, List<String>, List<String>, String, boolean, List<Feature>, StatisticsConfig, String, String) - Constructor for class com.logicalclocks.hsfs.spark.StreamFeatureGroup
StreamFeatureGroup() - Constructor for class com.logicalclocks.hsfs.spark.StreamFeatureGroup
StreamFeatureGroup(Integer, String, List<Feature>) - Constructor for class com.logicalclocks.hsfs.spark.StreamFeatureGroup
StreamFeatureGroup(FeatureStore, int) - Constructor for class com.logicalclocks.hsfs.spark.StreamFeatureGroup
STREAMING_QUERY - Static variable in class com.logicalclocks.hsfs.spark.engine.hudi.HudiEngine
streamToHoodieTable(Map<String, String>, SparkSession) - Method in class com.logicalclocks.hsfs.spark.engine.hudi.DeltaStreamerConfig
streamToHoodieTable(SparkSession, StreamFeatureGroup, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.engine.hudi.HudiEngine
streamToHudiTable(StreamFeatureGroup, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.engine.SparkEngine
subject - Variable in class com.logicalclocks.hsfs.FeatureGroupBase
Subject - Class in com.logicalclocks.hsfs.metadata
Subject() - Constructor for class com.logicalclocks.hsfs.metadata.Subject

T

T_CERTIFICATE - Static variable in class com.logicalclocks.hsfs.metadata.HopsworksExternalClient
table - Variable in class com.logicalclocks.hsfs.StorageConnector.SnowflakeConnector
tableName - Variable in class com.logicalclocks.hsfs.StorageConnector.RedshiftConnector
Tags - Class in com.logicalclocks.hsfs.metadata
Tags() - Constructor for class com.logicalclocks.hsfs.metadata.Tags
TAGS_PATH - Static variable in class com.logicalclocks.hsfs.metadata.TagsApi
tagsApi - Variable in class com.logicalclocks.hsfs.engine.FeatureGroupEngineBase
tagsApi - Variable in class com.logicalclocks.hsfs.engine.FeatureViewEngineBase
TagsApi - Class in com.logicalclocks.hsfs.metadata
TagsApi(EntityEndpointType) - Constructor for class com.logicalclocks.hsfs.metadata.TagsApi
TEST - Static variable in class com.logicalclocks.hsfs.Split
TF_CONNECTOR_RECORD_TYPE - Static variable in class com.logicalclocks.hsfs.util.Constants
timeStampToHudiFormat(Long) - Method in class com.logicalclocks.hsfs.engine.FeatureGroupUtils
timeTravelFormat - Variable in class com.logicalclocks.hsfs.FeatureGroupBase
TimeTravelFormat - Enum in com.logicalclocks.hsfs
toJson() - Method in class com.logicalclocks.hsfs.Feature
token - Variable in class com.logicalclocks.hsfs.StorageConnector.SnowflakeConnector
toString() - Method in class com.logicalclocks.hsfs.FeatureStoreBase
toString() - Method in class com.logicalclocks.hsfs.metadata.HopsworksClient.HopsworksErrorClass
toString() - Method in enum com.logicalclocks.hsfs.SslEndpointIdentificationAlgorithm
TRAIN - Static variable in class com.logicalclocks.hsfs.Split
TRAINING_DATASET_ID_PATH - Static variable in class com.logicalclocks.hsfs.metadata.TrainingDatasetApi
trainingData(String, String, String) - Method in class com.logicalclocks.hsfs.spark.FeatureView: Create the metadata for a training dataset and get the corresponding training data from the offline feature store.
trainingData(String, String, String, Long, StatisticsConfig, Map<String, String>, FilterLogic, Filter) - Method in class com.logicalclocks.hsfs.spark.FeatureView: Create the metadata for a training dataset and get the corresponding training data from the offline feature store.
TrainingDataset - Class in com.logicalclocks.hsfs.spark
TrainingDataset(String, Integer, String, DataFormat, Boolean, StorageConnector, String, List<Split>, String, Long, FeatureStore, StatisticsConfig, List<String>, String, String, TrainingDatasetType, Float, Float, String, String, String, String, String, String, Integer, FilterLogic, Filter) - Constructor for class com.logicalclocks.hsfs.spark.TrainingDataset
trainingDatasetApi - Variable in class com.logicalclocks.hsfs.FeatureStoreBase
TrainingDatasetApi - Class in com.logicalclocks.hsfs.metadata
TrainingDatasetApi() - Constructor for class com.logicalclocks.hsfs.metadata.TrainingDatasetApi
TrainingDatasetBase - Class in com.logicalclocks.hsfs
TrainingDatasetBase() - Constructor for class com.logicalclocks.hsfs.TrainingDatasetBase
TrainingDatasetBundle - Class in com.logicalclocks.hsfs.spark
TrainingDatasetBundle(Integer, Dataset<Row>, List<String>) - Constructor for class com.logicalclocks.hsfs.spark.TrainingDatasetBundle
TrainingDatasetBundle(Integer) - Constructor for class com.logicalclocks.hsfs.spark.TrainingDatasetBundle
TrainingDatasetBundle(Integer, Map<String, Dataset<Row>>, List<String>) - Constructor for class com.logicalclocks.hsfs.spark.TrainingDatasetBundle
TrainingDatasetEngine - Class in com.logicalclocks.hsfs.spark.engine
TrainingDatasetEngine() - Constructor for class com.logicalclocks.hsfs.spark.engine.TrainingDatasetEngine
TrainingDatasetFeature - Class in com.logicalclocks.hsfs
TrainingDatasetFeature(String, String) - Constructor for class com.logicalclocks.hsfs.TrainingDatasetFeature
TrainingDatasetFeature(String, String, Integer) - Constructor for class com.logicalclocks.hsfs.TrainingDatasetFeature
TrainingDatasetFeature(String, String, Integer, Boolean) - Constructor for class com.logicalclocks.hsfs.TrainingDatasetFeature
TrainingDatasetFeature(FeatureGroupBase, String, Boolean) - Constructor for class com.logicalclocks.hsfs.TrainingDatasetFeature
trainingDatasetSchemaMatch(Dataset<Row>, List<TrainingDatasetFeature>) - Method in class com.logicalclocks.hsfs.spark.engine.TrainingDatasetUtils
trainingDatasetType - Variable in class com.logicalclocks.hsfs.TrainingDatasetBase
TrainingDatasetType - Enum in com.logicalclocks.hsfs
TrainingDatasetUtils - Class in com.logicalclocks.hsfs.spark.engine
TrainingDatasetUtils() - Constructor for class com.logicalclocks.hsfs.spark.engine.TrainingDatasetUtils
trainSplit - Variable in class com.logicalclocks.hsfs.TrainingDatasetBase
trainTestSplit(Float, String, String, String, String, String) - Method in class com.logicalclocks.hsfs.spark.FeatureView: Create the metadata for a training dataset and get the corresponding training data from the offline feature store.
trainTestSplit(Float, String, String, String, String, String, Long, StatisticsConfig, Map<String, String>, FilterLogic, Filter) - Method in class com.logicalclocks.hsfs.spark.FeatureView: Create the metadata for a training dataset and get the corresponding training data from the offline feature store.
trainValidationTestSplit(Float, Float, String, String, String, String, String, String, String) - Method in class com.logicalclocks.hsfs.spark.FeatureView: Create the metadata for a training dataset and get the corresponding training data from the offline feature store.
trainValidationTestSplit(Float, Float, String, String, String, String, String, String, String, Long, StatisticsConfig, Map<String, String>, FilterLogic, Filter) - Method in class com.logicalclocks.hsfs.spark.FeatureView: Create the metadata for a training dataset and get the corresponding training data from the offline feature store.
TransformationFunction - Class in com.logicalclocks.hsfs
TransformationFunction() - Constructor for class com.logicalclocks.hsfs.TransformationFunction
TransformationFunctionAttached - Class in com.logicalclocks.hsfs.metadata
TransformationFunctionAttached() - Constructor for class com.logicalclocks.hsfs.metadata.TransformationFunctionAttached
trustStorePath - Variable in class com.logicalclocks.hsfs.HopsworksConnectionBase
trustStorePath - Variable in class com.logicalclocks.hsfs.metadata.HopsworksExternalClient
type - Variable in class com.logicalclocks.hsfs.FeatureGroupBase
type - Variable in class com.logicalclocks.hsfs.FeatureViewBase
type - Variable in class com.logicalclocks.hsfs.TrainingDatasetBase

U

UnauthorizedException - Exception in com.logicalclocks.hsfs.metadata
UnauthorizedException() - Constructor for exception com.logicalclocks.hsfs.metadata.UnauthorizedException
unloadSubject() - Method in class com.logicalclocks.hsfs.FeatureGroupBase
update(T2) - Method in class com.logicalclocks.hsfs.engine.FeatureViewEngineBase
update(T) - Method in class com.logicalclocks.hsfs.FeatureViewBase
update(FeatureView) - Method in class com.logicalclocks.hsfs.flink.engine.FeatureViewEngine
update(FeatureView) - Method in class com.logicalclocks.hsfs.flink.FeatureView
update(FeatureViewBase, Class<T>) - Method in class com.logicalclocks.hsfs.metadata.FeatureViewApi
update(FeatureView) - Method in class com.logicalclocks.hsfs.spark.engine.FeatureViewEngine
update(FeatureView) - Method in class com.logicalclocks.hsfs.spark.FeatureView: Update the description of the feature view.
update() - Method in class com.logicalclocks.hsfs.StorageConnector.JdbcConnector
update() - Method in class com.logicalclocks.hsfs.StorageConnector.RedshiftConnector
update() - Method in class com.logicalclocks.hsfs.StorageConnector.S3Connector
updateDescription(FeatureGroupBase, String, Class<T>) - Method in class com.logicalclocks.hsfs.engine.FeatureGroupEngineBase
updateDescription(String) - Method in class com.logicalclocks.hsfs.FeatureGroupBase: Update the description of the feature group.
updateFeatureDescription(String, String) - Method in class com.logicalclocks.hsfs.FeatureGroupBase: Update the description of a single feature.
updateFeatures(FeatureGroupBase, List<Feature>, Class<T>) - Method in class com.logicalclocks.hsfs.engine.FeatureGroupEngineBase
updateFeatures(List<Feature>) - Method in class com.logicalclocks.hsfs.FeatureGroupBase: Update the metadata of multiple features.
updateFeatures(Feature) - Method in class com.logicalclocks.hsfs.FeatureGroupBase: Update the metadata of multiple features.
updateFeatures(List<Feature>) - Method in class com.logicalclocks.hsfs.FeatureGroupBaseForApi
updateFeatures(Feature) - Method in class com.logicalclocks.hsfs.FeatureGroupBaseForApi
updateFeatures(Feature) - Method in class com.logicalclocks.hsfs.flink.StreamFeatureGroup
updateFeatures(List<Feature>) - Method in class com.logicalclocks.hsfs.flink.StreamFeatureGroup
updateFeatures(List<Feature>) - Method in class com.logicalclocks.hsfs.spark.ExternalFeatureGroup
updateFeatures(Feature) - Method in class com.logicalclocks.hsfs.spark.ExternalFeatureGroup
updateFeatures(List<Feature>) - Method in class com.logicalclocks.hsfs.spark.FeatureGroup: Update the metadata of multiple features.
updateFeatures(Feature) - Method in class com.logicalclocks.hsfs.spark.FeatureGroup: Update the metadata of feature.
updateFeatures(List<Feature>) - Method in class com.logicalclocks.hsfs.spark.StreamFeatureGroup: Update the metadata of multiple features.
updateFeatures(Feature) - Method in class com.logicalclocks.hsfs.spark.StreamFeatureGroup: Update the metadata of feature.
updateMetadata(FeatureGroupBase, String, Class<T>) - Method in class com.logicalclocks.hsfs.metadata.FeatureGroupApi
updateMetadata(FeatureGroupBase, String, Object, Class<T>) - Method in class com.logicalclocks.hsfs.metadata.FeatureGroupApi
updateMetadata(TrainingDatasetBase, String) - Method in class com.logicalclocks.hsfs.metadata.TrainingDatasetApi
updateStatisticsConfig(FeatureGroupBase, Class<T>) - Method in class com.logicalclocks.hsfs.engine.FeatureGroupEngineBase
updateStatisticsConfig() - Method in class com.logicalclocks.hsfs.FeatureGroupBase: Update the statistics configuration of the feature group.
updateStatisticsConfig(TrainingDataset) - Method in class com.logicalclocks.hsfs.spark.engine.TrainingDatasetEngine
updateStatisticsConfig() - Method in class com.logicalclocks.hsfs.spark.TrainingDataset: Update the statistics configuration of the training dataset.
updateStatisticsConfig() - Method in class com.logicalclocks.hsfs.TrainingDatasetBase: Update the statistics configuration of the training dataset.
url - Variable in class com.logicalclocks.hsfs.StorageConnector.SnowflakeConnector
User - Class in com.logicalclocks.hsfs.metadata
User() - Constructor for class com.logicalclocks.hsfs.metadata.User
user - Variable in class com.logicalclocks.hsfs.StorageConnector.SnowflakeConnector
utils - Variable in class com.logicalclocks.hsfs.engine.FeatureGroupEngineBase
utils - Variable in class com.logicalclocks.hsfs.FeatureGroupBase

V

validateSparkConfiguration() - Method in class com.logicalclocks.hsfs.spark.engine.SparkEngine
validateTrainTestSplit(Float, String, String) - Method in class com.logicalclocks.hsfs.FeatureViewBase
validateTrainValidationTestSplit(Float, Float, String, String, String, String) - Method in class com.logicalclocks.hsfs.FeatureViewBase
VALIDATION - Static variable in class com.logicalclocks.hsfs.Split
valueOf(String) - Static method in enum com.logicalclocks.hsfs.constructor.JoinType: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.logicalclocks.hsfs.constructor.SqlFilterCondition: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.logicalclocks.hsfs.constructor.SqlFilterLogic: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.logicalclocks.hsfs.DataFormat: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.logicalclocks.hsfs.EntityEndpointType: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.logicalclocks.hsfs.ExternalDataFormat: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.logicalclocks.hsfs.FeatureType: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.logicalclocks.hsfs.HudiOperationType: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.logicalclocks.hsfs.metadata.Code.RunType: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.logicalclocks.hsfs.SecretStore: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.logicalclocks.hsfs.SecurityProtocol: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.logicalclocks.hsfs.Split.SplitType: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.logicalclocks.hsfs.SslEndpointIdentificationAlgorithm: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.logicalclocks.hsfs.Storage: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.logicalclocks.hsfs.StorageConnectorType: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.logicalclocks.hsfs.TimeTravelFormat: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.logicalclocks.hsfs.TrainingDatasetType: Returns the enum constant of this type with the specified name.
values() - Static method in enum com.logicalclocks.hsfs.constructor.JoinType: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.logicalclocks.hsfs.constructor.SqlFilterCondition: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.logicalclocks.hsfs.constructor.SqlFilterLogic: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.logicalclocks.hsfs.DataFormat: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.logicalclocks.hsfs.EntityEndpointType: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.logicalclocks.hsfs.ExternalDataFormat: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.logicalclocks.hsfs.FeatureType: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.logicalclocks.hsfs.HudiOperationType: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.logicalclocks.hsfs.metadata.Code.RunType: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.logicalclocks.hsfs.SecretStore: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.logicalclocks.hsfs.SecurityProtocol: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.logicalclocks.hsfs.Split.SplitType: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.logicalclocks.hsfs.SslEndpointIdentificationAlgorithm: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.logicalclocks.hsfs.Storage: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.logicalclocks.hsfs.StorageConnectorType: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.logicalclocks.hsfs.TimeTravelFormat: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.logicalclocks.hsfs.TrainingDatasetType: Returns an array containing the constants of this enum type, in the order they are declared.
Variable - Class in com.logicalclocks.hsfs.metadata
Variable() - Constructor for class com.logicalclocks.hsfs.metadata.Variable
VariablesApi - Class in com.logicalclocks.hsfs.metadata
VariablesApi() - Constructor for class com.logicalclocks.hsfs.metadata.VariablesApi
VectorServer - Class in com.logicalclocks.hsfs.engine
VectorServer(boolean) - Constructor for class com.logicalclocks.hsfs.engine.VectorServer
vectorServer - Variable in class com.logicalclocks.hsfs.FeatureViewBase
vectorServer - Variable in class com.logicalclocks.hsfs.TrainingDatasetBase
verify(String, SSLSession) - Method in class com.logicalclocks.hsfs.metadata.HopsworksHostnameVerifier
verifyAttributeKeyNames(FeatureGroupBase, List<String>, String) - Method in class com.logicalclocks.hsfs.engine.FeatureGroupUtils
version - Variable in class com.logicalclocks.hsfs.FeatureGroupBase
version - Variable in class com.logicalclocks.hsfs.FeatureViewBase
version(Integer) - Method in class com.logicalclocks.hsfs.spark.FeatureView.FeatureViewBuilder
version - Variable in class com.logicalclocks.hsfs.TrainingDatasetBase

W

warehouse - Variable in class com.logicalclocks.hsfs.StorageConnector.SnowflakeConnector
write(TrainingDataset, Query, Map<String, String>, Map<String, String>, SaveMode) - Method in class com.logicalclocks.hsfs.spark.engine.SparkEngine: Setup Spark to write the data on the File System.
writeDataStream(StreamFeatureGroup, DataStream<?>, Map<String, String>) - Method in class com.logicalclocks.hsfs.flink.engine.FlinkEngine
writeEmptyDataframe(FeatureGroupBase) - Method in class com.logicalclocks.hsfs.spark.engine.SparkEngine
writeOfflineDataframe(FeatureGroupBase, Dataset<Row>, HudiOperationType, Map<String, String>, Integer) - Method in class com.logicalclocks.hsfs.spark.engine.SparkEngine
writeOnlineDataframe(FeatureGroupBase, Dataset<Row>, String, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.engine.SparkEngine: Writes feature group dataframe to kafka for online-fs ingestion.
writeStreamDataframe(FeatureGroupBase, Dataset<Row>, String, String, boolean, Long, String, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.engine.SparkEngine
writeTrainingDataset(FeatureView, TrainingDataset, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.engine.FeatureViewEngine

A B C D E F G H I J K L M N O P Q R S T U V W