# Generated by the protocol buffer compiler.  DO NOT EDIT!
# source: schema.proto

import sys
_b=sys.version_info[0]<3 and (lambda x:x) or (lambda x:x.encode('latin1'))
from google.protobuf.internal import enum_type_wrapper
from google.protobuf import descriptor as _descriptor
from google.protobuf import message as _message
from google.protobuf import reflection as _reflection
from google.protobuf import symbol_database as _symbol_database
from google.protobuf import descriptor_pb2
# @@protoc_insertion_point(imports)

_sym_db = _symbol_database.Default()




DESCRIPTOR = _descriptor.FileDescriptor(
  name='schema.proto',
  package='org.apache.beam.model.pipeline.v1',
  syntax='proto3',
  serialized_pb=_b('\n\x0cschema.proto\x12!org.apache.beam.model.pipeline.v1\"N\n\x06Schema\x12\x38\n\x06\x66ields\x18\x01 \x03(\x0b\x32(.org.apache.beam.model.pipeline.v1.Field\x12\n\n\x02id\x18\x02 \x01(\t\"\x8d\x01\n\x05\x46ield\x12\x0c\n\x04name\x18\x01 \x01(\t\x12\x13\n\x0b\x64\x65scription\x18\x02 \x01(\t\x12:\n\x04type\x18\x03 \x01(\x0b\x32,.org.apache.beam.model.pipeline.v1.FieldType\x12\n\n\x02id\x18\x04 \x01(\x05\x12\x19\n\x11\x65ncoding_position\x18\x05 \x01(\x05\"\xfc\x02\n\tFieldType\x12\x10\n\x08nullable\x18\x01 \x01(\x08\x12\x44\n\x0b\x61tomic_type\x18\x02 \x01(\x0e\x32-.org.apache.beam.model.pipeline.v1.AtomicTypeH\x00\x12\x42\n\narray_type\x18\x03 \x01(\x0b\x32,.org.apache.beam.model.pipeline.v1.ArrayTypeH\x00\x12>\n\x08map_type\x18\x04 \x01(\x0b\x32*.org.apache.beam.model.pipeline.v1.MapTypeH\x00\x12>\n\x08row_type\x18\x05 \x01(\x0b\x32*.org.apache.beam.model.pipeline.v1.RowTypeH\x00\x12\x46\n\x0clogical_type\x18\x06 \x01(\x0b\x32..org.apache.beam.model.pipeline.v1.LogicalTypeH\x00\x42\x0b\n\ttype_info\"O\n\tArrayType\x12\x42\n\x0c\x65lement_type\x18\x01 \x01(\x0b\x32,.org.apache.beam.model.pipeline.v1.FieldType\"\x8b\x01\n\x07MapType\x12>\n\x08key_type\x18\x01 \x01(\x0b\x32,.org.apache.beam.model.pipeline.v1.FieldType\x12@\n\nvalue_type\x18\x02 \x01(\x0b\x32,.org.apache.beam.model.pipeline.v1.FieldType\"D\n\x07RowType\x12\x39\n\x06schema\x18\x01 \x01(\x0b\x32).org.apache.beam.model.pipeline.v1.Schema\"n\n\x0bLogicalType\x12\x0b\n\x03urn\x18\x01 \x01(\t\x12\x0c\n\x04\x61rgs\x18\x02 \x01(\t\x12\x44\n\x0erepresentation\x18\x03 \x01(\x0b\x32,.org.apache.beam.model.pipeline.v1.FieldType*\x83\x01\n\nAtomicType\x12\x0f\n\x0bUNSPECIFIED\x10\x00\x12\x08\n\x04\x42YTE\x10\x01\x12\t\n\x05INT16\x10\x02\x12\t\n\x05INT32\x10\x03\x12\t\n\x05INT64\x10\x04\x12\t\n\x05\x46LOAT\x10\x05\x12\n\n\x06\x44OUBLE\x10\x06\x12\n\n\x06STRING\x10\x07\x12\x0b\n\x07\x42OOLEAN\x10\x08\x12\t\n\x05\x42YTES\x10\tB;\n!org.apache.beam.model.pipeline.v1B\tSchemaApiZ\x0bpipeline_v1b\x06proto3')
)

