YugabyteDB (2.13.0.0-b42, bfc6a6643e7399ac8a0e81d06a3ee6d6571b33ab)

// Generated by the protocol buffer compiler.  DO NOT EDIT!

// source: yb/cdc/cdc_consumer.proto

#include "yb/cdc/cdc_consumer.pb.h"

#include <algorithm>

#include <google/protobuf/stubs/common.h>

#include <google/protobuf/stubs/port.h>

#include <google/protobuf/stubs/once.h>

#include <google/protobuf/io/coded_stream.h>

#include <google/protobuf/wire_format_lite_inl.h>

#include <google/protobuf/descriptor.h>

#include <google/protobuf/generated_message_reflection.h>

#include <google/protobuf/reflection_ops.h>

#include <google/protobuf/wire_format.h>

// This is a temporary google only hack

#ifdef GOOGLE_PROTOBUF_ENFORCE_UNIQUENESS

#include "third_party/protobuf/version.h"

#endif

#include "yb/util/protobuf-annotations.h"

// @@protoc_insertion_point(includes)

namespace yb {

namespace cdc {

class ProducerTabletListPBDefaultTypeInternal {

 public:

  ::google::protobuf::internal::ExplicitlyConstructed<ProducerTabletListPB>

      _instance;

} _ProducerTabletListPB_default_instance_;

class StreamEntryPB_ConsumerProducerTabletMapEntry_DoNotUseDefaultTypeInternal {

 public:

  ::google::protobuf::internal::ExplicitlyConstructed<StreamEntryPB_ConsumerProducerTabletMapEntry_DoNotUse>

      _instance;

} _StreamEntryPB_ConsumerProducerTabletMapEntry_DoNotUse_default_instance_;

class StreamEntryPBDefaultTypeInternal {

 public:

  ::google::protobuf::internal::ExplicitlyConstructed<StreamEntryPB>

      _instance;

} _StreamEntryPB_default_instance_;

class ProducerEntryPB_StreamMapEntry_DoNotUseDefaultTypeInternal {

 public:

  ::google::protobuf::internal::ExplicitlyConstructed<ProducerEntryPB_StreamMapEntry_DoNotUse>

      _instance;

} _ProducerEntryPB_StreamMapEntry_DoNotUse_default_instance_;

class ProducerEntryPBDefaultTypeInternal {

 public:

  ::google::protobuf::internal::ExplicitlyConstructed<ProducerEntryPB>

      _instance;

} _ProducerEntryPB_default_instance_;

class ConsumerRegistryPB_ProducerMapEntry_DoNotUseDefaultTypeInternal {

 public:

  ::google::protobuf::internal::ExplicitlyConstructed<ConsumerRegistryPB_ProducerMapEntry_DoNotUse>

      _instance;

} _ConsumerRegistryPB_ProducerMapEntry_DoNotUse_default_instance_;

class ConsumerRegistryPBDefaultTypeInternal {

 public:

  ::google::protobuf::internal::ExplicitlyConstructed<ConsumerRegistryPB>

      _instance;

} _ConsumerRegistryPB_default_instance_;

}  // namespace cdc

}  // namespace yb

