ExecutorMetricsDistributions.fromJson constructor

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