本文整理了Java中org.apache.spark.executor.TaskMetrics.jvmGCTime()
方法的一些代码示例,展示了TaskMetrics.jvmGCTime()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。TaskMetrics.jvmGCTime()
方法的具体详情如下:
包路径:org.apache.spark.executor.TaskMetrics
类名称:TaskMetrics
方法名:jvmGCTime
暂无
代码示例来源:origin: apache/hive
public Metrics(TaskMetrics metrics, TaskInfo taskInfo) {
this(
metrics.executorDeserializeTime(),
TimeUnit.NANOSECONDS.toMillis(metrics.executorDeserializeCpuTime()),
metrics.executorRunTime(),
TimeUnit.NANOSECONDS.toMillis(metrics.executorCpuTime()),
metrics.resultSize(),
metrics.jvmGCTime(),
metrics.resultSerializationTime(),
metrics.memoryBytesSpilled(),
metrics.diskBytesSpilled(),
taskInfo.duration(),
optionalInputMetric(metrics),
optionalShuffleReadMetric(metrics),
optionalShuffleWriteMetrics(metrics),
optionalOutputMetrics(metrics));
}
代码示例来源:origin: com.facebook.presto.hive/hive-apache
executorRunTime += taskMetrics.executorRunTime();
resultSize += taskMetrics.resultSize();
jvmGCTime += taskMetrics.jvmGCTime();
resultSerializationTime += taskMetrics.resultSerializationTime();
memoryBytesSpilled += taskMetrics.memoryBytesSpilled();
代码示例来源:origin: org.apache.pig/pig
executorRunTime += taskMetrics.executorRunTime();
resultSize += taskMetrics.resultSize();
jvmGCTime += taskMetrics.jvmGCTime();
resultSerializationTime += taskMetrics.resultSerializationTime();
memoryBytesSpilled += taskMetrics.memoryBytesSpilled();
代码示例来源:origin: com.github.hyukjinkwon/spark-client
public Metrics(TaskMetrics metrics) {
this(
metrics.executorDeserializeTime(),
metrics.executorRunTime(),
metrics.resultSize(),
metrics.jvmGCTime(),
metrics.resultSerializationTime(),
metrics.memoryBytesSpilled(),
metrics.diskBytesSpilled(),
optionalInputMetric(metrics),
optionalShuffleReadMetric(metrics),
optionalShuffleWriteMetrics(metrics));
}
代码示例来源:origin: org.spark-project.hive/spark-client
public Metrics(TaskMetrics metrics) {
this(
metrics.executorDeserializeTime(),
metrics.executorRunTime(),
metrics.resultSize(),
metrics.jvmGCTime(),
metrics.resultSerializationTime(),
metrics.memoryBytesSpilled(),
metrics.diskBytesSpilled(),
optionalInputMetric(metrics),
optionalShuffleReadMetric(metrics),
optionalShuffleWriteMetrics(metrics));
}
代码示例来源:origin: com.criteo.java/garmadon-frameworks-spark
tryToSet(() -> taskEventBuilder.setExecutorDeserializeCpuTime(taskEnd.taskMetrics().executorDeserializeCpuTime()));
tryToSet(() -> taskEventBuilder.setExecutorRunTime(taskEnd.taskMetrics().executorRunTime()));
tryToSet(() -> taskEventBuilder.setJvmGcTime(taskEnd.taskMetrics().jvmGCTime()));
tryToSet(() -> taskEventBuilder.setExecutorDeserializeTime(taskEnd.taskMetrics().executorDeserializeTime()));
tryToSet(() -> taskEventBuilder.setResultSerializationTime(taskEnd.taskMetrics().resultSerializationTime()));
代码示例来源:origin: com.criteo.java/garmadon-frameworks-spark
tryToSet(() -> stageEventBuilder.setExecutorDeserializeCpuTime(stageCompleted.stageInfo().taskMetrics().executorDeserializeCpuTime()));
tryToSet(() -> stageEventBuilder.setExecutorRunTime(stageCompleted.stageInfo().taskMetrics().executorRunTime()));
tryToSet(() -> stageEventBuilder.setJvmGcTime(stageCompleted.stageInfo().taskMetrics().jvmGCTime()));
tryToSet(() -> stageEventBuilder.setExecutorDeserializeTime(stageCompleted.stageInfo().taskMetrics().executorDeserializeTime()));
tryToSet(() -> stageEventBuilder.setResultSerializationTime(stageCompleted.stageInfo().taskMetrics().resultSerializationTime()));
内容来源于网络,如有侵权,请联系作者删除!