_ATOMICTYPE = _descriptor.EnumDescriptor(
  name='AtomicType',
  full_name='org.apache.beam.model.pipeline.v1.AtomicType',
  filename=None,
  file=DESCRIPTOR,
  values=[
    _descriptor.EnumValueDescriptor(
      name='UNSPECIFIED', index=0, number=0,
      options=None,
      type=None),
    _descriptor.EnumValueDescriptor(
      name='BYTE', index=1, number=1,
      options=None,
      type=None),
    _descriptor.EnumValueDescriptor(
      name='INT16', index=2, number=2,
      options=None,
      type=None),
    _descriptor.EnumValueDescriptor(
      name='INT32', index=3, number=3,
      options=None,
      type=None),
    _descriptor.EnumValueDescriptor(
      name='INT64', index=4, number=4,
      options=None,
      type=None),
    _descriptor.EnumValueDescriptor(
      name='FLOAT', index=5, number=5,
      options=None,
      type=None),
    _descriptor.EnumValueDescriptor(
      name='DOUBLE', index=6, number=6,
      options=None,
      type=None),
    _descriptor.EnumValueDescriptor(
      name='STRING', index=7, number=7,
      options=None,
      type=None),
    _descriptor.EnumValueDescriptor(
      name='BOOLEAN', index=8, number=8,
      options=None,
      type=None),
    _descriptor.EnumValueDescriptor(
      name='BYTES', index=9, number=9,
      options=None,
      type=None),
  ],
  containing_type=None,
  options=None,
  serialized_start=1064,
  serialized_end=1195,
)
_sym_db.RegisterEnumDescriptor(_ATOMICTYPE)

AtomicType = enum_type_wrapper.EnumTypeWrapper(_ATOMICTYPE)
UNSPECIFIED = 0
BYTE = 1
INT16 = 2
INT32 = 3
INT64 = 4
FLOAT = 5
DOUBLE = 6
STRING = 7
BOOLEAN = 8
BYTES = 9



_SCHEMA = _descriptor.Descriptor(
  name='Schema',
  full_name='org.apache.beam.model.pipeline.v1.Schema',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='fields', full_name='org.apache.beam.model.pipeline.v1.Schema.fields', index=0,
      number=1, type=11, cpp_type=10, label=3,
      has_default_value=False, default_value=[],
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      options=None, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='id', full_name='org.apache.beam.model.pipeline.v1.Schema.id', index=1,
      number=2, type=9, cpp_type=9, label=1,
      has_default_value=False, default_value=_b("").decode('utf-8'),
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      options=None, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=51,
  serialized_end=129,
)


_FIELD = _descriptor.Descriptor(
  name='Field',
  full_name='org.apache.beam.model.pipeline.v1.Field',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='name', full_name='org.apache.beam.model.pipeline.v1.Field.name', index=0,
      number=1, type=9, cpp_type=9, label=1,
      has_default_value=False, default_value=_b("").decode('utf-8'),
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      options=None, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='description', full_name='org.apache.beam.model.pipeline.v1.Field.description', index=1,
      number=2, type=9, cpp_type=9, label=1,
      has_default_value=False, default_value=_b("").decode('utf-8'),
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      options=None, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='type', full_name='org.apache.beam.model.pipeline.v1.Field.type', index=2,
      number=3, type=11, cpp_type=10, label=1,
      has_default_value=False, default_value=None,
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      options=None, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='id', full_name='org.apache.beam.model.pipeline.v1.Field.id', index=3,
      number=4, type=5, cpp_type=1, label=1,
      has_default_value=False, default_value=0,
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      options=None, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='encoding_position', full_name='org.apache.beam.model.pipeline.v1.Field.encoding_position', index=4,
      number=5, type=5, cpp_type=1, label=1,
      has_default_value=False, default_value=0,
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      options=None, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=132,
  serialized_end=273,
)


_FIELDTYPE = _descriptor.Descriptor(
  name='FieldType',
  full_name='org.apache.beam.model.pipeline.v1.FieldType',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='nullable', full_name='org.apache.beam.model.pipeline.v1.FieldType.nullable', index=0,
      number=1, type=8, cpp_type=7, label=1,
      has_default_value=False, default_value=False,
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      options=None, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='atomic_type', full_name='org.apache.beam.model.pipeline.v1.FieldType.atomic_type', index=1,
      number=2, type=14, cpp_type=8, label=1,
      has_default_value=False, default_value=0,
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      options=None, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='array_type', full_name='org.apache.beam.model.pipeline.v1.FieldType.array_type', index=2,
      number=3, type=11, cpp_type=10, label=1,
      has_default_value=False, default_value=None,
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      options=None, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='map_type', full_name='org.apache.beam.model.pipeline.v1.FieldType.map_type', index=3,
      number=4, type=11, cpp_type=10, label=1,
      has_default_value=False, default_value=None,
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      options=None, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='row_type', full_name='org.apache.beam.model.pipeline.v1.FieldType.row_type', index=4,
      number=5, type=11, cpp_type=10, label=1,
      has_default_value=False, default_value=None,
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      options=None, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='logical_type', full_name='org.apache.beam.model.pipeline.v1.FieldType.logical_type', index=5,
      number=6, type=11, cpp_type=10, label=1,
      has_default_value=False, default_value=None,
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      options=None, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
    _descriptor.OneofDescriptor(
      name='type_info', full_name='org.apache.beam.model.pipeline.v1.FieldType.type_info',
      index=0, containing_type=None, fields=[]),
  ],
  serialized_start=276,
  serialized_end=656,
)


