Index (hsfs-parent 5.2.0-SNAPSHOT API)

A B C D E F G H I J K L M N O P Q R S T U V W Z
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form

A

accessKey - Variable in class com.logicalclocks.hsfs.StorageConnector.GlueConnector
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(FeatureViewBase, Integer, String, Object) - Method in class com.logicalclocks.hsfs.metadata.TagsApi
add(FeatureViewBase, String, Object) - Method in class com.logicalclocks.hsfs.metadata.TagsApi
add(TrainingDatasetBase, String, Object) - Method in class com.logicalclocks.hsfs.metadata.TagsApi
addFile(String) - Method in class com.logicalclocks.hsfs.beam.engine.BeamEngine
addFile(String) - Method in class com.logicalclocks.hsfs.engine.Engine
addFile(String) - Method in class com.logicalclocks.hsfs.engine.EngineBase
addFile(String) - Method in class com.logicalclocks.hsfs.flink.engine.FlinkEngine
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.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.
ADLS - Enum constant in enum class com.logicalclocks.hsfs.StorageConnectorType
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(Filter) - Method in class com.logicalclocks.hsfs.constructor.FilterLogic
and(FilterLogic) - Method in class com.logicalclocks.hsfs.constructor.Filter
and(FilterLogic) - Method in class com.logicalclocks.hsfs.constructor.FilterLogic
AND - Enum constant in enum class com.logicalclocks.hsfs.constructor.SqlFilterLogic
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(Feature) - Method in class com.logicalclocks.hsfs.spark.ExternalFeatureGroup
appendFeatures(Feature) - Method in class com.logicalclocks.hsfs.spark.FeatureGroup: Append a single feature to the schema of the feature group.
appendFeatures(Feature) - Method in class com.logicalclocks.hsfs.spark.StreamFeatureGroup: Append a single feature to the schema of the stream feature group.
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(List<Feature>) - Method in class com.logicalclocks.hsfs.spark.FeatureGroup: Append features 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.
application - Variable in class com.logicalclocks.hsfs.StorageConnector.SapHanaConnector
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.GlueConnector
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
arguments - Variable in class com.logicalclocks.hsfs.StorageConnector.SapHanaConnector
arguments - Variable in class com.logicalclocks.hsfs.StorageConnector.SqlConnector
asOf(String) - Method in class com.logicalclocks.hsfs.constructor.QueryBase: Perform time travel on the given Query.
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) - 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.constructor.QueryBase: Perform time travel on the given Query.
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, 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.
authMechanism - Variable in class com.logicalclocks.hsfs.StorageConnector.MongoDbConnector
AuthorizationHandler<T> - Class in com.logicalclocks.hsfs.metadata
authSource - Variable in class com.logicalclocks.hsfs.StorageConnector.MongoDbConnector
autoCreate - Variable in class com.logicalclocks.hsfs.StorageConnector.RedshiftConnector
AVRO - Enum constant in enum class com.logicalclocks.hsfs.DataFormat
AVRO - Enum constant in enum class com.logicalclocks.hsfs.ExternalDataFormat

B

BaseHandler(Class<T>, ObjectMapper) - Constructor for class com.logicalclocks.hsfs.metadata.HopsworksClient.BaseHandler
BeamEngine - Class in com.logicalclocks.hsfs.beam.engine
BeamKafkaProducer - Class in com.logicalclocks.hsfs.beam.engine
BeamKafkaProducer(Map) - Constructor for class com.logicalclocks.hsfs.beam.engine.BeamKafkaProducer
BeamProducer - Class in com.logicalclocks.hsfs.beam.engine
BeamProducer(String, Map<String, String>, Schema, Schema, Map<String, Schema>, List<String>, StreamFeatureGroup) - Constructor for class com.logicalclocks.hsfs.beam.engine.BeamProducer
BIGINT - Enum constant in enum class com.logicalclocks.hsfs.FeatureType
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 - Enum constant in enum class com.logicalclocks.hsfs.StorageConnectorType
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.beam.FeatureView.FeatureViewBuilder
build() - Method in class com.logicalclocks.hsfs.FeatureView.FeatureViewBuilder
build() - Method in class com.logicalclocks.hsfs.flink.FeatureView.FeatureViewBuilder
build() - Method in class com.logicalclocks.hsfs.spark.FeatureView.FeatureViewBuilder
buildStringEntity(Object) - Method in class com.logicalclocks.hsfs.metadata.HopsworksClient
BULK_INSERT - Enum constant in enum class com.logicalclocks.hsfs.HudiOperationType

C

