StreamingQueryProgress constructor

StreamingQueryProgress({
  1. String? batchDuration,
  2. String? batchId,
  3. Map<String, String>? durationMillis,
  4. Map<String, String>? eventTime,
  5. String? name,
  6. Map<String, String>? observedMetrics,
  7. String? runId,
  8. SinkProgress? sink,
  9. List<SourceProgress>? sources,
  10. List<StateOperatorProgress>? stateOperators,
  11. String? streamingQueryProgressId,
  12. String? timestamp,
})

Implementation

StreamingQueryProgress({
  this.batchDuration,
  this.batchId,
  this.durationMillis,
  this.eventTime,
  this.name,
  this.observedMetrics,
  this.runId,
  this.sink,
  this.sources,
  this.stateOperators,
  this.streamingQueryProgressId,
  this.timestamp,
});