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