_ARRAYTYPE = _descriptor.Descriptor(
  name='ArrayType',
  full_name='org.apache.beam.model.pipeline.v1.ArrayType',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='element_type', full_name='org.apache.beam.model.pipeline.v1.ArrayType.element_type', index=0,
      number=1, type=11, cpp_type=10, label=1,
      has_default_value=False, default_value=None,
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      options=None, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=658,
  serialized_end=737,
)


_MAPTYPE = _descriptor.Descriptor(
  name='MapType',
  full_name='org.apache.beam.model.pipeline.v1.MapType',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='key_type', full_name='org.apache.beam.model.pipeline.v1.MapType.key_type', index=0,
      number=1, type=11, cpp_type=10, label=1,
      has_default_value=False, default_value=None,
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      options=None, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='value_type', full_name='org.apache.beam.model.pipeline.v1.MapType.value_type', index=1,
      number=2, type=11, cpp_type=10, label=1,
      has_default_value=False, default_value=None,
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      options=None, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=740,
  serialized_end=879,
)


_ROWTYPE = _descriptor.Descriptor(
  name='RowType',
  full_name='org.apache.beam.model.pipeline.v1.RowType',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='schema', full_name='org.apache.beam.model.pipeline.v1.RowType.schema', index=0,
      number=1, type=11, cpp_type=10, label=1,
      has_default_value=False, default_value=None,
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      options=None, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=881,
  serialized_end=949,
)


_LOGICALTYPE = _descriptor.Descriptor(
  name='LogicalType',
  full_name='org.apache.beam.model.pipeline.v1.LogicalType',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='urn', full_name='org.apache.beam.model.pipeline.v1.LogicalType.urn', index=0,
      number=1, type=9, cpp_type=9, label=1,
      has_default_value=False, default_value=_b("").decode('utf-8'),
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      options=None, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='args', full_name='org.apache.beam.model.pipeline.v1.LogicalType.args', index=1,
      number=2, type=9, cpp_type=9, label=1,
      has_default_value=False, default_value=_b("").decode('utf-8'),
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      options=None, file=DESCRIPTOR),
    _descriptor.FieldDescriptor(
      name='representation', full_name='org.apache.beam.model.pipeline.v1.LogicalType.representation', index=2,
      number=3, type=11, cpp_type=10, label=1,
      has_default_value=False, default_value=None,
      message_type=None, enum_type=None, containing_type=None,
      is_extension=False, extension_scope=None,
      options=None, file=DESCRIPTOR),
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
  ],
  options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=951,
  serialized_end=1061,
)

_SCHEMA.fields_by_name['fields'].message_type = _FIELD
_FIELD.fields_by_name['type'].message_type = _FIELDTYPE
_FIELDTYPE.fields_by_name['atomic_type'].enum_type = _ATOMICTYPE
_FIELDTYPE.fields_by_name['array_type'].message_type = _ARRAYTYPE
_FIELDTYPE.fields_by_name['map_type'].message_type = _MAPTYPE
_FIELDTYPE.fields_by_name['row_type'].message_type = _ROWTYPE
_FIELDTYPE.fields_by_name['logical_type'].message_type = _LOGICALTYPE
_FIELDTYPE.oneofs_by_name['type_info'].fields.append(
  _FIELDTYPE.fields_by_name['atomic_type'])
_FIELDTYPE.fields_by_name['atomic_type'].containing_oneof = _FIELDTYPE.oneofs_by_name['type_info']
_FIELDTYPE.oneofs_by_name['type_info'].fields.append(
  _FIELDTYPE.fields_by_name['array_type'])
_FIELDTYPE.fields_by_name['array_type'].containing_oneof = _FIELDTYPE.oneofs_by_name['type_info']
_FIELDTYPE.oneofs_by_name['type_info'].fields.append(
  _FIELDTYPE.fields_by_name['map_type'])
