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