castColumnType(Dataset<Row>, List<TrainingDatasetFeature>) - Method in class com.logicalclocks.hsfs.spark.engine.SparkEngine
catalogId - Variable in class com.logicalclocks.hsfs.StorageConnector.GlueConnector
certKey - Variable in class com.logicalclocks.hsfs.metadata.HopsworksExternalClient
certPath - Variable in class com.logicalclocks.hsfs.HopsworksConnectionBase
checkDeprecated() - Method in class com.logicalclocks.hsfs.FeatureGroupBase
clean(FeatureStore, String, Integer) - Method in class com.logicalclocks.hsfs.spark.FeatureView: Delete the feature view and all associated metadata and training data.
CLICKHOUSE - Static variable in class com.logicalclocks.hsfs.StorageConnector.SqlConnector
close() - Method in class com.logicalclocks.hsfs.engine.VectorServer
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
closeSparkSession() - Method in class com.logicalclocks.hsfs.spark.engine.SparkEngine
closeVectorServer() - Method in class com.logicalclocks.hsfs.FeatureViewBase: Closes the ExecutorService and JDBC DataSource used to retrieve feature vectors from the online feature store.
clusterIdentifier - Variable in class com.logicalclocks.hsfs.StorageConnector.RedshiftConnector
coalesce - Variable in class com.logicalclocks.hsfs.TrainingDatasetBase
collection - Variable in class com.logicalclocks.hsfs.StorageConnector.MongoDbConnector
ColumnProfiler - Class in com.logicalclocks.hsfs.spark.engine.profile: Replacement for Deequ's ColumnProfilerRunner producing JSON wire-compatible with Deequ 2.0.7-spark-3.5 for all keys except kll.
ColumnProfiler() - Constructor for class com.logicalclocks.hsfs.spark.engine.profile.ColumnProfiler
com.logicalclocks.hsfs - package com.logicalclocks.hsfs
com.logicalclocks.hsfs.beam - package com.logicalclocks.hsfs.beam
com.logicalclocks.hsfs.beam.engine - package com.logicalclocks.hsfs.beam.engine
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.engine.profile - package com.logicalclocks.hsfs.spark.engine.profile
com.logicalclocks.hsfs.spark.util - package com.logicalclocks.hsfs.spark.util
com.logicalclocks.hsfs.util - package com.logicalclocks.hsfs.util
COMMA - Enum constant in enum class com.logicalclocks.hsfs.constructor.JoinType
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
commitDelete(FeatureGroupBase, Dataset<Row>, Map<String, String>, Storage) - Method in class com.logicalclocks.hsfs.spark.engine.FeatureGroupEngine: Deletes the records in genericDataset from the storage named by storage.
commitDeleteRecord(Dataset<Row>) - Method in class com.logicalclocks.hsfs.spark.FeatureGroup: Deprecated.
use FeatureGroup.removeRows(Dataset) instead.
commitDeleteRecord(Dataset<Row>) - Method in class com.logicalclocks.hsfs.spark.StreamFeatureGroup: Deprecated.
use StreamFeatureGroup.removeRows(Dataset) instead.
commitDeleteRecord(Dataset<Row>, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.FeatureGroup: Deprecated.
use FeatureGroup.removeRows(Dataset, Map) instead.
commitDeleteRecord(Dataset<Row>, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.StreamFeatureGroup: Deprecated.
use StreamFeatureGroup.removeRows(Dataset, Map) instead.
commitDetails() - Method in class com.logicalclocks.hsfs.spark.FeatureGroup: Retrieves commit timeline for this feature group.
commitDetails() - Method in class com.logicalclocks.hsfs.spark.StreamFeatureGroup: Retrieves commit timeline for this stream feature group.
commitDetails(FeatureGroupBase, Integer) - Method in class com.logicalclocks.hsfs.spark.engine.FeatureGroupEngine
commitDetails(Integer) - Method in class com.logicalclocks.hsfs.spark.FeatureGroup: Retrieves commit timeline for this 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.FeatureGroup: Return commit details as of specific point in time.
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.FeatureGroup: 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
computeAndSaveSplitStatistics(FeatureView, TrainingDataset, Map<String, Dataset<Row>>) - Method in class com.logicalclocks.hsfs.spark.engine.StatisticsEngine
computeAndSaveSplitStatistics(TrainingDataset) - Method in class com.logicalclocks.hsfs.spark.engine.StatisticsEngine
computeSketch(Dataset<Row>, String) - Method in class com.logicalclocks.hsfs.spark.engine.profile.KllAggregator: Builds a merged KllDoublesSketch over the given numeric column and returns its byte representation.
computeSplitStatistics(TrainingDataset) - Method in class com.logicalclocks.hsfs.spark.engine.StatisticsEngine
computeSplitStatistics(TrainingDataset, Map<String, Dataset<Row>>) - Method in class com.logicalclocks.hsfs.spark.engine.StatisticsEngine
computeStatistics() - 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() - Method in class com.logicalclocks.hsfs.spark.StreamFeatureGroup: Recompute the statistics for the stream 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(FeatureGroupBase, Dataset<Row>, Long) - Method in class com.logicalclocks.hsfs.spark.engine.StatisticsEngine
computeStatistics(FeatureView, 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.FeatureViewEngine
computeStatistics(TrainingDataset, Dataset<Row>) - Method in class com.logicalclocks.hsfs.spark.engine.StatisticsEngine
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(String) - Method in class com.logicalclocks.hsfs.spark.StreamFeatureGroup: Recompute the statistics for the feature group and save them to the feature store.
computeTrainingData(FeatureStoreBase, FeatureViewBase, TrainingDatasetBase) - Method in class com.logicalclocks.hsfs.metadata.FeatureViewApi
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
connectionString - Variable in class com.logicalclocks.hsfs.StorageConnector.MongoDbConnector
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
convertPojoToGenericRecord(Object, Schema, Schema, Map<String, Schema>) - Static method in class com.logicalclocks.hsfs.engine.PojoToAvroUtils
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.spark.FeatureStore: Create external feature group builder object.
createFeatureGroup() - Method in class com.logicalclocks.hsfs.spark.FeatureStore: Create feature group builder object.
createFeatureView() - Method in class com.logicalclocks.hsfs.beam.FeatureStore: Create a new feature view metadata object.
createFeatureView() - Method in class com.logicalclocks.hsfs.FeatureStore: Create a new feature view metadata object.
createFeatureView() - Method in class com.logicalclocks.hsfs.flink.FeatureStore: Create a new feature view metadata object.
createFeatureView() - Method in class com.logicalclocks.hsfs.spark.FeatureStore
createOnDemandFeatureGroup() - Method in class com.logicalclocks.hsfs.spark.FeatureStore: Deprecated.
createOnlineIngestion(FeatureGroupBase, OnlineIngestion) - Method in class com.logicalclocks.hsfs.metadata.OnlineIngestionApi
createStreamFeatureGroup() - Method in class com.logicalclocks.hsfs.beam.FeatureStore: Create a feature group builder object.
createStreamFeatureGroup() - Method in class com.logicalclocks.hsfs.FeatureStore: Create a feature group builder object.
createStreamFeatureGroup() - Method in class com.logicalclocks.hsfs.flink.FeatureStore: Create a feature group builder object.
createStreamFeatureGroup(String, Integer, String, Boolean, TimeTravelFormat, List<String>, List<String>, String, String, List<Feature>, StatisticsConfig, DataSource) - Method in class com.logicalclocks.hsfs.beam.FeatureStore
createStreamFeatureGroup(String, Integer, String, Boolean, TimeTravelFormat, List<String>, List<String>, String, String, List<Feature>, StatisticsConfig, DataSource) - Method in class com.logicalclocks.hsfs.FeatureStore
createStreamFeatureGroup(String, Integer, String, Boolean, TimeTravelFormat, List<String>, List<String>, String, String, List<Feature>, StatisticsConfig, DataSource) - Method in class com.logicalclocks.hsfs.FeatureStoreBase: Create a stream feature group object.
createStreamFeatureGroup(String, Integer, String, Boolean, TimeTravelFormat, List<String>, List<String>, String, String, List<Feature>, StatisticsConfig, DataSource) - Method in class com.logicalclocks.hsfs.flink.FeatureStore
createStreamFeatureGroup(String, Integer, String, Boolean, TimeTravelFormat, List<String>, List<String>, String, String, List<Feature>, StatisticsConfig, DataSource) - Method in class com.logicalclocks.hsfs.spark.FeatureStore
createStreamFeatureGroup(String, Integer, String, Boolean, TimeTravelFormat, List<String>, List<String>, String, String, List<Feature>, StatisticsConfig, StorageConnector, String) - Method in class com.logicalclocks.hsfs.beam.FeatureStore
createStreamFeatureGroup(String, Integer, String, Boolean, TimeTravelFormat, List<String>, List<String>, String, String, List<Feature>, StatisticsConfig, StorageConnector, String) - Method in class com.logicalclocks.hsfs.FeatureStore
createStreamFeatureGroup(String, Integer, String, Boolean, TimeTravelFormat, List<String>, List<String>, String, String, List<Feature>, StatisticsConfig, StorageConnector, String) - Method in class com.logicalclocks.hsfs.FeatureStoreBase: Deprecated.
Use FeatureStoreBase.createStreamFeatureGroup(String, Integer, String, Boolean, TimeTravelFormat, List, List, String, String, List, StatisticsConfig, DataSource) instead.
createStreamFeatureGroup(String, Integer, String, Boolean, TimeTravelFormat, List<String>, List<String>, String, String, List<Feature>, StatisticsConfig, StorageConnector, String) - Method in class com.logicalclocks.hsfs.flink.FeatureStore
createStreamFeatureGroup(String, Integer, String, Boolean, TimeTravelFormat, List<String>, List<String>, String, String, List<Feature>, StatisticsConfig, StorageConnector, String) - Method in class com.logicalclocks.hsfs.spark.FeatureStore
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.FeatureViewBase: Create the metadata for a training dataset and save the corresponding training data into `location`.
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, DataSource, Long, StatisticsConfig, Map<String, String>, FilterLogic, Filter) - Method in class com.logicalclocks.hsfs.FeatureViewBase: Create the metadata for a training dataset and save the corresponding training data into `location`.
createTrainingData(String, String, String, DataFormat, Boolean, DataSource, 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`.
createTrainingData(String, String, String, DataFormat, Boolean, StorageConnector, String, Long, StatisticsConfig, Map<String, String>, FilterLogic, Filter) - Method in class com.logicalclocks.hsfs.FeatureViewBase: Deprecated.
createTrainingData(String, String, String, DataFormat, Boolean, StorageConnector, String, Long, StatisticsConfig, Map<String, String>, FilterLogic, Filter) - Method in class com.logicalclocks.hsfs.spark.FeatureView: Deprecated.
createTrainingDataset() - Method in class com.logicalclocks.hsfs.spark.FeatureStore: Deprecated.
createTrainingDataset(FeatureView, TrainingDataset, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.engine.FeatureViewEngine
createTrainingDataset(TrainingDatasetBase) - Method in class com.logicalclocks.hsfs.metadata.TrainingDatasetApi
createTrainTestSplit(Float, String, String, String, String, String, DataFormat) - Method in class com.logicalclocks.hsfs.FeatureViewBase: Create the metadata for a training dataset and save the corresponding training data into `location`.
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, DataSource, Long, StatisticsConfig, Map<String, String>, FilterLogic, Filter) - Method in class com.logicalclocks.hsfs.FeatureViewBase: Create the metadata for a training dataset and save the corresponding training data into `location`.
createTrainTestSplit(Float, String, String, String, String, String, DataFormat, Boolean, DataSource, 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`.
createTrainTestSplit(Float, String, String, String, String, String, DataFormat, Boolean, StorageConnector, String, Long, StatisticsConfig, Map<String, String>, FilterLogic, Filter) - Method in class com.logicalclocks.hsfs.FeatureViewBase: Deprecated.
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: Deprecated.
createTrainValidationTestSplit(Float, Float, String, String, String, String, String, String, String, DataFormat) - Method in class com.logicalclocks.hsfs.FeatureViewBase: 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, DataSource, Long, StatisticsConfig, Map<String, String>, FilterLogic, Filter) - Method in class com.logicalclocks.hsfs.FeatureViewBase: 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, DataSource, 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, Boolean, StorageConnector, String, Long, StatisticsConfig, Map<String, String>, FilterLogic, Filter) - Method in class com.logicalclocks.hsfs.FeatureViewBase: Deprecated.
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: Deprecated.
creator - Variable in class com.logicalclocks.hsfs.FeatureGroupBase
Credentials - Class in com.logicalclocks.hsfs.metadata
Credentials() - Constructor for class com.logicalclocks.hsfs.metadata.Credentials
CROSS - Enum constant in enum class com.logicalclocks.hsfs.constructor.JoinType
CSV - Enum constant in enum class com.logicalclocks.hsfs.DataFormat
CSV - Enum constant in enum class com.logicalclocks.hsfs.ExternalDataFormat

D

database - Variable in class com.logicalclocks.hsfs.StorageConnector.GlueConnector
database - Variable in class com.logicalclocks.hsfs.StorageConnector.MongoDbConnector
database - Variable in class com.logicalclocks.hsfs.StorageConnector.SapHanaConnector
database - Variable in class com.logicalclocks.hsfs.StorageConnector.SnowflakeConnector
database - Variable in class com.logicalclocks.hsfs.StorageConnector.SqlConnector
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
databaseType - Variable in class com.logicalclocks.hsfs.StorageConnector.SqlConnector
databaseUserName - Variable in class com.logicalclocks.hsfs.StorageConnector.RedshiftConnector
dataFormat - Variable in class com.logicalclocks.hsfs.TrainingDatasetBase
DataFormat - Enum Class in com.logicalclocks.hsfs
dataset - Variable in class com.logicalclocks.hsfs.StorageConnector.BigqueryConnector
DatasetApi - Class in com.logicalclocks.hsfs.metadata
DatasetApi() - Constructor for class com.logicalclocks.hsfs.metadata.DatasetApi
datasetName - Variable in class com.logicalclocks.hsfs.StorageConnector.HopsFsConnector
dataSource - Variable in class com.logicalclocks.hsfs.FeatureGroupBase
dataSource - Variable in class com.logicalclocks.hsfs.TrainingDatasetBase
DataSource - Class in com.logicalclocks.hsfs
DataSource() - Constructor for class com.logicalclocks.hsfs.DataSource
DATE - Enum constant in enum class com.logicalclocks.hsfs.FeatureType
DEFAULT_HIVE_PARTITION_EXTRACTOR_CLASS_OPT_VAL - Static variable in class com.logicalclocks.hsfs.spark.engine.hudi.HudiEngine
DEFAULT_PORT - Static variable in class com.logicalclocks.hsfs.StorageConnector.SapHanaConnector
DEFAULT_VERSION - Static variable in class com.logicalclocks.hsfs.FeatureStoreBase
delete() - Method in class com.logicalclocks.hsfs.FeatureGroupBase
delete() - Method in class com.logicalclocks.hsfs.FeatureViewBase: Delete current feature view, all associated metadata and training data.
delete() - Method in class com.logicalclocks.hsfs.TrainingDatasetBase: Delete training dataset and all associated metadata.
delete(FeatureGroupBase) - Method in class com.logicalclocks.hsfs.engine.FeatureGroupEngineBase
delete(FeatureGroupBase) - Method in class com.logicalclocks.hsfs.metadata.FeatureGroupApi
delete(FeatureStoreBase, String, Boolean) - Method in class com.logicalclocks.hsfs.metadata.FeatureViewApi
delete(FeatureStoreBase, String, Integer, Boolean) - Method in class com.logicalclocks.hsfs.metadata.FeatureViewApi
delete(TrainingDatasetBase) - Method in class com.logicalclocks.hsfs.metadata.TrainingDatasetApi
delete(Boolean) - Method in class com.logicalclocks.hsfs.FeatureViewBase: Delete current feature view, all associated metadata and training data.
delete(T3, String) - Method in class com.logicalclocks.hsfs.engine.FeatureViewEngineBase
delete(T3, String, Boolean) - Method in class com.logicalclocks.hsfs.engine.FeatureViewEngineBase
delete(T3, String, Integer) - Method in class com.logicalclocks.hsfs.engine.FeatureViewEngineBase
delete(T3, String, Integer, Boolean) - Method in class com.logicalclocks.hsfs.engine.FeatureViewEngineBase
DELETE - Enum constant in enum class com.logicalclocks.hsfs.HudiOperationType
deleteAllTrainingDatasets() - Method in class com.logicalclocks.hsfs.spark.FeatureView: Delete all training datasets.
deleteContent(FeatureGroupBase) - Method in class com.logicalclocks.hsfs.metadata.FeatureGroupApi
deleteOnlineDataframe(FeatureGroupBase, Dataset<Row>, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.engine.SparkEngine: Produces an online delete tombstone for every row in the dataset.
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(FeatureGroupBase, String) - Method in class com.logicalclocks.hsfs.metadata.TagsApi
deleteTag(FeatureViewBase, Integer, String) - Method in class com.logicalclocks.hsfs.metadata.TagsApi
deleteTag(FeatureViewBase, String) - Method in class com.logicalclocks.hsfs.engine.FeatureViewEngineBase
deleteTag(FeatureViewBase, String) - Method in class com.logicalclocks.hsfs.metadata.TagsApi
deleteTag(FeatureViewBase, String, Integer) - Method in class com.logicalclocks.hsfs.engine.FeatureViewEngineBase
deleteTag(TrainingDatasetBase, String) - Method in class com.logicalclocks.hsfs.metadata.TagsApi
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.TrainingDatasetBase: Delete a tag of the training dataset.
deleteTrainingData(FeatureStoreBase, String, Integer) - Method in class com.logicalclocks.hsfs.metadata.FeatureViewApi
deleteTrainingData(FeatureStoreBase, String, Integer, Integer) - Method in class com.logicalclocks.hsfs.metadata.FeatureViewApi
deleteTrainingData(T2) - Method in class com.logicalclocks.hsfs.engine.FeatureViewEngineBase
deleteTrainingData(T2, Integer) - Method in class com.logicalclocks.hsfs.engine.FeatureViewEngineBase
deleteTrainingDataset(Integer) - Method in class com.logicalclocks.hsfs.spark.FeatureView: Delete a training dataset.
deleteTrainingDatasetOnly(FeatureStoreBase, String, Integer) - Method in class com.logicalclocks.hsfs.metadata.FeatureViewApi
deleteTrainingDatasetOnly(FeatureStoreBase, String, Integer, Integer) - Method in class com.logicalclocks.hsfs.metadata.FeatureViewApi
deleteTrainingDatasetOnly(T2) - Method in class com.logicalclocks.hsfs.engine.FeatureViewEngineBase
deleteTrainingDatasetOnly(T2, Integer) - Method in class com.logicalclocks.hsfs.engine.FeatureViewEngineBase
deleteTrainingDatasetTag(Integer, String) - Method in class com.logicalclocks.hsfs.FeatureViewBase: Delete a tag of the training dataset.
DELIMITER - Static variable in class com.logicalclocks.hsfs.util.Constants
DELTA - Enum constant in enum class com.logicalclocks.hsfs.ExternalDataFormat
DELTA - Enum constant in enum class com.logicalclocks.hsfs.TimeTravelFormat
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 - Variable in class com.logicalclocks.hsfs.FeatureGroupBase
DeltaStreamerJobConf - Class in com.logicalclocks.hsfs
DeltaStreamerJobConf() - Constructor for class com.logicalclocks.hsfs.DeltaStreamerJobConf
DeltaStreamerKafkaSource - Class in com.logicalclocks.hsfs.spark.engine.hudi
DeltaStreamerKafkaSource(TypedProperties, JavaSparkContext, SparkSession, HoodieIngestionMetrics, StreamContext) - Constructor for class com.logicalclocks.hsfs.spark.engine.hudi.DeltaStreamerKafkaSource
DeltaStreamerKafkaSource(TypedProperties, JavaSparkContext, SparkSession, SchemaProvider, HoodieIngestionMetrics) - 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
deprecated - Variable in class com.logicalclocks.hsfs.FeatureGroupBase
description - Variable in class com.logicalclocks.hsfs.FeatureGroupBase
description - Variable in class com.logicalclocks.hsfs.FeatureViewBase
description - Variable in class com.logicalclocks.hsfs.StorageConnector
description - Variable in class com.logicalclocks.hsfs.TrainingDatasetBase
description(String) - Method in class com.logicalclocks.hsfs.beam.FeatureView.FeatureViewBuilder
description(String) - Method in class com.logicalclocks.hsfs.FeatureView.FeatureViewBuilder
description(String) - Method in class com.logicalclocks.hsfs.flink.FeatureView.FeatureViewBuilder
description(String) - Method in class com.logicalclocks.hsfs.spark.FeatureView.FeatureViewBuilder
deserialize(String, byte[]) - Method in class com.logicalclocks.hsfs.spark.engine.hudi.DeltaStreamerAvroDeserializer
deserialize(String, Headers, byte[]) - Method in class com.logicalclocks.hsfs.spark.engine.hudi.DeltaStreamerAvroDeserializer
directoryId - Variable in class com.logicalclocks.hsfs.StorageConnector.AdlsConnector
DRIVER - Static variable in class com.logicalclocks.hsfs.StorageConnector.SapHanaConnector

E

EMPTY - Enum constant in enum class com.logicalclocks.hsfs.SslEndpointIdentificationAlgorithm
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
Engine<T> - Class in com.logicalclocks.hsfs.engine
EngineBase - Class in com.logicalclocks.hsfs.engine
EngineBase() - Constructor for class com.logicalclocks.hsfs.engine.EngineBase
ENTITY_ID_PATH - Static variable in class com.logicalclocks.hsfs.metadata.TagsApi
ENTITY_ROOT_PATH - Static variable in class com.logicalclocks.hsfs.metadata.TagsApi
EntityEndpointType - Enum Class in com.logicalclocks.hsfs
eq(Feature) - Method in class com.logicalclocks.hsfs.Feature
eq(Object) - Method in class com.logicalclocks.hsfs.Feature
EQUALS - Enum constant in enum class com.logicalclocks.hsfs.constructor.SqlFilterCondition
eventEndTime - Variable in class com.logicalclocks.hsfs.TrainingDatasetBase
eventStartTime - Variable in class com.logicalclocks.hsfs.TrainingDatasetBase
eventTime - Variable in class com.logicalclocks.hsfs.FeatureGroupBase
expand(PCollection<Row>) - Method in class com.logicalclocks.hsfs.beam.engine.BeamProducer
expectationsNames - Variable in class com.logicalclocks.hsfs.FeatureGroupBase
expiration - Variable in class com.logicalclocks.hsfs.StorageConnector.RedshiftConnector
EXTERNAL_TRAINING_DATASET - Enum constant in enum class com.logicalclocks.hsfs.TrainingDatasetType
ExternalDataFormat - Enum Class in com.logicalclocks.hsfs
ExternalFeatureGroup - Class in com.logicalclocks.hsfs.spark
ExternalFeatureGroup() - Constructor for class com.logicalclocks.hsfs.spark.ExternalFeatureGroup
ExternalFeatureGroup(FeatureStore, int) - Constructor for class com.logicalclocks.hsfs.spark.ExternalFeatureGroup
ExternalFeatureGroup(FeatureStore, String, Integer, String, ExternalDataFormat, String, Map<String, String>, StorageConnector, String, List<String>, List<Feature>, StatisticsConfig, String, boolean, String, String, String, OnlineConfig) - Constructor for class com.logicalclocks.hsfs.spark.ExternalFeatureGroup
ExternalFeatureGroup.ExternalFeatureGroupBuilder - Class in com.logicalclocks.hsfs.spark
externalKafka - Variable in class com.logicalclocks.hsfs.StorageConnector.KafkaConnector
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, int) - Constructor for class com.logicalclocks.hsfs.Feature
Feature(String, FeatureGroupBase) - 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 - Enum constant in enum class com.logicalclocks.hsfs.EntityEndpointType
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 - 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_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
FEATURE_VIEW - Enum constant in enum class com.logicalclocks.hsfs.EntityEndpointType
FeatureDescriptiveStatistics - Class in com.logicalclocks.hsfs.metadata
FeatureDescriptiveStatistics() - Constructor for class com.logicalclocks.hsfs.metadata.FeatureDescriptiveStatistics
FeatureGroup - Class in com.logicalclocks.hsfs.spark
FeatureGroup() - Constructor for class com.logicalclocks.hsfs.spark.FeatureGroup
FeatureGroup(FeatureStore, int) - Constructor for class com.logicalclocks.hsfs.spark.FeatureGroup
FeatureGroup(FeatureStore, String, Integer, String, List<String>, List<String>, String, boolean, TimeTravelFormat, List<Feature>, StatisticsConfig, String, String, String, String, OnlineConfig, StorageConnector, String) - 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.FeatureGroupBuilder - Class in com.logicalclocks.hsfs.spark
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
featureGroupCommit(FeatureGroupBase, FeatureGroupCommit) - Method in class com.logicalclocks.hsfs.metadata.FeatureGroupApi
FeatureGroupCommit - Class in com.logicalclocks.hsfs
FeatureGroupCommit() - Constructor for class com.logicalclocks.hsfs.FeatureGroupCommit
featureGroupEngine - Variable in class com.logicalclocks.hsfs.beam.StreamFeatureGroup
featureGroupEngine - Variable in class com.logicalclocks.hsfs.flink.StreamFeatureGroup
featureGroupEngine - Variable in class com.logicalclocks.hsfs.spark.FeatureGroup
featureGroupEngine - Variable in class com.logicalclocks.hsfs.spark.StreamFeatureGroup
featureGroupEngine - Variable in class com.logicalclocks.hsfs.StreamFeatureGroup
FeatureGroupEngine - Class in com.logicalclocks.hsfs.beam.engine
FeatureGroupEngine<T> - Class in com.logicalclocks.hsfs.engine
FeatureGroupEngine - Class in com.logicalclocks.hsfs.flink.engine
FeatureGroupEngine - Class in com.logicalclocks.hsfs.spark.engine
FeatureGroupEngine() - Constructor for class com.logicalclocks.hsfs.beam.engine.FeatureGroupEngine
FeatureGroupEngine() - Constructor for class com.logicalclocks.hsfs.engine.FeatureGroupEngine
FeatureGroupEngine() - Constructor for class com.logicalclocks.hsfs.flink.engine.FeatureGroupEngine
FeatureGroupEngine() - Constructor for class com.logicalclocks.hsfs.spark.engine.FeatureGroupEngine
featureGroupEngineBase - Variable in class com.logicalclocks.hsfs.FeatureGroupBase
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
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 - Variable in class com.logicalclocks.hsfs.TrainingDatasetBase
FeatureStore - Class in com.logicalclocks.hsfs.beam
FeatureStore - Class in com.logicalclocks.hsfs
FeatureStore - Class in com.logicalclocks.hsfs.flink
FeatureStore - Class in com.logicalclocks.hsfs.spark
FeatureStore() - Constructor for class com.logicalclocks.hsfs.beam.FeatureStore
FeatureStore() - Constructor for class com.logicalclocks.hsfs.FeatureStore
FeatureStore() - Constructor for class com.logicalclocks.hsfs.flink.FeatureStore
FeatureStore() - Constructor for class com.logicalclocks.hsfs.spark.FeatureStore
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.FeatureGroupBase
featurestoreId - Variable in class com.logicalclocks.hsfs.StorageConnector
featureStoreTopic - Variable in class com.logicalclocks.hsfs.Project
FeatureType - Enum Class in com.logicalclocks.hsfs
FeatureView - Class in com.logicalclocks.hsfs.beam
FeatureView - Class in com.logicalclocks.hsfs
FeatureView - Class in com.logicalclocks.hsfs.flink
FeatureView - Class in com.logicalclocks.hsfs.spark
FeatureView(String, Integer, Query, String, FeatureStore, List<String>) - Constructor for class com.logicalclocks.hsfs.beam.FeatureView
FeatureView(String, Integer, Query, String, FeatureStore, List<String>) - Constructor for class com.logicalclocks.hsfs.FeatureView
FeatureView(String, Integer, Query, String, FeatureStore, List<String>) - Constructor for class com.logicalclocks.hsfs.flink.FeatureView
FeatureView(String, Integer, Query, String, FeatureStore, List<String>) - Constructor for class com.logicalclocks.hsfs.spark.FeatureView
FeatureView.FeatureViewBuilder - Class in com.logicalclocks.hsfs.beam
FeatureView.FeatureViewBuilder - Class in com.logicalclocks.hsfs
FeatureView.FeatureViewBuilder - Class in com.logicalclocks.hsfs.flink
FeatureView.FeatureViewBuilder - Class in com.logicalclocks.hsfs.spark
featureViewApi - Variable in class com.logicalclocks.hsfs.engine.FeatureViewEngineBase
featureViewApi - Variable in class com.logicalclocks.hsfs.FeatureViewBase
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.beam.FeatureView.FeatureViewBuilder
FeatureViewBuilder(FeatureStore) - Constructor for class com.logicalclocks.hsfs.FeatureView.FeatureViewBuilder
FeatureViewBuilder(FeatureStore) - Constructor for class com.logicalclocks.hsfs.flink.FeatureView.FeatureViewBuilder
FeatureViewBuilder(FeatureStore) - Constructor for class com.logicalclocks.hsfs.spark.FeatureView.FeatureViewBuilder
FeatureViewEngine - Class in com.logicalclocks.hsfs.beam.engine
FeatureViewEngine - Class in com.logicalclocks.hsfs.engine
FeatureViewEngine - Class in com.logicalclocks.hsfs.flink.engine
FeatureViewEngine - Class in com.logicalclocks.hsfs.spark.engine
FeatureViewEngine() - Constructor for class com.logicalclocks.hsfs.beam.engine.FeatureViewEngine
FeatureViewEngine() - Constructor for class com.logicalclocks.hsfs.engine.FeatureViewEngine
FeatureViewEngine() - Constructor for class com.logicalclocks.hsfs.flink.engine.FeatureViewEngine
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
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
Filter - Class in com.logicalclocks.hsfs.constructor
Filter() - Constructor for class com.logicalclocks.hsfs.constructor.Filter
FilterLogic - Class in com.logicalclocks.hsfs.constructor
FilterLogic(Filter) - 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
FilterLogic(SqlFilterLogic, Filter, Filter) - Constructor for class com.logicalclocks.hsfs.constructor.FilterLogic
FilterLogic(SqlFilterLogic, Filter, FilterLogic) - Constructor for class com.logicalclocks.hsfs.constructor.FilterLogic
FlinkEngine - Class in com.logicalclocks.hsfs.flink.engine
fromDeequStatisticsJson(JSONObject) - Static method in class com.logicalclocks.hsfs.metadata.FeatureDescriptiveStatistics
fromString(String) - Static method in enum class 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
FULL - Enum constant in enum class com.logicalclocks.hsfs.constructor.JoinType
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

GCS - Enum constant in enum class com.logicalclocks.hsfs.StorageConnectorType
GcsConnector() - Constructor for class com.logicalclocks.hsfs.StorageConnector.GcsConnector
ge(Feature) - Method in class com.logicalclocks.hsfs.Feature
ge(Object) - Method in class com.logicalclocks.hsfs.Feature
generation - Variable in class com.logicalclocks.hsfs.StorageConnector.AdlsConnector
GenericAvroSerializer - Class in com.logicalclocks.hsfs.beam.engine
GenericAvroSerializer() - Constructor for class com.logicalclocks.hsfs.beam.engine.GenericAvroSerializer
get(FeatureStore, String, Integer) - Method in class com.logicalclocks.hsfs.beam.engine.FeatureViewEngine
get(FeatureGroupBase) - Method in class com.logicalclocks.hsfs.metadata.TagsApi
get(FeatureGroupBase, String) - Method in class com.logicalclocks.hsfs.metadata.StatisticsApi
get(FeatureGroupBase, String) - Method in class com.logicalclocks.hsfs.metadata.TagsApi
get(FeatureGroupBase, String) - Method in class com.logicalclocks.hsfs.spark.engine.StatisticsEngine
get(FeatureStoreBase, String) - Method in class com.logicalclocks.hsfs.metadata.FeatureViewApi
get(FeatureStoreBase, String, Integer) - Method in class com.logicalclocks.hsfs.metadata.TrainingDatasetApi
get(FeatureStoreBase, String, Integer, Class<T>) - Method in class com.logicalclocks.hsfs.metadata.FeatureViewApi
get(FeatureStore, String, Integer) - Method in class com.logicalclocks.hsfs.engine.FeatureViewEngine
get(FeatureViewBase) - Method in class com.logicalclocks.hsfs.metadata.TagsApi
get(FeatureViewBase, Integer) - Method in class com.logicalclocks.hsfs.metadata.TagsApi
get(FeatureViewBase, Integer, String) - Method in class com.logicalclocks.hsfs.metadata.TagsApi
get(FeatureViewBase, String) - Method in class com.logicalclocks.hsfs.metadata.TagsApi
get(FeatureStore, String, Integer) - Method in class com.logicalclocks.hsfs.flink.engine.FeatureViewEngine
get(FeatureStore, String, Integer) - Method in class com.logicalclocks.hsfs.spark.engine.FeatureViewEngine
get(TrainingDataset, String) - Method in class com.logicalclocks.hsfs.spark.engine.StatisticsEngine
get(TrainingDatasetBase) - Method in class com.logicalclocks.hsfs.metadata.TagsApi
get(TrainingDatasetBase, String) - Method in class com.logicalclocks.hsfs.metadata.StatisticsApi
get(TrainingDatasetBase, String) - Method in class com.logicalclocks.hsfs.metadata.TagsApi
get(Integer, String, Class<U>) - Method in class com.logicalclocks.hsfs.metadata.StorageConnectorApi
get(String) - Method in class com.logicalclocks.hsfs.metadata.ProjectApi
get(String) - Method in class com.logicalclocks.hsfs.metadata.VariablesApi
get(String, Class<T>) - Method in class com.logicalclocks.hsfs.metadata.FeatureStoreApi
get(T3, String) - Method in class com.logicalclocks.hsfs.engine.FeatureViewEngineBase
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
getAdlsConnector(String) - Method in class com.logicalclocks.hsfs.FeatureStoreBase: Get a previously created Adls compliant storage connector from the feature store.
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() - Method in class com.logicalclocks.hsfs.FeatureGroupBase
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(FeatureView, Date, Date, Map<String, String>, Integer) - Method in class com.logicalclocks.hsfs.spark.engine.FeatureViewEngine
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() - Method in class com.logicalclocks.hsfs.spark.FeatureView: Get a query string of the batch query.
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(String, String) - Method in class com.logicalclocks.hsfs.spark.FeatureView: Get a query string of the batch query.
getBatchQuery(T2, Date, Date, Boolean, Integer, Class<T1>) - Method in class com.logicalclocks.hsfs.engine.FeatureViewEngineBase
getBatchQueryString(FeatureView, Date, Date, Integer) - Method in class com.logicalclocks.hsfs.spark.engine.FeatureViewEngine
getBigqueryConnector(String) - Method in class com.logicalclocks.hsfs.FeatureStoreBase: Get a previously created BigQuery compliant storage connector from the feature store.
getBigqueryConnector(String) - Method in class com.logicalclocks.hsfs.spark.FeatureStore: Get a previously created BigQuery compliant storage connector from the feature store.
getByName(FeatureStoreBase, String, Class<T>) - Method in class com.logicalclocks.hsfs.metadata.StorageConnectorApi
getCertKey() - Method in interface com.logicalclocks.hsfs.metadata.HopsworksHttpClient
getCertKey() - Method in class com.logicalclocks.hsfs.spark.engine.SparkEngine
getCommitDetails(FeatureGroupBase, Long, Integer) - Method in class com.logicalclocks.hsfs.metadata.FeatureGroupApi
getCommitDetails(FeatureGroupBase, String, Integer) - Method in class com.logicalclocks.hsfs.engine.FeatureGroupUtils
getComplexFeatures() - Method in class com.logicalclocks.hsfs.FeatureGroupBase
getComplexFeatures(List<Feature>) - Method in class com.logicalclocks.hsfs.engine.FeatureGroupUtils
getComplexFeatureSchemas(List<TrainingDatasetFeature>, Map<Integer, String>) - Method in class com.logicalclocks.hsfs.engine.VectorServer
getCount() - Method in class com.logicalclocks.hsfs.metadata.RestDto
getCredentials() - 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
getDatasetType(String) - Method in class com.logicalclocks.hsfs.engine.FeatureGroupUtils
getDataSource(String) - Method in class com.logicalclocks.hsfs.FeatureStoreBase: Get a previously created data source from the feature store.
getDateFromDateString(String) - Static method in class com.logicalclocks.hsfs.engine.FeatureGroupUtils
getDeserializedAvroSchema() - Method in class com.logicalclocks.hsfs.FeatureGroupBase
getDeserializedAvroSchema(String) - Method in class com.logicalclocks.hsfs.engine.FeatureGroupUtils
getDeserializedEncodedAvroSchema() - Method in class com.logicalclocks.hsfs.FeatureGroupBase
getDeserializedEncodedAvroSchema(Schema, List<String>) - Method in class com.logicalclocks.hsfs.engine.FeatureGroupUtils
getEncodedAvroSchema() - Method in class com.logicalclocks.hsfs.FeatureGroupBase
getEncodedAvroSchema(Schema, List<String>) - Method in class com.logicalclocks.hsfs.engine.FeatureGroupUtils
getEndTime() - Method in class com.logicalclocks.hsfs.engine.FeatureViewEngineBase
getExternalFeatureGroup(String, Integer) - Method in class com.logicalclocks.hsfs.spark.FeatureStore: Get an external feature group object from the feature store.
getExternalFeatureGroup(FeatureStore, String, Integer) - Method in class com.logicalclocks.hsfs.spark.engine.FeatureGroupEngine
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.spark.FeatureStore: Get a list of all versions of an external feature group from the feature store.
getExternalFeatureGroups(FeatureStore, String) - Method in class com.logicalclocks.hsfs.spark.engine.FeatureGroupEngine
getFeature(String) - Method in class com.logicalclocks.hsfs.FeatureGroupBase: Retrieve a feature of the feature group by name.
getFeatureAvroSchema(String) - Method in class com.logicalclocks.hsfs.FeatureGroupBase
getFeatureAvroSchema(String, Schema) - Method in class com.logicalclocks.hsfs.engine.FeatureGroupUtils
getFeatureGroup(String, Integer) - Method in class com.logicalclocks.hsfs.spark.FeatureStore: Get a feature group object from the feature store.
getFeatureGroup(FeatureStore, String, Integer) - Method in class com.logicalclocks.hsfs.spark.engine.FeatureGroupEngine
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.spark.FeatureStore: Get a list of all versions of a feature group from the feature store.
getFeatureGroups(FeatureStore, String) - Method in class com.logicalclocks.hsfs.spark.engine.FeatureGroupEngine
getFeatureStore() - Method in class com.logicalclocks.hsfs.beam.HopsworksConnection: Retrieve the project feature store.
getFeatureStore() - Method in class com.logicalclocks.hsfs.flink.HopsworksConnection: Retrieve the project feature store.
getFeatureStore() - Method in class com.logicalclocks.hsfs.HopsworksConnection: Retrieve the project feature store.
getFeatureStore() - 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.beam.HopsworksConnection: Retrieve a feature store based on name.
getFeatureStore(String) - Method in class com.logicalclocks.hsfs.flink.HopsworksConnection: Retrieve a feature store based on name.
getFeatureStore(String) - Method in class com.logicalclocks.hsfs.HopsworksConnection: Retrieve a feature store based on name.
getFeatureStore(String) - Method in class com.logicalclocks.hsfs.HopsworksConnectionBase
getFeatureStore(String) - Method in class com.logicalclocks.hsfs.spark.HopsworksConnection: Retrieve a feature store based on name.
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.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.
getFeatureVectorObject(FeatureViewBase, Map<String, Object>, boolean, Class<T>) - Method in class com.logicalclocks.hsfs.engine.VectorServer
getFeatureVectorObject(Map<String, Object>, boolean, Class<T>) - Method in class com.logicalclocks.hsfs.FeatureViewBase: Returns assembled feature vector from online feature store (as Object).
getFeatureVectorObject(Map<String, Object>, Class<T>) - Method in class com.logicalclocks.hsfs.engine.VectorServer
getFeatureVectorObject(Map<String, Object>, Class<T>) - Method in class com.logicalclocks.hsfs.FeatureViewBase: Returns assembled feature vector from online feature store (as Object).
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.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, Integer) - Method in class com.logicalclocks.hsfs.beam.FeatureStore: Get a feature view object from the selected feature store.
getFeatureView(String, Integer) - Method in class com.logicalclocks.hsfs.FeatureStore: Get a feature view object from the selected feature store.
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, 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.beam.FeatureStore: Get a feature view object from the selected feature store.
getFeatureView(String) - Method in class com.logicalclocks.hsfs.FeatureStore: Get a feature view object from the selected feature store.
getFeatureView(String) - Method in class com.logicalclocks.hsfs.FeatureStoreBase
getFeatureView(String) - 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.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: Get a previously created Gcs compliant storage connector from the feature store.
getGcsConnector(String) - Method in class com.logicalclocks.hsfs.spark.FeatureStore: Get a previously created Gcs compliant storage connector from the feature store.
getHeaders(FeatureGroupBase, Long) - Static method in class com.logicalclocks.hsfs.engine.FeatureGroupUtils
getHeaders(FeatureGroupBase, Long, Map<String, String>) - Static method in class com.logicalclocks.hsfs.engine.FeatureGroupUtils
getHeaders(FeatureGroupBase, Long, Map<String, String>, String) - Static method in class com.logicalclocks.hsfs.engine.FeatureGroupUtils
getHeaders(FeatureGroupBase, Long, Map<String, String>, String, Storage) - Static method in class com.logicalclocks.hsfs.engine.FeatureGroupUtils: Kafka headers for the records of one write to the online topic.
getHiveServerConnection(FeatureGroupBase, String) - Method in class com.logicalclocks.hsfs.engine.FeatureGroupUtils
getHopsFsConnector(String) - Method in class com.logicalclocks.hsfs.FeatureStoreBase: Get a previously created HopsFs compliant storage connector from the feature store.
getHopsFsConnector(String) - Method in class com.logicalclocks.hsfs.spark.FeatureStore: Get a previously created HopsFs compliant storage connector from the feature store.
getHudiTableSize(JavaSparkContext, String) - Method in class com.logicalclocks.hsfs.spark.engine.hudi.HudiEngine
getInstance() - Static method in class com.logicalclocks.hsfs.beam.engine.BeamEngine
getInstance() - Static method in class com.logicalclocks.hsfs.engine.Engine
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.hudi.HudiEngine
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: Get a previously created JDBC compliant storage connector from the feature store.
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.beam.engine.BeamEngine
getKafkaConfig(FeatureGroupBase, Map<String, String>) - Method in class com.logicalclocks.hsfs.engine.Engine
getKafkaConfig(FeatureGroupBase, Map<String, String>) - Method in class com.logicalclocks.hsfs.engine.EngineBase
getKafkaConfig(FeatureGroupBase, Map<String, String>) - Method in class com.logicalclocks.hsfs.flink.engine.FlinkEngine
getKafkaConfig(FeatureGroupBase, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.engine.SparkEngine
getKafkaConnector(String) - Method in class com.logicalclocks.hsfs.FeatureStoreBase: Get a previously created Kafka compliant storage connector from the feature store.
getKafkaConnector(String) - Method in class com.logicalclocks.hsfs.spark.FeatureStore: Get a previously created Kafka compliant storage connector from the feature store.
getKafkaStorageConnector(FeatureStoreBase, boolean) - Method in class com.logicalclocks.hsfs.metadata.StorageConnectorApi
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(FeatureGroupBase) - Method in class com.logicalclocks.hsfs.spark.engine.StatisticsEngine
getLast(TrainingDataset) - Method in class com.logicalclocks.hsfs.spark.engine.StatisticsEngine
getLast(TrainingDatasetBase) - Method in class com.logicalclocks.hsfs.metadata.StatisticsApi
getLatestOnlineIngestion() - Method in class com.logicalclocks.hsfs.FeatureGroupBase
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.
getOnlineIngestion(FeatureGroupBase, String) - Method in class com.logicalclocks.hsfs.metadata.OnlineIngestionApi
getOnlineIngestion(Integer) - Method in class com.logicalclocks.hsfs.FeatureGroupBase
getOnlineStorageConnector() - Method in class com.logicalclocks.hsfs.FeatureStoreBase: Get a previously created JDBC compliant storage connector from the feature store to connect to the online feature store.
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.
getOnlineStorageConnector(FeatureStoreBase, Class<T>) - Method in class com.logicalclocks.hsfs.metadata.StorageConnectorApi
getOrCreateFeatureGroup(FeatureStore, String, Integer, String, Boolean, TimeTravelFormat, List<String>, List<String>, String, String, List<Feature>, StatisticsConfig, DataSource, OnlineConfig) - Method in class com.logicalclocks.hsfs.beam.engine.FeatureGroupEngine
getOrCreateFeatureGroup(FeatureStore, String, Integer, String, Boolean, TimeTravelFormat, List<String>, List<String>, String, String, List<Feature>, StatisticsConfig, StorageConnector, String, OnlineConfig) - Method in class com.logicalclocks.hsfs.beam.engine.FeatureGroupEngine
getOrCreateFeatureGroup(FeatureStore, String, Integer, String, Boolean, TimeTravelFormat, List<String>, List<String>, String, String, List<Feature>, StatisticsConfig, DataSource, OnlineConfig) - Method in class com.logicalclocks.hsfs.engine.FeatureGroupEngine
getOrCreateFeatureGroup(FeatureStore, String, Integer, String, Boolean, TimeTravelFormat, List<String>, List<String>, String, String, List<Feature>, StatisticsConfig, StorageConnector, String, OnlineConfig) - Method in class com.logicalclocks.hsfs.engine.FeatureGroupEngine
getOrCreateFeatureGroup(FeatureStore, String, Integer, String, Boolean, TimeTravelFormat, List<String>, List<String>, String, String, List<Feature>, StatisticsConfig, DataSource, OnlineConfig) - Method in class com.logicalclocks.hsfs.flink.engine.FeatureGroupEngine
getOrCreateFeatureGroup(FeatureStore, String, Integer, String, Boolean, TimeTravelFormat, List<String>, List<String>, String, String, List<Feature>, StatisticsConfig, StorageConnector, String, OnlineConfig) - Method in class com.logicalclocks.hsfs.flink.engine.FeatureGroupEngine
getOrCreateFeatureGroup(FeatureStore, String, Integer, String, List<String>, List<String>, String, boolean, TimeTravelFormat, StatisticsConfig, String, String, String, OnlineConfig) - 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, String, List<String>, List<String>, String, boolean, TimeTravelFormat, StatisticsConfig, String, String, String, OnlineConfig) - 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.
getOrCreateFeatureView(FeatureStore, String, Integer, Query, String, List<String>) - Method in class com.logicalclocks.hsfs.beam.engine.FeatureViewEngine
getOrCreateFeatureView(FeatureStore, String, Integer, Query, String, List<String>) - Method in class com.logicalclocks.hsfs.engine.FeatureViewEngine
getOrCreateFeatureView(FeatureStore, String, Integer, Query, String, List<String>) - Method in class com.logicalclocks.hsfs.flink.engine.FeatureViewEngine
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.beam.FeatureStore: Get feature view metadata object or create a new one if it doesn't exist.
getOrCreateFeatureView(String, Query, Integer) - Method in class com.logicalclocks.hsfs.FeatureStore: Get feature view metadata object or create a new one if it doesn't exist.
getOrCreateFeatureView(String, Query, Integer) - Method in class com.logicalclocks.hsfs.flink.FeatureStore: Get feature view metadata object or create a new one if it doesn't exist.
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, String, Boolean, TimeTravelFormat, List<String>, List<String>, String, String, List<Feature>, StatisticsConfig, DataSource, OnlineConfig) - Method in class com.logicalclocks.hsfs.beam.FeatureStore
getOrCreateStreamFeatureGroup(String, Integer, String, Boolean, TimeTravelFormat, List<String>, List<String>, String, String, List<Feature>, StatisticsConfig, DataSource, OnlineConfig) - Method in class com.logicalclocks.hsfs.FeatureStore
getOrCreateStreamFeatureGroup(String, Integer, String, Boolean, TimeTravelFormat, List<String>, List<String>, String, String, List<Feature>, StatisticsConfig, DataSource, OnlineConfig) - Method in class com.logicalclocks.hsfs.FeatureStoreBase: Get a stream feature group metadata object or create a new one if it doesn't exist.
getOrCreateStreamFeatureGroup(String, Integer, String, Boolean, TimeTravelFormat, List<String>, List<String>, String, String, List<Feature>, StatisticsConfig, DataSource, OnlineConfig) - Method in class com.logicalclocks.hsfs.flink.FeatureStore
getOrCreateStreamFeatureGroup(String, Integer, String, Boolean, TimeTravelFormat, List<String>, List<String>, String, String, List<Feature>, StatisticsConfig, DataSource, OnlineConfig) - Method in class com.logicalclocks.hsfs.spark.FeatureStore
getOrCreateStreamFeatureGroup(String, Integer, String, Boolean, TimeTravelFormat, List<String>, List<String>, String, String, List<Feature>, StatisticsConfig, StorageConnector, String, OnlineConfig) - Method in class com.logicalclocks.hsfs.beam.FeatureStore
getOrCreateStreamFeatureGroup(String, Integer, String, Boolean, TimeTravelFormat, List<String>, List<String>, String, String, List<Feature>, StatisticsConfig, StorageConnector, String, OnlineConfig) - Method in class com.logicalclocks.hsfs.FeatureStore
getOrCreateStreamFeatureGroup(String, Integer, String, Boolean, TimeTravelFormat, List<String>, List<String>, String, String, List<Feature>, StatisticsConfig, StorageConnector, String, OnlineConfig) - Method in class com.logicalclocks.hsfs.FeatureStoreBase: Deprecated.
Use FeatureStoreBase.getOrCreateStreamFeatureGroup(String, Integer, String, Boolean, TimeTravelFormat, List, List, String, String, List, StatisticsConfig, DataSource, OnlineConfig) instead.
getOrCreateStreamFeatureGroup(String, Integer, String, Boolean, TimeTravelFormat, List<String>, List<String>, String, String, List<Feature>, StatisticsConfig, StorageConnector, String, OnlineConfig) - Method in class com.logicalclocks.hsfs.flink.FeatureStore
getOrCreateStreamFeatureGroup(String, Integer, String, Boolean, TimeTravelFormat, List<String>, List<String>, String, String, List<Feature>, StatisticsConfig, StorageConnector, String, OnlineConfig) - 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(FeatureStore, String, Integer, String, List<String>, List<String>, String, boolean, StatisticsConfig, String, TimeTravelFormat, List<Feature>, DataSource, OnlineConfig) - Method in class com.logicalclocks.hsfs.spark.engine.FeatureGroupEngine
getOrCreateStreamFeatureGroup(FeatureStore, String, Integer, String, List<String>, List<String>, String, boolean, StatisticsConfig, String, TimeTravelFormat, List<Feature>, StorageConnector, String, OnlineConfig) - 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, String, List<String>, List<String>, String, boolean, StatisticsConfig, String, TimeTravelFormat) - 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.
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.GlueConnector
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.MongoDbConnector
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.SapHanaConnector
getPath(String) - Method in class com.logicalclocks.hsfs.StorageConnector.SnowflakeConnector
getPath(String) - Method in class com.logicalclocks.hsfs.StorageConnector.SqlConnector
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.
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
getReadOptions(Map<String, String>, DataFormat) - Method in class com.logicalclocks.hsfs.spark.engine.SparkEngine
getRedshiftConnector(String) - Method in class com.logicalclocks.hsfs.FeatureStoreBase: Get a previously created Redshift compliant storage connector from the feature store.
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: Get a previously created S3 compliant storage connector from the feature store.
getS3Connector(String) - Method in class com.logicalclocks.hsfs.spark.FeatureStore: Get a previously created S3 compliant storage connector from the feature store.
getServingPreparedStatement(FeatureViewBase, boolean) - Method in class com.logicalclocks.hsfs.metadata.FeatureViewApi
getServingPreparedStatement(TrainingDatasetBase, boolean) - Method in class com.logicalclocks.hsfs.metadata.TrainingDatasetApi
getSnowflakeConnector(String) - Method in class com.logicalclocks.hsfs.FeatureStoreBase: Get a previously created Snowflake compliant storage connector from the feature store.
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
getSqlConnector(String) - Method in class com.logicalclocks.hsfs.beam.FeatureStore
getSqlConnector(String) - Method in class com.logicalclocks.hsfs.FeatureStore
getSqlConnector(String) - Method in class com.logicalclocks.hsfs.FeatureStoreBase
getSqlConnector(String) - Method in class com.logicalclocks.hsfs.flink.FeatureStore
getSqlConnector(String) - Method in class com.logicalclocks.hsfs.spark.FeatureStore: Get a previously created SQL storage connector from the feature store.
getStartTime() - Method in class com.logicalclocks.hsfs.engine.FeatureViewEngineBase
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.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 previously created storage connector from the feature store.
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.beam.FeatureStore: Get a stream feature group object from the feature store.
getStreamFeatureGroup(String, Integer) - Method in class com.logicalclocks.hsfs.FeatureStore: Get a stream feature group object from the feature store.
getStreamFeatureGroup(String, Integer) - Method in class com.logicalclocks.hsfs.FeatureStoreBase: Get a 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(String, Integer) - Method in class com.logicalclocks.hsfs.spark.FeatureStore: Get a stream feature group object from the feature store.
getStreamFeatureGroup(FeatureStore, String, Integer) - Method in class com.logicalclocks.hsfs.beam.engine.FeatureGroupEngine
getStreamFeatureGroup(FeatureStore, String, Integer) - Method in class com.logicalclocks.hsfs.engine.FeatureGroupEngine
getStreamFeatureGroup(FeatureStore, String, Integer) - Method in class com.logicalclocks.hsfs.flink.engine.FeatureGroupEngine
getStreamFeatureGroup(FeatureStore, String, Integer) - Method in class com.logicalclocks.hsfs.spark.engine.FeatureGroupEngine
getStreamFeatureGroup(String) - Method in class com.logicalclocks.hsfs.beam.FeatureStore: Get a stream feature group object from the feature store.
getStreamFeatureGroup(String) - Method in class com.logicalclocks.hsfs.FeatureStore: Get a stream 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(String) - Method in class com.logicalclocks.hsfs.flink.FeatureStore: Get a stream feature group object from the feature store.
getStreamFeatureGroup(String) - Method in class com.logicalclocks.hsfs.spark.FeatureStore: Get a stream feature group object with default version `1` from the feature store.
getStreamFeatureGroups(FeatureStore, String) - Method in class com.logicalclocks.hsfs.beam.engine.FeatureGroupEngine
getStreamFeatureGroups(FeatureStore, String) - Method in class com.logicalclocks.hsfs.engine.FeatureGroupEngine
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() - Method in class com.logicalclocks.hsfs.FeatureGroupBase
getSubject(FeatureGroupBase) - Method in class com.logicalclocks.hsfs.engine.FeatureGroupUtils
getSubject(FeatureStoreBase, String) - Method in class com.logicalclocks.hsfs.metadata.KafkaApi
getSubject(Integer, String) - Method in class com.logicalclocks.hsfs.metadata.KafkaApi
getSubject(Integer, String, String) - Method in class com.logicalclocks.hsfs.metadata.KafkaApi
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.TrainingDatasetBase: Get a single tag value of the training dataset.
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.TrainingDatasetBase: Get all tags 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
getTimeStampFromDateString(String) - Static method in class com.logicalclocks.hsfs.engine.FeatureGroupUtils
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.spark.FeatureStore: Deprecated.
getTrainingDataset(FeatureStoreBase, String, Integer) - Method in class com.logicalclocks.hsfs.metadata.TrainingDatasetApi
getTrainingDataset(FeatureView, TrainingDataset, 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, Integer, List<String>, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.engine.FeatureViewEngine
getTrainingDataset(String) - Method in class com.logicalclocks.hsfs.spark.FeatureStore: Deprecated.
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.
getTrainingDatasetTags(Integer) - Method in class com.logicalclocks.hsfs.FeatureViewBase: Get all tags of the training dataset.
getTrainingDatasetType(DataSource) - Method in class com.logicalclocks.hsfs.TrainingDatasetBase
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) - 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 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 class com.logicalclocks.hsfs.EntityEndpointType
getValue() - Method in enum class com.logicalclocks.hsfs.HudiOperationType
getValue() - Method in enum class com.logicalclocks.hsfs.SslEndpointIdentificationAlgorithm
getWriteOptions(Map<String, String>, DataFormat) - Method in class com.logicalclocks.hsfs.spark.engine.SparkEngine
GLUE - Enum constant in enum class com.logicalclocks.hsfs.StorageConnectorType
GlueConnector() - Constructor for class com.logicalclocks.hsfs.StorageConnector.GlueConnector
GREATER_THAN - Enum constant in enum class com.logicalclocks.hsfs.constructor.SqlFilterCondition
GREATER_THAN_OR_EQUAL - Enum constant in enum class com.logicalclocks.hsfs.constructor.SqlFilterCondition
gt(Feature) - Method in class com.logicalclocks.hsfs.Feature
gt(Object) - Method in class com.logicalclocks.hsfs.Feature

