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