from __future__ import absolute_import
# Generated by the protocol buffer compiler.  DO NOT EDIT!
# source: standard_window_fns.proto

import sys
_b=sys.version_info[0]<3 and (lambda x:x) or (lambda x:x.encode('latin1'))
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()


from . import beam_runner_api_pb2 as beam__runner__api__pb2
from google.protobuf import duration_pb2 as google_dot_protobuf_dot_duration__pb2
from google.protobuf import timestamp_pb2 as google_dot_protobuf_dot_timestamp__pb2


DESCRIPTOR = _descriptor.FileDescriptor(
  name='standard_window_fns.proto',
  package='org.apache.beam.model.pipeline.v1',
  syntax='proto3',
  serialized_pb=_b('\n\x19standard_window_fns.proto\x12!org.apache.beam.model.pipeline.v1\x1a\x15\x62\x65\x61m_runner_api.proto\x1a\x1egoogle/protobuf/duration.proto\x1a\x1fgoogle/protobuf/timestamp.proto\"W\n\x14GlobalWindowsPayload\"?\n\x04\x45num\x12\x37\n\nPROPERTIES\x10\x00\x1a\'\xa2\xb4\xfa\xc2\x05!beam:windowfn:global_windows:v0.1\"\xaa\x01\n\x13\x46ixedWindowsPayload\x12\'\n\x04size\x18\x01 \x01(\x0b\x32\x19.google.protobuf.Duration\x12*\n\x06offset\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\">\n\x04\x45num\x12\x36\n\nPROPERTIES\x10\x00\x1a&\xa2\xb4\xfa\xc2\x05 beam:windowfn:fixed_windows:v0.1\"\xd9\x01\n\x15SlidingWindowsPayload\x12\'\n\x04size\x18\x01 \x01(\x0b\x32\x19.google.protobuf.Duration\x12*\n\x06offset\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12)\n\x06period\x18\x03 \x01(\x0b\x32\x19.google.protobuf.Duration\"@\n\x04\x45num\x12\x38\n\nPROPERTIES\x10\x00\x1a(\xa2\xb4\xfa\xc2\x05\"beam:windowfn:sliding_windows:v0.1\"\x80\x01\n\x0fSessionsPayload\x12+\n\x08gap_size\x18\x01 \x01(\x0b\x32\x19.google.protobuf.Duration\"@\n\x04\x45num\x12\x38\n\nPROPERTIES\x10\x00\x1a(\xa2\xb4\xfa\xc2\x05\"beam:windowfn:session_windows:v0.1BC\n!org.apache.beam.model.pipeline.v1B\x11StandardWindowFnsZ\x0bpipeline_v1b\x06proto3')
  ,
  dependencies=[beam__runner__api__pb2.DESCRIPTOR,google_dot_protobuf_dot_duration__pb2.DESCRIPTOR,google_dot_protobuf_dot_timestamp__pb2.DESCRIPTOR,])



_GLOBALWINDOWSPAYLOAD_ENUM = _descriptor.EnumDescriptor(
  name='Enum',
  full_name='org.apache.beam.model.pipeline.v1.GlobalWindowsPayload.Enum',
  filename=None,
  file=DESCRIPTOR,
  values=[
    _descriptor.EnumValueDescriptor(
      name='PROPERTIES', index=0, number=0,
      options=_descriptor._ParseOptions(descriptor_pb2.EnumValueOptions(), _b('\242\264\372\302\005!beam:windowfn:global_windows:v0.1')),
      type=None),
  ],
  containing_type=None,
  options=None,
  serialized_start=176,
  serialized_end=239,
)
_sym_db.RegisterEnumDescriptor(_GLOBALWINDOWSPAYLOAD_ENUM)

_FIXEDWINDOWSPAYLOAD_ENUM = _descriptor.EnumDescriptor(
  name='Enum',
  full_name='org.apache.beam.model.pipeline.v1.FixedWindowsPayload.Enum',
  filename=None,
  file=DESCRIPTOR,
  values=[
    _descriptor.EnumValueDescriptor(
      name='PROPERTIES', index=0, number=0,
      options=_descriptor._ParseOptions(descriptor_pb2.EnumValueOptions(), _b('\242\264\372\302\005 beam:windowfn:fixed_windows:v0.1')),
      type=None),
  ],
  containing_type=None,
  options=None,
  serialized_start=350,
  serialized_end=412,
)
_sym_db.RegisterEnumDescriptor(_FIXEDWINDOWSPAYLOAD_ENUM)

