TaskData.fromJson constructor

TaskData.fromJson(
  1. Map json_
)

Implementation

TaskData.fromJson(core.Map json_)
  : this(
      accumulatorUpdates:
          (json_['accumulatorUpdates'] as core.List?)
              ?.map(
                (value) => AccumulableInfo.fromJson(
                  value as core.Map<core.String, core.dynamic>,
                ),
              )
              .toList(),
      attempt: json_['attempt'] as core.int?,
      durationMillis: json_['durationMillis'] as core.String?,
      errorMessage: json_['errorMessage'] as core.String?,
      executorId: json_['executorId'] as core.String?,
      executorLogs: (json_['executorLogs']
              as core.Map<core.String, core.dynamic>?)
          ?.map((key, value) => core.MapEntry(key, value as core.String)),
      gettingResultTimeMillis:
          json_['gettingResultTimeMillis'] as core.String?,
      hasMetrics: json_['hasMetrics'] as core.bool?,
      host: json_['host'] as core.String?,
      index: json_['index'] as core.int?,
      launchTime: json_['launchTime'] as core.String?,
      partitionId: json_['partitionId'] as core.int?,
      resultFetchStart: json_['resultFetchStart'] as core.String?,
      schedulerDelayMillis: json_['schedulerDelayMillis'] as core.String?,
      speculative: json_['speculative'] as core.bool?,
      stageAttemptId: json_['stageAttemptId'] as core.int?,
      stageId: json_['stageId'] as core.String?,
      status: json_['status'] as core.String?,
      taskId: json_['taskId'] as core.String?,
      taskLocality: json_['taskLocality'] as core.String?,
      taskMetrics:
          json_.containsKey('taskMetrics')
              ? TaskMetrics.fromJson(
                json_['taskMetrics'] as core.Map<core.String, core.dynamic>,
              )
              : null,
    );