TaskMetrics.fromJson constructor

TaskMetrics.fromJson(
  1. Map json_
)

Implementation

TaskMetrics.fromJson(core.Map json_)
    : this(
        diskBytesSpilled: json_['diskBytesSpilled'] as core.String?,
        executorCpuTimeNanos: json_['executorCpuTimeNanos'] as core.String?,
        executorDeserializeCpuTimeNanos:
            json_['executorDeserializeCpuTimeNanos'] as core.String?,
        executorDeserializeTimeMillis:
            json_['executorDeserializeTimeMillis'] as core.String?,
        executorRunTimeMillis: json_['executorRunTimeMillis'] as core.String?,
        inputMetrics: json_.containsKey('inputMetrics')
            ? InputMetrics.fromJson(
                json_['inputMetrics'] as core.Map<core.String, core.dynamic>)
            : null,
        jvmGcTimeMillis: json_['jvmGcTimeMillis'] as core.String?,
        memoryBytesSpilled: json_['memoryBytesSpilled'] as core.String?,
        outputMetrics: json_.containsKey('outputMetrics')
            ? OutputMetrics.fromJson(
                json_['outputMetrics'] as core.Map<core.String, core.dynamic>)
            : null,
        peakExecutionMemoryBytes:
            json_['peakExecutionMemoryBytes'] as core.String?,
        resultSerializationTimeMillis:
            json_['resultSerializationTimeMillis'] as core.String?,
        resultSize: json_['resultSize'] as core.String?,
        shuffleReadMetrics: json_.containsKey('shuffleReadMetrics')
            ? ShuffleReadMetrics.fromJson(json_['shuffleReadMetrics']
                as core.Map<core.String, core.dynamic>)
            : null,
        shuffleWriteMetrics: json_.containsKey('shuffleWriteMetrics')
            ? ShuffleWriteMetrics.fromJson(json_['shuffleWriteMetrics']
                as core.Map<core.String, core.dynamic>)
            : null,
      );