_SLIDINGWINDOWSPAYLOAD_ENUM = _descriptor.EnumDescriptor(
  name='Enum',
  full_name='org.apache.beam.model.pipeline.v1.SlidingWindowsPayload.Enum',
  filename=None,
  file=DESCRIPTOR,
  values=[
    _descriptor.EnumValueDescriptor(
      name='PROPERTIES', index=0, number=0,
      options=_descriptor._ParseOptions(descriptor_pb2.EnumValueOptions(), _b('\242\264\372\302\005\"beam:windowfn:sliding_windows:v0.1')),
      type=None),
  ],
  containing_type=None,
  options=None,
  serialized_start=568,
  serialized_end=632,
)
_sym_db.RegisterEnumDescriptor(_SLIDINGWINDOWSPAYLOAD_ENUM)

_SESSIONSPAYLOAD_ENUM = _descriptor.EnumDescriptor(
  name='Enum',
  full_name='org.apache.beam.model.pipeline.v1.SessionsPayload.Enum',
  filename=None,
  file=DESCRIPTOR,
  values=[
    _descriptor.EnumValueDescriptor(
      name='PROPERTIES', index=0, number=0,
      options=_descriptor._ParseOptions(descriptor_pb2.EnumValueOptions(), _b('\242\264\372\302\005\"beam:windowfn:session_windows:v0.1')),
      type=None),
  ],
  containing_type=None,
  options=None,
  serialized_start=699,
  serialized_end=763,
)
_sym_db.RegisterEnumDescriptor(_SESSIONSPAYLOAD_ENUM)


_GLOBALWINDOWSPAYLOAD = _descriptor.Descriptor(
  name='GlobalWindowsPayload',
  full_name='org.apache.beam.model.pipeline.v1.GlobalWindowsPayload',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
  ],
  extensions=[
  ],
  nested_types=[],
  enum_types=[
    _GLOBALWINDOWSPAYLOAD_ENUM,
  ],
  options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=152,
  serialized_end=239,
)


_FIXEDWINDOWSPAYLOAD = _descriptor.Descriptor(
  name='FixedWindowsPayload',
  full_name='org.apache.beam.model.pipeline.v1.FixedWindowsPayload',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='size', full_name='org.apache.beam.model.pipeline.v1.FixedWindowsPayload.size', 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='offset', full_name='org.apache.beam.model.pipeline.v1.FixedWindowsPayload.offset', 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=[
    _FIXEDWINDOWSPAYLOAD_ENUM,
  ],
  options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=242,
  serialized_end=412,
)


_SLIDINGWINDOWSPAYLOAD = _descriptor.Descriptor(
  name='SlidingWindowsPayload',
  full_name='org.apache.beam.model.pipeline.v1.SlidingWindowsPayload',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='size', full_name='org.apache.beam.model.pipeline.v1.SlidingWindowsPayload.size', 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='offset', full_name='org.apache.beam.model.pipeline.v1.SlidingWindowsPayload.offset', 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),
    _descriptor.FieldDescriptor(
      name='period', full_name='org.apache.beam.model.pipeline.v1.SlidingWindowsPayload.period', 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=[
    _SLIDINGWINDOWSPAYLOAD_ENUM,
  ],
  options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=415,
  serialized_end=632,
)


