Package | Description |
---|---|
com.logicalclocks.hsfs | |
com.logicalclocks.hsfs.flink | |
com.logicalclocks.hsfs.metadata | |
com.logicalclocks.hsfs.spark | |
com.logicalclocks.hsfs.spark.engine |
Modifier and Type | Method and Description |
---|---|
abstract Statistics |
FeatureGroupBase.computeStatistics()
Recompute the statistics for the feature group and save them to the feature store.
|
abstract Statistics |
TrainingDatasetBase.computeStatistics()
Recompute the statistics for the entire training dataset and save them to the feature store.
|
Statistics |
FeatureGroupBaseForApi.computeStatistics() |
abstract Statistics |
FeatureGroupBase.computeStatistics(String wallclockTime) |
Statistics |
FeatureGroupBaseForApi.computeStatistics(String wallclockTime) |
abstract Statistics |
FeatureGroupBase.getStatistics()
Get the last statistics commit for the feature group.
|
abstract Statistics |
TrainingDatasetBase.getStatistics()
Get the last statistics commit for the training dataset.
|
Statistics |
FeatureGroupBaseForApi.getStatistics() |
abstract Statistics |
TrainingDatasetBase.getStatistics(String commitTime)
Get the statistics of a specific commit time for the training dataset.
|
Modifier and Type | Method and Description |
---|---|
Statistics |
StreamFeatureGroup.computeStatistics() |
Statistics |
StreamFeatureGroup.computeStatistics(String wallclockTime) |
Statistics |
StreamFeatureGroup.getStatistics() |
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 |
TrainingDataset.computeStatistics()
Recompute the statistics for the entire training dataset and save them to the feature store.
|
Statistics |
ExternalFeatureGroup.computeStatistics() |
Statistics |
StreamFeatureGroup.computeStatistics()
Recompute the statistics for the stream feature group and save them to the feature store.
|
Statistics |
FeatureGroup.computeStatistics()
Recompute the statistics for the feature group and save them to the feature store.
|
Statistics |
ExternalFeatureGroup.computeStatistics(String wallclockTime) |
Statistics |
StreamFeatureGroup.computeStatistics(String wallclockTime)
Recompute the statistics for the feature group and save them to the feature store.
|
Statistics |
FeatureGroup.computeStatistics(String wallclockTime)
Recompute the statistics for the feature group and save them to the feature store.
|
Statistics |
TrainingDataset.getStatistics()
Get the last statistics commit for the training dataset.
|
Statistics |
ExternalFeatureGroup.getStatistics() |
Statistics |
StreamFeatureGroup.getStatistics() |
Statistics |
FeatureGroup.getStatistics()
Get the last statistics commit for the feature group.
|
Statistics |
TrainingDataset.getStatistics(String commitTime)
Get the statistics of a specific commit time for the training dataset.
|
Modifier and Type | Method and Description |
---|---|
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) |
Statistics |
StatisticsEngine.getSplitStatistics(TrainingDataset trainingDataset) |
Statistics |
StatisticsEngine.getSplitStatistics(TrainingDataset trainingDataset,
Map<String,org.apache.spark.sql.Dataset<org.apache.spark.sql.Row>> splitDatasets) |
Statistics |
StatisticsEngine.registerSplitStatistics(FeatureView featureView,
TrainingDataset trainingDataset,
Map<String,org.apache.spark.sql.Dataset<org.apache.spark.sql.Row>> splitDatasets) |
Statistics |
StatisticsEngine.registerSplitStatistics(TrainingDataset trainingDataset) |
Copyright © 2023. All rights reserved.