SourceProgress.fromJson constructor

SourceProgress.fromJson(
  1. Map json_
)

Implementation

SourceProgress.fromJson(core.Map json_)
    : this(
        description: json_['description'] as core.String?,
        endOffset: json_['endOffset'] as core.String?,
        inputRowsPerSecond:
            (json_['inputRowsPerSecond'] as core.num?)?.toDouble(),
        latestOffset: json_['latestOffset'] as core.String?,
        metrics:
            (json_['metrics'] as core.Map<core.String, core.dynamic>?)?.map(
          (key, value) => core.MapEntry(
            key,
            value as core.String,
          ),
        ),
        numInputRows: json_['numInputRows'] as core.String?,
        processedRowsPerSecond:
            (json_['processedRowsPerSecond'] as core.num?)?.toDouble(),
        startOffset: json_['startOffset'] as core.String?,
      );