_SESSIONSPAYLOAD = _descriptor.Descriptor(
  name='SessionsPayload',
  full_name='org.apache.beam.model.pipeline.v1.SessionsPayload',
  filename=None,
  file=DESCRIPTOR,
  containing_type=None,
  fields=[
    _descriptor.FieldDescriptor(
      name='gap_size', full_name='org.apache.beam.model.pipeline.v1.SessionsPayload.gap_size', 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=[
    _SESSIONSPAYLOAD_ENUM,
  ],
  options=None,
  is_extendable=False,
  syntax='proto3',
  extension_ranges=[],
  oneofs=[
  ],
  serialized_start=635,
  serialized_end=763,
)

_GLOBALWINDOWSPAYLOAD_ENUM.containing_type = _GLOBALWINDOWSPAYLOAD
_FIXEDWINDOWSPAYLOAD.fields_by_name['size'].message_type = google_dot_protobuf_dot_duration__pb2._DURATION
_FIXEDWINDOWSPAYLOAD.fields_by_name['offset'].message_type = google_dot_protobuf_dot_timestamp__pb2._TIMESTAMP
_FIXEDWINDOWSPAYLOAD_ENUM.containing_type = _FIXEDWINDOWSPAYLOAD
_SLIDINGWINDOWSPAYLOAD.fields_by_name['size'].message_type = google_dot_protobuf_dot_duration__pb2._DURATION
_SLIDINGWINDOWSPAYLOAD.fields_by_name['offset'].message_type = google_dot_protobuf_dot_timestamp__pb2._TIMESTAMP
_SLIDINGWINDOWSPAYLOAD.fields_by_name['period'].message_type = google_dot_protobuf_dot_duration__pb2._DURATION
_SLIDINGWINDOWSPAYLOAD_ENUM.containing_type = _SLIDINGWINDOWSPAYLOAD
_SESSIONSPAYLOAD.fields_by_name['gap_size'].message_type = google_dot_protobuf_dot_duration__pb2._DURATION
_SESSIONSPAYLOAD_ENUM.containing_type = _SESSIONSPAYLOAD
DESCRIPTOR.message_types_by_name['GlobalWindowsPayload'] = _GLOBALWINDOWSPAYLOAD
DESCRIPTOR.message_types_by_name['FixedWindowsPayload'] = _FIXEDWINDOWSPAYLOAD
DESCRIPTOR.message_types_by_name['SlidingWindowsPayload'] = _SLIDINGWINDOWSPAYLOAD
DESCRIPTOR.message_types_by_name['SessionsPayload'] = _SESSIONSPAYLOAD
_sym_db.RegisterFileDescriptor(DESCRIPTOR)

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

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

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

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


DESCRIPTOR.has_options = True
DESCRIPTOR._options = _descriptor._ParseOptions(descriptor_pb2.FileOptions(), _b('\n!org.apache.beam.model.pipeline.v1B\021StandardWindowFnsZ\013pipeline_v1'))
_GLOBALWINDOWSPAYLOAD_ENUM.values_by_name["PROPERTIES"].has_options = True
_GLOBALWINDOWSPAYLOAD_ENUM.values_by_name["PROPERTIES"]._options = _descriptor._ParseOptions(descriptor_pb2.EnumValueOptions(), _b('\242\264\372\302\005!beam:windowfn:global_windows:v0.1'))
_FIXEDWINDOWSPAYLOAD_ENUM.values_by_name["PROPERTIES"].has_options = True
_FIXEDWINDOWSPAYLOAD_ENUM.values_by_name["PROPERTIES"]._options = _descriptor._ParseOptions(descriptor_pb2.EnumValueOptions(), _b('\242\264\372\302\005 beam:windowfn:fixed_windows:v0.1'))
_SLIDINGWINDOWSPAYLOAD_ENUM.values_by_name["PROPERTIES"].has_options = True
_SLIDINGWINDOWSPAYLOAD_ENUM.values_by_name["PROPERTIES"]._options = _descriptor._ParseOptions(descriptor_pb2.EnumValueOptions(), _b('\242\264\372\302\005\"beam:windowfn:sliding_windows:v0.1'))
_SESSIONSPAYLOAD_ENUM.values_by_name["PROPERTIES"].has_options = True
_SESSIONSPAYLOAD_ENUM.values_by_name["PROPERTIES"]._options = _descriptor._ParseOptions(descriptor_pb2.EnumValueOptions(), _b('\242\264\372\302\005\"beam:windowfn:session_windows:v0.1'))
# @@protoc_insertion_point(module_scope)
