NAME
Google::Dataflow::V1beta3::Streaming::TopologyConfig - Compiled Protocol Buffers message class
SYNOPSIS
use Google::Dataflow::V1beta3::Streaming;
my $msg = Google::Dataflow::V1beta3::Streaming::TopologyConfig->new(
computations => $value,
);FIELDS
computations
Type: Message (.google.dataflow.v1beta3.ComputationTopology)
data_disk_assignments
Type: Message (.google.dataflow.v1beta3.DataDiskAssignment)
user_stage_to_computation_name_map
Type: Message (.google.dataflow.v1beta3.TopologyConfig.UserStageToComputationNameMapEntry)
forwarding_key_bits
Type: Int32
persistent_state_version
Type: Int32
NAME
Google::Dataflow::V1beta3::Streaming::PubsubLocation - Compiled Protocol Buffers message class
SYNOPSIS
use Google::Dataflow::V1beta3::Streaming;
my $msg = Google::Dataflow::V1beta3::Streaming::PubsubLocation->new(
topic => $value,
);FIELDS
topic
Type: String
subscription
Type: String
timestamp_label
Type: String
id_label
Type: String
drop_late_data
Type: Bool
tracking_subscription
Type: String
with_attributes
Type: Bool
dynamic_destinations
Type: Bool
NAME
Google::Dataflow::V1beta3::Streaming::StreamingStageLocation - Compiled Protocol Buffers message class
SYNOPSIS
use Google::Dataflow::V1beta3::Streaming;
my $msg = Google::Dataflow::V1beta3::Streaming::StreamingStageLocation->new(
stream_id => $value,
);FIELDS
stream_id
Type: String
NAME
Google::Dataflow::V1beta3::Streaming::StreamingSideInputLocation - Compiled Protocol Buffers message class
SYNOPSIS
use Google::Dataflow::V1beta3::Streaming;
my $msg = Google::Dataflow::V1beta3::Streaming::StreamingSideInputLocation->new(
tag => $value,
);FIELDS
tag
Type: String
state_family
Type: String
NAME
Google::Dataflow::V1beta3::Streaming::CustomSourceLocation - Compiled Protocol Buffers message class
SYNOPSIS
use Google::Dataflow::V1beta3::Streaming;
my $msg = Google::Dataflow::V1beta3::Streaming::CustomSourceLocation->new(
stateful => $value,
);FIELDS
stateful
Type: Bool
NAME
Google::Dataflow::V1beta3::Streaming::StreamLocation - Compiled Protocol Buffers message class
SYNOPSIS
use Google::Dataflow::V1beta3::Streaming;
my $msg = Google::Dataflow::V1beta3::Streaming::StreamLocation->new(
streaming_stage_location => $value,
);FIELDS
streaming_stage_location
Type: Message (.google.dataflow.v1beta3.StreamingStageLocation)
pubsub_location
Type: Message (.google.dataflow.v1beta3.PubsubLocation)
side_input_location
Type: Message (.google.dataflow.v1beta3.StreamingSideInputLocation)
custom_source_location
Type: Message (.google.dataflow.v1beta3.CustomSourceLocation)
NAME
Google::Dataflow::V1beta3::Streaming::StateFamilyConfig - Compiled Protocol Buffers message class
SYNOPSIS
use Google::Dataflow::V1beta3::Streaming;
my $msg = Google::Dataflow::V1beta3::Streaming::StateFamilyConfig->new(
state_family => $value,
);FIELDS
state_family
Type: String
is_read
Type: Bool
NAME
Google::Dataflow::V1beta3::Streaming::ComputationTopology - Compiled Protocol Buffers message class
SYNOPSIS
use Google::Dataflow::V1beta3::Streaming;
my $msg = Google::Dataflow::V1beta3::Streaming::ComputationTopology->new(
system_stage_name => $value,
);FIELDS
system_stage_name
Type: String
computation_id
Type: String
key_ranges
Type: Message (.google.dataflow.v1beta3.KeyRangeLocation)
inputs
Type: Message (.google.dataflow.v1beta3.StreamLocation)
outputs
Type: Message (.google.dataflow.v1beta3.StreamLocation)
state_families
Type: Message (.google.dataflow.v1beta3.StateFamilyConfig)
NAME
Google::Dataflow::V1beta3::Streaming::KeyRangeLocation - Compiled Protocol Buffers message class
SYNOPSIS
use Google::Dataflow::V1beta3::Streaming;
my $msg = Google::Dataflow::V1beta3::Streaming::KeyRangeLocation->new(
start => $value,
);FIELDS
start
Type: String
end
Type: String
delivery_endpoint
Type: String
data_disk
Type: String
deprecated_persistent_directory
Type: String
NAME
Google::Dataflow::V1beta3::Streaming::MountedDataDisk - Compiled Protocol Buffers message class
SYNOPSIS
use Google::Dataflow::V1beta3::Streaming;
my $msg = Google::Dataflow::V1beta3::Streaming::MountedDataDisk->new(
data_disk => $value,
);FIELDS
data_disk
Type: String
NAME
Google::Dataflow::V1beta3::Streaming::DataDiskAssignment - Compiled Protocol Buffers message class
SYNOPSIS
use Google::Dataflow::V1beta3::Streaming;
my $msg = Google::Dataflow::V1beta3::Streaming::DataDiskAssignment->new(
vm_instance => $value,
);FIELDS
vm_instance
Type: String
data_disks
Type: String
NAME
Google::Dataflow::V1beta3::Streaming::KeyRangeDataDiskAssignment - Compiled Protocol Buffers message class
SYNOPSIS
use Google::Dataflow::V1beta3::Streaming;
my $msg = Google::Dataflow::V1beta3::Streaming::KeyRangeDataDiskAssignment->new(
start => $value,
);FIELDS
start
Type: String
end
Type: String
data_disk
Type: String
NAME
Google::Dataflow::V1beta3::Streaming::StreamingComputationRanges - Compiled Protocol Buffers message class
SYNOPSIS
use Google::Dataflow::V1beta3::Streaming;
my $msg = Google::Dataflow::V1beta3::Streaming::StreamingComputationRanges->new(
computation_id => $value,
);FIELDS
computation_id
Type: String
range_assignments
Type: Message (.google.dataflow.v1beta3.KeyRangeDataDiskAssignment)
NAME
Google::Dataflow::V1beta3::Streaming::StreamingApplianceSnapshotConfig - Compiled Protocol Buffers message class
SYNOPSIS
use Google::Dataflow::V1beta3::Streaming;
my $msg = Google::Dataflow::V1beta3::Streaming::StreamingApplianceSnapshotConfig->new(
snapshot_id => $value,
);FIELDS
snapshot_id
Type: String
import_state_endpoint
Type: String
NAME
Google::Dataflow::V1beta3::Streaming - Protocol Buffers schema definition
DESCRIPTION
Auto-generated Protocol Buffers schema definition class.
LICENSE AND COPYRIGHT
Copyright (C) 2026 Google LLC
This program is released under the Apache 2.0 license.