public class MLOpsReporting extends Object
| Constructor and Description |
|---|
MLOpsReporting() |
| Modifier and Type | Method and Description |
|---|---|
static void |
reportActuals(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> dataFrame,
String deploymentID,
String modelId,
String channelConfig)
Report actuals/outcomes of predictions.
|
static void |
reportAggregatedStats(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> dataFrame,
Double scoringTime,
List<String> targetColumnNames,
Integer predictionsServiced,
String deploymentID,
String modelId,
String channelConfig,
Map<String,com.datarobot.mlops.stats.FeatureType> featureTypes,
Integer distinctCategoryCount,
Integer histogramBinCount,
Integer aggregationMaxRecords,
Integer groupSize)
Report predictions statistics utility function for a Spark environment.
|
static void |
reportPredictions(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> dataFrame,
String deploymentID,
String modelId,
String channelConfig,
Double scoringTime,
List<String> targetColumnNames,
String assocIdColName,
Integer predictionsServiced,
int groupSize)
Report predictions utility function for a Spark environment.
|
public static void reportPredictions(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> dataFrame,
String deploymentID,
String modelId,
String channelConfig,
Double scoringTime,
List<String> targetColumnNames,
String assocIdColName,
Integer predictionsServiced,
int groupSize)
throws com.datarobot.mlops.common.exceptions.DRCommonException
dataFrame - The Dataframe containing the data to reportdeploymentID - Deployment id to report data tomodelId - Model this reporting is associated withchannelConfig - Channel configuration string, to configure how to send the prediction information to the MLOps
Agent.scoringTime - Time in milliseconds it took to perform scoringtargetColumnNames - A list of column names containing the prediction value. If only one column is provided then
the model is assumed to be a regression model. If the number of columns is greater than 1
the model is assumed to be a classification model.assocIdColName - Optional column name containing the association ids to report with the predictions.com.datarobot.mlops.common.exceptions.DRCommonExceptionpublic static void reportAggregatedStats(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> dataFrame,
Double scoringTime,
List<String> targetColumnNames,
Integer predictionsServiced,
String deploymentID,
String modelId,
String channelConfig,
Map<String,com.datarobot.mlops.stats.FeatureType> featureTypes,
Integer distinctCategoryCount,
Integer histogramBinCount,
Integer aggregationMaxRecords,
Integer groupSize)
throws com.datarobot.mlops.common.exceptions.DRCommonException
dataFrame - The Dataframe containing the data to calculate and report statistics ondeploymentID - Deployment id to report statistics tomodelId - Model this reporting is associated withchannelConfig - Channel configuration string, to configure how to send the prediction information to the MLOps
Agent.scoringTime - Time in milliseconds it took to perform scoringtargetColumnNames - A list of column names containing the prediction value. If only one column is provided then
the model is assumed to be a regression model. If the number of columns is greater than 1
the model is assumed to be a classification model.com.datarobot.mlops.common.exceptions.DRCommonExceptionpublic static void reportActuals(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> dataFrame,
String deploymentID,
String modelId,
String channelConfig)
throws com.datarobot.mlops.common.exceptions.DRCommonException
dataFrame - The dataframe containing all necessary data to report actualsdeploymentID - Deployment id to report statistics tomodelId - Model this reporting is associated withchannelConfig - Channel configuration string, to configure how to send the prediction information to the MLOps
Agent.com.datarobot.mlops.common.exceptions.DRCommonExceptionCopyright © 2022. All rights reserved.