ExecutorMetricsDistributions.fromJson constructor

ExecutorMetricsDistributions.fromJson(
  1. Map json_
)

Implementation

ExecutorMetricsDistributions.fromJson(core.Map json_)
    : this(
        diskBytesSpilled: (json_['diskBytesSpilled'] as core.List?)
            ?.map((value) => (value as core.num).toDouble())
            .toList(),
        failedTasks: (json_['failedTasks'] as core.List?)
            ?.map((value) => (value as core.num).toDouble())
            .toList(),
        inputBytes: (json_['inputBytes'] as core.List?)
            ?.map((value) => (value as core.num).toDouble())
            .toList(),
        inputRecords: (json_['inputRecords'] as core.List?)
            ?.map((value) => (value as core.num).toDouble())
            .toList(),
        killedTasks: (json_['killedTasks'] as core.List?)
            ?.map((value) => (value as core.num).toDouble())
            .toList(),
        memoryBytesSpilled: (json_['memoryBytesSpilled'] as core.List?)
            ?.map((value) => (value as core.num).toDouble())
            .toList(),
        outputBytes: (json_['outputBytes'] as core.List?)
            ?.map((value) => (value as core.num).toDouble())
            .toList(),
        outputRecords: (json_['outputRecords'] as core.List?)
            ?.map((value) => (value as core.num).toDouble())
            .toList(),
        peakMemoryMetrics: json_.containsKey('peakMemoryMetrics')
            ? ExecutorPeakMetricsDistributions.fromJson(
                json_['peakMemoryMetrics']
                    as core.Map<core.String, core.dynamic>)
            : null,
        quantiles: (json_['quantiles'] as core.List?)
            ?.map((value) => (value as core.num).toDouble())
            .toList(),
        shuffleRead: (json_['shuffleRead'] as core.List?)
            ?.map((value) => (value as core.num).toDouble())
            .toList(),
        shuffleReadRecords: (json_['shuffleReadRecords'] as core.List?)
            ?.map((value) => (value as core.num).toDouble())
            .toList(),
        shuffleWrite: (json_['shuffleWrite'] as core.List?)
            ?.map((value) => (value as core.num).toDouble())
            .toList(),
        shuffleWriteRecords: (json_['shuffleWriteRecords'] as core.List?)
            ?.map((value) => (value as core.num).toDouble())
            .toList(),
        succeededTasks: (json_['succeededTasks'] as core.List?)
            ?.map((value) => (value as core.num).toDouble())
            .toList(),
        taskTimeMillis: (json_['taskTimeMillis'] as core.List?)
            ?.map((value) => (value as core.num).toDouble())
            .toList(),
      );