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