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