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