Hi,
I was wondering what does this utilization metric in the SamzaContainerMetrics
show? I am asking this sine in the code it is calculated as below:
while (!shutdownNow) {
val loopStartTime = clock();
process
window
commit
val totalMs = clock() - loopStartTime
metrics.utilization.set(activeMs.toFloat/totalMs)
activeMs = 0L
}
Where the totalMs is the time it takes to start calling process until commit is
done which is equal to the time it takes to run process, window, and commit.
And they way activeMs is calculated is by summing up the time it takes to call
process, window and commit, which means these two values are going to be almost
the same and the utilization is always going to be almost 1.
I was just wondering what is the point of doing this?
