TopologyConfig

import type { TopologyConfig } from "https://googleapis.deno.dev/v1/dataflow:v1b3.ts";

Global topology of the streaming Dataflow job, including all computations and their sharded locations.

interface TopologyConfig {

dataDiskAssignments?: DataDiskAssignment[];

forwardingKeyBits?: number;

persistentStateVersion?: number;

userStageToComputationNameMap?: {

[key: string]: string;

};

}

§Properties

The computations associated with a streaming Dataflow job.

dataDiskAssignments?: DataDiskAssignment[]

The disks assigned to a streaming Dataflow job.

forwardingKeyBits?: number

The size (in bits) of keys that will be assigned to source messages.

persistentStateVersion?: number

Version number for persistent state.

userStageToComputationNameMap?: {

[key: string]: string;

}

Maps user stage names to stable computation names.