namespace protobuf_yb_2fcdc_2fcdc_5fconsumer_2eproto {

void InitDefaultsProducerTabletListPBImpl() {

  GOOGLE_PROTOBUF_VERIFY_VERSION;

#ifdef GOOGLE_PROTOBUF_ENFORCE_UNIQUENESS

  ::google::protobuf::internal::InitProtobufDefaultsForceUnique();

#else

  ::google::protobuf::internal::InitProtobufDefaults();

#endif  // GOOGLE_PROTOBUF_ENFORCE_UNIQUENESS

  {

    void* ptr = &::yb::cdc::_ProducerTabletListPB_default_instance_;

    new (ptr) ::yb::cdc::ProducerTabletListPB();

    ::google::protobuf::internal::OnShutdownDestroyMessage(ptr);

  }

  ::yb::cdc::ProducerTabletListPB::InitAsDefaultInstance();

}

void InitDefaultsProducerTabletListPB() {

  static GOOGLE_PROTOBUF_DECLARE_ONCE(once);

  ::google::protobuf::GoogleOnceInit(&once, &InitDefaultsProducerTabletListPBImpl);

}

void InitDefaultsStreamEntryPB_ConsumerProducerTabletMapEntry_DoNotUseImpl() {

  GOOGLE_PROTOBUF_VERIFY_VERSION;

#ifdef GOOGLE_PROTOBUF_ENFORCE_UNIQUENESS

  ::google::protobuf::internal::InitProtobufDefaultsForceUnique();

#else

  ::google::protobuf::internal::InitProtobufDefaults();

#endif  // GOOGLE_PROTOBUF_ENFORCE_UNIQUENESS

  protobuf_yb_2fcdc_2fcdc_5fconsumer_2eproto::InitDefaultsProducerTabletListPB();

  {

    void* ptr = &::yb::cdc::_StreamEntryPB_ConsumerProducerTabletMapEntry_DoNotUse_default_instance_;

    new (ptr) ::yb::cdc::StreamEntryPB_ConsumerProducerTabletMapEntry_DoNotUse();

  }

  ::yb::cdc::StreamEntryPB_ConsumerProducerTabletMapEntry_DoNotUse::InitAsDefaultInstance();

}

void InitDefaultsStreamEntryPB_ConsumerProducerTabletMapEntry_DoNotUse() {

  static GOOGLE_PROTOBUF_DECLARE_ONCE(once);

  ::google::protobuf::GoogleOnceInit(&once, &InitDefaultsStreamEntryPB_ConsumerProducerTabletMapEntry_DoNotUseImpl);

}

void InitDefaultsStreamEntryPBImpl() {

  GOOGLE_PROTOBUF_VERIFY_VERSION;

#ifdef GOOGLE_PROTOBUF_ENFORCE_UNIQUENESS

  ::google::protobuf::internal::InitProtobufDefaultsForceUnique();

#else

  ::google::protobuf::internal::InitProtobufDefaults();

#endif  // GOOGLE_PROTOBUF_ENFORCE_UNIQUENESS

  protobuf_yb_2fcdc_2fcdc_5fconsumer_2eproto::InitDefaultsStreamEntryPB_ConsumerProducerTabletMapEntry_DoNotUse();

  {

    void* ptr = &::yb::cdc::_StreamEntryPB_default_instance_;

    new (ptr) ::yb::cdc::StreamEntryPB();

    ::google::protobuf::internal::OnShutdownDestroyMessage(ptr);

  }

  ::yb::cdc::StreamEntryPB::InitAsDefaultInstance();

}

void InitDefaultsStreamEntryPB() {

  static GOOGLE_PROTOBUF_DECLARE_ONCE(once);

  ::google::protobuf::GoogleOnceInit(&once, &InitDefaultsStreamEntryPBImpl);

}

void InitDefaultsProducerEntryPB_StreamMapEntry_DoNotUseImpl() {

  GOOGLE_PROTOBUF_VERIFY_VERSION;

#ifdef GOOGLE_PROTOBUF_ENFORCE_UNIQUENESS

  ::google::protobuf::internal::InitProtobufDefaultsForceUnique();

#else

  ::google::protobuf::internal::InitProtobufDefaults();

#endif  // GOOGLE_PROTOBUF_ENFORCE_UNIQUENESS

  protobuf_yb_2fcdc_2fcdc_5fconsumer_2eproto::InitDefaultsStreamEntryPB();

  {

    void* ptr = &::yb::cdc::_ProducerEntryPB_StreamMapEntry_DoNotUse_default_instance_;

    new (ptr) ::yb::cdc::ProducerEntryPB_StreamMapEntry_DoNotUse();

  }

  ::yb::cdc::ProducerEntryPB_StreamMapEntry_DoNotUse::InitAsDefaultInstance();

}

void InitDefaultsProducerEntryPB_StreamMapEntry_DoNotUse() {

  static GOOGLE_PROTOBUF_DECLARE_ONCE(once);

  ::google::protobuf::GoogleOnceInit(&once, &InitDefaultsProducerEntryPB_StreamMapEntry_DoNotUseImpl);

}

void InitDefaultsProducerEntryPBImpl() {

  GOOGLE_PROTOBUF_VERIFY_VERSION;

#ifdef GOOGLE_PROTOBUF_ENFORCE_UNIQUENESS

  ::google::protobuf::internal::InitProtobufDefaultsForceUnique();

#else

  ::google::protobuf::internal::InitProtobufDefaults();

#endif  // GOOGLE_PROTOBUF_ENFORCE_UNIQUENESS

  protobuf_yb_2fcdc_2fcdc_5fconsumer_2eproto::InitDefaultsProducerEntryPB_StreamMapEntry_DoNotUse();

  protobuf_yb_2fcommon_2fcommon_5fnet_2eproto::InitDefaultsHostPortPB();

  {

    void* ptr = &::yb::cdc::_ProducerEntryPB_default_instance_;

    new (ptr) ::yb::cdc::ProducerEntryPB();

    ::google::protobuf::internal::OnShutdownDestroyMessage(ptr);

  }

  ::yb::cdc::ProducerEntryPB::InitAsDefaultInstance();

}

void InitDefaultsProducerEntryPB() {

  static GOOGLE_PROTOBUF_DECLARE_ONCE(once);

  ::google::protobuf::GoogleOnceInit(&once, &InitDefaultsProducerEntryPBImpl);

}

void InitDefaultsConsumerRegistryPB_ProducerMapEntry_DoNotUseImpl() {

  GOOGLE_PROTOBUF_VERIFY_VERSION;

#ifdef GOOGLE_PROTOBUF_ENFORCE_UNIQUENESS

  ::google::protobuf::internal::InitProtobufDefaultsForceUnique();

#else

  ::google::protobuf::internal::InitProtobufDefaults();

#endif  // GOOGLE_PROTOBUF_ENFORCE_UNIQUENESS

  protobuf_yb_2fcdc_2fcdc_5fconsumer_2eproto::InitDefaultsProducerEntryPB();

  {

    void* ptr = &::yb::cdc::_ConsumerRegistryPB_ProducerMapEntry_DoNotUse_default_instance_;

    new (ptr) ::yb::cdc::ConsumerRegistryPB_ProducerMapEntry_DoNotUse();

  }

  ::yb::cdc::ConsumerRegistryPB_ProducerMapEntry_DoNotUse::InitAsDefaultInstance();

}

void InitDefaultsConsumerRegistryPB_ProducerMapEntry_DoNotUse() {

  static GOOGLE_PROTOBUF_DECLARE_ONCE(once);

  ::google::protobuf::GoogleOnceInit(&once, &InitDefaultsConsumerRegistryPB_ProducerMapEntry_DoNotUseImpl);

}

void InitDefaultsConsumerRegistryPBImpl() {

  GOOGLE_PROTOBUF_VERIFY_VERSION;

#ifdef GOOGLE_PROTOBUF_ENFORCE_UNIQUENESS

  ::google::protobuf::internal::InitProtobufDefaultsForceUnique();

#else

  ::google::protobuf::internal::InitProtobufDefaults();

#endif  // GOOGLE_PROTOBUF_ENFORCE_UNIQUENESS

  protobuf_yb_2fcdc_2fcdc_5fconsumer_2eproto::InitDefaultsConsumerRegistryPB_ProducerMapEntry_DoNotUse();

  {

    void* ptr = &::yb::cdc::_ConsumerRegistryPB_default_instance_;

    new (ptr) ::yb::cdc::ConsumerRegistryPB();

    ::google::protobuf::internal::OnShutdownDestroyMessage(ptr);

  }

  ::yb::cdc::ConsumerRegistryPB::InitAsDefaultInstance();

}

void InitDefaultsConsumerRegistryPB() {

  static GOOGLE_PROTOBUF_DECLARE_ONCE(once);

  ::google::protobuf::GoogleOnceInit(&once, &InitDefaultsConsumerRegistryPBImpl);

}

::google::protobuf::Metadata file_level_metadata[7];

const ::google::protobuf::uint32 TableStruct::offsets[] GOOGLE_PROTOBUF_ATTRIBUTE_SECTION_VARIABLE(protodesc_cold) = {

  ~0u,  // no _has_bits_

  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::cdc::ProducerTabletListPB, _internal_metadata_),

  ~0u,  // no _extensions_

  ~0u,  // no _oneof_case_

