StreamingQueryProgress
import type { StreamingQueryProgress } from "https://googleapis.deno.dev/v1/dataproc:v1.ts";
interface StreamingQueryProgress {
batchDuration?: bigint;
batchId?: bigint;
durationMillis?: {};
[key: string]: bigint;
eventTime?: {};
[key: string]: string;
name?: string;
observedMetrics?: {};
[key: string]: string;
runId?: string;
sink?: SinkProgress;
sources?: SourceProgress[];
stateOperators?: StateOperatorProgress[];
streamingQueryProgressId?: string;
timestamp?: string;
}§Properties
§
sink?: SinkProgress
[src]§
sources?: SourceProgress[]
[src]§
stateOperators?: StateOperatorProgress[]
[src]