H

handleRequest(HttpRequest) - Method in class com.logicalclocks.hsfs.metadata.HopsworksClient
handleRequest(HttpRequest, Class<T>) - Method in class com.logicalclocks.hsfs.metadata.HopsworksClient
handleRequest(HttpRequest, ResponseHandler<T>) - 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
HASH - Enum constant in enum class com.logicalclocks.hsfs.PrimaryKeyIndexType
HEADER - Static variable in class com.logicalclocks.hsfs.util.Constants
heapify(byte[]) - Static method in class com.logicalclocks.hsfs.spark.engine.profile.KllAggregator: Deserialises bytes produced by KllDoublesSketch.toByteArray() back into a live sketch.
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
HOPSFS - Enum constant in enum class com.logicalclocks.hsfs.StorageConnectorType
HOPSFS_TRAINING_DATASET - Enum constant in enum class com.logicalclocks.hsfs.TrainingDatasetType
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.beam
HopsworksConnection - Class in com.logicalclocks.hsfs.flink
HopsworksConnection - Class in com.logicalclocks.hsfs
HopsworksConnection - Class in com.logicalclocks.hsfs.spark
HopsworksConnection(String, int, String, Region, SecretStore, boolean, String, String, String, String) - Constructor for class com.logicalclocks.hsfs.beam.HopsworksConnection
HopsworksConnection(String, int, String, Region, SecretStore, boolean, String, String, String, String) - Constructor for class com.logicalclocks.hsfs.flink.HopsworksConnection
HopsworksConnection(String, int, String, Region, SecretStore, boolean, String, String, String, String) - Constructor for class com.logicalclocks.hsfs.HopsworksConnection
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
host - Variable in class com.logicalclocks.hsfs.StorageConnector.SapHanaConnector
host - Variable in class com.logicalclocks.hsfs.StorageConnector.SqlConnector
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
HTTPS - Enum constant in enum class com.logicalclocks.hsfs.SslEndpointIdentificationAlgorithm
HUDI - Enum constant in enum class com.logicalclocks.hsfs.ExternalDataFormat
HUDI - Enum constant in enum class com.logicalclocks.hsfs.TimeTravelFormat
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_METADATA_ENABLE - 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_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_SPARK_FORMAT - Static variable in class com.logicalclocks.hsfs.spark.engine.hudi.HudiEngine
HUDI_TABLE_BASE_FILE_FORMAT - Static variable in class com.logicalclocks.hsfs.spark.engine.hudi.HudiEngine
HUDI_TABLE_KEY_GENERATOR_CLASS - Static variable in class com.logicalclocks.hsfs.spark.engine.hudi.HudiEngine
HUDI_TABLE_METADATA_PARTITIONS - 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_PARTITION_KEY_FIELDS - Static variable in class com.logicalclocks.hsfs.spark.engine.hudi.HudiEngine
HUDI_TABLE_PRECOMBINE_FIELD - Static variable in class com.logicalclocks.hsfs.spark.engine.hudi.HudiEngine
HUDI_TABLE_RECORD_KEY_FIELD - 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_TABLE_TYPE - Static variable in class com.logicalclocks.hsfs.spark.engine.hudi.HudiEngine
HUDI_TABLE_VERSION - 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
HUDI_WRITE_PRECOMBINE_FIELD - Static variable in class com.logicalclocks.hsfs.spark.engine.hudi.HudiEngine
HUDI_WRITE_RECORD_KEY - Static variable in class com.logicalclocks.hsfs.spark.engine.hudi.HudiEngine
HudiEngine - Class in com.logicalclocks.hsfs.spark.engine.hudi
HudiOperationType - Enum Class in com.logicalclocks.hsfs
hudiPrecombineKey - Variable in class com.logicalclocks.hsfs.FeatureGroupBase

