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