StateOperatorProgress.fromJson constructor

StateOperatorProgress.fromJson(
  1. Map json_
)

Implementation

StateOperatorProgress.fromJson(core.Map json_)
    : this(
        allRemovalsTimeMs: json_['allRemovalsTimeMs'] as core.String?,
        allUpdatesTimeMs: json_['allUpdatesTimeMs'] as core.String?,
        commitTimeMs: json_['commitTimeMs'] as core.String?,
        customMetrics:
            (json_['customMetrics'] as core.Map<core.String, core.dynamic>?)
                ?.map(
          (key, value) => core.MapEntry(
            key,
            value as core.String,
          ),
        ),
        memoryUsedBytes: json_['memoryUsedBytes'] as core.String?,
        numRowsDroppedByWatermark:
            json_['numRowsDroppedByWatermark'] as core.String?,
        numRowsRemoved: json_['numRowsRemoved'] as core.String?,
        numRowsTotal: json_['numRowsTotal'] as core.String?,
        numRowsUpdated: json_['numRowsUpdated'] as core.String?,
        numShufflePartitions: json_['numShufflePartitions'] as core.String?,
        numStateStoreInstances:
            json_['numStateStoreInstances'] as core.String?,
        operatorName: json_['operatorName'] as core.String?,
      );