Package | Description |
---|---|
com.logicalclocks.hsfs | |
com.logicalclocks.hsfs.engine | |
com.logicalclocks.hsfs.metadata |
Modifier and Type | Class and Description |
---|---|
class |
FeatureViewBase<T extends FeatureViewBase,T3 extends FeatureStoreBase<T4>,T4 extends QueryBase,T5> |
Modifier and Type | Class and Description |
---|---|
class |
FeatureStore |
Modifier and Type | Field and Description |
---|---|
protected FeatureStoreBase |
FeatureGroupBase.featureStore |
protected T3 |
FeatureViewBase.featureStore |
protected FeatureStoreBase |
TrainingDatasetBase.featureStore |
Constructor and Description |
---|
StreamFeatureGroup(FeatureStoreBase featureStore,
int id) |
StreamFeatureGroup(FeatureStoreBase featureStore,
@NonNull String name,
Integer version,
String description,
TimeTravelFormat timeTravelFormat,
List<String> primaryKeys,
List<String> partitionKeys,
String hudiPrecombineKey,
boolean onlineEnabled,
List<Feature> features,
StatisticsConfig statisticsConfig,
String onlineTopicName,
String eventTime,
StorageConnector storageConnector,
String path) |
Modifier and Type | Class and Description |
---|---|
class |
FeatureViewEngineBase<T1 extends QueryBase<T1,T4,T5>,T2 extends FeatureViewBase<T2,T3,T1,T5>,T3 extends FeatureStoreBase<T1>,T4 extends FeatureGroupBase,T5> |
Modifier and Type | Method and Description |
---|---|
void |
VectorServer.initPreparedStatement(FeatureStoreBase featureStoreBase,
List<TrainingDatasetFeature> features,
List<ServingPreparedStatement> servingPreparedStatements,
boolean batch,
boolean external) |
void |
VectorServer.setupHikariPool(FeatureStoreBase featureStoreBase,
Boolean external) |
Modifier and Type | Method and Description |
---|---|
<T> FsQueryBase |
QueryConstructorApi.constructQuery(FeatureStoreBase featureStoreBase,
QueryBase queryBase,
Class<T> fsQueryType) |
void |
FeatureViewApi.delete(FeatureStoreBase featureStoreBase,
String name) |
void |
FeatureViewApi.delete(FeatureStoreBase featureStoreBase,
String name,
Integer version) |
void |
FeatureViewApi.deleteTrainingData(FeatureStoreBase featureStoreBase,
String name,
Integer version) |
void |
FeatureViewApi.deleteTrainingData(FeatureStoreBase featureStoreBase,
String featureViewName,
Integer featureViewVersion,
Integer trainingDataVersion) |
void |
FeatureViewApi.deleteTrainingDatasetOnly(FeatureStoreBase featureStoreBase,
String name,
Integer version) |
void |
FeatureViewApi.deleteTrainingDatasetOnly(FeatureStoreBase featureStoreBase,
String name,
Integer version,
Integer trainingDataVersion) |
List<FeatureViewBase> |
FeatureViewApi.get(FeatureStoreBase featureStoreBase,
String name) |
List<TrainingDatasetBase> |
TrainingDatasetApi.get(FeatureStoreBase featureStoreBase,
String tdName,
Integer tdVersion) |
<T extends FeatureViewBase> |
FeatureViewApi.get(FeatureStoreBase featureStoreBase,
String name,
Integer version,
Class<T> fvType) |
<T extends QueryBase> |
FeatureViewApi.getBatchQuery(FeatureStoreBase featureStoreBase,
String name,
Integer version,
Long startTime,
Long endTime,
Boolean withLabels,
Integer trainingDataVersion,
Class<T> queryType) |
<T> T |
StorageConnectorApi.getByName(FeatureStoreBase featureStoreBase,
String name,
Class<T> storageConnectorType) |
<T extends FeatureGroupBase> |
FeatureGroupApi.getInternal(FeatureStoreBase featureStoreBase,
String fgName,
Integer fgVersion,
Class<T[]> fgType) |
StorageConnector.KafkaConnector |
StorageConnectorApi.getKafkaStorageConnector(FeatureStoreBase featureStoreBase,
boolean external) |
<T> T |
StorageConnectorApi.getOnlineStorageConnector(FeatureStoreBase featureStoreBase,
Class<T> storageConnectorType) |
Subject |
KafkaApi.getSubject(FeatureStoreBase featureStoreBase,
String subjectName) |
Subject |
KafkaApi.getSubject(FeatureStoreBase featureStoreBase,
String subjectName,
String subjectVersion) |
<T extends TrainingDatasetBase> |
FeatureViewApi.getTrainingData(FeatureStoreBase featureStoreBase,
String featureViewName,
Integer featureViewVersion,
Integer trainingDataVersion,
Class<T> tdType) |
TrainingDatasetBase |
TrainingDatasetApi.getTrainingDataset(FeatureStoreBase featureStoreBase,
String tdName,
Integer tdVersion) |
Copyright © 2025. All rights reserved.