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