  ~0u,  // no _weak_field_map_

  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::cdc::ProducerTabletListPB, tablets_),

  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::cdc::StreamEntryPB_ConsumerProducerTabletMapEntry_DoNotUse, _has_bits_),

  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::cdc::StreamEntryPB_ConsumerProducerTabletMapEntry_DoNotUse, _internal_metadata_),

  ~0u,  // no _extensions_

  ~0u,  // no _oneof_case_

  ~0u,  // no _weak_field_map_

  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::cdc::StreamEntryPB_ConsumerProducerTabletMapEntry_DoNotUse, key_),

  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::cdc::StreamEntryPB_ConsumerProducerTabletMapEntry_DoNotUse, value_),

  0,

  1,

  ~0u,  // no _has_bits_

  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::cdc::StreamEntryPB, _internal_metadata_),

  ~0u,  // no _extensions_

  ~0u,  // no _oneof_case_

  ~0u,  // no _weak_field_map_

  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::cdc::StreamEntryPB, consumer_producer_tablet_map_),

  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::cdc::StreamEntryPB, consumer_table_id_),

  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::cdc::StreamEntryPB, producer_table_id_),

  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::cdc::StreamEntryPB, same_num_producer_consumer_tablets_),

  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::cdc::ProducerEntryPB_StreamMapEntry_DoNotUse, _has_bits_),

  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::cdc::ProducerEntryPB_StreamMapEntry_DoNotUse, _internal_metadata_),

  ~0u,  // no _extensions_

  ~0u,  // no _oneof_case_

  ~0u,  // no _weak_field_map_

  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::cdc::ProducerEntryPB_StreamMapEntry_DoNotUse, key_),

  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::cdc::ProducerEntryPB_StreamMapEntry_DoNotUse, value_),

  0,

  1,

  ~0u,  // no _has_bits_

  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::cdc::ProducerEntryPB, _internal_metadata_),

  ~0u,  // no _extensions_

  ~0u,  // no _oneof_case_

  ~0u,  // no _weak_field_map_

  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::cdc::ProducerEntryPB, stream_map_),

  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::cdc::ProducerEntryPB, master_addrs_),

  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::cdc::ProducerEntryPB, tserver_addrs_),

  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::cdc::ProducerEntryPB, disable_stream_),

  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::cdc::ConsumerRegistryPB_ProducerMapEntry_DoNotUse, _has_bits_),

  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::cdc::ConsumerRegistryPB_ProducerMapEntry_DoNotUse, _internal_metadata_),

  ~0u,  // no _extensions_

  ~0u,  // no _oneof_case_

  ~0u,  // no _weak_field_map_

  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::cdc::ConsumerRegistryPB_ProducerMapEntry_DoNotUse, key_),

  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::cdc::ConsumerRegistryPB_ProducerMapEntry_DoNotUse, value_),

  0,

  1,

  ~0u,  // no _has_bits_

  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::cdc::ConsumerRegistryPB, _internal_metadata_),

  ~0u,  // no _extensions_

  ~0u,  // no _oneof_case_

  ~0u,  // no _weak_field_map_

  GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(::yb::cdc::ConsumerRegistryPB, producer_map_),

};

static const ::google::protobuf::internal::MigrationSchema schemas[] GOOGLE_PROTOBUF_ATTRIBUTE_SECTION_VARIABLE(protodesc_cold) = {

  { 0, -1, sizeof(::yb::cdc::ProducerTabletListPB)},

  { 6, 13, sizeof(::yb::cdc::StreamEntryPB_ConsumerProducerTabletMapEntry_DoNotUse)},

  { 15, -1, sizeof(::yb::cdc::StreamEntryPB)},

  { 24, 31, sizeof(::yb::cdc::ProducerEntryPB_StreamMapEntry_DoNotUse)},

  { 33, -1, sizeof(::yb::cdc::ProducerEntryPB)},

  { 42, 49, sizeof(::yb::cdc::ConsumerRegistryPB_ProducerMapEntry_DoNotUse)},

  { 51, -1, sizeof(::yb::cdc::ConsumerRegistryPB)},

};

static ::google::protobuf::Message const * const file_default_instances[] = {

  reinterpret_cast<const ::google::protobuf::Message*>(&::yb::cdc::_ProducerTabletListPB_default_instance_),

  reinterpret_cast<const ::google::protobuf::Message*>(&::yb::cdc::_StreamEntryPB_ConsumerProducerTabletMapEntry_DoNotUse_default_instance_),

  reinterpret_cast<const ::google::protobuf::Message*>(&::yb::cdc::_StreamEntryPB_default_instance_),

  reinterpret_cast<const ::google::protobuf::Message*>(&::yb::cdc::_ProducerEntryPB_StreamMapEntry_DoNotUse_default_instance_),

  reinterpret_cast<const ::google::protobuf::Message*>(&::yb::cdc::_ProducerEntryPB_default_instance_),

  reinterpret_cast<const ::google::protobuf::Message*>(&::yb::cdc::_ConsumerRegistryPB_ProducerMapEntry_DoNotUse_default_instance_),

  reinterpret_cast<const ::google::protobuf::Message*>(&::yb::cdc::_ConsumerRegistryPB_default_instance_),

};

void protobuf_AssignDescriptors() {

  AddDescriptors();

  ::google::protobuf::MessageFactory* factory = NULL;

  AssignDescriptors(

      "yb/cdc/cdc_consumer.proto", schemas, file_default_instances, TableStruct::offsets, factory,

      file_level_metadata, NULL, NULL);

}

void protobuf_AssignDescriptorsOnce() {

  static GOOGLE_PROTOBUF_DECLARE_ONCE(once);

  ::google::protobuf::GoogleOnceInit(&once, &protobuf_AssignDescriptors);

}

void protobuf_RegisterTypes(const ::std::string&) GOOGLE_PROTOBUF_ATTRIBUTE_COLD;

void protobuf_RegisterTypes(const ::std::string&) {

  protobuf_AssignDescriptorsOnce();

  ::google::protobuf::internal::RegisterAllTypes(file_level_metadata, 7);

}

