ExecutorSummary.fromJson constructor

ExecutorSummary.fromJson(Map json_)

Implementation

ExecutorSummary.fromJson(core.Map json_)
  : this(
      activeTasks: json_['activeTasks'] as core.int?,
      addTime: json_['addTime'] as core.String?,
      attributes: (json_['attributes']
              as core.Map<core.String, core.dynamic>?)
          ?.map((key, value) => core.MapEntry(key, value as core.String)),
      completedTasks: json_['completedTasks'] as core.int?,
      diskUsed: json_['diskUsed'] as core.String?,
      excludedInStages:
          (json_['excludedInStages'] as core.List?)
              ?.map((value) => value as core.String)
              .toList(),
      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)),
      failedTasks: json_['failedTasks'] as core.int?,
      hostPort: json_['hostPort'] as core.String?,
      isActive: json_['isActive'] as core.bool?,
      isExcluded: json_['isExcluded'] as core.bool?,
      maxMemory: json_['maxMemory'] as core.String?,
      maxTasks: json_['maxTasks'] as core.int?,
      memoryMetrics:
          json_.containsKey('memoryMetrics')
              ? MemoryMetrics.fromJson(
                json_['memoryMetrics'] as core.Map<core.String, core.dynamic>,
              )
              : null,
      memoryUsed: json_['memoryUsed'] as core.String?,
      peakMemoryMetrics:
          json_.containsKey('peakMemoryMetrics')
              ? ExecutorMetrics.fromJson(
                json_['peakMemoryMetrics']
                    as core.Map<core.String, core.dynamic>,
              )
              : null,
      rddBlocks: json_['rddBlocks'] as core.int?,
      removeReason: json_['removeReason'] as core.String?,
      removeTime: json_['removeTime'] as core.String?,
      resourceProfileId: json_['resourceProfileId'] as core.int?,
      resources: (json_['resources'] as core.Map<core.String, core.dynamic>?)
          ?.map(
            (key, value) => core.MapEntry(
              key,
              ResourceInformation.fromJson(
                value as core.Map<core.String, core.dynamic>,
              ),
            ),
          ),
      totalCores: json_['totalCores'] as core.int?,
      totalDurationMillis: json_['totalDurationMillis'] as core.String?,
      totalGcTimeMillis: json_['totalGcTimeMillis'] as core.String?,
      totalInputBytes: json_['totalInputBytes'] as core.String?,
      totalShuffleRead: json_['totalShuffleRead'] as core.String?,
      totalShuffleWrite: json_['totalShuffleWrite'] as core.String?,
      totalTasks: json_['totalTasks'] as core.int?,
    );