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