void AddDescriptorsImpl() {

  InitDefaults();

  static const char descriptor[] GOOGLE_PROTOBUF_ATTRIBUTE_SECTION_VARIABLE(protodesc_cold) = {

      "\n\031yb/cdc/cdc_consumer.proto\022\006yb.cdc\032\032yb/"

      "common/common_net.proto\"\'\n\024ProducerTable"

      "tListPB\022\017\n\007tablets\030\001 \003(\t\"\255\002\n\rStreamEntry"

      "PB\022Z\n\034consumer_producer_tablet_map\030\001 \003(\013"

      "24.yb.cdc.StreamEntryPB.ConsumerProducer"

      "TabletMapEntry\022\031\n\021consumer_table_id\030\002 \001("

      "\t\022\031\n\021producer_table_id\030\003 \001(\t\022*\n\"same_num"

      "_producer_consumer_tablets\030\004 \001(\010\032^\n\036Cons"

      "umerProducerTabletMapEntry\022\013\n\003key\030\001 \001(\t\022"

      "+\n\005value\030\002 \001(\0132\034.yb.cdc.ProducerTabletLi"

      "stPB:\0028\001\"\373\001\n\017ProducerEntryPB\022:\n\nstream_m"

      "ap\030\001 \003(\0132&.yb.cdc.ProducerEntryPB.Stream"

      "MapEntry\022$\n\014master_addrs\030\002 \003(\0132\016.yb.Host"

      "PortPB\022%\n\rtserver_addrs\030\003 \003(\0132\016.yb.HostP"

      "ortPB\022\026\n\016disable_stream\030\004 \001(\010\032G\n\016StreamM"

      "apEntry\022\013\n\003key\030\001 \001(\t\022$\n\005value\030\002 \001(\0132\025.yb"

      ".cdc.StreamEntryPB:\0028\001\"\244\001\n\022ConsumerRegis"

      "tryPB\022A\n\014producer_map\030\001 \003(\0132+.yb.cdc.Con"

      "sumerRegistryPB.ProducerMapEntry\032K\n\020Prod"

      "ucerMapEntry\022\013\n\003key\030\001 \001(\t\022&\n\005value\030\002 \001(\013"

      "2\027.yb.cdc.ProducerEntryPB:\0028\001B\014\n\norg.yb."

      "cdcb\006proto3"

  };

  ::google::protobuf::DescriptorPool::InternalAddGeneratedFile(

      descriptor, 851);

  ::google::protobuf::MessageFactory::InternalRegisterGeneratedFile(

    "yb/cdc/cdc_consumer.proto", &protobuf_RegisterTypes);

  ::protobuf_yb_2fcommon_2fcommon_5fnet_2eproto::AddDescriptors();

}

void AddDescriptors() {

  static GOOGLE_PROTOBUF_DECLARE_ONCE(once);

  ::google::protobuf::GoogleOnceInit(&once, &AddDescriptorsImpl);

}

// Force AddDescriptors() to be called at dynamic initialization time.

struct StaticDescriptorInitializer {

  StaticDescriptorInitializer() {

    AddDescriptors();

  }

} static_descriptor_initializer;

}  // namespace protobuf_yb_2fcdc_2fcdc_5fconsumer_2eproto

namespace yb {

namespace cdc {

// ===================================================================

void ProducerTabletListPB::InitAsDefaultInstance() {

}

#if !defined(_MSC_VER) || _MSC_VER >= 1900

const int ProducerTabletListPB::kTabletsFieldNumber;

#endif  // !defined(_MSC_VER) || _MSC_VER >= 1900

ProducerTabletListPB::ProducerTabletListPB()

  : ::google::protobuf::Message(), _internal_metadata_(NULL) {

  if (GOOGLE_PREDICT_TRUE(this != internal_default_instance())) {

    ::protobuf_yb_2fcdc_2fcdc_5fconsumer_2eproto::InitDefaultsProducerTabletListPB();

  }

  SharedCtor();

  // @@protoc_insertion_point(constructor:yb.cdc.ProducerTabletListPB)

}

ProducerTabletListPB::ProducerTabletListPB(const ProducerTabletListPB& from)

  : ::google::protobuf::Message(),

      _internal_metadata_(NULL),

      tablets_(from.tablets_),

