From 2d536829d253f8367c17fb1069a8f91f20dd3f97 Mon Sep 17 00:00:00 2001 From: cindyyuanjiang Date: Wed, 30 Oct 2024 15:38:23 -0700 Subject: [PATCH] add new file Signed-off-by: cindyyuanjiang --- .../rapids/tool/analysis/AnalysisUtils.scala | 32 +++++++++++++++++++ 1 file changed, 32 insertions(+) create mode 100644 core/src/main/scala/com/nvidia/spark/rapids/tool/analysis/AnalysisUtils.scala diff --git a/core/src/main/scala/com/nvidia/spark/rapids/tool/analysis/AnalysisUtils.scala b/core/src/main/scala/com/nvidia/spark/rapids/tool/analysis/AnalysisUtils.scala new file mode 100644 index 000000000..1ecd6d891 --- /dev/null +++ b/core/src/main/scala/com/nvidia/spark/rapids/tool/analysis/AnalysisUtils.scala @@ -0,0 +1,32 @@ +/* + * Copyright (c) 2024, NVIDIA CORPORATION. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +package com.nvidia.spark.rapids.tool.analysis + +/** + * object Utils provides toolkit functions + * + */ +object AnalysisUtils { + val MEMORY_SPILLED_METRIC = "internal.metrics.memoryBytesSpilled" + val DISK_SPILLED_METRIC = "internal.metrics.diskBytesSpilled" + val INPUT_BYTES_READ_METRIC = "internal.metrics.input.bytesRead" + val OUTPUT_BYTES_WRITTEN_METRIC = "internal.metrics.output.bytesWritten" + val SW_TOTAL_BYTES_METRIC = "internal.metrics.shuffle.write.bytesWritten" + val SR_FETCH_WAIT_TIME_METRIC = "internal.metrics.shuffle.read.fetchWaitTime" + val SW_WRITE_TIME_METRIC = "internal.metrics.shuffle.write.writeTime" + val GPU_SEMAPHORE_WAIT_METRIC = "gpuSemaphoreWait" +}