| Package | Description | 
|---|---|
| com.logicalclocks.hsfs | |
| com.logicalclocks.hsfs.metadata | |
| com.logicalclocks.hsfs.spark | |
| com.logicalclocks.hsfs.spark.engine | 
| Modifier and Type | Method and Description | 
|---|---|
| Statistics | TrainingDatasetBase. getStatistics()Get the last statistics commit for the training dataset. | 
| Statistics | TrainingDatasetBase. getStatistics(String commitTime)Get the statistics of a specific commit time for the training dataset. | 
| Modifier and Type | Method and Description | 
|---|---|
| Statistics | StatisticsApi. get(FeatureGroupBase featureGroup,
   String commitTime) | 
| Statistics | StatisticsApi. get(TrainingDatasetBase trainingDatasetBase,
   String commitTime) | 
| Statistics | StatisticsApi. getLast(FeatureGroupBase featureGroup) | 
| Statistics | StatisticsApi. getLast(TrainingDatasetBase trainingDatasetBase) | 
| Statistics | StatisticsApi. post(FeatureGroupBase featureGroup,
    Statistics statistics) | 
| Statistics | StatisticsApi. post(FeatureViewBase featureViewBase,
    Integer trainingDataVersion,
    Statistics statistics) | 
| Statistics | StatisticsApi. post(TrainingDatasetBase trainingDatasetBase,
    Statistics statistics) | 
| Modifier and Type | Method and Description | 
|---|---|
| Statistics | StatisticsApi. post(FeatureGroupBase featureGroup,
    Statistics statistics) | 
| Statistics | StatisticsApi. post(FeatureViewBase featureViewBase,
    Integer trainingDataVersion,
    Statistics statistics) | 
| Statistics | StatisticsApi. post(TrainingDatasetBase trainingDatasetBase,
    Statistics statistics) | 
| Modifier and Type | Method and Description | 
|---|---|
| Statistics | FeatureGroup. computeStatistics()Recompute the statistics for the feature group and save them to the feature store. | 
| Statistics | TrainingDataset. computeStatistics()Recompute the statistics for the entire training dataset and save them to the feature store. | 
| Statistics | StreamFeatureGroup. computeStatistics()Recompute the statistics for the stream feature group and save them to the feature store. | 
| Statistics | ExternalFeatureGroup. computeStatistics() | 
| Statistics | FeatureGroup. computeStatistics(String wallclockTime)Recompute the statistics for the feature group and save them to the feature store. | 
| Statistics | StreamFeatureGroup. computeStatistics(String wallclockTime)Recompute the statistics for the feature group and save them to the feature store. | 
| Statistics | FeatureGroup. getStatistics()Get the last statistics commit for the feature group. | 
| Statistics | StreamFeatureGroup. getStatistics() | 
| Statistics | ExternalFeatureGroup. getStatistics() | 
| Modifier and Type | Method and Description | 
|---|---|
| Statistics | StatisticsEngine. computeAndSaveSplitStatistics(FeatureView featureView,
                             TrainingDataset trainingDataset,
                             Map<String,org.apache.spark.sql.Dataset<org.apache.spark.sql.Row>> splitDatasets) | 
| Statistics | StatisticsEngine. computeAndSaveSplitStatistics(TrainingDataset trainingDataset) | 
| Statistics | StatisticsEngine. computeSplitStatistics(TrainingDataset trainingDataset) | 
| Statistics | StatisticsEngine. computeSplitStatistics(TrainingDataset trainingDataset,
                      Map<String,org.apache.spark.sql.Dataset<org.apache.spark.sql.Row>> splitDatasets) | 
| Statistics | StatisticsEngine. computeStatistics(FeatureGroupBase featureGroup,
                 org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> dataFrame,
                 Long commitId) | 
| 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) | 
| Statistics | StatisticsEngine. computeStatistics(TrainingDataset trainingDataset,
                 org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> dataFrame) | 
| Statistics | StatisticsEngine. get(FeatureGroupBase featureGroup,
   String commitTime) | 
| Statistics | StatisticsEngine. get(TrainingDataset trainingDataset,
   String commitTime) | 
| Statistics | StatisticsEngine. getLast(FeatureGroupBase featureGroup) | 
| Statistics | StatisticsEngine. getLast(TrainingDataset trainingDataset) | 
Copyright © 2025. All rights reserved.