<?php
# Generated by the protocol buffer compiler.  DO NOT EDIT!
# source: google/dataflow/v1beta3/streaming.proto

namespace GPBMetadata\Google\Dataflow\V1Beta3;

class Streaming
{
    public static $is_initialized = false;

    public static function initOnce() {
        $pool = \Google\Protobuf\Internal\DescriptorPool::getGeneratedPool();

        if (static::$is_initialized == true) {
          return;
        }
        $pool->internalAddGeneratedFile(
            '

\'google/dataflow/v1beta3/streaming.protogoogle.dataflow.v1beta3"
TopologyConfigB
computations (2,.google.dataflow.v1beta3.ComputationTopologyJ
data_disk_assignments (2+.google.dataflow.v1beta3.DataDiskAssignmentv
"user_stage_to_computation_name_map (2J.google.dataflow.v1beta3.TopologyConfig.UserStageToComputationNameMapEntry
forwarding_key_bits ( 
persistent_state_version (D
"UserStageToComputationNameMapEntry
key (	
value (	:8"
PubsubLocation
topic (	
subscription (	
timestamp_label (	
id_label (	
drop_late_data (
tracking_subscription (	
with_attributes ("+
StreamingStageLocation
	stream_id (	"?
StreamingSideInputLocation
tag (	
state_family (	"(
CustomSourceLocation
stateful ("
StreamLocationS
streaming_stage_location (2/.google.dataflow.v1beta3.StreamingStageLocationH B
pubsub_location (2\'.google.dataflow.v1beta3.PubsubLocationH R
side_input_location (23.google.dataflow.v1beta3.StreamingSideInputLocationH O
custom_source_location (2-.google.dataflow.v1beta3.CustomSourceLocationH B

location":
StateFamilyConfig
state_family (	
is_read ("
ComputationTopology
system_stage_name (	
computation_id (	=

key_ranges (2).google.dataflow.v1beta3.KeyRangeLocation7
inputs (2\'.google.dataflow.v1beta3.StreamLocation8
outputs (2\'.google.dataflow.v1beta3.StreamLocationB
state_families (2*.google.dataflow.v1beta3.StateFamilyConfig"
KeyRangeLocation
start (	
end (	
delivery_endpoint (	
	data_disk (	+
deprecated_persistent_directory (	B"$
MountedDataDisk
	data_disk (	"=
DataDiskAssignment
vm_instance (	

data_disks (	"K
KeyRangeDataDiskAssignment
start (	
end (	
	data_disk (	"
StreamingComputationRanges
computation_id (	N
range_assignments (23.google.dataflow.v1beta3.KeyRangeDataDiskAssignment"V
 StreamingApplianceSnapshotConfig
snapshot_id (	
import_state_endpoint (	B
com.google.dataflow.v1beta3BStreamingProtoPZ?google.golang.org/genproto/googleapis/dataflow/v1beta3;dataflowGoogle.Cloud.Dataflow.V1Beta3Google\\Cloud\\Dataflow\\V1beta3 Google::Cloud::Dataflow::V1beta3bproto3'
        , true);

        static::$is_initialized = true;
    }
}