I

iamRole - Variable in class com.logicalclocks.hsfs.StorageConnector.GlueConnector
iamRole - Variable in class com.logicalclocks.hsfs.StorageConnector.RedshiftConnector
iamRole - Variable in class com.logicalclocks.hsfs.StorageConnector.S3Connector
ICEBERG - Enum constant in enum class com.logicalclocks.hsfs.ExternalDataFormat
ICEBERG - Enum constant in enum class com.logicalclocks.hsfs.TimeTravelFormat
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
IMAGE - Enum constant in enum class com.logicalclocks.hsfs.DataFormat
in(Collection<?>) - Method in class com.logicalclocks.hsfs.Feature: Deprecated.
`in` method is deprecated. Use `isin` instead.
IN - Enum constant in enum class com.logicalclocks.hsfs.constructor.SqlFilterCondition
IN_MEMORY_TRAINING_DATASET - Enum constant in enum class com.logicalclocks.hsfs.TrainingDatasetType
INFER_SCHEMA - Static variable in class com.logicalclocks.hsfs.util.Constants
init() - Method in class com.logicalclocks.hsfs.flink.engine.PojoToAvroRecord
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(FeatureStoreBase, List<TrainingDatasetFeature>, List<ServingPreparedStatement>, 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
initServing() - Method in class com.logicalclocks.hsfs.FeatureViewBase: Initialise feature view to retrieve feature vector from online feature store.
initServing(FeatureViewBase, boolean) - Method in class com.logicalclocks.hsfs.engine.VectorServer
initServing(FeatureViewBase, boolean, boolean) - Method in class com.logicalclocks.hsfs.engine.VectorServer
initServing(Boolean) - 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: Initialise feature view to retrieve feature vector from online feature store.
INNER - Enum constant in enum class com.logicalclocks.hsfs.constructor.JoinType
insert(ExternalFeatureGroup, Dataset<Row>, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.engine.FeatureGroupEngine
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(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>) - 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>) - 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) - 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.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>) - 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.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.FeatureGroup
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.
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>, HudiOperationType) - Method in class com.logicalclocks.hsfs.spark.StreamFeatureGroup
insert(Dataset<Row>, JobConfiguration) - Method in class com.logicalclocks.hsfs.spark.FeatureGroup
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>, Storage) - Method in class com.logicalclocks.hsfs.spark.ExternalFeatureGroup
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>, Storage) - Method in class com.logicalclocks.hsfs.spark.StreamFeatureGroup
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>, Storage, boolean) - Method in class com.logicalclocks.hsfs.spark.StreamFeatureGroup
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>, Storage, boolean, HudiOperationType, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.StreamFeatureGroup
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>, 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>, 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 - Enum constant in enum class com.logicalclocks.hsfs.HudiOperationType
insertStream() - Method in class com.logicalclocks.hsfs.beam.StreamFeatureGroup: Ingest a feature data to the online feature store using Beam Pipeline object.
insertStream(StreamFeatureGroup, Map<String, String>) - Method in class com.logicalclocks.hsfs.beam.engine.BeamEngine
insertStream(StreamFeatureGroup, Map<String, String>) - Method in class com.logicalclocks.hsfs.beam.engine.FeatureGroupEngine
insertStream(StreamFeatureGroup, DataStream<?>, Map<String, String>) - Method in class com.logicalclocks.hsfs.flink.engine.FeatureGroupEngine
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(StreamFeatureGroup, List<T>, Map<String, String>) - Method in class com.logicalclocks.hsfs.engine.FeatureGroupEngine
insertStream(List<T>) - Method in class com.logicalclocks.hsfs.StreamFeatureGroup
insertStream(List<T>, Map<String, String>) - Method in class com.logicalclocks.hsfs.StreamFeatureGroup
insertStream(Map<String, String>) - Method in class com.logicalclocks.hsfs.beam.StreamFeatureGroup
insertStream(PCollection<Object>) - Method in class com.logicalclocks.hsfs.beam.StreamFeatureGroup
insertStream(PCollection<Object>, Map<String, String>) - Method in class com.logicalclocks.hsfs.beam.StreamFeatureGroup
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(Dataset<Row>) - 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>) - 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.FeatureGroup: Deprecated.
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>, String, String) - Method in class com.logicalclocks.hsfs.spark.FeatureGroup: Deprecated.
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, 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) - 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.FeatureGroup: Deprecated.
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.FeatureGroup: Deprecated.
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, Long, String, Map<String, String>, JobConfiguration) - Method in class com.logicalclocks.hsfs.spark.FeatureGroup
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.
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, String) - Method in class com.logicalclocks.hsfs.spark.StreamFeatureGroup
insertStream(Dataset<Row>, String, String, String) - Method in class com.logicalclocks.hsfs.spark.FeatureGroup: Deprecated.
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, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.FeatureGroup
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>, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.ExternalFeatureGroup
insertStream(Dataset<Row>, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.FeatureGroup: Deprecated.
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(T) - Method in class com.logicalclocks.hsfs.FeatureGroupBase
insertStream(T, Map<String, String>) - Method in class com.logicalclocks.hsfs.FeatureGroupBase
INSTANCE - Static variable in class com.logicalclocks.hsfs.spark.engine.hudi.HudiEngine
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 - Enum constant in enum class com.logicalclocks.hsfs.StorageConnectorType
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(int, int, int, int, boolean, int, int) - Constructor for class com.logicalclocks.hsfs.JobConfiguration
join(T) - 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, 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>, 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>) - 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
join(T, List<String>, List<String>, String) - Method in class com.logicalclocks.hsfs.constructor.QueryBase
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
joinFeatures(T, List<Feature>) - 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>, 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>, 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
joinFeatures(T, List<Feature>, List<Feature>, String) - Method in class com.logicalclocks.hsfs.constructor.QueryBase
joins - Variable in class com.logicalclocks.hsfs.constructor.QueryBase
JoinType - Enum Class in com.logicalclocks.hsfs.constructor

