StageData.fromJson constructor

StageData.fromJson(Map json_)

Implementation

StageData.fromJson(core.Map json_)
    : this(
        accumulatorUpdates: (json_['accumulatorUpdates'] as core.List?)
            ?.map((value) => AccumulableInfo.fromJson(
                value as core.Map<core.String, core.dynamic>))
            .toList(),
        completionTime: json_['completionTime'] as core.String?,
        description: json_['description'] as core.String?,
        details: json_['details'] as core.String?,
        executorMetricsDistributions:
            json_.containsKey('executorMetricsDistributions')
                ? ExecutorMetricsDistributions.fromJson(
                    json_['executorMetricsDistributions']
                        as core.Map<core.String, core.dynamic>)
                : null,
        executorSummary:
            (json_['executorSummary'] as core.Map<core.String, core.dynamic>?)
                ?.map(
          (key, value) => core.MapEntry(
            key,
            ExecutorStageSummary.fromJson(
                value as core.Map<core.String, core.dynamic>),
          ),
        ),
        failureReason: json_['failureReason'] as core.String?,
        firstTaskLaunchedTime: json_['firstTaskLaunchedTime'] as core.String?,
        isShufflePushEnabled: json_['isShufflePushEnabled'] as core.bool?,
        jobIds: (json_['jobIds'] as core.List?)
            ?.map((value) => value as core.String)
            .toList(),
        killedTasksSummary: (json_['killedTasksSummary']
                as core.Map<core.String, core.dynamic>?)
            ?.map(
          (key, value) => core.MapEntry(
            key,
            value as core.int,
          ),
        ),
        locality:
            (json_['locality'] as core.Map<core.String, core.dynamic>?)?.map(
          (key, value) => core.MapEntry(
            key,
            value as core.String,
          ),
        ),
        name: json_['name'] as core.String?,
        numActiveTasks: json_['numActiveTasks'] as core.int?,
        numCompleteTasks: json_['numCompleteTasks'] as core.int?,
        numCompletedIndices: json_['numCompletedIndices'] as core.int?,
        numFailedTasks: json_['numFailedTasks'] as core.int?,
        numKilledTasks: json_['numKilledTasks'] as core.int?,
        numTasks: json_['numTasks'] as core.int?,
        parentStageIds: (json_['parentStageIds'] as core.List?)
            ?.map((value) => value as core.String)
            .toList(),
        peakExecutorMetrics: json_.containsKey('peakExecutorMetrics')
            ? ExecutorMetrics.fromJson(json_['peakExecutorMetrics']
                as core.Map<core.String, core.dynamic>)
            : null,
        rddIds: (json_['rddIds'] as core.List?)
            ?.map((value) => value as core.String)
            .toList(),
        resourceProfileId: json_['resourceProfileId'] as core.int?,
        schedulingPool: json_['schedulingPool'] as core.String?,
        shuffleMergersCount: json_['shuffleMergersCount'] as core.int?,
        speculationSummary: json_.containsKey('speculationSummary')
            ? SpeculationStageSummary.fromJson(json_['speculationSummary']
                as core.Map<core.String, core.dynamic>)
            : null,
        stageAttemptId: json_['stageAttemptId'] as core.int?,
        stageId: json_['stageId'] as core.String?,
        stageMetrics: json_.containsKey('stageMetrics')
            ? StageMetrics.fromJson(
                json_['stageMetrics'] as core.Map<core.String, core.dynamic>)
            : null,
        status: json_['status'] as core.String?,
        submissionTime: json_['submissionTime'] as core.String?,
        taskQuantileMetrics: json_.containsKey('taskQuantileMetrics')
            ? TaskQuantileMetrics.fromJson(json_['taskQuantileMetrics']
                as core.Map<core.String, core.dynamic>)
            : null,
        tasks: (json_['tasks'] as core.Map<core.String, core.dynamic>?)?.map(
          (key, value) => core.MapEntry(
            key,
            TaskData.fromJson(value as core.Map<core.String, core.dynamic>),
          ),
        ),
      );