| Package | Description |
|---|---|
| com.logicalclocks.hsfs | |
| com.logicalclocks.hsfs.engine | |
| com.logicalclocks.hsfs.metadata | |
| com.logicalclocks.hsfs.spark |
| 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 |
TrainingDatasetBase.featureStore |
protected FeatureStoreBase |
FeatureGroupBase.featureStore |
protected T3 |
FeatureViewBase.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,
OnlineConfig onlineConfig) |
TrainingDatasetBase(Integer version,
String description,
DataFormat dataFormat,
Boolean coalesce,
StorageConnector storageConnector,
String location,
List<Split> splits,
String trainSplit,
Long seed,
FeatureStoreBase featureStore,
StatisticsConfig statisticsConfig,
List<String> label,
String eventStartTime,
String eventEndTime,
TrainingDatasetType trainingDatasetType,
Float validationSize,
Float testSize,
String trainStart,
String trainEnd,
String validationStart,
String validationEnd,
String testStart,
String testEnd,
Integer timeSplitSize,
FilterLogic extraFilterLogic,
Filter extraFilter) |
| 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 |
|---|---|
void |
FeatureViewApi.computeTrainingData(FeatureStoreBase featureStore,
FeatureViewBase featureViewBase,
TrainingDatasetBase trainingData) |
<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) |
<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) |
| Constructor and Description |
|---|
TrainingDataset(Integer version,
String description,
DataFormat dataFormat,
Boolean coalesce,
StorageConnector storageConnector,
String location,
List<Split> splits,
String trainSplit,
Long seed,
FeatureStoreBase featureStore,
StatisticsConfig statisticsConfig,
List<String> label,
String eventStartTime,
String eventEndTime,
TrainingDatasetType trainingDatasetType,
Float validationSize,
Float testSize,
String trainStart,
String trainEnd,
String validationStart,
String validationEnd,
String testStart,
String testEnd,
Integer timeSplitSize,
FilterLogic extraFilterLogic,
Filter extraFilter) |
Copyright © 2025. All rights reserved.