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,
    );