StreamingQueryProgress.fromJson constructor

StreamingQueryProgress.fromJson(Map json_)

Implementation

StreamingQueryProgress.fromJson(core.Map json_)
  : this(
      batchDuration: json_['batchDuration'] as core.String?,
      batchId: json_['batchId'] as core.String?,
      durationMillis:
          (json_['durationMillis'] as core.Map<core.String, core.dynamic>?)
              ?.map((key, value) => core.MapEntry(key, value as core.String)),
      eventTime: (json_['eventTime'] as core.Map<core.String, core.dynamic>?)
          ?.map((key, value) => core.MapEntry(key, value as core.String)),
      name: json_['name'] as core.String?,
      observedMetrics:
          (json_['observedMetrics'] as core.Map<core.String, core.dynamic>?)
              ?.map((key, value) => core.MapEntry(key, value as core.String)),
      runId: json_['runId'] as core.String?,
      sink: json_.containsKey('sink')
          ? SinkProgress.fromJson(
              json_['sink'] as core.Map<core.String, core.dynamic>,
            )
          : null,
      sources: (json_['sources'] as core.List?)
          ?.map(
            (value) => SourceProgress.fromJson(
              value as core.Map<core.String, core.dynamic>,
            ),
          )
          .toList(),
      stateOperators: (json_['stateOperators'] as core.List?)
          ?.map(
            (value) => StateOperatorProgress.fromJson(
              value as core.Map<core.String, core.dynamic>,
            ),
          )
          .toList(),
      streamingQueryProgressId:
          json_['streamingQueryProgressId'] as core.String?,
      timestamp: json_['timestamp'] as core.String?,
    );