K

K_CERTIFICATE - Static variable in class com.logicalclocks.hsfs.metadata.HopsworksExternalClient
KAFKA - Enum constant in enum class com.logicalclocks.hsfs.StorageConnectorType
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
kafkaOptions() - Method in class com.logicalclocks.hsfs.StorageConnector.KafkaConnector
KafkaRecordSerializer - Class in com.logicalclocks.hsfs.engine
KafkaRecordSerializer - Class in com.logicalclocks.hsfs.flink.engine
KafkaRecordSerializer(StreamFeatureGroup) - Constructor for class com.logicalclocks.hsfs.flink.engine.KafkaRecordSerializer
keyPath - Variable in class com.logicalclocks.hsfs.StorageConnector.BigqueryConnector
keyPath - Variable in class com.logicalclocks.hsfs.StorageConnector.GcsConnector
KeySerializer - Class in com.logicalclocks.hsfs.beam.engine
KeySerializer(List<String>) - Constructor for class com.logicalclocks.hsfs.beam.engine.KeySerializer
keyStorePath - Variable in class com.logicalclocks.hsfs.HopsworksConnectionBase
keyStorePath - Variable in class com.logicalclocks.hsfs.metadata.HopsworksExternalClient
KllAggregator - Class in com.logicalclocks.hsfs.spark.engine.profile: Builds a KllDoublesSketch over a numeric column using a distributed mapPartitions approach.
KllAggregator() - Constructor for class com.logicalclocks.hsfs.spark.engine.profile.KllAggregator
KllMerger - Class in com.logicalclocks.hsfs.spark.engine.profile: Merges per-batch native-format KLL sketches into a single aggregate sketch, then derives a 100-element percentiles vector and a histogram-from-CDF.

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.beam.FeatureView.FeatureViewBuilder
labels(List<String>) - Method in class com.logicalclocks.hsfs.FeatureView.FeatureViewBuilder
labels(List<String>) - Method in class com.logicalclocks.hsfs.flink.FeatureView.FeatureViewBuilder
labels(List<String>) - Method in class com.logicalclocks.hsfs.spark.FeatureView.FeatureViewBuilder
le(Feature) - Method in class com.logicalclocks.hsfs.Feature
le(Object) - Method in class com.logicalclocks.hsfs.Feature
LEFT - Enum constant in enum class com.logicalclocks.hsfs.constructor.JoinType
LEFT_SEMI_JOIN - Enum constant in enum class com.logicalclocks.hsfs.constructor.JoinType
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
LESS_THAN - Enum constant in enum class com.logicalclocks.hsfs.constructor.SqlFilterCondition
LESS_THAN_OR_EQUAL - Enum constant in enum class com.logicalclocks.hsfs.constructor.SqlFilterCondition
like(Object) - Method in class com.logicalclocks.hsfs.Feature
LIKE - Enum constant in enum class com.logicalclocks.hsfs.constructor.SqlFilterCondition
limit - Variable in class com.logicalclocks.hsfs.constructor.QueryBase
limit(int) - Method in class com.logicalclocks.hsfs.constructor.QueryBase: Limit the number of rows returned by the query.
LOADBALANCER_EXTERNAL_DOMAIN_MYSQL - 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.DataSource
LOGGER - Static variable in class com.logicalclocks.hsfs.engine.EngineBase
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.OnlineIngestion
LOGGER - Static variable in class com.logicalclocks.hsfs.StorageConnector
LOGGER - Static variable in class com.logicalclocks.hsfs.TrainingDatasetBase
lt(Feature) - Method in class com.logicalclocks.hsfs.Feature
lt(Object) - Method in class com.logicalclocks.hsfs.Feature

