/*
 * Copyright 2020 Google LLC
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *     https://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
// Generated by the protocol buffer compiler.  DO NOT EDIT!
// source: google/dataflow/v1beta3/streaming.proto

package com.google.dataflow.v1beta3;

public final class StreamingProto {
  private StreamingProto() {}

  public static void registerAllExtensions(com.google.protobuf.ExtensionRegistryLite registry) {}

  public static void registerAllExtensions(com.google.protobuf.ExtensionRegistry registry) {
    registerAllExtensions((com.google.protobuf.ExtensionRegistryLite) registry);
  }

  static final com.google.protobuf.Descriptors.Descriptor
      internal_static_google_dataflow_v1beta3_TopologyConfig_descriptor;
  static final com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
      internal_static_google_dataflow_v1beta3_TopologyConfig_fieldAccessorTable;
  static final com.google.protobuf.Descriptors.Descriptor
      internal_static_google_dataflow_v1beta3_TopologyConfig_UserStageToComputationNameMapEntry_descriptor;
  static final com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
      internal_static_google_dataflow_v1beta3_TopologyConfig_UserStageToComputationNameMapEntry_fieldAccessorTable;
  static final com.google.protobuf.Descriptors.Descriptor
      internal_static_google_dataflow_v1beta3_PubsubLocation_descriptor;
  static final com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
      internal_static_google_dataflow_v1beta3_PubsubLocation_fieldAccessorTable;
  static final com.google.protobuf.Descriptors.Descriptor
      internal_static_google_dataflow_v1beta3_StreamingStageLocation_descriptor;
  static final com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
      internal_static_google_dataflow_v1beta3_StreamingStageLocation_fieldAccessorTable;
  static final com.google.protobuf.Descriptors.Descriptor
      internal_static_google_dataflow_v1beta3_StreamingSideInputLocation_descriptor;
  static final com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
      internal_static_google_dataflow_v1beta3_StreamingSideInputLocation_fieldAccessorTable;
  static final com.google.protobuf.Descriptors.Descriptor
      internal_static_google_dataflow_v1beta3_CustomSourceLocation_descriptor;
  static final com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
      internal_static_google_dataflow_v1beta3_CustomSourceLocation_fieldAccessorTable;
  static final com.google.protobuf.Descriptors.Descriptor
      internal_static_google_dataflow_v1beta3_StreamLocation_descriptor;
  static final com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
      internal_static_google_dataflow_v1beta3_StreamLocation_fieldAccessorTable;
  static final com.google.protobuf.Descriptors.Descriptor
      internal_static_google_dataflow_v1beta3_StateFamilyConfig_descriptor;
  static final com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
      internal_static_google_dataflow_v1beta3_StateFamilyConfig_fieldAccessorTable;
  static final com.google.protobuf.Descriptors.Descriptor
      internal_static_google_dataflow_v1beta3_ComputationTopology_descriptor;
  static final com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
      internal_static_google_dataflow_v1beta3_ComputationTopology_fieldAccessorTable;
  static final com.google.protobuf.Descriptors.Descriptor
      internal_static_google_dataflow_v1beta3_KeyRangeLocation_descriptor;
  static final com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
      internal_static_google_dataflow_v1beta3_KeyRangeLocation_fieldAccessorTable;
  static final com.google.protobuf.Descriptors.Descriptor
      internal_static_google_dataflow_v1beta3_MountedDataDisk_descriptor;
  static final com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
      internal_static_google_dataflow_v1beta3_MountedDataDisk_fieldAccessorTable;
  static final com.google.protobuf.Descriptors.Descriptor
      internal_static_google_dataflow_v1beta3_DataDiskAssignment_descriptor;
  static final com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
      internal_static_google_dataflow_v1beta3_DataDiskAssignment_fieldAccessorTable;
  static final com.google.protobuf.Descriptors.Descriptor
      internal_static_google_dataflow_v1beta3_KeyRangeDataDiskAssignment_descriptor;
  static final com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
      internal_static_google_dataflow_v1beta3_KeyRangeDataDiskAssignment_fieldAccessorTable;
  static final com.google.protobuf.Descriptors.Descriptor
      internal_static_google_dataflow_v1beta3_StreamingComputationRanges_descriptor;
  static final com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
      internal_static_google_dataflow_v1beta3_StreamingComputationRanges_fieldAccessorTable;
  static final com.google.protobuf.Descriptors.Descriptor
      internal_static_google_dataflow_v1beta3_StreamingApplianceSnapshotConfig_descriptor;
  static final com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
      internal_static_google_dataflow_v1beta3_StreamingApplianceSnapshotConfig_fieldAccessorTable;

  public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() {
    return descriptor;
  }

  private static com.google.protobuf.Descriptors.FileDescriptor descriptor;

  static {
    java.lang.String[] descriptorData = {
      "\n\'google/dataflow/v1beta3/streaming.prot"
          + "o\022\027google.dataflow.v1beta3\"\235\003\n\016TopologyC"
          + "onfig\022B\n\014computations\030\001 \003(\0132,.google.dat"
          + "aflow.v1beta3.ComputationTopology\022J\n\025dat"
          + "a_disk_assignments\030\002 \003(\0132+.google.datafl"
          + "ow.v1beta3.DataDiskAssignment\022v\n\"user_st"
          + "age_to_computation_name_map\030\003 \003(\0132J.goog"
          + "le.dataflow.v1beta3.TopologyConfig.UserS"
          + "tageToComputationNameMapEntry\022\033\n\023forward"
          + "ing_key_bits\030\004 \001(\005\022 \n\030persistent_state_v"
          + "ersion\030\005 \001(\005\032D\n\"UserStageToComputationNa"
          + "meMapEntry\022\013\n\003key\030\001 \001(\t\022\r\n\005value\030\002 \001(\t:\002"
          + "8\001\"\260\001\n\016PubsubLocation\022\r\n\005topic\030\001 \001(\t\022\024\n\014"
          + "subscription\030\002 \001(\t\022\027\n\017timestamp_label\030\003 "
          + "\001(\t\022\020\n\010id_label\030\004 \001(\t\022\026\n\016drop_late_data\030"
          + "\005 \001(\010\022\035\n\025tracking_subscription\030\006 \001(\t\022\027\n\017"
          + "with_attributes\030\007 \001(\010\"+\n\026StreamingStageL"
          + "ocation\022\021\n\tstream_id\030\001 \001(\t\"?\n\032StreamingS"
          + "ideInputLocation\022\013\n\003tag\030\001 \001(\t\022\024\n\014state_f"
          + "amily\030\002 \001(\t\"(\n\024CustomSourceLocation\022\020\n\010s"
          + "tateful\030\001 \001(\010\"\332\002\n\016StreamLocation\022S\n\030stre"
          + "aming_stage_location\030\001 \001(\0132/.google.data"
          + "flow.v1beta3.StreamingStageLocationH\000\022B\n"
          + "\017pubsub_location\030\002 \001(\0132\'.google.dataflow"
          + ".v1beta3.PubsubLocationH\000\022R\n\023side_input_"
          + "location\030\003 \001(\01323.google.dataflow.v1beta3"
          + ".StreamingSideInputLocationH\000\022O\n\026custom_"
          + "source_location\030\004 \001(\0132-.google.dataflow."
          + "v1beta3.CustomSourceLocationH\000B\n\n\010locati"
          + "on\":\n\021StateFamilyConfig\022\024\n\014state_family\030"
          + "\001 \001(\t\022\017\n\007is_read\030\002 \001(\010\"\276\002\n\023ComputationTo"
          + "pology\022\031\n\021system_stage_name\030\001 \001(\t\022\026\n\016com"
          + "putation_id\030\005 \001(\t\022=\n\nkey_ranges\030\002 \003(\0132)."
          + "google.dataflow.v1beta3.KeyRangeLocation"
          + "\0227\n\006inputs\030\003 \003(\0132\'.google.dataflow.v1bet"
          + "a3.StreamLocation\0228\n\007outputs\030\004 \003(\0132\'.goo"
          + "gle.dataflow.v1beta3.StreamLocation\022B\n\016s"
          + "tate_families\030\007 \003(\0132*.google.dataflow.v1"
          + "beta3.StateFamilyConfig\"\211\001\n\020KeyRangeLoca"
          + "tion\022\r\n\005start\030\001 \001(\t\022\013\n\003end\030\002 \001(\t\022\031\n\021deli"
          + "very_endpoint\030\003 \001(\t\022\021\n\tdata_disk\030\005 \001(\t\022+"
          + "\n\037deprecated_persistent_directory\030\004 \001(\tB"
          + "\002\030\001\"$\n\017MountedDataDisk\022\021\n\tdata_disk\030\001 \001("
          + "\t\"=\n\022DataDiskAssignment\022\023\n\013vm_instance\030\001"
          + " \001(\t\022\022\n\ndata_disks\030\002 \003(\t\"K\n\032KeyRangeData"
          + "DiskAssignment\022\r\n\005start\030\001 \001(\t\022\013\n\003end\030\002 \001"
          + "(\t\022\021\n\tdata_disk\030\003 \001(\t\"\204\001\n\032StreamingCompu"
          + "tationRanges\022\026\n\016computation_id\030\001 \001(\t\022N\n\021"
          + "range_assignments\030\002 \003(\01323.google.dataflo"
          + "w.v1beta3.KeyRangeDataDiskAssignment\"V\n "
          + "StreamingApplianceSnapshotConfig\022\023\n\013snap"
          + "shot_id\030\001 \001(\t\022\035\n\025import_state_endpoint\030\002"
          + " \001(\tB\323\001\n\033com.google.dataflow.v1beta3B\016St"
          + "reamingProtoP\001Z?google.golang.org/genpro"
          + "to/googleapis/dataflow/v1beta3;dataflow\252"
          + "\002\035Google.Cloud.Dataflow.V1Beta3\312\002\035Google"
          + "\\Cloud\\Dataflow\\V1beta3\352\002 Google::Cloud:"
          + ":Dataflow::V1beta3b\006proto3"
    };
    descriptor =
        com.google.protobuf.Descriptors.FileDescriptor.internalBuildGeneratedFileFrom(
            descriptorData, new com.google.protobuf.Descriptors.FileDescriptor[] {});
    internal_static_google_dataflow_v1beta3_TopologyConfig_descriptor =
        getDescriptor().getMessageTypes().get(0);
    internal_static_google_dataflow_v1beta3_TopologyConfig_fieldAccessorTable =
        new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
            internal_static_google_dataflow_v1beta3_TopologyConfig_descriptor,
            new java.lang.String[] {
              "Computations",
              "DataDiskAssignments",
              "UserStageToComputationNameMap",
              "ForwardingKeyBits",
              "PersistentStateVersion",
            });
    internal_static_google_dataflow_v1beta3_TopologyConfig_UserStageToComputationNameMapEntry_descriptor =
        internal_static_google_dataflow_v1beta3_TopologyConfig_descriptor.getNestedTypes().get(0);
    internal_static_google_dataflow_v1beta3_TopologyConfig_UserStageToComputationNameMapEntry_fieldAccessorTable =
        new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
            internal_static_google_dataflow_v1beta3_TopologyConfig_UserStageToComputationNameMapEntry_descriptor,
            new java.lang.String[] {
              "Key", "Value",
            });
    internal_static_google_dataflow_v1beta3_PubsubLocation_descriptor =
        getDescriptor().getMessageTypes().get(1);
    internal_static_google_dataflow_v1beta3_PubsubLocation_fieldAccessorTable =
        new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
            internal_static_google_dataflow_v1beta3_PubsubLocation_descriptor,
            new java.lang.String[] {
              "Topic",
              "Subscription",
              "TimestampLabel",
              "IdLabel",
              "DropLateData",
              "TrackingSubscription",
              "WithAttributes",
            });
    internal_static_google_dataflow_v1beta3_StreamingStageLocation_descriptor =
        getDescriptor().getMessageTypes().get(2);
    internal_static_google_dataflow_v1beta3_StreamingStageLocation_fieldAccessorTable =
        new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
            internal_static_google_dataflow_v1beta3_StreamingStageLocation_descriptor,
            new java.lang.String[] {
              "StreamId",
            });
    internal_static_google_dataflow_v1beta3_StreamingSideInputLocation_descriptor =
        getDescriptor().getMessageTypes().get(3);
    internal_static_google_dataflow_v1beta3_StreamingSideInputLocation_fieldAccessorTable =
        new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
            internal_static_google_dataflow_v1beta3_StreamingSideInputLocation_descriptor,
            new java.lang.String[] {
              "Tag", "StateFamily",
            });
    internal_static_google_dataflow_v1beta3_CustomSourceLocation_descriptor =
        getDescriptor().getMessageTypes().get(4);
    internal_static_google_dataflow_v1beta3_CustomSourceLocation_fieldAccessorTable =
        new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
            internal_static_google_dataflow_v1beta3_CustomSourceLocation_descriptor,
            new java.lang.String[] {
              "Stateful",
            });
    internal_static_google_dataflow_v1beta3_StreamLocation_descriptor =
        getDescriptor().getMessageTypes().get(5);
    internal_static_google_dataflow_v1beta3_StreamLocation_fieldAccessorTable =
        new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
            internal_static_google_dataflow_v1beta3_StreamLocation_descriptor,
            new java.lang.String[] {
              "StreamingStageLocation",
              "PubsubLocation",
              "SideInputLocation",
              "CustomSourceLocation",
              "Location",
            });
    internal_static_google_dataflow_v1beta3_StateFamilyConfig_descriptor =
        getDescriptor().getMessageTypes().get(6);
    internal_static_google_dataflow_v1beta3_StateFamilyConfig_fieldAccessorTable =
        new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
            internal_static_google_dataflow_v1beta3_StateFamilyConfig_descriptor,
            new java.lang.String[] {
              "StateFamily", "IsRead",
            });
    internal_static_google_dataflow_v1beta3_ComputationTopology_descriptor =
        getDescriptor().getMessageTypes().get(7);
    internal_static_google_dataflow_v1beta3_ComputationTopology_fieldAccessorTable =
        new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
            internal_static_google_dataflow_v1beta3_ComputationTopology_descriptor,
            new java.lang.String[] {
              "SystemStageName", "ComputationId", "KeyRanges", "Inputs", "Outputs", "StateFamilies",
            });
    internal_static_google_dataflow_v1beta3_KeyRangeLocation_descriptor =
        getDescriptor().getMessageTypes().get(8);
    internal_static_google_dataflow_v1beta3_KeyRangeLocation_fieldAccessorTable =
        new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
            internal_static_google_dataflow_v1beta3_KeyRangeLocation_descriptor,
            new java.lang.String[] {
              "Start", "End", "DeliveryEndpoint", "DataDisk", "DeprecatedPersistentDirectory",
            });
    internal_static_google_dataflow_v1beta3_MountedDataDisk_descriptor =
        getDescriptor().getMessageTypes().get(9);
    internal_static_google_dataflow_v1beta3_MountedDataDisk_fieldAccessorTable =
        new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
            internal_static_google_dataflow_v1beta3_MountedDataDisk_descriptor,
            new java.lang.String[] {
              "DataDisk",
            });
    internal_static_google_dataflow_v1beta3_DataDiskAssignment_descriptor =
        getDescriptor().getMessageTypes().get(10);
    internal_static_google_dataflow_v1beta3_DataDiskAssignment_fieldAccessorTable =
        new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
            internal_static_google_dataflow_v1beta3_DataDiskAssignment_descriptor,
            new java.lang.String[] {
              "VmInstance", "DataDisks",
            });
    internal_static_google_dataflow_v1beta3_KeyRangeDataDiskAssignment_descriptor =
        getDescriptor().getMessageTypes().get(11);
    internal_static_google_dataflow_v1beta3_KeyRangeDataDiskAssignment_fieldAccessorTable =
        new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
            internal_static_google_dataflow_v1beta3_KeyRangeDataDiskAssignment_descriptor,
            new java.lang.String[] {
              "Start", "End", "DataDisk",
            });
    internal_static_google_dataflow_v1beta3_StreamingComputationRanges_descriptor =
        getDescriptor().getMessageTypes().get(12);
    internal_static_google_dataflow_v1beta3_StreamingComputationRanges_fieldAccessorTable =
        new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
            internal_static_google_dataflow_v1beta3_StreamingComputationRanges_descriptor,
            new java.lang.String[] {
              "ComputationId", "RangeAssignments",
            });
    internal_static_google_dataflow_v1beta3_StreamingApplianceSnapshotConfig_descriptor =
        getDescriptor().getMessageTypes().get(13);
    internal_static_google_dataflow_v1beta3_StreamingApplianceSnapshotConfig_fieldAccessorTable =
        new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
            internal_static_google_dataflow_v1beta3_StreamingApplianceSnapshotConfig_descriptor,
            new java.lang.String[] {
              "SnapshotId", "ImportStateEndpoint",
            });
  }

  // @@protoc_insertion_point(outer_class_scope)
}