      _cached_size_(0) {

  _internal_metadata_.MergeFrom(from._internal_metadata_);

  // @@protoc_insertion_point(copy_constructor:yb.cdc.ProducerTabletListPB)

}

void ProducerTabletListPB::SharedCtor() {

  _cached_size_ = 0;

}

ProducerTabletListPB::~ProducerTabletListPB() {

  // @@protoc_insertion_point(destructor:yb.cdc.ProducerTabletListPB)

  SharedDtor();

}

void ProducerTabletListPB::SharedDtor() {

}

void ProducerTabletListPB::SetCachedSize(int size) const {

  GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();

  _cached_size_ = size;

  GOOGLE_SAFE_CONCURRENT_WRITES_END();

}

const ::google::protobuf::Descriptor* ProducerTabletListPB::descriptor() {

  ::protobuf_yb_2fcdc_2fcdc_5fconsumer_2eproto::protobuf_AssignDescriptorsOnce();

  return ::protobuf_yb_2fcdc_2fcdc_5fconsumer_2eproto::file_level_metadata[kIndexInFileMessages].descriptor;

}

const ProducerTabletListPB& ProducerTabletListPB::default_instance() {

  ::protobuf_yb_2fcdc_2fcdc_5fconsumer_2eproto::InitDefaultsProducerTabletListPB();

  return *internal_default_instance();

}

ProducerTabletListPB* ProducerTabletListPB::New(::google::protobuf::Arena* arena) const {

  ProducerTabletListPB* n = new ProducerTabletListPB;

  if (arena != NULL) {

    arena->Own(n);

  }

  return n;

}

void ProducerTabletListPB::Clear() {

// @@protoc_insertion_point(message_clear_start:yb.cdc.ProducerTabletListPB)

  ::google::protobuf::uint32 cached_has_bits = 0;

  // Prevent compiler warnings about cached_has_bits being unused

  (void) cached_has_bits;

  tablets_.Clear();

  _internal_metadata_.Clear();

}

bool ProducerTabletListPB::MergePartialFromCodedStream(

    ::google::protobuf::io::CodedInputStream* input) {

#define DO_(EXPRESSION) if (!GOOGLE_PREDICT_TRUE(EXPRESSION)) goto failure

  ::google::protobuf::uint32 tag;

  // @@protoc_insertion_point(parse_start:yb.cdc.ProducerTabletListPB)

  for (;;) {

    ::std::pair< ::google::protobuf::uint32, bool> p = input->ReadTagWithCutoffNoLastTag(127u);

    tag = p.first;

    if (!p.second) goto handle_unusual;

    switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {

      // repeated string tablets = 1;

      case 1: {

        if (static_cast< ::google::protobuf::uint8>(tag) ==

            static_cast< ::google::protobuf::uint8>(10u /* 10 & 0xFF */)) {

          DO_(::google::protobuf::internal::WireFormatLite::ReadString(

                input, this->add_tablets()));

          DO_(::google::protobuf::internal::WireFormatLite::VerifyUtf8String(

            this->tablets(this->tablets_size() - 1).data(),

            static_cast<int>(this->tablets(this->tablets_size() - 1).length()),

            ::google::protobuf::internal::WireFormatLite::PARSE,

            "yb.cdc.ProducerTabletListPB.tablets"));

        } else {

          goto handle_unusual;

        }

        break;

      }

      default: {

      handle_unusual:

        if (tag == 0) {

          goto success;

        }

        DO_(::google::protobuf::internal::WireFormat::SkipField(

              input, tag, _internal_metadata_.mutable_unknown_fields()));

        break;

      }

    }

  }

success:

  // @@protoc_insertion_point(parse_success:yb.cdc.ProducerTabletListPB)

  return true;

failure:

  // @@protoc_insertion_point(parse_failure:yb.cdc.ProducerTabletListPB)

  return false;

#undef DO_

}

void ProducerTabletListPB::SerializeWithCachedSizes(

    ::google::protobuf::io::CodedOutputStream* output) const {

  // @@protoc_insertion_point(serialize_start:yb.cdc.ProducerTabletListPB)

  ::google::protobuf::uint32 cached_has_bits = 0;

  (void) cached_has_bits;

  // repeated string tablets = 1;

  for (int i = 0, n = this->tablets_size(); i < n; i++) {

    ::google::protobuf::internal::WireFormatLite::VerifyUtf8String(

      this->tablets(i).data(), static_cast<int>(this->tablets(i).length()),

      ::google::protobuf::internal::WireFormatLite::SERIALIZE,

      "yb.cdc.ProducerTabletListPB.tablets");

    ::google::protobuf::internal::WireFormatLite::WriteString(

      1, this->tablets(i), output);

  }

  if ((_internal_metadata_.have_unknown_fields() &&  ::google::protobuf::internal::GetProto3PreserveUnknownsDefault())) {

    ::google::protobuf::internal::WireFormat::SerializeUnknownFields(

        (::google::protobuf::internal::GetProto3PreserveUnknownsDefault()   ? _internal_metadata_.unknown_fields()   : _internal_metadata_.default_instance()), output);

  }

  // @@protoc_insertion_point(serialize_end:yb.cdc.ProducerTabletListPB)

}

::google::protobuf::uint8* ProducerTabletListPB::InternalSerializeWithCachedSizesToArray(

    bool deterministic, ::google::protobuf::uint8* target) const {

  (void)deterministic; // Unused

  // @@protoc_insertion_point(serialize_to_array_start:yb.cdc.ProducerTabletListPB)

  ::google::protobuf::uint32 cached_has_bits = 0;

  (void) cached_has_bits;

  // repeated string tablets = 1;

  for (int i = 0, n = this->tablets_size(); i < n; i++) {

    ::google::protobuf::internal::WireFormatLite::VerifyUtf8String(

      this->tablets(i).data(), static_cast<int>(this->tablets(i).length()),

      ::google::protobuf::internal::WireFormatLite::SERIALIZE,

      "yb.cdc.ProducerTabletListPB.tablets");

    target = ::google::protobuf::internal::WireFormatLite::

      WriteStringToArray(1, this->tablets(i), target);

  }

  if ((_internal_metadata_.have_unknown_fields() &&  ::google::protobuf::internal::GetProto3PreserveUnknownsDefault())) {

    target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(

        (::google::protobuf::internal::GetProto3PreserveUnknownsDefault()   ? _internal_metadata_.unknown_fields()   : _internal_metadata_.default_instance()), target);

  }

  // @@protoc_insertion_point(serialize_to_array_end:yb.cdc.ProducerTabletListPB)

  return target;

}

size_t ProducerTabletListPB::ByteSizeLong() const {

// @@protoc_insertion_point(message_byte_size_start:yb.cdc.ProducerTabletListPB)

  size_t total_size = 0;

  if ((_internal_metadata_.have_unknown_fields() &&  ::google::protobuf::internal::GetProto3PreserveUnknownsDefault())) {

    total_size +=

      ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(

        (::google::protobuf::internal::GetProto3PreserveUnknownsDefault()   ? _internal_metadata_.unknown_fields()   : _internal_metadata_.default_instance()));

  }

  // repeated string tablets = 1;

  total_size += 1 *

      ::google::protobuf::internal::FromIntSize(this->tablets_size());

  for (int i = 0, n = this->tablets_size(); i < n; i++) {

    total_size += ::google::protobuf::internal::WireFormatLite::StringSize(

      this->tablets(i));

  }

  int cached_size = ::google::protobuf::internal::ToCachedSize(total_size);

  GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();

  _cached_size_ = cached_size;

  GOOGLE_SAFE_CONCURRENT_WRITES_END();

  return total_size;

}

void ProducerTabletListPB::MergeFrom(const ::google::protobuf::Message& from) {

// @@protoc_insertion_point(generalized_merge_from_start:yb.cdc.ProducerTabletListPB)

  GOOGLE_DCHECK_NE(&from, this);

  const ProducerTabletListPB* source =

      ::google::protobuf::internal::DynamicCastToGenerated<const ProducerTabletListPB>(

          &from);

  if (source == NULL) {

  // @@protoc_insertion_point(generalized_merge_from_cast_fail:yb.cdc.ProducerTabletListPB)

    ::google::protobuf::internal::ReflectionOps::Merge(from, this);

  } else {

  // @@protoc_insertion_point(generalized_merge_from_cast_success:yb.cdc.ProducerTabletListPB)

    MergeFrom(*source);

  }

}

void ProducerTabletListPB::MergeFrom(const ProducerTabletListPB& from) {

// @@protoc_insertion_point(class_specific_merge_from_start:yb.cdc.ProducerTabletListPB)

  GOOGLE_DCHECK_NE(&from, this);

  _internal_metadata_.MergeFrom(from._internal_metadata_);

  ::google::protobuf::uint32 cached_has_bits = 0;

  (void) cached_has_bits;

  tablets_.MergeFrom(from.tablets_);

}

void ProducerTabletListPB::CopyFrom(const ::google::protobuf::Message& from) {

// @@protoc_insertion_point(generalized_copy_from_start:yb.cdc.ProducerTabletListPB)

  if (&from == this) return;

  Clear();

  MergeFrom(from);

}

void ProducerTabletListPB::CopyFrom(const ProducerTabletListPB& from) {

// @@protoc_insertion_point(class_specific_copy_from_start:yb.cdc.ProducerTabletListPB)

  if (&from == this) return;

  Clear();

  MergeFrom(from);

}

bool ProducerTabletListPB::IsInitialized() const {

  return true;

}

void ProducerTabletListPB::Swap(ProducerTabletListPB* other) {

  if (other == this) return;

  InternalSwap(other);

}

void ProducerTabletListPB::InternalSwap(ProducerTabletListPB* other) {

  using std::swap;

  tablets_.InternalSwap(&other->tablets_);

  _internal_metadata_.Swap(&other->_internal_metadata_);

  swap(_cached_size_, other->_cached_size_);

}

::google::protobuf::Metadata ProducerTabletListPB::GetMetadata() const {

  protobuf_yb_2fcdc_2fcdc_5fconsumer_2eproto::protobuf_AssignDescriptorsOnce();

  return ::protobuf_yb_2fcdc_2fcdc_5fconsumer_2eproto::file_level_metadata[kIndexInFileMessages];

}

// ===================================================================

StreamEntryPB_ConsumerProducerTabletMapEntry_DoNotUse::StreamEntryPB_ConsumerProducerTabletMapEntry_DoNotUse() {}

StreamEntryPB_ConsumerProducerTabletMapEntry_DoNotUse::StreamEntryPB_ConsumerProducerTabletMapEntry_DoNotUse(::google::protobuf::Arena* arena) : SuperType(arena) {}

void StreamEntryPB_ConsumerProducerTabletMapEntry_DoNotUse::MergeFrom(const StreamEntryPB_ConsumerProducerTabletMapEntry_DoNotUse& other) {

  MergeFromInternal(other);

}

::google::protobuf::Metadata StreamEntryPB_ConsumerProducerTabletMapEntry_DoNotUse::GetMetadata() const {

  ::protobuf_yb_2fcdc_2fcdc_5fconsumer_2eproto::protobuf_AssignDescriptorsOnce();

  return ::protobuf_yb_2fcdc_2fcdc_5fconsumer_2eproto::file_level_metadata[1];

}

void StreamEntryPB_ConsumerProducerTabletMapEntry_DoNotUse::MergeFrom(

    const ::google::protobuf::Message& other) {

  ::google::protobuf::Message::MergeFrom(other);

}

// ===================================================================

void StreamEntryPB::InitAsDefaultInstance() {

}

#if !defined(_MSC_VER) || _MSC_VER >= 1900

const int StreamEntryPB::kConsumerProducerTabletMapFieldNumber;

const int StreamEntryPB::kConsumerTableIdFieldNumber;

const int StreamEntryPB::kProducerTableIdFieldNumber;

const int StreamEntryPB::kSameNumProducerConsumerTabletsFieldNumber;

#endif  // !defined(_MSC_VER) || _MSC_VER >= 1900

StreamEntryPB::StreamEntryPB()

