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