[ML] Add anomaly job timing stats to Counts & JSON

qn895 · qn895 · commit 1196dd1da1ce · 2020-04-30T10:05:13.000-05:00
diff --git a/x-pack/plugins/ml/public/application/jobs/jobs_list/components/job_details/extract_job_details.js b/x-pack/plugins/ml/public/application/jobs/jobs_list/components/job_details/extract_job_details.js
@@ -165,6 +165,15 @@ export function extractJobDetails(job) {
     items: filterObjects(job.model_size_stats).map(formatValues),
   };
 
+  const jobTimingStats = {
+    id: 'jobTimingStats',
+    title: i18n.translate('xpack.ml.jobsList.jobDetails.jobTimingStatsTitle', {
+      defaultMessage: 'Job timing stats',
+    }),
+    position: 'left',
+    items: filterObjects(job.timing_stats).map(formatValues),
+  };
+
   const datafeedTimingStats = {
     id: 'datafeedTimingStats',
     title: i18n.translate('xpack.ml.jobsList.jobDetails.datafeedTimingStatsTitle', {
@@ -192,6 +201,7 @@ export function extractJobDetails(job) {
     datafeed,
     counts,
     modelSizeStats,
+    jobTimingStats,
     datafeedTimingStats,
   };
 }
diff --git a/x-pack/plugins/ml/public/application/jobs/jobs_list/components/job_details/format_values.js b/x-pack/plugins/ml/public/application/jobs/jobs_list/components/job_details/format_values.js
@@ -16,6 +16,10 @@ function formatData(txt) {
   return numeral(txt).format(DATA_FORMAT);
 }
 
+function roundTo3DecimalPlace(value) {
+  return typeof value === 'number' ? roundToDecimalPlace(value, 3).toLocaleString() : value;
+}
+
 export function formatValues([key, value]) {
   // time
   switch (key) {
@@ -63,7 +67,16 @@ export function formatValues([key, value]) {
     // numbers rounded to 3 decimal places
     case 'average_search_time_per_bucket_ms':
     case 'exponential_average_search_time_per_hour_ms':
-      value = typeof value === 'number' ? roundToDecimalPlace(value, 3).toLocaleString() : value;
+      value = roundTo3DecimalPlace(value);
+      break;
+    case 'total_bucket_processing_time_ms':
+      value = roundTo3DecimalPlace(value);
+      break;
+    case 'average_bucket_processing_time_ms':
+      value = roundTo3DecimalPlace(value);
+      break;
+    case 'exponential_average_bucket_processing_time_ms':
+      value = roundTo3DecimalPlace(value);
       break;
 
     default:
diff --git a/x-pack/plugins/ml/public/application/jobs/jobs_list/components/job_details/job_details.js b/x-pack/plugins/ml/public/application/jobs/jobs_list/components/job_details/job_details.js
@@ -60,6 +60,7 @@ export class JobDetails extends Component {
         datafeed,
         counts,
         modelSizeStats,
+        jobTimingStats,
         datafeedTimingStats,
       } = extractJobDetails(job);
 
@@ -102,7 +103,7 @@ export class JobDetails extends Component {
           content: (
             <JobDetailsPane
               data-test-subj="mlJobDetails-counts"
-              sections={[counts, modelSizeStats]}
+              sections={[counts, modelSizeStats, jobTimingStats]}
             />
           ),
         },
diff --git a/x-pack/plugins/ml/server/models/job_service/jobs.ts b/x-pack/plugins/ml/server/models/job_service/jobs.ts
@@ -328,7 +328,7 @@ export function jobsProvider(callAsCurrentUser: APICaller) {
     // create jobs objects containing job stats, datafeeds, datafeed stats and calendars
     if (jobResults && jobResults.jobs) {
       jobResults.jobs.forEach(job => {
-        const tempJob = job as CombinedJobWithStats;
+        let tempJob = job as CombinedJobWithStats;
 
         const calendars: string[] = [
           ...(calendarsByJobId[tempJob.job_id] || []),
@@ -341,9 +341,7 @@ export function jobsProvider(callAsCurrentUser: APICaller) {
         if (jobStatsResults && jobStatsResults.jobs) {
           const jobStats = jobStatsResults.jobs.find(js => js.job_id === tempJob.job_id);
           if (jobStats !== undefined) {
-            tempJob.state = jobStats.state;
-            tempJob.data_counts = jobStats.data_counts;
-            tempJob.model_size_stats = jobStats.model_size_stats;
+            tempJob = { ...tempJob, ...jobStats };
             if (jobStats.node) {
               tempJob.node = jobStats.node;
             }