  : ::google::protobuf::Message(), _internal_metadata_(NULL) {

  if (GOOGLE_PREDICT_TRUE(this != internal_default_instance())) {

    ::protobuf_yb_2fcdc_2fcdc_5fconsumer_2eproto::InitDefaultsStreamEntryPB();

  }

  SharedCtor();

  // @@protoc_insertion_point(constructor:yb.cdc.StreamEntryPB)

}

StreamEntryPB::StreamEntryPB(const StreamEntryPB& from)

  : ::google::protobuf::Message(),

      _internal_metadata_(NULL),

      _cached_size_(0) {

  _internal_metadata_.MergeFrom(from._internal_metadata_);

  consumer_producer_tablet_map_.MergeFrom(from.consumer_producer_tablet_map_);

  consumer_table_id_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited());

  if (from.consumer_table_id().size() > 0) {

    consumer_table_id_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.consumer_table_id_);

  }

  producer_table_id_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited());

  if (from.producer_table_id().size() > 0) {

    producer_table_id_.AssignWithDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited(), from.producer_table_id_);

  }

  same_num_producer_consumer_tablets_ = from.same_num_producer_consumer_tablets_;

  // @@protoc_insertion_point(copy_constructor:yb.cdc.StreamEntryPB)

}

void StreamEntryPB::SharedCtor() {

  consumer_table_id_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited());

  producer_table_id_.UnsafeSetDefault(&::google::protobuf::internal::GetEmptyStringAlreadyInited());

  same_num_producer_consumer_tablets_ = false;

  _cached_size_ = 0;

}

StreamEntryPB::~StreamEntryPB() {

  // @@protoc_insertion_point(destructor:yb.cdc.StreamEntryPB)

  SharedDtor();

}

void StreamEntryPB::SharedDtor() {

  consumer_table_id_.DestroyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());

  producer_table_id_.DestroyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());

}

void StreamEntryPB::SetCachedSize(int size) const {

  GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();

  _cached_size_ = size;

  GOOGLE_SAFE_CONCURRENT_WRITES_END();

}

const ::google::protobuf::Descriptor* StreamEntryPB::descriptor() {

  ::protobuf_yb_2fcdc_2fcdc_5fconsumer_2eproto::protobuf_AssignDescriptorsOnce();

  return ::protobuf_yb_2fcdc_2fcdc_5fconsumer_2eproto::file_level_metadata[kIndexInFileMessages].descriptor;

}

const StreamEntryPB& StreamEntryPB::default_instance() {

  ::protobuf_yb_2fcdc_2fcdc_5fconsumer_2eproto::InitDefaultsStreamEntryPB();

  return *internal_default_instance();

}

StreamEntryPB* StreamEntryPB::New(::google::protobuf::Arena* arena) const {

  StreamEntryPB* n = new StreamEntryPB;

  if (arena != NULL) {

    arena->Own(n);

  }

  return n;

}