M

makeLabelFeatures(QueryBase, List<String>) - Static method in class com.logicalclocks.hsfs.engine.FeatureViewEngineBase
makeQueryName(String, FeatureGroupBase) - Method in class com.logicalclocks.hsfs.spark.engine.SparkEngine
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
maybeAppendKafkaOffsets(JavaRDD<ConsumerRecord<Object, Object>>) - Method in class com.logicalclocks.hsfs.spark.engine.hudi.DeltaStreamerKafkaSource
merge(List<String>, int) - Static method in class com.logicalclocks.hsfs.spark.engine.profile.KllMerger: Merge per-batch KLL sketches into a single sketch and derive monitoring artifacts.
migrateTable(Map<String, String>, JavaSparkContext) - Method in class com.logicalclocks.hsfs.spark.engine.hudi.TableMigrateUtils
MIN_SYNC_INTERVAL_SECONDS - Static variable in class com.logicalclocks.hsfs.spark.engine.hudi.HudiEngine
MONGODB - Enum constant in enum class com.logicalclocks.hsfs.StorageConnectorType
MONGODB_FORMAT - Static variable in class com.logicalclocks.hsfs.StorageConnector.MongoDbConnector
MongoDbConnector() - Constructor for class com.logicalclocks.hsfs.StorageConnector.MongoDbConnector
MYSQL - Static variable in class com.logicalclocks.hsfs.StorageConnector.SqlConnector

N

name - Variable in class com.logicalclocks.hsfs.FeatureGroupBase
name - Variable in class com.logicalclocks.hsfs.FeatureViewBase
name - Variable in class com.logicalclocks.hsfs.StorageConnector
name - Variable in class com.logicalclocks.hsfs.TrainingDatasetBase
name(String) - Method in class com.logicalclocks.hsfs.beam.FeatureView.FeatureViewBuilder
name(String) - Method in class com.logicalclocks.hsfs.FeatureView.FeatureViewBuilder
name(String) - Method in class com.logicalclocks.hsfs.flink.FeatureView.FeatureViewBuilder
name(String) - Method in class com.logicalclocks.hsfs.spark.FeatureView.FeatureViewBuilder
ne(Feature) - Method in class com.logicalclocks.hsfs.Feature
ne(Object) - Method in class com.logicalclocks.hsfs.Feature
NONE - Enum constant in enum class com.logicalclocks.hsfs.TimeTravelFormat
NOT_EQUALS - Enum constant in enum class com.logicalclocks.hsfs.constructor.SqlFilterCondition
notificationTopicName - Variable in class com.logicalclocks.hsfs.FeatureGroupBase

O

