| Package | Description | 
|---|---|
| com.logicalclocks.hsfs.spark | |
| com.logicalclocks.hsfs.spark.engine | 
| Modifier and Type | Method and Description | 
|---|---|
FeatureView | 
FeatureView.FeatureViewBuilder.build()  | 
FeatureView | 
FeatureStore.getFeatureView(String name)
Get a feature view object with the default version `1` from the selected feature store. 
 | 
FeatureView | 
FeatureStore.getFeatureView(@NonNull String name,
              @NonNull Integer version)
Get a feature view object from the selected feature store. 
 | 
FeatureView | 
FeatureStore.getOrCreateFeatureView(String name,
                      Query query,
                      Integer version)
Get feature view metadata object or create a new one if it doesn't exist. 
 | 
FeatureView | 
FeatureStore.getOrCreateFeatureView(String name,
                      Query query,
                      Integer version,
                      String description,
                      List<String> labels)
Get feature view metadata object or create a new one if it doesn't exist. 
 | 
FeatureView | 
FeatureView.update(FeatureView other)
Update the description of the feature view. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
FeatureView | 
FeatureView.update(FeatureView other)
Update the description of the feature view. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
FeatureView | 
FeatureViewEngine.get(FeatureStore featureStore,
   String name,
   Integer version)  | 
FeatureView | 
FeatureViewEngine.getOrCreateFeatureView(FeatureStore featureStore,
                      String name,
                      Integer version,
                      Query query,
                      String description,
                      List<String> labels)  | 
FeatureView | 
FeatureViewEngine.update(FeatureView featureView)  | 
| Modifier and Type | Method and Description | 
|---|---|
Statistics | 
StatisticsEngine.computeStatistics(FeatureView featureView,
                 TrainingDataset trainingDataset,
                 org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> dataFrame)  | 
Statistics | 
FeatureViewEngine.computeStatistics(FeatureView featureView,
                 TrainingDataset trainingDataset,
                 org.apache.spark.sql.Dataset<org.apache.spark.sql.Row>[] datasets)  | 
TrainingDatasetBundle | 
FeatureViewEngine.createTrainingDataset(FeatureView featureView,
                     TrainingDataset trainingDataset,
                     Map<String,String> userWriteOptions)  | 
org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> | 
FeatureViewEngine.getBatchData(FeatureView featureView,
            Date startTime,
            Date endTime,
            Map<String,String> readOptions,
            Integer trainingDataVersion)  | 
Query | 
FeatureViewEngine.getBatchQuery(FeatureView featureView,
             Date startTime,
             Date endTime,
             Boolean withLabels,
             Integer trainingDataVersion)  | 
String | 
FeatureViewEngine.getBatchQueryString(FeatureView featureView,
                   Date startTime,
                   Date endTime,
                   Integer trainingDataVersion)  | 
TrainingDatasetBundle | 
FeatureViewEngine.getTrainingDataset(FeatureView featureView,
                  Integer trainingDatasetVersion,
                  List<String> requestedSplits,
                  Map<String,String> userReadOptions)  | 
TrainingDatasetBundle | 
FeatureViewEngine.getTrainingDataset(FeatureView featureView,
                  TrainingDataset trainingDataset,
                  List<String> requestedSplits,
                  Map<String,String> userReadOptions)  | 
TrainingDatasetBundle | 
FeatureViewEngine.getTrainingDataset(FeatureView featureView,
                  TrainingDataset trainingDataset,
                  Map<String,String> userReadOptions)  | 
void | 
FeatureViewEngine.recreateTrainingDataset(FeatureView featureView,
                       Integer version,
                       Map<String,String> userWriteOptions)  | 
Statistics | 
StatisticsEngine.registerSplitStatistics(FeatureView featureView,
                       TrainingDataset trainingDataset,
                       Map<String,org.apache.spark.sql.Dataset<org.apache.spark.sql.Row>> splitDatasets)  | 
FeatureView | 
FeatureViewEngine.update(FeatureView featureView)  | 
void | 
FeatureViewEngine.writeTrainingDataset(FeatureView featureView,
                    TrainingDataset trainingDataset,
                    Map<String,String> userWriteOptions)  | 
Copyright © 2023. All rights reserved.