_FIELDTYPE.fields_by_name['map_type'].containing_oneof = _FIELDTYPE.oneofs_by_name['type_info']
_FIELDTYPE.oneofs_by_name['type_info'].fields.append(
  _FIELDTYPE.fields_by_name['row_type'])
_FIELDTYPE.fields_by_name['row_type'].containing_oneof = _FIELDTYPE.oneofs_by_name['type_info']
_FIELDTYPE.oneofs_by_name['type_info'].fields.append(
  _FIELDTYPE.fields_by_name['logical_type'])
_FIELDTYPE.fields_by_name['logical_type'].containing_oneof = _FIELDTYPE.oneofs_by_name['type_info']
_ARRAYTYPE.fields_by_name['element_type'].message_type = _FIELDTYPE
_MAPTYPE.fields_by_name['key_type'].message_type = _FIELDTYPE
_MAPTYPE.fields_by_name['value_type'].message_type = _FIELDTYPE
_ROWTYPE.fields_by_name['schema'].message_type = _SCHEMA
_LOGICALTYPE.fields_by_name['representation'].message_type = _FIELDTYPE
DESCRIPTOR.message_types_by_name['Schema'] = _SCHEMA
DESCRIPTOR.message_types_by_name['Field'] = _FIELD
DESCRIPTOR.message_types_by_name['FieldType'] = _FIELDTYPE
DESCRIPTOR.message_types_by_name['ArrayType'] = _ARRAYTYPE
DESCRIPTOR.message_types_by_name['MapType'] = _MAPTYPE
DESCRIPTOR.message_types_by_name['RowType'] = _ROWTYPE
DESCRIPTOR.message_types_by_name['LogicalType'] = _LOGICALTYPE
DESCRIPTOR.enum_types_by_name['AtomicType'] = _ATOMICTYPE
_sym_db.RegisterFileDescriptor(DESCRIPTOR)

Schema = _reflection.GeneratedProtocolMessageType('Schema', (_message.Message,), dict(
  DESCRIPTOR = _SCHEMA,
  __module__ = 'schema_pb2'
  # @@protoc_insertion_point(class_scope:org.apache.beam.model.pipeline.v1.Schema)
  ))
_sym_db.RegisterMessage(Schema)

Field = _reflection.GeneratedProtocolMessageType('Field', (_message.Message,), dict(
  DESCRIPTOR = _FIELD,
  __module__ = 'schema_pb2'
  # @@protoc_insertion_point(class_scope:org.apache.beam.model.pipeline.v1.Field)
  ))
_sym_db.RegisterMessage(Field)

FieldType = _reflection.GeneratedProtocolMessageType('FieldType', (_message.Message,), dict(
  DESCRIPTOR = _FIELDTYPE,
  __module__ = 'schema_pb2'
  # @@protoc_insertion_point(class_scope:org.apache.beam.model.pipeline.v1.FieldType)
  ))
_sym_db.RegisterMessage(FieldType)

ArrayType = _reflection.GeneratedProtocolMessageType('ArrayType', (_message.Message,), dict(
  DESCRIPTOR = _ARRAYTYPE,
  __module__ = 'schema_pb2'
  # @@protoc_insertion_point(class_scope:org.apache.beam.model.pipeline.v1.ArrayType)
  ))
_sym_db.RegisterMessage(ArrayType)

MapType = _reflection.GeneratedProtocolMessageType('MapType', (_message.Message,), dict(
  DESCRIPTOR = _MAPTYPE,
  __module__ = 'schema_pb2'
  # @@protoc_insertion_point(class_scope:org.apache.beam.model.pipeline.v1.MapType)
  ))
_sym_db.RegisterMessage(MapType)

RowType = _reflection.GeneratedProtocolMessageType('RowType', (_message.Message,), dict(
  DESCRIPTOR = _ROWTYPE,
  __module__ = 'schema_pb2'
  # @@protoc_insertion_point(class_scope:org.apache.beam.model.pipeline.v1.RowType)
  ))
_sym_db.RegisterMessage(RowType)

LogicalType = _reflection.GeneratedProtocolMessageType('LogicalType', (_message.Message,), dict(
  DESCRIPTOR = _LOGICALTYPE,
  __module__ = 'schema_pb2'
  # @@protoc_insertion_point(class_scope:org.apache.beam.model.pipeline.v1.LogicalType)
  ))
_sym_db.RegisterMessage(LogicalType)


DESCRIPTOR.has_options = True
DESCRIPTOR._options = _descriptor._ParseOptions(descriptor_pb2.FileOptions(), _b('\n!org.apache.beam.model.pipeline.v1B\tSchemaApiZ\013pipeline_v1'))
# @@protoc_insertion_point(module_scope)