void StreamEntryPB::Clear() {

// @@protoc_insertion_point(message_clear_start:yb.cdc.StreamEntryPB)

  ::google::protobuf::uint32 cached_has_bits = 0;

  // Prevent compiler warnings about cached_has_bits being unused

  (void) cached_has_bits;

  consumer_producer_tablet_map_.Clear();

  consumer_table_id_.ClearToEmptyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());

  producer_table_id_.ClearToEmptyNoArena(&::google::protobuf::internal::GetEmptyStringAlreadyInited());

  same_num_producer_consumer_tablets_ = false;

  _internal_metadata_.Clear();

}

bool StreamEntryPB::MergePartialFromCodedStream(

    ::google::protobuf::io::CodedInputStream* input) {

#define DO_(EXPRESSION) if (!GOOGLE_PREDICT_TRUE(EXPRESSION)) goto failure

  ::google::protobuf::uint32 tag;

  // @@protoc_insertion_point(parse_start:yb.cdc.StreamEntryPB)

  for (;;) {

    ::std::pair< ::google::protobuf::uint32, bool> p = input->ReadTagWithCutoffNoLastTag(127u);

    tag = p.first;

    if (!p.second) goto handle_unusual;

    switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {

      // map<string, .yb.cdc.ProducerTabletListPB> consumer_producer_tablet_map = 1;

      case 1: {

        if (static_cast< ::google::protobuf::uint8>(tag) ==

            static_cast< ::google::protobuf::uint8>(10u /* 10 & 0xFF */)) {

          StreamEntryPB_ConsumerProducerTabletMapEntry_DoNotUse::Parser< ::google::protobuf::internal::MapField<

              StreamEntryPB_ConsumerProducerTabletMapEntry_DoNotUse,

              ::std::string, ::yb::cdc::ProducerTabletListPB,

              ::google::protobuf::internal::WireFormatLite::TYPE_STRING,

              ::google::protobuf::internal::WireFormatLite::TYPE_MESSAGE,

              0 >,

            ::google::protobuf::Map< ::std::string, ::yb::cdc::ProducerTabletListPB > > parser(&consumer_producer_tablet_map_);

          DO_(::google::protobuf::internal::WireFormatLite::ReadMessageNoVirtual(

              input, &parser));

          DO_(::google::protobuf::internal::WireFormatLite::VerifyUtf8String(

            parser.key().data(), static_cast<int>(parser.key().length()),

            ::google::protobuf::internal::WireFormatLite::PARSE,

            "yb.cdc.StreamEntryPB.ConsumerProducerTabletMapEntry.key"));

        } else {

          goto handle_unusual;

        }

        break;

      }

      // string consumer_table_id = 2;

      case 2: {

        if (static_cast< ::google::protobuf::uint8>(tag) ==

            static_cast< ::google::protobuf::uint8>(18u /* 18 & 0xFF */)) {

          DO_(::google::protobuf::internal::WireFormatLite::ReadString(

                input, this->mutable_consumer_table_id()));

          DO_(::google::protobuf::internal::WireFormatLite::VerifyUtf8String(

            this->consumer_table_id().data(), static_cast<int>(this->consumer_table_id().length()),

            ::google::protobuf::internal::WireFormatLite::PARSE,

            "yb.cdc.StreamEntryPB.consumer_table_id"));

        } else {

          goto handle_unusual;

        }

        break;

      }

      // string producer_table_id = 3;

      case 3: {

        if (static_cast< ::google::protobuf::uint8>(tag) ==

            static_cast< ::google::protobuf::uint8>(26u /* 26 & 0xFF */)) {

          DO_(::google::protobuf::internal::WireFormatLite::ReadString(

                input, this->mutable_producer_table_id()));

          DO_(::google::protobuf::internal::WireFormatLite::VerifyUtf8String(

            this->producer_table_id().data(), static_cast<int>(this->producer_table_id().length()),

            ::google::protobuf::internal::WireFormatLite::PARSE,

            "yb.cdc.StreamEntryPB.producer_table_id"));

        } else {

          goto handle_unusual;

        }

        break;

      }

      // bool same_num_producer_consumer_tablets = 4;

      case 4: {

        if (static_cast< ::google::protobuf::uint8>(tag) ==

            static_cast< ::google::protobuf::uint8>(32u /* 32 & 0xFF */)) {

          DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive<

                   bool, ::google::protobuf::internal::WireFormatLite::TYPE_BOOL>(

                 input, &same_num_producer_consumer_tablets_)));

        } else {

          goto handle_unusual;

        }

        break;

      }

      default: {

      handle_unusual:

        if (tag == 0) {

          goto success;

        }

        DO_(::google::protobuf::internal::WireFormat::SkipField(

              input, tag, _internal_metadata_.mutable_unknown_fields()));

        break;

      }

    }

  }

success:

  // @@protoc_insertion_point(parse_success:yb.cdc.StreamEntryPB)

  return true;

failure:

  // @@protoc_insertion_point(parse_failure:yb.cdc.StreamEntryPB)

  return false;

#undef DO_

}