objectMapper - Variable in class com.logicalclocks.hsfs.metadata.HopsworksClient
objectToDataset(Object) - Method in class com.logicalclocks.hsfs.spark.engine.SparkEngine
OFFLINE - Enum constant in enum class com.logicalclocks.hsfs.Storage
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
ONLINE - Enum constant in enum class com.logicalclocks.hsfs.Storage
ONLINE_INGESTION_PATH - Static variable in class com.logicalclocks.hsfs.metadata.OnlineIngestionApi
onlineConfig - Variable in class com.logicalclocks.hsfs.FeatureGroupBase
OnlineConfig - Class in com.logicalclocks.hsfs
OnlineConfig(List<String>, String) - Constructor for class com.logicalclocks.hsfs.OnlineConfig
OnlineConfig(List<String>, String, PrimaryKeyIndexType) - Constructor for class com.logicalclocks.hsfs.OnlineConfig
onlineEnabled - Variable in class com.logicalclocks.hsfs.FeatureGroupBase
OnlineIngestion - Class in com.logicalclocks.hsfs
OnlineIngestion(Long) - Constructor for class com.logicalclocks.hsfs.OnlineIngestion
onlineIngestionApi - Variable in class com.logicalclocks.hsfs.FeatureGroupBase
OnlineIngestionApi - Class in com.logicalclocks.hsfs.metadata
OnlineIngestionApi() - Constructor for class com.logicalclocks.hsfs.metadata.OnlineIngestionApi
OnlineIngestionResult - Class in com.logicalclocks.hsfs
OnlineIngestionResult() - Constructor for class com.logicalclocks.hsfs.OnlineIngestionResult
onlineTopicName - Variable in class com.logicalclocks.hsfs.FeatureGroupBase
open(SerializationSchema.InitializationContext, KafkaRecordSerializationSchema.KafkaSinkContext) - Method in class com.logicalclocks.hsfs.flink.engine.KafkaRecordSerializer
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
options - Variable in class com.logicalclocks.hsfs.StorageConnector.MongoDbConnector
or(Filter) - 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.Filter
or(FilterLogic) - Method in class com.logicalclocks.hsfs.constructor.FilterLogic
OR - Enum constant in enum class com.logicalclocks.hsfs.constructor.SqlFilterLogic
ORC - Enum constant in enum class com.logicalclocks.hsfs.DataFormat
ORC - Enum constant in enum class com.logicalclocks.hsfs.ExternalDataFormat
ORDERED - Enum constant in enum class com.logicalclocks.hsfs.PrimaryKeyIndexType

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
PARAMETER_STORE - Enum constant in enum class com.logicalclocks.hsfs.SecretStore
parentProject - Variable in class com.logicalclocks.hsfs.StorageConnector.BigqueryConnector
PARQUET - Enum constant in enum class com.logicalclocks.hsfs.DataFormat
PARQUET - Enum constant in enum class com.logicalclocks.hsfs.ExternalDataFormat
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
partitionKeys - Variable in class com.logicalclocks.hsfs.FeatureGroupBase
password - Variable in class com.logicalclocks.hsfs.StorageConnector.MongoDbConnector
password - Variable in class com.logicalclocks.hsfs.StorageConnector.SapHanaConnector
password - Variable in class com.logicalclocks.hsfs.StorageConnector.SnowflakeConnector
password - Variable in class com.logicalclocks.hsfs.StorageConnector.SqlConnector
path - Variable in class com.logicalclocks.hsfs.StorageConnector.S3Connector
PLAINTEXT - Enum constant in enum class com.logicalclocks.hsfs.SecurityProtocol
PojoToAvroRecord<T> - Class in com.logicalclocks.hsfs.flink.engine
PojoToAvroRecord(String, String, Map<String, String>) - Constructor for class com.logicalclocks.hsfs.flink.engine.PojoToAvroRecord
PojoToAvroUtils - Class in com.logicalclocks.hsfs.engine
PojoToAvroUtils() - Constructor for class com.logicalclocks.hsfs.engine.PojoToAvroUtils
port - Variable in class com.logicalclocks.hsfs.HopsworksConnectionBase
port - Variable in class com.logicalclocks.hsfs.StorageConnector.SapHanaConnector
port - Variable in class com.logicalclocks.hsfs.StorageConnector.SqlConnector
post(FeatureGroupBase, Statistics) - Method in class com.logicalclocks.hsfs.metadata.StatisticsApi
post(FeatureViewBase, Integer, Statistics) - Method in class com.logicalclocks.hsfs.metadata.StatisticsApi
post(TrainingDatasetBase, Statistics) - Method in class com.logicalclocks.hsfs.metadata.StatisticsApi
POSTGRESQL - Static variable in class com.logicalclocks.hsfs.StorageConnector.SqlConnector
PreparedStatementParameter - Class in com.logicalclocks.hsfs.constructor
PreparedStatementParameter() - Constructor for class com.logicalclocks.hsfs.constructor.PreparedStatementParameter
PrimaryKeyIndexType - Enum Class in com.logicalclocks.hsfs
primaryKeys - Variable in class com.logicalclocks.hsfs.FeatureGroupBase
processQuery(Map<String, Object>, int, T) - Method in class com.logicalclocks.hsfs.engine.VectorServer
profile(Dataset<Row>) - 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>, List<String>) - Method in class com.logicalclocks.hsfs.spark.engine.SparkEngine
profile(Dataset<Row>, List<String>, boolean, boolean, int, boolean, boolean) - Method in class com.logicalclocks.hsfs.spark.engine.profile.ColumnProfiler: Profiles the given dataframe and returns a JSON string matching the Deequ wire format.
profile(Dataset<Row>, List<String>, Boolean, Boolean) - Method in class com.logicalclocks.hsfs.spark.engine.SparkEngine
profile(Dataset<Row>, List<String>, Boolean, Boolean, Boolean) - Method in class com.logicalclocks.hsfs.spark.engine.SparkEngine
profile(Dataset<Row>, List<String>, Boolean, Boolean, Boolean, Boolean, Integer) - 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.spark.FeatureView: Delete all training datasets in this feature view (data only).
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(Query) - Method in class com.logicalclocks.hsfs.beam.FeatureView.FeatureViewBuilder: Query of a feature view.
query(Query) - Method in class com.logicalclocks.hsfs.FeatureView.FeatureViewBuilder: Query of a feature view.
query(Query) - Method in class com.logicalclocks.hsfs.flink.FeatureView.FeatureViewBuilder: Query of a feature view.
query(Query) - Method in class com.logicalclocks.hsfs.spark.FeatureView.FeatureViewBuilder: Query of a feature view.
Query - Class in com.logicalclocks.hsfs.constructor
Query - Class in com.logicalclocks.hsfs.spark.constructor
Query(FeatureGroupBase, List<Feature>) - Constructor for class com.logicalclocks.hsfs.spark.constructor.Query
Query(StreamFeatureGroup, List<Feature>) - Constructor for class com.logicalclocks.hsfs.constructor.Query
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(FeatureGroupBase, 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

RANDOM_SPLIT - Enum constant in enum class com.logicalclocks.hsfs.Split.SplitType
read() - Method in class com.logicalclocks.hsfs.spark.constructor.Query
read() - 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() - Method in class com.logicalclocks.hsfs.spark.StreamFeatureGroup: Reads the feature group from the offline storage as Spark DataFrame.
read() - Method in class com.logicalclocks.hsfs.spark.TrainingDataset: Read the content of the training dataset.
read(boolean) - Method in class com.logicalclocks.hsfs.spark.constructor.Query
read(boolean) - Method in class com.logicalclocks.hsfs.spark.ExternalFeatureGroup
read(boolean) - Method in class com.logicalclocks.hsfs.spark.FeatureGroup: Reads the feature group from the offline or online 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(boolean, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.constructor.Query
read(boolean, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.ExternalFeatureGroup
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(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(TrainingDataset, String, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.engine.TrainingDatasetEngine
read(StorageConnector.AdlsConnector, DataSource, String, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.util.StorageConnectorUtils: Reads path into a spark dataframe using the AdlsConnector.
read(StorageConnector.BigqueryConnector, DataSource, Map<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.GcsConnector, DataSource, String, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.util.StorageConnectorUtils: Reads a path into a spark dataframe using the GcsConnector.
read(StorageConnector.GlueConnector, DataSource, String, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.util.StorageConnectorUtils: Reads a Glue catalog table into a spark dataframe using the GlueConnector.
read(StorageConnector.HopsFsConnector, DataSource, String, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.util.StorageConnectorUtils: Reads path into a spark dataframe using the HopsFsConnector.
read(StorageConnector.JdbcConnector, DataSource, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.util.StorageConnectorUtils: Reads query into a spark dataframe using the JdbcConnector.
read(StorageConnector.RedshiftConnector, DataSource, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.util.StorageConnectorUtils: Reads query into a spark dataframe using the RedshiftConnector.
read(StorageConnector.S3Connector, DataSource, String, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.util.StorageConnectorUtils: Reads path into a spark dataframe using the S3Connector.
read(StorageConnector.SnowflakeConnector, DataSource, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.util.StorageConnectorUtils: Reads query into a spark dataframe using the SnowflakeConnector.
read(StorageConnector.SqlConnector, DataSource, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.util.StorageConnectorUtils: Reads a query into a spark dataframe using the SqlConnector.
read(StorageConnector, DataSource, String, Map<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(StorageConnector, String, Map<String, String>, String) - Method in class com.logicalclocks.hsfs.spark.engine.SparkEngine
read(String) - Method in class com.logicalclocks.hsfs.spark.FeatureGroup: Reads Feature group into a dataframe at a specific point in time.
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) - 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.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.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.TrainingDataset: Read a single split from the training dataset.
read(Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.ExternalFeatureGroup
read(Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.FeatureGroup: Reads the feature group from the offline 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(Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.TrainingDataset: Read the content of 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) - 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.FeatureGroup: Deprecated.
readChanges(String, String, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.StreamFeatureGroup: Deprecated.
readContent(String) - Static method in class com.logicalclocks.hsfs.metadata.DatasetApi
readContent(String, String) - Static method in class com.logicalclocks.hsfs.metadata.DatasetApi
readFromCheckpoint(Option<Checkpoint>, long) - Method in class com.logicalclocks.hsfs.spark.engine.hudi.DeltaStreamerKafkaSource
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.
readStream(StorageConnector, String, String, String, Map<String, String>, boolean) - Method in class com.logicalclocks.hsfs.spark.engine.SparkEngine
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.
REDSHIFT - Enum constant in enum class com.logicalclocks.hsfs.StorageConnectorType
RedshiftConnector() - Constructor for class com.logicalclocks.hsfs.StorageConnector.RedshiftConnector
refetch() - Method in class com.logicalclocks.hsfs.StorageConnector
refresh() - Method in class com.logicalclocks.hsfs.OnlineIngestion
refreshJwt() - Method in class com.logicalclocks.hsfs.metadata.HopsworksInternalClient
region - Variable in class com.logicalclocks.hsfs.HopsworksConnectionBase
region - Variable in class com.logicalclocks.hsfs.StorageConnector.GlueConnector
region - Variable in class com.logicalclocks.hsfs.StorageConnector.S3Connector
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
removeNewLines() - Method in class com.logicalclocks.hsfs.constructor.FsQueryBase
removeRows(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.
removeRows(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.
removeRows(Dataset<Row>, Storage) - Method in class com.logicalclocks.hsfs.spark.FeatureGroup: Drops records present in the provided DataFrame from the offline table, and optionally from the online store of an online-enabled feature group.
removeRows(Dataset<Row>, Storage) - Method in class com.logicalclocks.hsfs.spark.StreamFeatureGroup: Drops records present in the provided DataFrame from the offline table, and optionally from the online store of an online-enabled feature group.
removeRows(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.
removeRows(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.
removeRows(Dataset<Row>, Map<String, String>, Storage) - Method in class com.logicalclocks.hsfs.spark.FeatureGroup: Drops records present in the provided DataFrame from the offline table, and optionally from the online store of an online-enabled feature group.
removeRows(Dataset<Row>, Map<String, String>, Storage) - Method in class com.logicalclocks.hsfs.spark.StreamFeatureGroup: Drops records present in the provided DataFrame from the offline table, and optionally from the online store of an online-enabled feature group.
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
RIGHT - Enum constant in enum class com.logicalclocks.hsfs.constructor.JoinType
role - Variable in class com.logicalclocks.hsfs.StorageConnector.SnowflakeConnector

S

S3 - Enum constant in enum class com.logicalclocks.hsfs.StorageConnectorType
S3_ACCESS_KEY_ENV - Static variable in class com.logicalclocks.hsfs.util.Constants
S3_CONNECTION_USE_SSL - 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_PATH_STYLE_ACCESS - 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
SAP_HANA - Enum constant in enum class com.logicalclocks.hsfs.StorageConnectorType
SapHanaConnector() - Constructor for class com.logicalclocks.hsfs.StorageConnector.SapHanaConnector
SASL_PLAINTEXT - Enum constant in enum class com.logicalclocks.hsfs.SecurityProtocol
SASL_SSL - Enum constant in enum class com.logicalclocks.hsfs.SecurityProtocol
save() - Method in class com.logicalclocks.hsfs.beam.StreamFeatureGroup: Save the feature group metadata on Hopsworks.
save() - Method in class com.logicalclocks.hsfs.flink.StreamFeatureGroup: Save the feature group metadata on Hopsworks.
save() - Method in class com.logicalclocks.hsfs.spark.ExternalFeatureGroup
save() - Method in class com.logicalclocks.hsfs.StreamFeatureGroup: Save the feature group metadata on Hopsworks.
save(StreamFeatureGroup, List<String>, String, Map<String, String>, JobConfiguration) - Method in class com.logicalclocks.hsfs.beam.engine.FeatureGroupEngine
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(StreamFeatureGroup, List<String>, String, Map<String, String>, JobConfiguration) - Method in class com.logicalclocks.hsfs.flink.engine.FeatureGroupEngine
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(StreamFeatureGroup, List<String>, String, Map<String, String>, JobConfiguration) - Method in class com.logicalclocks.hsfs.engine.FeatureGroupEngine
save(Map<String, String>, JobConfiguration) - Method in class com.logicalclocks.hsfs.beam.StreamFeatureGroup: Save the feature group metadata on Hopsworks.
save(Map<String, String>, JobConfiguration) - Method in class com.logicalclocks.hsfs.flink.StreamFeatureGroup: Save the feature group metadata on Hopsworks.
save(Map<String, String>, JobConfiguration) - Method in class com.logicalclocks.hsfs.StreamFeatureGroup: Save the feature group metadata on Hopsworks.
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(T2, Class<T2>) - Method in class com.logicalclocks.hsfs.engine.FeatureViewEngineBase
saveDataframe(FeatureGroup, Dataset<Row>, Storage, HudiOperationType, 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.SapHanaConnector
schema - Variable in class com.logicalclocks.hsfs.StorageConnector.SnowflakeConnector
SCHEMA_PROVIDER - Static variable in class com.logicalclocks.hsfs.spark.engine.hudi.HudiEngine
SECRET_MANAGER - Enum constant in enum class com.logicalclocks.hsfs.SecretStore
secretKey - Variable in class com.logicalclocks.hsfs.StorageConnector.GlueConnector
secretKey - Variable in class com.logicalclocks.hsfs.StorageConnector.S3Connector
secretStore - Variable in class com.logicalclocks.hsfs.HopsworksConnectionBase
SecretStore - Enum Class in com.logicalclocks.hsfs
securityProtocol - Variable in class com.logicalclocks.hsfs.StorageConnector.KafkaConnector
SecurityProtocol - Enum Class in com.logicalclocks.hsfs
seed - Variable in class com.logicalclocks.hsfs.TrainingDatasetBase
select(List<String>) - Method in class com.logicalclocks.hsfs.beam.StreamFeatureGroup: Select a subset of features of the feature group and return a query object.
select(List<String>) - Method in class com.logicalclocks.hsfs.flink.StreamFeatureGroup: Select a subset of features of the feature group and return a query object.
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.
select(List<String>) - Method in class com.logicalclocks.hsfs.StreamFeatureGroup: Select a subset of features of the feature group and return a query object.
selectAll() - Method in class com.logicalclocks.hsfs.beam.StreamFeatureGroup: Select all features of the feature group and return a query object.
selectAll() - Method in class com.logicalclocks.hsfs.flink.StreamFeatureGroup: Select all features of the feature group and return a query object.
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.
selectAll() - Method in class com.logicalclocks.hsfs.StreamFeatureGroup: Select all features of the feature group and return a query object.
selectExcept(List<String>) - Method in class com.logicalclocks.hsfs.beam.StreamFeatureGroup: 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.flink.StreamFeatureGroup: 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.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.
selectExcept(List<String>) - Method in class com.logicalclocks.hsfs.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.beam.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.flink.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.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.
selectExceptFeatures(List<Feature>) - Method in class com.logicalclocks.hsfs.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.beam.StreamFeatureGroup: Select a subset of features of the feature group and return a query object.
selectFeatures(List<Feature>) - Method in class com.logicalclocks.hsfs.flink.StreamFeatureGroup: Select a subset of features of the feature group and return a query object.
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.
selectFeatures(List<Feature>) - Method in class com.logicalclocks.hsfs.StreamFeatureGroup: Select a subset of features of the feature group and return a query object.
send(ProducerRecord) - Method in class com.logicalclocks.hsfs.beam.engine.BeamKafkaProducer
send(ProducerRecord, Callback) - Method in class com.logicalclocks.hsfs.beam.engine.BeamKafkaProducer
serialize(String, GenericRecord) - Method in class com.logicalclocks.hsfs.beam.engine.GenericAvroSerializer
serialize(String, GenericRecord) - Method in class com.logicalclocks.hsfs.beam.engine.KeySerializer
serialize(GenericRecord) - Method in class com.logicalclocks.hsfs.engine.KafkaRecordSerializer
serialize(GenericRecord, KafkaRecordSerializationSchema.KafkaSinkContext, Long) - Method in class com.logicalclocks.hsfs.flink.engine.KafkaRecordSerializer
serializeKey(GenericRecord) - Method in class com.logicalclocks.hsfs.engine.KafkaRecordSerializer
serializeKey(GenericRecord) - Method in class com.logicalclocks.hsfs.flink.engine.KafkaRecordSerializer
serializeValue(GenericRecord) - Method in class com.logicalclocks.hsfs.engine.KafkaRecordSerializer
serializeValue(GenericRecord) - Method in class com.logicalclocks.hsfs.flink.engine.KafkaRecordSerializer
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(Integer, List<PreparedStatementParameter>, String) - Constructor for class com.logicalclocks.hsfs.constructor.ServingPreparedStatement
sessionToken - Variable in class com.logicalclocks.hsfs.StorageConnector.GlueConnector
sessionToken - Variable in class com.logicalclocks.hsfs.StorageConnector.S3Connector
setCertKey(String) - Method in interface com.logicalclocks.hsfs.metadata.HopsworksHttpClient
setCount(Long) - Method in class com.logicalclocks.hsfs.metadata.RestDto
setDataSource(DataSource) - Method in class com.logicalclocks.hsfs.FeatureGroupBase
setDeprecated(Boolean) - Method in class com.logicalclocks.hsfs.FeatureGroupBase
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
setSecondaryIndexes(List<List<String>>) - Method in class com.logicalclocks.hsfs.OnlineConfig
setStorageConnectorApi(StorageConnectorApi) - Method in class com.logicalclocks.hsfs.flink.engine.FlinkEngine
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
setupHikariPool(FeatureStoreBase, Boolean) - Method in class com.logicalclocks.hsfs.engine.VectorServer
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 class com.logicalclocks.hsfs.SslEndpointIdentificationAlgorithm
sfOptions - Variable in class com.logicalclocks.hsfs.StorageConnector.SnowflakeConnector
show(boolean, int) - Method in class com.logicalclocks.hsfs.spark.constructor.Query
show(int) - Method in class com.logicalclocks.hsfs.spark.constructor.Query
show(int) - 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) - 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, boolean) - Method in class com.logicalclocks.hsfs.spark.ExternalFeatureGroup
show(int, boolean) - 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.StreamFeatureGroup: Show the first `n` rows of the feature group.
SINGLE - Enum constant in enum class com.logicalclocks.hsfs.constructor.SqlFilterLogic
SNOWFLAKE - Enum constant in enum class com.logicalclocks.hsfs.StorageConnectorType
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
sparkOptions(DataSource) - Method in class com.logicalclocks.hsfs.StorageConnector.AdlsConnector
sparkOptions(DataSource) - Method in class com.logicalclocks.hsfs.StorageConnector.BigqueryConnector: Set spark options specific to BigQuery.
sparkOptions(DataSource) - Method in class com.logicalclocks.hsfs.StorageConnector.GcsConnector
sparkOptions(DataSource) - Method in class com.logicalclocks.hsfs.StorageConnector.GlueConnector
sparkOptions(DataSource) - Method in class com.logicalclocks.hsfs.StorageConnector.HopsFsConnector
sparkOptions(DataSource) - Method in class com.logicalclocks.hsfs.StorageConnector.JdbcConnector
sparkOptions(DataSource) - Method in class com.logicalclocks.hsfs.StorageConnector.KafkaConnector
sparkOptions(DataSource) - Method in class com.logicalclocks.hsfs.StorageConnector.MongoDbConnector
sparkOptions(DataSource) - Method in class com.logicalclocks.hsfs.StorageConnector.RedshiftConnector
sparkOptions(DataSource) - Method in class com.logicalclocks.hsfs.StorageConnector.S3Connector
sparkOptions(DataSource) - Method in class com.logicalclocks.hsfs.StorageConnector.SapHanaConnector
sparkOptions(DataSource) - Method in class com.logicalclocks.hsfs.StorageConnector.SnowflakeConnector
sparkOptions(DataSource) - Method in class com.logicalclocks.hsfs.StorageConnector
sparkOptions(DataSource) - Method in class com.logicalclocks.hsfs.StorageConnector.SqlConnector
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 Class 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.spark.constructor.Query
sql(Storage) - Method in class com.logicalclocks.hsfs.spark.constructor.Query
sql(Storage, Class<T2>) - Method in class com.logicalclocks.hsfs.constructor.QueryBase
sql(String) - Method in class com.logicalclocks.hsfs.spark.engine.SparkEngine
sql(String) - Method in class com.logicalclocks.hsfs.spark.FeatureStore
SQL - Enum constant in enum class com.logicalclocks.hsfs.StorageConnectorType
SqlConnector() - Constructor for class com.logicalclocks.hsfs.StorageConnector.SqlConnector
SqlFilterCondition - Enum Class in com.logicalclocks.hsfs.constructor
SqlFilterLogic - Enum Class in com.logicalclocks.hsfs.constructor
SSL - Enum constant in enum class com.logicalclocks.hsfs.SecurityProtocol
sslEndpointIdentificationAlgorithm - Variable in class com.logicalclocks.hsfs.StorageConnector.KafkaConnector
SslEndpointIdentificationAlgorithm - Enum Class in com.logicalclocks.hsfs
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(Long, Float, Collection<FeatureDescriptiveStatistics>, Long, Long) - Constructor for class com.logicalclocks.hsfs.metadata.Statistics
Statistics(Long, Float, List<SplitStatistics>) - 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 - Variable in class com.logicalclocks.hsfs.TrainingDatasetBase
StatisticsConfig - Class in com.logicalclocks.hsfs
StatisticsConfig(Boolean, Boolean, Boolean, Boolean) - Constructor for class com.logicalclocks.hsfs.StatisticsConfig
statisticsEngine - Variable in class com.logicalclocks.hsfs.spark.FeatureGroup
StatisticsEngine - Class in com.logicalclocks.hsfs.spark.engine
StatisticsEngine(EntityEndpointType) - Constructor for class com.logicalclocks.hsfs.spark.engine.StatisticsEngine
Storage - Enum Class in com.logicalclocks.hsfs
StorageConnector - Class in com.logicalclocks.hsfs
StorageConnector() - Constructor for class com.logicalclocks.hsfs.StorageConnector
StorageConnector.AdlsConnector - Class in com.logicalclocks.hsfs
StorageConnector.BigqueryConnector - Class in com.logicalclocks.hsfs
StorageConnector.GcsConnector - Class in com.logicalclocks.hsfs
StorageConnector.GlueConnector - 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.MongoDbConnector - Class in com.logicalclocks.hsfs
StorageConnector.RedshiftConnector - Class in com.logicalclocks.hsfs
StorageConnector.S3Connector - Class in com.logicalclocks.hsfs
StorageConnector.SapHanaConnector - Class in com.logicalclocks.hsfs
StorageConnector.SnowflakeConnector - Class in com.logicalclocks.hsfs
StorageConnector.SqlConnector - Class in com.logicalclocks.hsfs
storageConnectorApi - Variable in class com.logicalclocks.hsfs.constructor.QueryBase
storageConnectorApi - Variable in class com.logicalclocks.hsfs.engine.EngineBase
storageConnectorApi - Variable in class com.logicalclocks.hsfs.FeatureStoreBase
storageConnectorApi - Variable in class com.logicalclocks.hsfs.StorageConnector
StorageConnectorApi - Class in com.logicalclocks.hsfs.metadata
StorageConnectorApi() - Constructor for class com.logicalclocks.hsfs.metadata.StorageConnectorApi
storageConnectorType - Variable in class com.logicalclocks.hsfs.StorageConnector
StorageConnectorType - Enum Class in com.logicalclocks.hsfs
StorageConnectorUtils - Class in com.logicalclocks.hsfs.spark.util
StorageConnectorUtils() - Constructor for class com.logicalclocks.hsfs.spark.util.StorageConnectorUtils
STREAMER_CHECKPOINT_KEY_V2 - Static variable in class com.logicalclocks.hsfs.spark.engine.hudi.HudiEngine
StreamFeatureGroup - Class in com.logicalclocks.hsfs.beam
StreamFeatureGroup - Class in com.logicalclocks.hsfs.flink
StreamFeatureGroup - Class in com.logicalclocks.hsfs.spark
StreamFeatureGroup<T> - Class in com.logicalclocks.hsfs
StreamFeatureGroup() - Constructor for class com.logicalclocks.hsfs.beam.StreamFeatureGroup
StreamFeatureGroup() - Constructor for class com.logicalclocks.hsfs.flink.StreamFeatureGroup
StreamFeatureGroup() - Constructor for class com.logicalclocks.hsfs.spark.StreamFeatureGroup
StreamFeatureGroup() - Constructor for class com.logicalclocks.hsfs.StreamFeatureGroup
StreamFeatureGroup(FeatureStore, int) - Constructor for class com.logicalclocks.hsfs.beam.StreamFeatureGroup
StreamFeatureGroup(FeatureStore, String, Integer, String, List<String>, List<String>, String, boolean, TimeTravelFormat, List<Feature>, StatisticsConfig, String, String, OnlineConfig, StorageConnector, String) - Constructor for class com.logicalclocks.hsfs.beam.StreamFeatureGroup
StreamFeatureGroup(FeatureStoreBase, int) - Constructor for class com.logicalclocks.hsfs.StreamFeatureGroup
StreamFeatureGroup(FeatureStoreBase, String, Integer, String, TimeTravelFormat, List<String>, List<String>, String, boolean, List<Feature>, StatisticsConfig, String, String, StorageConnector, String, OnlineConfig) - Constructor for class com.logicalclocks.hsfs.StreamFeatureGroup
StreamFeatureGroup(FeatureStore, int) - Constructor for class com.logicalclocks.hsfs.flink.StreamFeatureGroup
StreamFeatureGroup(FeatureStore, String, Integer, String, List<String>, List<String>, String, boolean, TimeTravelFormat, List<Feature>, StatisticsConfig, String, String, String, String, OnlineConfig, StorageConnector, String) - Constructor for class com.logicalclocks.hsfs.flink.StreamFeatureGroup
StreamFeatureGroup(FeatureStore, int) - Constructor for class com.logicalclocks.hsfs.spark.StreamFeatureGroup
StreamFeatureGroup(FeatureStore, String, Integer, String, List<String>, List<String>, String, boolean, TimeTravelFormat, List<Feature>, StatisticsConfig, String, String, String, String, OnlineConfig, StorageConnector, String) - Constructor for class com.logicalclocks.hsfs.spark.StreamFeatureGroup
StreamFeatureGroup(Integer, String, List<Feature>) - Constructor for class com.logicalclocks.hsfs.beam.StreamFeatureGroup
StreamFeatureGroup(Integer, String, List<Feature>) - Constructor for class com.logicalclocks.hsfs.flink.StreamFeatureGroup
StreamFeatureGroup(Integer, String, List<Feature>) - Constructor for class com.logicalclocks.hsfs.spark.StreamFeatureGroup
StreamFeatureGroup(Integer, String, List<Feature>) - Constructor for class com.logicalclocks.hsfs.StreamFeatureGroup
StreamFeatureGroup.StreamFeatureGroupBuilder - Class in com.logicalclocks.hsfs.beam
StreamFeatureGroup.StreamFeatureGroupBuilder - Class in com.logicalclocks.hsfs.flink
StreamFeatureGroup.StreamFeatureGroupBuilder<T> - Class in com.logicalclocks.hsfs
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
SUBJECT_ID - Static variable in class com.logicalclocks.hsfs.spark.engine.hudi.HudiEngine

T

T_CERTIFICATE - Static variable in class com.logicalclocks.hsfs.metadata.HopsworksExternalClient
table - Variable in class com.logicalclocks.hsfs.StorageConnector.GlueConnector
table - Variable in class com.logicalclocks.hsfs.StorageConnector.SapHanaConnector
table - Variable in class com.logicalclocks.hsfs.StorageConnector.SnowflakeConnector
TableMigrateUtils - Class in com.logicalclocks.hsfs.spark.engine.hudi
TableMigrateUtils() - Constructor for class com.logicalclocks.hsfs.spark.engine.hudi.TableMigrateUtils
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 - Variable in class com.logicalclocks.hsfs.FeatureViewBase
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
TFRECORD - Enum constant in enum class com.logicalclocks.hsfs.DataFormat
TFRECORDS - Enum constant in enum class com.logicalclocks.hsfs.DataFormat
TIME_SERIES_SPLIT - Enum constant in enum class com.logicalclocks.hsfs.Split.SplitType
TIMESTAMP - Enum constant in enum class com.logicalclocks.hsfs.FeatureType
timeStampToHudiFormat(Long) - Method in class com.logicalclocks.hsfs.engine.FeatureGroupUtils
timeTravelFormat - Variable in class com.logicalclocks.hsfs.FeatureGroupBase
TimeTravelFormat - Enum Class in com.logicalclocks.hsfs
toBatch(OffsetRange[]) - Method in class com.logicalclocks.hsfs.spark.engine.hudi.DeltaStreamerKafkaSource
toJson() - Method in class com.logicalclocks.hsfs.Feature
token - Variable in class com.logicalclocks.hsfs.StorageConnector.SnowflakeConnector
topicName - Variable in class com.logicalclocks.hsfs.FeatureGroupBase
toString() - Method in class com.logicalclocks.hsfs.FeatureStoreBase
toString() - Method in class com.logicalclocks.hsfs.metadata.HopsworksClient.HopsworksErrorClass
toString() - Method in enum class com.logicalclocks.hsfs.SslEndpointIdentificationAlgorithm
TRAIN - Static variable in class com.logicalclocks.hsfs.Split
TRAINING_DATASET - Enum constant in enum class com.logicalclocks.hsfs.EntityEndpointType
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(Integer, String, DataFormat, Boolean, StorageConnector, String, List<Split>, String, Long, FeatureStoreBase, StatisticsConfig, List<String>, String, String, TrainingDatasetType, Float, Float, String, String, String, String, String, String, Integer, FilterLogic, Filter, DataSource) - Constructor for class com.logicalclocks.hsfs.spark.TrainingDataset
TrainingDataset.TrainingDatasetBuilder - Class in com.logicalclocks.hsfs.spark
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(Integer, String, DataFormat, Boolean, StorageConnector, String, List<Split>, String, Long, FeatureStoreBase, StatisticsConfig, List<String>, String, String, TrainingDatasetType, Float, Float, String, String, String, String, String, String, Integer, FilterLogic, Filter, DataSource) - Constructor for class com.logicalclocks.hsfs.TrainingDatasetBase
TrainingDatasetBundle - Class in com.logicalclocks.hsfs.spark
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
TrainingDatasetBundle(Integer, 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(StreamFeatureGroup, String, Boolean) - Constructor for class com.logicalclocks.hsfs.TrainingDatasetFeature
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
TrainingDatasetJobConf - Class in com.logicalclocks.hsfs
TrainingDatasetJobConf() - Constructor for class com.logicalclocks.hsfs.TrainingDatasetJobConf
trainingDatasetSchemaMatch(Dataset<Row>, List<TrainingDatasetFeature>) - Method in class com.logicalclocks.hsfs.spark.engine.TrainingDatasetUtils
trainingDatasetType - Variable in class com.logicalclocks.hsfs.TrainingDatasetBase
TrainingDatasetType - Enum Class 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
TSV - Enum constant in enum class com.logicalclocks.hsfs.DataFormat
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() - Method in class com.logicalclocks.hsfs.StorageConnector.GlueConnector
update() - Method in class com.logicalclocks.hsfs.StorageConnector.JdbcConnector
update() - Method in class com.logicalclocks.hsfs.StorageConnector.MongoDbConnector
update() - Method in class com.logicalclocks.hsfs.StorageConnector.RedshiftConnector
update() - Method in class com.logicalclocks.hsfs.StorageConnector.S3Connector
update() - Method in class com.logicalclocks.hsfs.StorageConnector.SapHanaConnector
update() - Method in class com.logicalclocks.hsfs.StorageConnector.SqlConnector
update(FeatureView) - Method in class com.logicalclocks.hsfs.beam.engine.FeatureViewEngine
update(FeatureView) - Method in class com.logicalclocks.hsfs.engine.FeatureViewEngine
update(FeatureViewBase, Class<T>) - Method in class com.logicalclocks.hsfs.metadata.FeatureViewApi
update(FeatureView) - Method in class com.logicalclocks.hsfs.flink.engine.FeatureViewEngine
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(T2) - Method in class com.logicalclocks.hsfs.engine.FeatureViewEngineBase
updateDeprecated() - Method in class com.logicalclocks.hsfs.FeatureGroupBase: Deprecate the feature group.
updateDeprecated(FeatureGroupBase, Boolean, Class<T>) - Method in class com.logicalclocks.hsfs.engine.FeatureGroupEngineBase
updateDeprecated(Boolean) - Method in class com.logicalclocks.hsfs.FeatureGroupBase: Deprecate the feature group.
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(Feature) - Method in class com.logicalclocks.hsfs.spark.ExternalFeatureGroup
updateFeatures(Feature) - Method in class com.logicalclocks.hsfs.spark.FeatureGroup: Update the metadata of feature.
updateFeatures(Feature) - Method in class com.logicalclocks.hsfs.spark.StreamFeatureGroup: Update the metadata of feature.
updateFeatures(FeatureGroupBase, List<Feature>, Class<T>) - Method in class com.logicalclocks.hsfs.engine.FeatureGroupEngineBase
updateFeatures(List<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(List<Feature>) - Method in class com.logicalclocks.hsfs.spark.StreamFeatureGroup: Update the metadata of multiple features.
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
updateNotificationTopicName(FeatureGroupBase, String, Class<T>) - Method in class com.logicalclocks.hsfs.engine.FeatureGroupEngineBase
updateNotificationTopicName(String) - Method in class com.logicalclocks.hsfs.FeatureGroupBase: Update the notification topic name of the feature group.
updateStatisticsConfig() - Method in class com.logicalclocks.hsfs.FeatureGroupBase: Update the statistics configuration of the feature group.
updateStatisticsConfig(FeatureGroupBase, Class<T>) - Method in class com.logicalclocks.hsfs.engine.FeatureGroupEngineBase
updateStorageConnector(StorageConnector) - Method in class com.logicalclocks.hsfs.DataSource
UPSERT - Enum constant in enum class com.logicalclocks.hsfs.HudiOperationType
url - Variable in class com.logicalclocks.hsfs.StorageConnector.SnowflakeConnector
user - Variable in class com.logicalclocks.hsfs.StorageConnector.MongoDbConnector
user - Variable in class com.logicalclocks.hsfs.StorageConnector.SapHanaConnector
user - Variable in class com.logicalclocks.hsfs.StorageConnector.SnowflakeConnector
user - Variable in class com.logicalclocks.hsfs.StorageConnector.SqlConnector
User - Class in com.logicalclocks.hsfs.metadata
User() - Constructor for class com.logicalclocks.hsfs.metadata.User
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 class com.logicalclocks.hsfs.constructor.JoinType: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class com.logicalclocks.hsfs.constructor.SqlFilterCondition: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class com.logicalclocks.hsfs.constructor.SqlFilterLogic: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class com.logicalclocks.hsfs.DataFormat: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class com.logicalclocks.hsfs.EntityEndpointType: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class com.logicalclocks.hsfs.ExternalDataFormat: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class com.logicalclocks.hsfs.FeatureType: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class com.logicalclocks.hsfs.HudiOperationType: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class com.logicalclocks.hsfs.PrimaryKeyIndexType: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class com.logicalclocks.hsfs.SecretStore: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class com.logicalclocks.hsfs.SecurityProtocol: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class com.logicalclocks.hsfs.Split.SplitType: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class com.logicalclocks.hsfs.SslEndpointIdentificationAlgorithm: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class com.logicalclocks.hsfs.Storage: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class com.logicalclocks.hsfs.StorageConnectorType: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class com.logicalclocks.hsfs.TimeTravelFormat: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class com.logicalclocks.hsfs.TrainingDatasetType: Returns the enum constant of this class with the specified name.
values() - Static method in enum class com.logicalclocks.hsfs.constructor.JoinType: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class com.logicalclocks.hsfs.constructor.SqlFilterCondition: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class com.logicalclocks.hsfs.constructor.SqlFilterLogic: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class com.logicalclocks.hsfs.DataFormat: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class com.logicalclocks.hsfs.EntityEndpointType: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class com.logicalclocks.hsfs.ExternalDataFormat: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class com.logicalclocks.hsfs.FeatureType: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class com.logicalclocks.hsfs.HudiOperationType: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class com.logicalclocks.hsfs.PrimaryKeyIndexType: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class com.logicalclocks.hsfs.SecretStore: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class com.logicalclocks.hsfs.SecurityProtocol: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class com.logicalclocks.hsfs.Split.SplitType: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class com.logicalclocks.hsfs.SslEndpointIdentificationAlgorithm: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class com.logicalclocks.hsfs.Storage: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class com.logicalclocks.hsfs.StorageConnectorType: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class com.logicalclocks.hsfs.TimeTravelFormat: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class com.logicalclocks.hsfs.TrainingDatasetType: Returns an array containing the constants of this enum class, 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 - Variable in class com.logicalclocks.hsfs.FeatureViewBase
VectorServer - Class in com.logicalclocks.hsfs.engine
VectorServer() - Constructor for class com.logicalclocks.hsfs.engine.VectorServer
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 - Variable in class com.logicalclocks.hsfs.TrainingDatasetBase
version(Integer) - Method in class com.logicalclocks.hsfs.beam.FeatureView.FeatureViewBuilder
version(Integer) - Method in class com.logicalclocks.hsfs.FeatureView.FeatureViewBuilder
version(Integer) - Method in class com.logicalclocks.hsfs.flink.FeatureView.FeatureViewBuilder
version(Integer) - Method in class com.logicalclocks.hsfs.spark.FeatureView.FeatureViewBuilder

W

waitForCompletion(int, int) - Method in class com.logicalclocks.hsfs.OnlineIngestion
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>, Map<String, String>) - Method in class com.logicalclocks.hsfs.spark.engine.SparkEngine: Writes feature group dataframe to kafka for online-fs ingestion.
writeOnlineDataframe(FeatureGroupBase, Dataset<Row>, Map<String, String>, Storage) - Method in class com.logicalclocks.hsfs.spark.engine.SparkEngine: Writes feature group dataframe to kafka for online-fs ingestion.
writeStream(StreamFeatureGroup, List<T>, Map<String, String>) - Method in class com.logicalclocks.hsfs.engine.Engine
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

Z

zipArraysToTupleString(List<List<Object>>) - Method in class com.logicalclocks.hsfs.engine.VectorServer

A B C D E F G H I J K L M N O P Q R S T U V W Z
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form