void StreamEntryPB::SerializeWithCachedSizes(

    ::google::protobuf::io::CodedOutputStream* output) const {

  // @@protoc_insertion_point(serialize_start:yb.cdc.StreamEntryPB)

  ::google::protobuf::uint32 cached_has_bits = 0;

  (void) cached_has_bits;

  // map<string, .yb.cdc.ProducerTabletListPB> consumer_producer_tablet_map = 1;

  if (!this->consumer_producer_tablet_map().empty()) {

    typedef ::google::protobuf::Map< ::std::string, ::yb::cdc::ProducerTabletListPB >::const_pointer

        ConstPtr;

    typedef ConstPtr SortItem;

    typedef ::google::protobuf::internal::CompareByDerefFirst<SortItem> Less;

    struct Utf8Check {

      static void Check(ConstPtr p) {

        ::google::protobuf::internal::WireFormatLite::VerifyUtf8String(

          p->first.data(), static_cast<int>(p->first.length()),

          ::google::protobuf::internal::WireFormatLite::SERIALIZE,

          "yb.cdc.StreamEntryPB.ConsumerProducerTabletMapEntry.key");

      }

    };

    if (output->IsSerializationDeterministic() &&

        this->consumer_producer_tablet_map().size() > 1) {

      ::google::protobuf::scoped_array<SortItem> items(

          new SortItem[this->consumer_producer_tablet_map().size()]);

      typedef ::google::protobuf::Map< ::std::string, ::yb::cdc::ProducerTabletListPB >::size_type size_type;

      size_type n = 0;

      for (::google::protobuf::Map< ::std::string, ::yb::cdc::ProducerTabletListPB >::const_iterator

          it = this->consumer_producer_tablet_map().begin();

          it != this->consumer_producer_tablet_map().end(); ++it, ++n) {

        items[static_cast<ptrdiff_t>(n)] = SortItem(&*it);

      }

      ::std::sort(&items[0], &items[static_cast<ptrdiff_t>(n)], Less());

      ::google::protobuf::scoped_ptr<StreamEntryPB_ConsumerProducerTabletMapEntry_DoNotUse> entry;

      for (size_type i = 0; i < n; i++) {

        entry.reset(consumer_producer_tablet_map_.NewEntryWrapper(

            items[static_cast<ptrdiff_t>(i)]->first, items[static_cast<ptrdiff_t>(i)]->second));

        ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(

            1, *entry, output);

        Utf8Check::Check(items[static_cast<ptrdiff_t>(i)]);

      }

    } else {

      ::google::protobuf::scoped_ptr<StreamEntryPB_ConsumerProducerTabletMapEntry_DoNotUse> entry;

      for (::google::protobuf::Map< ::std::string, ::yb::cdc::ProducerTabletListPB >::const_iterator

          it = this->consumer_producer_tablet_map().begin();

          it != this->consumer_producer_tablet_map().end(); ++it) {

        entry.reset(consumer_producer_tablet_map_.NewEntryWrapper(

            it->first, it->second));

        ::google::protobuf::internal::WireFormatLite::WriteMessageMaybeToArray(

            1, *entry, output);

        Utf8Check::Check(&*it);

      }

    }

  }

  // string consumer_table_id = 2;

  if (this->consumer_table_id().size() > 0) {

    ::google::protobuf::internal::WireFormatLite::VerifyUtf8String(

      this->consumer_table_id().data(), static_cast<int>(this->consumer_table_id().length()),

      ::google::protobuf::internal::WireFormatLite::SERIALIZE,

      "yb.cdc.StreamEntryPB.consumer_table_id");

    ::google::protobuf::internal::WireFormatLite::WriteStringMaybeAliased(

      2, this->consumer_table_id(), output);

  }

  // string producer_table_id = 3;

  if (this->producer_table_id().size() > 0) {

    ::google::protobuf::internal::WireFormatLite::VerifyUtf8String(

      this->producer_table_id().data(), static_cast<int>(this->producer_table_id().length()),

      ::google::protobuf::internal::WireFormatLite::SERIALIZE,

      "yb.cdc.StreamEntryPB.producer_table_id");

    ::google::protobuf::internal::WireFormatLite::WriteStringMaybeAliased(

      3, this->producer_table_id(), output);

  }

  // bool same_num_producer_consumer_tablets = 4;

  if (this->same_num_producer_consumer_tablets() != 0) {

    ::google::protobuf::internal::WireFormatLite::WriteBool(4, this->same_num_producer_consumer_tablets(), output);

  }

  if ((_internal_metadata_.have_unknown_fields() &&  ::google::protobuf::internal::GetProto3PreserveUnknownsDefault())) {

    ::google::protobuf::internal::WireFormat::SerializeUnknownFields(

        (::google::protobuf::internal::GetProto3PreserveUnknownsDefault()   ? _internal_metadata_.unknown_fields()   : _internal_metadata_.default_instance()), output);

  }

  // @@protoc_insertion_point(serialize_end:yb.cdc.StreamEntryPB)

}

::google::protobuf::uint8* StreamEntryPB::InternalSerializeWithCachedSizesToArray(

    bool deterministic, ::google::protobuf::uint8* target) const {

  (void)deterministic; // Unused

  // @@protoc_insertion_point(serialize_to_array_start:yb.cdc.StreamEntryPB)

  ::google::protobuf::uint32 cached_has_bits = 0;

  (void) cached_has_bits;

  // map<string, .yb.cdc.ProducerTabletListPB> consumer_producer_tablet_map = 1;

  if (!this->consumer_producer_tablet_map().empty()) {

    typedef ::google::protobuf::Map< ::std::string, ::yb::cdc::ProducerTabletListPB >::const_pointer

        ConstPtr;

    typedef ConstPtr SortItem;

    typedef ::google::protobuf::internal::CompareByDerefFirst<SortItem> Less;

    struct Utf8Check {

      static void Check(ConstPtr p) {

        ::google::protobuf::internal::WireFormatLite::VerifyUtf8String(

          p->first.data(), static_cast<int>(p->first.length()),

          ::google::protobuf::internal::WireFormatLite::SERIALIZE,

          "yb.cdc.StreamEntryPB.ConsumerProducerTabletMapEntry.key");

      }

    };

    if (deterministic &&

        this->consumer_producer_tablet_map().size() > 1) {

      ::google::protobuf::scoped_array<SortItem> items(

          new SortItem[this->consumer_producer_tablet_map().size()]);

      typedef ::google::protobuf::Map< ::std::string, ::yb::cdc::ProducerTabletListPB >::size_type size_type;

      size_type n = 0;

      for (::google::protobuf::Map< ::std::string, ::yb::cdc::ProducerTabletListPB >::const_iterator

          it = this->consumer_producer_tablet_map().begin();

          it != this->consumer_producer_tablet_map().end(); ++it, ++n) {

        items[static_cast<ptrdiff_t>(n)] = SortItem(&*it);

      }

      ::std::sort(&items[0], &items[static_cast<ptrdiff_t>(n)], Less());

      ::google::protobuf::scoped_ptr<StreamEntryPB_ConsumerProducerTabletMapEntry_DoNotUse> entry;

      for (size_type i = 0; i < n; i++) {

        entry.reset(consumer_producer_tablet_map_.NewEntryWrapper(

            items[static_cast<ptrdiff_t>(i)]->first, items[static_cast<ptrdiff_t>(i)]->second));

        target = ::google::protobuf::internal::WireFormatLite::

                   InternalWriteMessageNoVirtualToArray(

                       1, *entry, deterministic, target);

;

        Utf8Check::Check(items[static_cast<ptrdiff_t>(i)]);

      }