path: root/contrib/native/client/src/protobuf/BitControl.pb.h

// Generated by the protocol buffer compiler.  DO NOT EDIT!
// source: BitControl.proto

#ifndef PROTOBUF_BitControl_2eproto__INCLUDED
#define PROTOBUF_BitControl_2eproto__INCLUDED

#include <string>

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

#if GOOGLE_PROTOBUF_VERSION < 2005000
#error This file was generated by a newer version of protoc which is
#error incompatible with your Protocol Buffer headers.  Please update
#error your headers.
#endif
#if 2005000 < GOOGLE_PROTOBUF_MIN_PROTOC_VERSION
#error This file was generated by an older version of protoc which is
#error incompatible with your Protocol Buffer headers.  Please
#error regenerate this file with a newer version of protoc.
#endif

#include <google/protobuf/generated_message_util.h>
#include <google/protobuf/message.h>
#include <google/protobuf/repeated_field.h>
#include <google/protobuf/extension_set.h>
#include <google/protobuf/generated_enum_reflection.h>
#include <google/protobuf/unknown_field_set.h>
#include "ExecutionProtos.pb.h"
#include "Coordination.pb.h"
#include "UserBitShared.pb.h"
// @@protoc_insertion_point(includes)

namespace exec {
namespace bit {
namespace control {

// Internal implementation detail -- do not call these.
void  protobuf_AddDesc_BitControl_2eproto();
void protobuf_AssignDesc_BitControl_2eproto();
void protobuf_ShutdownFile_BitControl_2eproto();

class BitControlHandshake;
class BitStatus;
class FragmentStatus;
class InitializeFragments;
class CustomMessage;
class PlanFragment;
class Collector;
class QueryContextInformation;
class WorkQueueStatus;
class FinishedReceiver;

enum RpcType {
  HANDSHAKE = 0,
  ACK = 1,
  GOODBYE = 2,
  REQ_INITIALIZE_FRAGMENTS = 3,
  REQ_CANCEL_FRAGMENT = 6,
  REQ_RECEIVER_FINISHED = 7,
  REQ_FRAGMENT_STATUS = 8,
  REQ_BIT_STATUS = 9,
  REQ_QUERY_STATUS = 10,
  REQ_QUERY_CANCEL = 15,
  REQ_UNPAUSE_FRAGMENT = 16,
  REQ_CUSTOM = 17,
  RESP_FRAGMENT_HANDLE = 11,
  RESP_FRAGMENT_STATUS = 12,
  RESP_BIT_STATUS = 13,
  RESP_QUERY_STATUS = 14,
  RESP_CUSTOM = 18,
  SASL_MESSAGE = 19
};
bool RpcType_IsValid(int value);
const RpcType RpcType_MIN = HANDSHAKE;
const RpcType RpcType_MAX = SASL_MESSAGE;
const int RpcType_ARRAYSIZE = RpcType_MAX + 1;

const ::google::protobuf::EnumDescriptor* RpcType_descriptor();
inline const ::std::string& RpcType_Name(RpcType value) {
  return ::google::protobuf::internal::NameOfEnum(
    RpcType_descriptor(), value);
}
inline bool RpcType_Parse(
    const ::std::string& name, RpcType* value) {
  return ::google::protobuf::internal::ParseNamedEnum<RpcType>(
    RpcType_descriptor(), name, value);
}
// ===================================================================

class BitControlHandshake : public ::google::protobuf::Message {
 public:
  BitControlHandshake();
  virtual ~BitControlHandshake();

  BitControlHandshake(const BitControlHandshake& from);

  inline BitControlHandshake& operator=(const BitControlHandshake& from) {
    CopyFrom(from);
    return *this;
  }

  inline const ::google::protobuf::UnknownFieldSet& unknown_fields() const {
    return _unknown_fields_;
  }

  inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() {
    return &_unknown_fields_;
  }

  static const ::google::protobuf::Descriptor* descriptor();
  static const BitControlHandshake& default_instance();

  void Swap(BitControlHandshake* other);

  // implements Message ----------------------------------------------

  BitControlHandshake* New() const;
  void CopyFrom(const ::google::protobuf::Message& from);
  void MergeFrom(const ::google::protobuf::Message& from);
  void CopyFrom(const BitControlHandshake& from);
  void MergeFrom(const BitControlHandshake& from);
  void Clear();
  bool IsInitialized() const;

  int ByteSize() const;
  bool MergePartialFromCodedStream(
      ::google::protobuf::io::CodedInputStream* input);
  void SerializeWithCachedSizes(
      ::google::protobuf::io::CodedOutputStream* output) const;
  ::google::protobuf::uint8* SerializeWithCachedSizesToArray(::google::protobuf::uint8* output) const;
  int GetCachedSize() const { return _cached_size_; }
  private:
  void SharedCtor();
  void SharedDtor();
  void SetCachedSize(int size) const;
  public:

  ::google::protobuf::Metadata GetMetadata() const;

  // nested types ----------------------------------------------------

  // accessors -------------------------------------------------------

  // optional int32 rpc_version = 1;
  inline bool has_rpc_version() const;
  inline void clear_rpc_version();
  static const int kRpcVersionFieldNumber = 1;
  inline ::google::protobuf::int32 rpc_version() const;
  inline void set_rpc_version(::google::protobuf::int32 value);

  // optional .exec.shared.RpcChannel channel = 2 [default = BIT_CONTROL];
  inline bool has_channel() const;
  inline void clear_channel();
  static const int kChannelFieldNumber = 2;
  inline ::exec::shared::RpcChannel channel() const;
  inline void set_channel(::exec::shared::RpcChannel value);

  // optional .exec.DrillbitEndpoint endpoint = 3;
  inline bool has_endpoint() const;
  inline void clear_endpoint();
  static const int kEndpointFieldNumber = 3;
  inline const ::exec::DrillbitEndpoint& endpoint() const;
  inline ::exec::DrillbitEndpoint* mutable_endpoint();
  inline ::exec::DrillbitEndpoint* release_endpoint();
  inline void set_allocated_endpoint(::exec::DrillbitEndpoint* endpoint);

  // repeated string authenticationMechanisms = 4;
  inline int authenticationmechanisms_size() const;
  inline void clear_authenticationmechanisms();
  static const int kAuthenticationMechanismsFieldNumber = 4;
  inline const ::std::string& authenticationmechanisms(int index) const;
  inline ::std::string* mutable_authenticationmechanisms(int index);
  inline void set_authenticationmechanisms(int index, const ::std::string& value);
  inline void set_authenticationmechanisms(int index, const char* value);
  inline void set_authenticationmechanisms(int index, const char* value, size_t size);
  inline ::std::string* add_authenticationmechanisms();
  inline void add_authenticationmechanisms(const ::std::string& value);
  inline void add_authenticationmechanisms(const char* value);
  inline void add_authenticationmechanisms(const char* value, size_t size);
  inline const ::google::protobuf::RepeatedPtrField< ::std::string>& authenticationmechanisms() const;
  inline ::google::protobuf::RepeatedPtrField< ::std::string>* mutable_authenticationmechanisms();

  // @@protoc_insertion_point(class_scope:exec.bit.control.BitControlHandshake)
 private:
  inline void set_has_rpc_version();
  inline void clear_has_rpc_version();
  inline void set_has_channel();
  inline void clear_has_channel();
  inline void set_has_endpoint();
  inline void clear_has_endpoint();

  ::google::protobuf::UnknownFieldSet _unknown_fields_;

  ::google::protobuf::int32 rpc_version_;
  int channel_;
  ::exec::DrillbitEndpoint* endpoint_;
  ::google::protobuf::RepeatedPtrField< ::std::string> authenticationmechanisms_;

  mutable int _cached_size_;
  ::google::protobuf::uint32 _has_bits_[(4 + 31) / 32];

  friend void  protobuf_AddDesc_BitControl_2eproto();
  friend void protobuf_AssignDesc_BitControl_2eproto();
  friend void protobuf_ShutdownFile_BitControl_2eproto();

  void InitAsDefaultInstance();
  static BitControlHandshake* default_instance_;
};
// -------------------------------------------------------------------

class BitStatus : public ::google::protobuf::Message {
 public:
  BitStatus();
  virtual ~BitStatus();

  BitStatus(const BitStatus& from);

  inline BitStatus& operator=(const BitStatus& from) {
    CopyFrom(from);
    return *this;
  }

  inline const ::google::protobuf::UnknownFieldSet& unknown_fields() const {
    return _unknown_fields_;
  }

  inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() {
    return &_unknown_fields_;
  }

  static const ::google::protobuf::Descriptor* descriptor();
  static const BitStatus& default_instance();

  void Swap(BitStatus* other);

  // implements Message ----------------------------------------------

  BitStatus* New() const;
  void CopyFrom(const ::google::protobuf::Message& from);
  void MergeFrom(const ::google::protobuf::Message& from);
  void CopyFrom(const BitStatus& from);
  void MergeFrom(const BitStatus& from);
  void Clear();
  bool IsInitialized() const;

  int ByteSize() const;
  bool MergePartialFromCodedStream(
      ::google::protobuf::io::CodedInputStream* input);
  void SerializeWithCachedSizes(
      ::google::protobuf::io::CodedOutputStream* output) const;
  ::google::protobuf::uint8* SerializeWithCachedSizesToArray(::google::protobuf::uint8* output) const;
  int GetCachedSize() const { return _cached_size_; }
  private:
  void SharedCtor();
  void SharedDtor();
  void SetCachedSize(int size) const;
  public:

  ::google::protobuf::Metadata GetMetadata() const;

  // nested types ----------------------------------------------------

  // accessors -------------------------------------------------------

  // repeated .exec.bit.control.FragmentStatus fragment_status = 1;
  inline int fragment_status_size() const;
  inline void clear_fragment_status();
  static const int kFragmentStatusFieldNumber = 1;
  inline const ::exec::bit::control::FragmentStatus& fragment_status(int index) const;
  inline ::exec::bit::control::FragmentStatus* mutable_fragment_status(int index);
  inline ::exec::bit::control::FragmentStatus* add_fragment_status();
  inline const ::google::protobuf::RepeatedPtrField< ::exec::bit::control::FragmentStatus >&
      fragment_status() const;
  inline ::google::protobuf::RepeatedPtrField< ::exec::bit::control::FragmentStatus >*
      mutable_fragment_status();

  // @@protoc_insertion_point(class_scope:exec.bit.control.BitStatus)
 private:

  ::google::protobuf::UnknownFieldSet _unknown_fields_;

  ::google::protobuf::RepeatedPtrField< ::exec::bit::control::FragmentStatus > fragment_status_;

  mutable int _cached_size_;
  ::google::protobuf::uint32 _has_bits_[(1 + 31) / 32];

  friend void  protobuf_AddDesc_BitControl_2eproto();
  friend void protobuf_AssignDesc_BitControl_2eproto();
  friend void protobuf_ShutdownFile_BitControl_2eproto();

  void InitAsDefaultInstance();
  static BitStatus* default_instance_;
};
// -------------------------------------------------------------------

class FragmentStatus : public ::google::protobuf::Message {
 public:
  FragmentStatus();
  virtual ~FragmentStatus();

  FragmentStatus(const FragmentStatus& from);

  inline FragmentStatus& operator=(const FragmentStatus& from) {
    CopyFrom(from);
    return *this;
  }

  inline const ::google::protobuf::UnknownFieldSet& unknown_fields() const {
    return _unknown_fields_;
  }

  inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() {
    return &_unknown_fields_;
  }

  static const ::google::protobuf::Descriptor* descriptor();
  static const FragmentStatus& default_instance();

  void Swap(FragmentStatus* other);

  // implements Message ----------------------------------------------

  FragmentStatus* New() const;
  void CopyFrom(const ::google::protobuf::Message& from);
  void MergeFrom(const ::google::protobuf::Message& from);
  void CopyFrom(const FragmentStatus& from);
  void MergeFrom(const FragmentStatus& from);
  void Clear();
  bool IsInitialized() const;

  int ByteSize() const;
  bool MergePartialFromCodedStream(
      ::google::protobuf::io::CodedInputStream* input);
  void SerializeWithCachedSizes(
      ::google::protobuf::io::CodedOutputStream* output) const;
  ::google::protobuf::uint8* SerializeWithCachedSizesToArray(::google::protobuf::uint8* output) const;
  int GetCachedSize() const { return _cached_size_; }
  private:
  void SharedCtor();
  void SharedDtor();
  void SetCachedSize(int size) const;
  public:

  ::google::protobuf::Metadata GetMetadata() const;

  // nested types ----------------------------------------------------

  // accessors -------------------------------------------------------

  // optional .exec.shared.MinorFragmentProfile profile = 1;
  inline bool has_profile() const;
  inline void clear_profile();
  static const int kProfileFieldNumber = 1;
  inline const ::exec::shared::MinorFragmentProfile& profile() const;
  inline ::exec::shared::MinorFragmentProfile* mutable_profile();
  inline ::exec::shared::MinorFragmentProfile* release_profile();
  inline void set_allocated_profile(::exec::shared::MinorFragmentProfile* profile);

  // optional .exec.bit.FragmentHandle handle = 2;
  inline bool has_handle() const;
  inline void clear_handle();
  static const int kHandleFieldNumber = 2;
  inline const ::exec::bit::FragmentHandle& handle() const;
  inline ::exec::bit::FragmentHandle* mutable_handle();
  inline ::exec::bit::FragmentHandle* release_handle();
  inline void set_allocated_handle(::exec::bit::FragmentHandle* handle);

  // @@protoc_insertion_point(class_scope:exec.bit.control.FragmentStatus)
 private:
  inline void set_has_profile();
  inline void clear_has_profile();
  inline void set_has_handle();
  inline void clear_has_handle();

  ::google::protobuf::UnknownFieldSet _unknown_fields_;

  ::exec::shared::MinorFragmentProfile* profile_;
  ::exec::bit::FragmentHandle* handle_;

  mutable int _cached_size_;
  ::google::protobuf::uint32 _has_bits_[(2 + 31) / 32];

  friend void  protobuf_AddDesc_BitControl_2eproto();
  friend void protobuf_AssignDesc_BitControl_2eproto();
  friend void protobuf_ShutdownFile_BitControl_2eproto();

  void InitAsDefaultInstance();
  static FragmentStatus* default_instance_;
};
// -------------------------------------------------------------------

class InitializeFragments : public ::google::protobuf::Message {
 public:
  InitializeFragments();
  virtual ~InitializeFragments();

  InitializeFragments(const InitializeFragments& from);

  inline InitializeFragments& operator=(const InitializeFragments& from) {
    CopyFrom(from);
    return *this;
  }

  inline const ::google::protobuf::UnknownFieldSet& unknown_fields() const {
    return _unknown_fields_;
  }

  inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() {
    return &_unknown_fields_;
  }

  static const ::google::protobuf::Descriptor* descriptor();
  static const InitializeFragments& default_instance();

  void Swap(InitializeFragments* other);

  // implements Message ----------------------------------------------

  InitializeFragments* New() const;
  void CopyFrom(const ::google::protobuf::Message& from);
  void MergeFrom(const ::google::protobuf::Message& from);
  void CopyFrom(const InitializeFragments& from);
  void MergeFrom(const InitializeFragments& from);
  void Clear();
  bool IsInitialized() const;

  int ByteSize() const;
  bool MergePartialFromCodedStream(
      ::google::protobuf::io::CodedInputStream* input);
  void SerializeWithCachedSizes(
      ::google::protobuf::io::CodedOutputStream* output) const;
  ::google::protobuf::uint8* SerializeWithCachedSizesToArray(::google::protobuf::uint8* output) const;
  int GetCachedSize() const { return _cached_size_; }
  private:
  void SharedCtor();
  void SharedDtor();
  void SetCachedSize(int size) const;
  public:

  ::google::protobuf::Metadata GetMetadata() const;

  // nested types ----------------------------------------------------

  // accessors -------------------------------------------------------

  // repeated .exec.bit.control.PlanFragment fragment = 1;
  inline int fragment_size() const;
  inline void clear_fragment();
  static const int kFragmentFieldNumber = 1;
  inline const ::exec::bit::control::PlanFragment& fragment(int index) const;
  inline ::exec::bit::control::PlanFragment* mutable_fragment(int index);
  inline ::exec::bit::control::PlanFragment* add_fragment();
  inline const ::google::protobuf::RepeatedPtrField< ::exec::bit::control::PlanFragment >&
      fragment() const;
  inline ::google::protobuf::RepeatedPtrField< ::exec::bit::control::PlanFragment >*
      mutable_fragment();

  // @@protoc_insertion_point(class_scope:exec.bit.control.InitializeFragments)
 private:

  ::google::protobuf::UnknownFieldSet _unknown_fields_;

  ::google::protobuf::RepeatedPtrField< ::exec::bit::control::PlanFragment > fragment_;

  mutable int _cached_size_;
  ::google::protobuf::uint32 _has_bits_[(1 + 31) / 32];

  friend void  protobuf_AddDesc_BitControl_2eproto();
  friend void protobuf_AssignDesc_BitControl_2eproto();
  friend void protobuf_ShutdownFile_BitControl_2eproto();

  void InitAsDefaultInstance();
  static InitializeFragments* default_instance_;
};
// -------------------------------------------------------------------

class CustomMessage : public ::google::protobuf::Message {
 public:
  CustomMessage();
  virtual ~CustomMessage();

  CustomMessage(const CustomMessage& from);

  inline CustomMessage& operator=(const CustomMessage& from) {
    CopyFrom(from);
    return *this;
  }

  inline const ::google::protobuf::UnknownFieldSet& unknown_fields() const {
    return _unknown_fields_;
  }

  inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() {
    return &_unknown_fields_;
  }

  static const ::google::protobuf::Descriptor* descriptor();
  static const CustomMessage& default_instance();

  void Swap(CustomMessage* other);

  // implements Message ----------------------------------------------

  CustomMessage* New() const;
  void CopyFrom(const ::google::protobuf::Message& from);
  void MergeFrom(const ::google::protobuf::Message& from);
  void CopyFrom(const CustomMessage& from);
  void MergeFrom(const CustomMessage& from);
  void Clear();
  bool IsInitialized() const;

  int ByteSize() const;
  bool MergePartialFromCodedStream(
      ::google::protobuf::io::CodedInputStream* input);
  void SerializeWithCachedSizes(
      ::google::protobuf::io::CodedOutputStream* output) const;
  ::google::protobuf::uint8* SerializeWithCachedSizesToArray(::google::protobuf::uint8* output) const;
  int GetCachedSize() const { return _cached_size_; }
  private:
  void SharedCtor();
  void SharedDtor();
  void SetCachedSize(int size) const;
  public:

  ::google::protobuf::Metadata GetMetadata() const;

  // nested types ----------------------------------------------------

  // accessors -------------------------------------------------------

  // optional int32 type = 1;
  inline bool has_type() const;
  inline void clear_type();
  static const int kTypeFieldNumber = 1;
  inline ::google::protobuf::int32 type() const;
  inline void set_type(::google::protobuf::int32 value);

  // optional bytes message = 2;
  inline bool has_message() const;
  inline void clear_message();
  static const int kMessageFieldNumber = 2;
  inline const ::std::string& message() const;
  inline void set_message(const ::std::string& value);
  inline void set_message(const char* value);
  inline void set_message(const void* value, size_t size);
  inline ::std::string* mutable_message();
  inline ::std::string* release_message();
  inline void set_allocated_message(::std::string* message);

  // @@protoc_insertion_point(class_scope:exec.bit.control.CustomMessage)
 private:
  inline void set_has_type();
  inline void clear_has_type();
  inline void set_has_message();
  inline void clear_has_message();

  ::google::protobuf::UnknownFieldSet _unknown_fields_;

  ::std::string* message_;
  ::google::protobuf::int32 type_;

  mutable int _cached_size_;
  ::google::protobuf::uint32 _has_bits_[(2 + 31) / 32];

  friend void  protobuf_AddDesc_BitControl_2eproto();
  friend void protobuf_AssignDesc_BitControl_2eproto();
  friend void protobuf_ShutdownFile_BitControl_2eproto();

  void InitAsDefaultInstance();
  static CustomMessage* default_instance_;
};
// -------------------------------------------------------------------

class PlanFragment : public ::google::protobuf::Message {
 public:
  PlanFragment();
  virtual ~PlanFragment();

  PlanFragment(const PlanFragment& from);

  inline PlanFragment& operator=(const PlanFragment& from) {
    CopyFrom(from);
    return *this;
  }

  inline const ::google::protobuf::UnknownFieldSet& unknown_fields() const {
    return _unknown_fields_;
  }

  inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() {
    return &_unknown_fields_;
  }

  static const ::google::protobuf::Descriptor* descriptor();
  static const PlanFragment& default_instance();

  void Swap(PlanFragment* other);

  // implements Message ----------------------------------------------

  PlanFragment* New() const;
  void CopyFrom(const ::google::protobuf::Message& from);
  void MergeFrom(const ::google::protobuf::Message& from);
  void CopyFrom(const PlanFragment& from);
  void MergeFrom(const PlanFragment& from);
  void Clear();
  bool IsInitialized() const;

  int ByteSize() const;
  bool MergePartialFromCodedStream(
      ::google::protobuf::io::CodedInputStream* input);
  void SerializeWithCachedSizes(
      ::google::protobuf::io::CodedOutputStream* output) const;
  ::google::protobuf::uint8* SerializeWithCachedSizesToArray(::google::protobuf::uint8* output) const;
  int GetCachedSize() const { return _cached_size_; }
  private:
  void SharedCtor();
  void SharedDtor();
  void SetCachedSize(int size) const;
  public:

  ::google::protobuf::Metadata GetMetadata() const;

  // nested types ----------------------------------------------------

  // accessors -------------------------------------------------------

  // optional .exec.bit.FragmentHandle handle = 1;
  inline bool has_handle() const;
  inline void clear_handle();
  static const int kHandleFieldNumber = 1;
  inline const ::exec::bit::FragmentHandle& handle() const;
  inline ::exec::bit::FragmentHandle* mutable_handle();
  inline ::exec::bit::FragmentHandle* release_handle();
  inline void set_allocated_handle(::exec::bit::FragmentHandle* handle);

  // optional float network_cost = 4;
  inline bool has_network_cost() const;
  inline void clear_network_cost();
  static const int kNetworkCostFieldNumber = 4;
  inline float network_cost() const;
  inline void set_network_cost(float value);

  // optional float cpu_cost = 5;
  inline bool has_cpu_cost() const;
  inline void clear_cpu_cost();
  static const int kCpuCostFieldNumber = 5;
  inline float cpu_cost() const;
  inline void set_cpu_cost(float value);

  // optional float disk_cost = 6;
  inline bool has_disk_cost() const;
  inline void clear_disk_cost();
  static const int kDiskCostFieldNumber = 6;
  inline float disk_cost() const;
  inline void set_disk_cost(float value);

  // optional float memory_cost = 7;
  inline bool has_memory_cost() const;
  inline void clear_memory_cost();
  static const int kMemoryCostFieldNumber = 7;
  inline float memory_cost() const;
  inline void set_memory_cost(float value);

  // optional string fragment_json = 8;
  inline bool has_fragment_json() const;
  inline void clear_fragment_json();
  static const int kFragmentJsonFieldNumber = 8;
  inline const ::std::string& fragment_json() const;
  inline void set_fragment_json(const ::std::string& value);
  inline void set_fragment_json(const char* value);
  inline void set_fragment_json(const char* value, size_t size);
  inline ::std::string* mutable_fragment_json();
  inline ::std::string* release_fragment_json();
  inline void set_allocated_fragment_json(::std::string* fragment_json);

  // optional bool leaf_fragment = 9;
  inline bool has_leaf_fragment() const;
  inline void clear_leaf_fragment();
  static const int kLeafFragmentFieldNumber = 9;
  inline bool leaf_fragment() const;
  inline void set_leaf_fragment(bool value);

  // optional .exec.DrillbitEndpoint assignment = 10;
  inline bool has_assignment() const;
  inline void clear_assignment();
  static const int kAssignmentFieldNumber = 10;
  inline const ::exec::DrillbitEndpoint& assignment() const;
  inline ::exec::DrillbitEndpoint* mutable_assignment();
  inline ::exec::DrillbitEndpoint* release_assignment();
  inline void set_allocated_assignment(::exec::DrillbitEndpoint* assignment);

  // optional .exec.DrillbitEndpoint foreman = 11;
  inline bool has_foreman() const;
  inline void clear_foreman();
  static const int kForemanFieldNumber = 11;
  inline const ::exec::DrillbitEndpoint& foreman() const;
  inline ::exec::DrillbitEndpoint* mutable_foreman();
  inline ::exec::DrillbitEndpoint* release_foreman();
  inline void set_allocated_foreman(::exec::DrillbitEndpoint* foreman);

  // optional int64 mem_initial = 12 [default = 20000000];
  inline bool has_mem_initial() const;
  inline void clear_mem_initial();
  static const int kMemInitialFieldNumber = 12;
  inline ::google::protobuf::int64 mem_initial() const;
  inline void set_mem_initial(::google::protobuf::int64 value);

  // optional int64 mem_max = 13 [default = 2000000000];
  inline bool has_mem_max() const;
  inline void clear_mem_max();
  static const int kMemMaxFieldNumber = 13;
  inline ::google::protobuf::int64 mem_max() const;
  inline void set_mem_max(::google::protobuf::int64 value);

  // optional .exec.shared.UserCredentials credentials = 14;
  inline bool has_credentials() const;
  inline void clear_credentials();
  static const int kCredentialsFieldNumber = 14;
  inline const ::exec::shared::UserCredentials& credentials() const;
  inline ::exec::shared::UserCredentials* mutable_credentials();
  inline ::exec::shared::UserCredentials* release_credentials();
  inline void set_allocated_credentials(::exec::shared::UserCredentials* credentials);

  // optional string options_json = 15;
  inline bool has_options_json() const;
  inline void clear_options_json();
  static const int kOptionsJsonFieldNumber = 15;
  inline const ::std::string& options_json() const;
  inline void set_options_json(const ::std::string& value);
  inline void set_options_json(const char* value);
  inline void set_options_json(const char* value, size_t size);
  inline ::std::string* mutable_options_json();
  inline ::std::string* release_options_json();
  inline void set_allocated_options_json(::std::string* options_json);

  // optional .exec.bit.control.QueryContextInformation context = 16;
  inline bool has_context() const;
  inline void clear_context();
  static const int kContextFieldNumber = 16;
  inline const ::exec::bit::control::QueryContextInformation& context() const;
  inline ::exec::bit::control::QueryContextInformation* mutable_context();
  inline ::exec::bit::control::QueryContextInformation* release_context();
  inline void set_allocated_context(::exec::bit::control::QueryContextInformation* context);

  // repeated .exec.bit.control.Collector collector = 17;
  inline int collector_size() const;
  inline void clear_collector();
  static const int kCollectorFieldNumber = 17;
  inline const ::exec::bit::control::Collector& collector(int index) const;
  inline ::exec::bit::control::Collector* mutable_collector(int index);
  inline ::exec::bit::control::Collector* add_collector();
  inline const ::google::protobuf::RepeatedPtrField< ::exec::bit::control::Collector >&
      collector() const;
  inline ::google::protobuf::RepeatedPtrField< ::exec::bit::control::Collector >*
      mutable_collector();

  // @@protoc_insertion_point(class_scope:exec.bit.control.PlanFragment)
 private:
  inline void set_has_handle();
  inline void clear_has_handle();
  inline void set_has_network_cost();
  inline void clear_has_network_cost();
  inline void set_has_cpu_cost();
  inline void clear_has_cpu_cost();
  inline void set_has_disk_cost();
  inline void clear_has_disk_cost();
  inline void set_has_memory_cost();
  inline void clear_has_memory_cost();
  inline void set_has_fragment_json();
  inline void clear_has_fragment_json();
  inline void set_has_leaf_fragment();
  inline void clear_has_leaf_fragment();
  inline void set_has_assignment();
  inline void clear_has_assignment();
  inline void set_has_foreman();
  inline void clear_has_foreman();
  inline void set_has_mem_initial();
  inline void clear_has_mem_initial();
  inline void set_has_mem_max();
  inline void clear_has_mem_max();
  inline void set_has_credentials();
  inline void clear_has_credentials();
  inline void set_has_options_json();
  inline void clear_has_options_json();
  inline void set_has_context();
  inline void clear_has_context();

  ::google::protobuf::UnknownFieldSet _unknown_fields_;

  ::exec::bit::FragmentHandle* handle_;
  float network_cost_;
  float cpu_cost_;
  float disk_cost_;
  float memory_cost_;
  ::std::string* fragment_json_;
  ::exec::DrillbitEndpoint* assignment_;
  ::exec::DrillbitEndpoint* foreman_;
  ::google::protobuf::int64 mem_initial_;
  ::google::protobuf::int64 mem_max_;
  ::exec::shared::UserCredentials* credentials_;
  ::std::string* options_json_;
  ::exec::bit::control::QueryContextInformation* context_;
  ::google::protobuf::RepeatedPtrField< ::exec::bit::control::Collector > collector_;
  bool leaf_fragment_;

  mutable int _cached_size_;
  ::google::protobuf::uint32 _has_bits_[(15 + 31) / 32];

  friend void  protobuf_AddDesc_BitControl_2eproto();
  friend void protobuf_AssignDesc_BitControl_2eproto();
  friend void protobuf_ShutdownFile_BitControl_2eproto();

  void InitAsDefaultInstance();
  static PlanFragment* default_instance_;
};
// -------------------------------------------------------------------

class Collector : public ::google::protobuf::Message {
 public:
  Collector();
  virtual ~Collector();

  Collector(const Collector& from);

  inline Collector& operator=(const Collector& from) {
    CopyFrom(from);
    return *this;
  }

  inline const ::google::protobuf::UnknownFieldSet& unknown_fields() const {
    return _unknown_fields_;
  }

  inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() {
    return &_unknown_fields_;
  }

  static const ::google::protobuf::Descriptor* descriptor();
  static const Collector& default_instance();

  void Swap(Collector* other);

  // implements Message ----------------------------------------------

  Collector* New() const;
  void CopyFrom(const ::google::protobuf::Message& from);
  void MergeFrom(const ::google::protobuf::Message& from);
  void CopyFrom(const Collector& from);
  void MergeFrom(const Collector& from);
  void Clear();
  bool IsInitialized() const;

  int ByteSize() const;
  bool MergePartialFromCodedStream(
      ::google::protobuf::io::CodedInputStream* input);
  void SerializeWithCachedSizes(
      ::google::protobuf::io::CodedOutputStream* output) const;
  ::google::protobuf::uint8* SerializeWithCachedSizesToArray(::google::protobuf::uint8* output) const;
  int GetCachedSize() const { return _cached_size_; }
  private:
  void SharedCtor();
  void SharedDtor();
  void SetCachedSize(int size) const;
  public:

  ::google::protobuf::Metadata GetMetadata() const;

  // nested types ----------------------------------------------------

  // accessors -------------------------------------------------------

  // optional int32 opposite_major_fragment_id = 1;
  inline bool has_opposite_major_fragment_id() const;
  inline void clear_opposite_major_fragment_id();
  static const int kOppositeMajorFragmentIdFieldNumber = 1;
  inline ::google::protobuf::int32 opposite_major_fragment_id() const;
  inline void set_opposite_major_fragment_id(::google::protobuf::int32 value);

  // repeated int32 incoming_minor_fragment = 2 [packed = true];
  inline int incoming_minor_fragment_size() const;
  inline void clear_incoming_minor_fragment();
  static const int kIncomingMinorFragmentFieldNumber = 2;
  inline ::google::protobuf::int32 incoming_minor_fragment(int index) const;
  inline void set_incoming_minor_fragment(int index, ::google::protobuf::int32 value);
  inline void add_incoming_minor_fragment(::google::protobuf::int32 value);
  inline const ::google::protobuf::RepeatedField< ::google::protobuf::int32 >&
      incoming_minor_fragment() const;
  inline ::google::protobuf::RepeatedField< ::google::protobuf::int32 >*
      mutable_incoming_minor_fragment();

  // optional bool supports_out_of_order = 3;
  inline bool has_supports_out_of_order() const;
  inline void clear_supports_out_of_order();
  static const int kSupportsOutOfOrderFieldNumber = 3;
  inline bool supports_out_of_order() const;
  inline void set_supports_out_of_order(bool value);

  // optional bool is_spooling = 4;
  inline bool has_is_spooling() const;
  inline void clear_is_spooling();
  static const int kIsSpoolingFieldNumber = 4;
  inline bool is_spooling() const;
  inline void set_is_spooling(bool value);

  // @@protoc_insertion_point(class_scope:exec.bit.control.Collector)
 private:
  inline void set_has_opposite_major_fragment_id();
  inline void clear_has_opposite_major_fragment_id();
  inline void set_has_supports_out_of_order();
  inline void clear_has_supports_out_of_order();
  inline void set_has_is_spooling();
  inline void clear_has_is_spooling();

  ::google::protobuf::UnknownFieldSet _unknown_fields_;

  ::google::protobuf::RepeatedField< ::google::protobuf::int32 > incoming_minor_fragment_;
  mutable int _incoming_minor_fragment_cached_byte_size_;
  ::google::protobuf::int32 opposite_major_fragment_id_;
  bool supports_out_of_order_;
  bool is_spooling_;

  mutable int _cached_size_;
  ::google::protobuf::uint32 _has_bits_[(4 + 31) / 32];

  friend void  protobuf_AddDesc_BitControl_2eproto();
  friend void protobuf_AssignDesc_BitControl_2eproto();
  friend void protobuf_ShutdownFile_BitControl_2eproto();

  void InitAsDefaultInstance();
  static Collector* default_instance_;
};
// -------------------------------------------------------------------

class QueryContextInformation : public ::google::protobuf::Message {
 public:
  QueryContextInformation();
  virtual ~QueryContextInformation();

  QueryContextInformation(const QueryContextInformation& from);

  inline QueryContextInformation& operator=(const QueryContextInformation& from) {
    CopyFrom(from);
    return *this;
  }

  inline const ::google::protobuf::UnknownFieldSet& unknown_fields() const {
    return _unknown_fields_;
  }

  inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() {
    return &_unknown_fields_;
  }

  static const ::google::protobuf::Descriptor* descriptor();
  static const QueryContextInformation& default_instance();

  void Swap(QueryContextInformation* other);

  // implements Message ----------------------------------------------

  QueryContextInformation* New() const;
  void CopyFrom(const ::google::protobuf::Message& from);
  void MergeFrom(const ::google::protobuf::Message& from);
  void CopyFrom(const QueryContextInformation& from);
  void MergeFrom(const QueryContextInformation& from);
  void Clear();
  bool IsInitialized() const;

  int ByteSize() const;
  bool MergePartialFromCodedStream(
      ::google::protobuf::io::CodedInputStream* input);
  void SerializeWithCachedSizes(
      ::google::protobuf::io::CodedOutputStream* output) const;
  ::google::protobuf::uint8* SerializeWithCachedSizesToArray(::google::protobuf::uint8* output) const;
  int GetCachedSize() const { return _cached_size_; }
  private:
  void SharedCtor();
  void SharedDtor();
  void SetCachedSize(int size) const;
  public:

  ::google::protobuf::Metadata GetMetadata() const;

  // nested types ----------------------------------------------------

  // accessors -------------------------------------------------------

  // optional int64 query_start_time = 1;
  inline bool has_query_start_time() const;
  inline void clear_query_start_time();
  static const int kQueryStartTimeFieldNumber = 1;
  inline ::google::protobuf::int64 query_start_time() const;
  inline void set_query_start_time(::google::protobuf::int64 value);

  // optional int32 time_zone = 2;
  inline bool has_time_zone() const;
  inline void clear_time_zone();
  static const int kTimeZoneFieldNumber = 2;
  inline ::google::protobuf::int32 time_zone() const;
  inline void set_time_zone(::google::protobuf::int32 value);

  // optional string default_schema_name = 3;
  inline bool has_default_schema_name() const;
  inline void clear_default_schema_name();
  static const int kDefaultSchemaNameFieldNumber = 3;
  inline const ::std::string& default_schema_name() const;
  inline void set_default_schema_name(const ::std::string& value);
  inline void set_default_schema_name(const char* value);
  inline void set_default_schema_name(const char* value, size_t size);
  inline ::std::string* mutable_default_schema_name();
  inline ::std::string* release_default_schema_name();
  inline void set_allocated_default_schema_name(::std::string* default_schema_name);

  // optional string session_id = 4;
  inline bool has_session_id() const;
  inline void clear_session_id();
  static const int kSessionIdFieldNumber = 4;
  inline const ::std::string& session_id() const;
  inline void set_session_id(const ::std::string& value);
  inline void set_session_id(const char* value);
  inline void set_session_id(const char* value, size_t size);
  inline ::std::string* mutable_session_id();
  inline ::std::string* release_session_id();
  inline void set_allocated_session_id(::std::string* session_id);

  // @@protoc_insertion_point(class_scope:exec.bit.control.QueryContextInformation)
 private:
  inline void set_has_query_start_time();
  inline void clear_has_query_start_time();
  inline void set_has_time_zone();
  inline void clear_has_time_zone();
  inline void set_has_default_schema_name();
  inline void clear_has_default_schema_name();
  inline void set_has_session_id();
  inline void clear_has_session_id();

  ::google::protobuf::UnknownFieldSet _unknown_fields_;

  ::google::protobuf::int64 query_start_time_;
  ::std::string* default_schema_name_;
  ::std::string* session_id_;
  ::google::protobuf::int32 time_zone_;

  mutable int _cached_size_;
  ::google::protobuf::uint32 _has_bits_[(4 + 31) / 32];

  friend void  protobuf_AddDesc_BitControl_2eproto();
  friend void protobuf_AssignDesc_BitControl_2eproto();
  friend void protobuf_ShutdownFile_BitControl_2eproto();

  void InitAsDefaultInstance();
  static QueryContextInformation* default_instance_;
};
// -------------------------------------------------------------------

class WorkQueueStatus : public ::google::protobuf::Message {
 public:
  WorkQueueStatus();
  virtual ~WorkQueueStatus();

  WorkQueueStatus(const WorkQueueStatus& from);

  inline WorkQueueStatus& operator=(const WorkQueueStatus& from) {
    CopyFrom(from);
    return *this;
  }

  inline const ::google::protobuf::UnknownFieldSet& unknown_fields() const {
    return _unknown_fields_;
  }

  inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() {
    return &_unknown_fields_;
  }

  static const ::google::protobuf::Descriptor* descriptor();
  static const WorkQueueStatus& default_instance();

  void Swap(WorkQueueStatus* other);

  // implements Message ----------------------------------------------

  WorkQueueStatus* New() const;
  void CopyFrom(const ::google::protobuf::Message& from);
  void MergeFrom(const ::google::protobuf::Message& from);
  void CopyFrom(const WorkQueueStatus& from);
  void MergeFrom(const WorkQueueStatus& from);
  void Clear();
  bool IsInitialized() const;

  int ByteSize() const;
  bool MergePartialFromCodedStream(
      ::google::protobuf::io::CodedInputStream* input);
  void SerializeWithCachedSizes(
      ::google::protobuf::io::CodedOutputStream* output) const;
  ::google::protobuf::uint8* SerializeWithCachedSizesToArray(::google::protobuf::uint8* output) const;
  int GetCachedSize() const { return _cached_size_; }
  private:
  void SharedCtor();
  void SharedDtor();
  void SetCachedSize(int size) const;
  public:

  ::google::protobuf::Metadata GetMetadata() const;

  // nested types ----------------------------------------------------

  // accessors -------------------------------------------------------

  // optional .exec.DrillbitEndpoint endpoint = 1;
  inline bool has_endpoint() const;
  inline void clear_endpoint();
  static const int kEndpointFieldNumber = 1;
  inline const ::exec::DrillbitEndpoint& endpoint() const;
  inline ::exec::DrillbitEndpoint* mutable_endpoint();
  inline ::exec::DrillbitEndpoint* release_endpoint();
  inline void set_allocated_endpoint(::exec::DrillbitEndpoint* endpoint);

  // optional int32 queue_length = 2;
  inline bool has_queue_length() const;
  inline void clear_queue_length();
  static const int kQueueLengthFieldNumber = 2;
  inline ::google::protobuf::int32 queue_length() const;
  inline void set_queue_length(::google::protobuf::int32 value);

  // optional int64 report_time = 3;
  inline bool has_report_time() const;
  inline void clear_report_time();
  static const int kReportTimeFieldNumber = 3;
  inline ::google::protobuf::int64 report_time() const;
  inline void set_report_time(::google::protobuf::int64 value);

  // @@protoc_insertion_point(class_scope:exec.bit.control.WorkQueueStatus)
 private:
  inline void set_has_endpoint();
  inline void clear_has_endpoint();
  inline void set_has_queue_length();
  inline void clear_has_queue_length();
  inline void set_has_report_time();
  inline void clear_has_report_time();

  ::google::protobuf::UnknownFieldSet _unknown_fields_;

  ::exec::DrillbitEndpoint* endpoint_;
  ::google::protobuf::int64 report_time_;
  ::google::protobuf::int32 queue_length_;

  mutable int _cached_size_;
  ::google::protobuf::uint32 _has_bits_[(3 + 31) / 32];

  friend void  protobuf_AddDesc_BitControl_2eproto();
  friend void protobuf_AssignDesc_BitControl_2eproto();
  friend void protobuf_ShutdownFile_BitControl_2eproto();

  void InitAsDefaultInstance();
  static WorkQueueStatus* default_instance_;
};
// -------------------------------------------------------------------

class FinishedReceiver : public ::google::protobuf::Message {
 public:
  FinishedReceiver();
  virtual ~FinishedReceiver();

  FinishedReceiver(const FinishedReceiver& from);

  inline FinishedReceiver& operator=(const FinishedReceiver& from) {
    CopyFrom(from);
    return *this;
  }

  inline const ::google::protobuf::UnknownFieldSet& unknown_fields() const {
    return _unknown_fields_;
  }

  inline ::google::protobuf::UnknownFieldSet* mutable_unknown_fields() {
    return &_unknown_fields_;
  }

  static const ::google::protobuf::Descriptor* descriptor();
  static const FinishedReceiver& default_instance();

  void Swap(FinishedReceiver* other);

  // implements Message ----------------------------------------------

  FinishedReceiver* New() const;
  void CopyFrom(const ::google::protobuf::Message& from);
  void MergeFrom(const ::google::protobuf::Message& from);
  void CopyFrom(const FinishedReceiver& from);
  void MergeFrom(const FinishedReceiver& from);
  void Clear();
  bool IsInitialized() const;

  int ByteSize() const;
  bool MergePartialFromCodedStream(
      ::google::protobuf::io::CodedInputStream* input);
  void SerializeWithCachedSizes(
      ::google::protobuf::io::CodedOutputStream* output) const;
  ::google::protobuf::uint8* SerializeWithCachedSizesToArray(::google::protobuf::uint8* output) const;
  int GetCachedSize() const { return _cached_size_; }
  private:
  void SharedCtor();
  void SharedDtor();
  void SetCachedSize(int size) const;
  public:

  ::google::protobuf::Metadata GetMetadata() const;

  // nested types ----------------------------------------------------

  // accessors -------------------------------------------------------

  // optional .exec.bit.FragmentHandle receiver = 1;
  inline bool has_receiver() const;
  inline void clear_receiver();
  static const int kReceiverFieldNumber = 1;
  inline const ::exec::bit::FragmentHandle& receiver() const;
  inline ::exec::bit::FragmentHandle* mutable_receiver();
  inline ::exec::bit::FragmentHandle* release_receiver();
  inline void set_allocated_receiver(::exec::bit::FragmentHandle* receiver);

  // optional .exec.bit.FragmentHandle sender = 2;
  inline bool has_sender() const;
  inline void clear_sender();
  static const int kSenderFieldNumber = 2;
  inline const ::exec::bit::FragmentHandle& sender() const;
  inline ::exec::bit::FragmentHandle* mutable_sender();
  inline ::exec::bit::FragmentHandle* release_sender();
  inline void set_allocated_sender(::exec::bit::FragmentHandle* sender);

  // @@protoc_insertion_point(class_scope:exec.bit.control.FinishedReceiver)
 private:
  inline void set_has_receiver();
  inline void clear_has_receiver();
  inline void set_has_sender();
  inline void clear_has_sender();

  ::google::protobuf::UnknownFieldSet _unknown_fields_;

  ::exec::bit::FragmentHandle* receiver_;
  ::exec::bit::FragmentHandle* sender_;

  mutable int _cached_size_;
  ::google::protobuf::uint32 _has_bits_[(2 + 31) / 32];

  friend void  protobuf_AddDesc_BitControl_2eproto();
  friend void protobuf_AssignDesc_BitControl_2eproto();
  friend void protobuf_ShutdownFile_BitControl_2eproto();

  void InitAsDefaultInstance();
  static FinishedReceiver* default_instance_;
};
// ===================================================================


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

// BitControlHandshake

// optional int32 rpc_version = 1;
inline bool BitControlHandshake::has_rpc_version() const {
  return (_has_bits_[0] & 0x00000001u) != 0;
}
inline void BitControlHandshake::set_has_rpc_version() {
  _has_bits_[0] |= 0x00000001u;
}
inline void BitControlHandshake::clear_has_rpc_version() {
  _has_bits_[0] &= ~0x00000001u;
}
inline void BitControlHandshake::clear_rpc_version() {
  rpc_version_ = 0;
  clear_has_rpc_version();
}
inline ::google::protobuf::int32 BitControlHandshake::rpc_version() const {
  return rpc_version_;
}
inline void BitControlHandshake::set_rpc_version(::google::protobuf::int32 value) {
  set_has_rpc_version();
  rpc_version_ = value;
}

// optional .exec.shared.RpcChannel channel = 2 [default = BIT_CONTROL];
inline bool BitControlHandshake::has_channel() const {
  return (_has_bits_[0] & 0x00000002u) != 0;
}
inline void BitControlHandshake::set_has_channel() {
  _has_bits_[0] |= 0x00000002u;
}
inline void BitControlHandshake::clear_has_channel() {
  _has_bits_[0] &= ~0x00000002u;
}
inline void BitControlHandshake::clear_channel() {
  channel_ = 0;
  clear_has_channel();
}
inline ::exec::shared::RpcChannel BitControlHandshake::channel() const {
  return static_cast< ::exec::shared::RpcChannel >(channel_);
}
inline void BitControlHandshake::set_channel(::exec::shared::RpcChannel value) {
  assert(::exec::shared::RpcChannel_IsValid(value));
  set_has_channel();
  channel_ = value;
}

// optional .exec.DrillbitEndpoint endpoint = 3;
inline bool BitControlHandshake::has_endpoint() const {
  return (_has_bits_[0] & 0x00000004u) != 0;
}
inline void BitControlHandshake::set_has_endpoint() {
  _has_bits_[0] |= 0x00000004u;
}
inline void BitControlHandshake::clear_has_endpoint() {
  _has_bits_[0] &= ~0x00000004u;
}
inline void BitControlHandshake::clear_endpoint() {
  if (endpoint_ != NULL) endpoint_->::exec::DrillbitEndpoint::Clear();
  clear_has_endpoint();
}
inline const ::exec::DrillbitEndpoint& BitControlHandshake::endpoint() const {
  return endpoint_ != NULL ? *endpoint_ : *default_instance_->endpoint_;
}
inline ::exec::DrillbitEndpoint* BitControlHandshake::mutable_endpoint() {
  set_has_endpoint();
  if (endpoint_ == NULL) endpoint_ = new ::exec::DrillbitEndpoint;
  return endpoint_;
}
inline ::exec::DrillbitEndpoint* BitControlHandshake::release_endpoint() {
  clear_has_endpoint();
  ::exec::DrillbitEndpoint* temp = endpoint_;
  endpoint_ = NULL;
  return temp;
}
inline void BitControlHandshake::set_allocated_endpoint(::exec::DrillbitEndpoint* endpoint) {
  delete endpoint_;
  endpoint_ = endpoint;
  if (endpoint) {
    set_has_endpoint();
  } else {
    clear_has_endpoint();
  }
}

// repeated string authenticationMechanisms = 4;
inline int BitControlHandshake::authenticationmechanisms_size() const {
  return authenticationmechanisms_.size();
}
inline void BitControlHandshake::clear_authenticationmechanisms() {
  authenticationmechanisms_.Clear();
}
inline const ::std::string& BitControlHandshake::authenticationmechanisms(int index) const {
  return authenticationmechanisms_.Get(index);
}
inline ::std::string* BitControlHandshake::mutable_authenticationmechanisms(int index) {
  return authenticationmechanisms_.Mutable(index);
}
inline void BitControlHandshake::set_authenticationmechanisms(int index, const ::std::string& value) {
  authenticationmechanisms_.Mutable(index)->assign(value);
}
inline void BitControlHandshake::set_authenticationmechanisms(int index, const char* value) {
  authenticationmechanisms_.Mutable(index)->assign(value);
}
inline void BitControlHandshake::set_authenticationmechanisms(int index, const char* value, size_t size) {
  authenticationmechanisms_.Mutable(index)->assign(
    reinterpret_cast<const char*>(value), size);
}
inline ::std::string* BitControlHandshake::add_authenticationmechanisms() {
  return authenticationmechanisms_.Add();
}
inline void BitControlHandshake::add_authenticationmechanisms(const ::std::string& value) {
  authenticationmechanisms_.Add()->assign(value);
}
inline void BitControlHandshake::add_authenticationmechanisms(const char* value) {
  authenticationmechanisms_.Add()->assign(value);
}
inline void BitControlHandshake::add_authenticationmechanisms(const char* value, size_t size) {
  authenticationmechanisms_.Add()->assign(reinterpret_cast<const char*>(value), size);
}
inline const ::google::protobuf::RepeatedPtrField< ::std::string>&
BitControlHandshake::authenticationmechanisms() const {
  return authenticationmechanisms_;
}
inline ::google::protobuf::RepeatedPtrField< ::std::string>*
BitControlHandshake::mutable_authenticationmechanisms() {
  return &authenticationmechanisms_;
}

// -------------------------------------------------------------------

// BitStatus

// repeated .exec.bit.control.FragmentStatus fragment_status = 1;
inline int BitStatus::fragment_status_size() const {
  return fragment_status_.size();
}
inline void BitStatus::clear_fragment_status() {
  fragment_status_.Clear();
}
inline const ::exec::bit::control::FragmentStatus& BitStatus::fragment_status(int index) const {
  return fragment_status_.Get(index);
}
inline ::exec::bit::control::FragmentStatus* BitStatus::mutable_fragment_status(int index) {
  return fragment_status_.Mutable(index);
}
inline ::exec::bit::control::FragmentStatus* BitStatus::add_fragment_status() {
  return fragment_status_.Add();
}
inline const ::google::protobuf::RepeatedPtrField< ::exec::bit::control::FragmentStatus >&
BitStatus::fragment_status() const {
  return fragment_status_;
}
inline ::google::protobuf::RepeatedPtrField< ::exec::bit::control::FragmentStatus >*
BitStatus::mutable_fragment_status() {
  return &fragment_status_;
}

// -------------------------------------------------------------------

// FragmentStatus

// optional .exec.shared.MinorFragmentProfile profile = 1;
inline bool FragmentStatus::has_profile() const {
  return (_has_bits_[0] & 0x00000001u) != 0;
}
inline void FragmentStatus::set_has_profile() {
  _has_bits_[0] |= 0x00000001u;
}
inline void FragmentStatus::clear_has_profile() {
  _has_bits_[0] &= ~0x00000001u;
}
inline void FragmentStatus::clear_profile() {
  if (profile_ != NULL) profile_->::exec::shared::MinorFragmentProfile::Clear();
  clear_has_profile();
}
inline const ::exec::shared::MinorFragmentProfile& FragmentStatus::profile() const {
  return profile_ != NULL ? *profile_ : *default_instance_->profile_;
}
inline ::exec::shared::MinorFragmentProfile* FragmentStatus::mutable_profile() {
  set_has_profile();
  if (profile_ == NULL) profile_ = new ::exec::shared::MinorFragmentProfile;
  return profile_;
}
inline ::exec::shared::MinorFragmentProfile* FragmentStatus::release_profile() {
  clear_has_profile();
  ::exec::shared::MinorFragmentProfile* temp = profile_;
  profile_ = NULL;
  return temp;
}
inline void FragmentStatus::set_allocated_profile(::exec::shared::MinorFragmentProfile* profile) {
  delete profile_;
  profile_ = profile;
  if (profile) {
    set_has_profile();
  } else {
    clear_has_profile();
  }
}

// optional .exec.bit.FragmentHandle handle = 2;
inline bool FragmentStatus::has_handle() const {
  return (_has_bits_[0] & 0x00000002u) != 0;
}
inline void FragmentStatus::set_has_handle() {
  _has_bits_[0] |= 0x00000002u;
}
inline void FragmentStatus::clear_has_handle() {
  _has_bits_[0] &= ~0x00000002u;
}
inline void FragmentStatus::clear_handle() {
  if (handle_ != NULL) handle_->::exec::bit::FragmentHandle::Clear();
  clear_has_handle();
}
inline const ::exec::bit::FragmentHandle& FragmentStatus::handle() const {
  return handle_ != NULL ? *handle_ : *default_instance_->handle_;
}
inline ::exec::bit::FragmentHandle* FragmentStatus::mutable_handle() {
  set_has_handle();
  if (handle_ == NULL) handle_ = new ::exec::bit::FragmentHandle;
  return handle_;
}
inline ::exec::bit::FragmentHandle* FragmentStatus::release_handle() {
  clear_has_handle();
  ::exec::bit::FragmentHandle* temp = handle_;
  handle_ = NULL;
  return temp;
}
inline void FragmentStatus::set_allocated_handle(::exec::bit::FragmentHandle* handle) {
  delete handle_;
  handle_ = handle;
  if (handle) {
    set_has_handle();
  } else {
    clear_has_handle();
  }
}

// -------------------------------------------------------------------

// InitializeFragments

// repeated .exec.bit.control.PlanFragment fragment = 1;
inline int InitializeFragments::fragment_size() const {
  return fragment_.size();
}
inline void InitializeFragments::clear_fragment() {
  fragment_.Clear();
}
inline const ::exec::bit::control::PlanFragment& InitializeFragments::fragment(int index) const {
  return fragment_.Get(index);
}
inline ::exec::bit::control::PlanFragment* InitializeFragments::mutable_fragment(int index) {
  return fragment_.Mutable(index);
}
inline ::exec::bit::control::PlanFragment* InitializeFragments::add_fragment() {
  return fragment_.Add();
}
inline const ::google::protobuf::RepeatedPtrField< ::exec::bit::control::PlanFragment >&
InitializeFragments::fragment() const {
  return fragment_;
}
inline ::google::protobuf::RepeatedPtrField< ::exec::bit::control::PlanFragment >*
InitializeFragments::mutable_fragment() {
  return &fragment_;
}

// -------------------------------------------------------------------

// CustomMessage

// optional int32 type = 1;
inline bool CustomMessage::has_type() const {
  return (_has_bits_[0] & 0x00000001u) != 0;
}
inline void CustomMessage::set_has_type() {
  _has_bits_[0] |= 0x00000001u;
}
inline void CustomMessage::clear_has_type() {
  _has_bits_[0] &= ~0x00000001u;
}
inline void CustomMessage::clear_type() {
  type_ = 0;
  clear_has_type();
}
inline ::google::protobuf::int32 CustomMessage::type() const {
  return type_;
}
inline void CustomMessage::set_type(::google::protobuf::int32 value) {
  set_has_type();
  type_ = value;
}

// optional bytes message = 2;
inline bool CustomMessage::has_message() const {
  return (_has_bits_[0] & 0x00000002u) != 0;
}
inline void CustomMessage::set_has_message() {
  _has_bits_[0] |= 0x00000002u;
}
inline void CustomMessage::clear_has_message() {
  _has_bits_[0] &= ~0x00000002u;
}
inline void CustomMessage::clear_message() {
  if (message_ != &::google::protobuf::internal::kEmptyString) {
    message_->clear();
  }
  clear_has_message();
}
inline const ::std::string& CustomMessage::message() const {
  return *message_;
}
inline void CustomMessage::set_message(const ::std::string& value) {
  set_has_message();
  if (message_ == &::google::protobuf::internal::kEmptyString) {
    message_ = new ::std::string;
  }
  message_->assign(value);
}
inline void CustomMessage::set_message(const char* value) {
  set_has_message();
  if (message_ == &::google::protobuf::internal::kEmptyString) {
    message_ = new ::std::string;
  }
  message_->assign(value);
}
inline void CustomMessage::set_message(const void* value, size_t size) {
  set_has_message();
  if (message_ == &::google::protobuf::internal::kEmptyString) {
    message_ = new ::std::string;
  }
  message_->assign(reinterpret_cast<const char*>(value), size);
}
inline ::std::string* CustomMessage::mutable_message() {
  set_has_message();
  if (message_ == &::google::protobuf::internal::kEmptyString) {
    message_ = new ::std::string;
  }
  return message_;
}
inline ::std::string* CustomMessage::release_message() {
  clear_has_message();
  if (message_ == &::google::protobuf::internal::kEmptyString) {
    return NULL;
  } else {
    ::std::string* temp = message_;
    message_ = const_cast< ::std::string*>(&::google::protobuf::internal::kEmptyString);
    return temp;
  }
}
inline void CustomMessage::set_allocated_message(::std::string* message) {
  if (message_ != &::google::protobuf::internal::kEmptyString) {
    delete message_;
  }
  if (message) {
    set_has_message();
    message_ = message;
  } else {
    clear_has_message();
    message_ = const_cast< ::std::string*>(&::google::protobuf::internal::kEmptyString);
  }
}

// -------------------------------------------------------------------

// PlanFragment

// optional .exec.bit.FragmentHandle handle = 1;
inline bool PlanFragment::has_handle() const {
  return (_has_bits_[0] & 0x00000001u) != 0;
}
inline void PlanFragment::set_has_handle() {
  _has_bits_[0] |= 0x00000001u;
}
inline void PlanFragment::clear_has_handle() {
  _has_bits_[0] &= ~0x00000001u;
}
inline void PlanFragment::clear_handle() {
  if (handle_ != NULL) handle_->::exec::bit::FragmentHandle::Clear();
  clear_has_handle();
}
inline const ::exec::bit::FragmentHandle& PlanFragment::handle() const {
  return handle_ != NULL ? *handle_ : *default_instance_->handle_;
}
inline ::exec::bit::FragmentHandle* PlanFragment::mutable_handle() {
  set_has_handle();
  if (handle_ == NULL) handle_ = new ::exec::bit::FragmentHandle;
  return handle_;
}
inline ::exec::bit::FragmentHandle* PlanFragment::release_handle() {
  clear_has_handle();
  ::exec::bit::FragmentHandle* temp = handle_;
  handle_ = NULL;
  return temp;
}
inline void PlanFragment::set_allocated_handle(::exec::bit::FragmentHandle* handle) {
  delete handle_;
  handle_ = handle;
  if (handle) {
    set_has_handle();
  } else {
    clear_has_handle();
  }
}

// optional float network_cost = 4;
inline bool PlanFragment::has_network_cost() const {
  return (_has_bits_[0] & 0x00000002u) != 0;
}
inline void PlanFragment::set_has_network_cost() {
  _has_bits_[0] |= 0x00000002u;
}
inline void PlanFragment::clear_has_network_cost() {
  _has_bits_[0] &= ~0x00000002u;
}
inline void PlanFragment::clear_network_cost() {
  network_cost_ = 0;
  clear_has_network_cost();
}
inline float PlanFragment::network_cost() const {
  return network_cost_;
}
inline void PlanFragment::set_network_cost(float value) {
  set_has_network_cost();
  network_cost_ = value;
}

// optional float cpu_cost = 5;
inline bool PlanFragment::has_cpu_cost() const {
  return (_has_bits_[0] & 0x00000004u) != 0;
}
inline void PlanFragment::set_has_cpu_cost() {
  _has_bits_[0] |= 0x00000004u;
}
inline void PlanFragment::clear_has_cpu_cost() {
  _has_bits_[0] &= ~0x00000004u;
}
inline void PlanFragment::clear_cpu_cost() {
  cpu_cost_ = 0;
  clear_has_cpu_cost();
}
inline float PlanFragment::cpu_cost() const {
  return cpu_cost_;
}
inline void PlanFragment::set_cpu_cost(float value) {
  set_has_cpu_cost();
  cpu_cost_ = value;
}

// optional float disk_cost = 6;
inline bool PlanFragment::has_disk_cost() const {
  return (_has_bits_[0] & 0x00000008u) != 0;
}
inline void PlanFragment::set_has_disk_cost() {
  _has_bits_[0] |= 0x00000008u;
}
inline void PlanFragment::clear_has_disk_cost() {
  _has_bits_[0] &= ~0x00000008u;
}
inline void PlanFragment::clear_disk_cost() {
  disk_cost_ = 0;
  clear_has_disk_cost();
}
inline float PlanFragment::disk_cost() const {
  return disk_cost_;
}
inline void PlanFragment::set_disk_cost(float value) {
  set_has_disk_cost();
  disk_cost_ = value;
}

// optional float memory_cost = 7;
inline bool PlanFragment::has_memory_cost() const {
  return (_has_bits_[0] & 0x00000010u) != 0;
}
inline void PlanFragment::set_has_memory_cost() {
  _has_bits_[0] |= 0x00000010u;
}
inline void PlanFragment::clear_has_memory_cost() {
  _has_bits_[0] &= ~0x00000010u;
}
inline void PlanFragment::clear_memory_cost() {
  memory_cost_ = 0;
  clear_has_memory_cost();
}
inline float PlanFragment::memory_cost() const {
  return memory_cost_;
}
inline void PlanFragment::set_memory_cost(float value) {
  set_has_memory_cost();
  memory_cost_ = value;
}

// optional string fragment_json = 8;
inline bool PlanFragment::has_fragment_json() const {
  return (_has_bits_[0] & 0x00000020u) != 0;
}
inline void PlanFragment::set_has_fragment_json() {
  _has_bits_[0] |= 0x00000020u;
}
inline void PlanFragment::clear_has_fragment_json() {
  _has_bits_[0] &= ~0x00000020u;
}
inline void PlanFragment::clear_fragment_json() {
  if (fragment_json_ != &::google::protobuf::internal::kEmptyString) {
    fragment_json_->clear();
  }
  clear_has_fragment_json();
}
inline const ::std::string& PlanFragment::fragment_json() const {
  return *fragment_json_;
}
inline void PlanFragment::set_fragment_json(const ::std::string& value) {
  set_has_fragment_json();
  if (fragment_json_ == &::google::protobuf::internal::kEmptyString) {
    fragment_json_ = new ::std::string;
  }
  fragment_json_->assign(value);
}
inline void PlanFragment::set_fragment_json(const char* value) {
  set_has_fragment_json();
  if (fragment_json_ == &::google::protobuf::internal::kEmptyString) {
    fragment_json_ = new ::std::string;
  }
  fragment_json_->assign(value);
}
inline void PlanFragment::set_fragment_json(const char* value, size_t size) {
  set_has_fragment_json();
  if (fragment_json_ == &::google::protobuf::internal::kEmptyString) {
    fragment_json_ = new ::std::string;
  }
  fragment_json_->assign(reinterpret_cast<const char*>(value), size);
}
inline ::std::string* PlanFragment::mutable_fragment_json() {
  set_has_fragment_json();
  if (fragment_json_ == &::google::protobuf::internal::kEmptyString) {
    fragment_json_ = new ::std::string;
  }
  return fragment_json_;
}
inline ::std::string* PlanFragment::release_fragment_json() {
  clear_has_fragment_json();
  if (fragment_json_ == &::google::protobuf::internal::kEmptyString) {
    return NULL;
  } else {
    ::std::string* temp = fragment_json_;
    fragment_json_ = const_cast< ::std::string*>(&::google::protobuf::internal::kEmptyString);
    return temp;
  }
}
inline void PlanFragment::set_allocated_fragment_json(::std::string* fragment_json) {
  if (fragment_json_ != &::google::protobuf::internal::kEmptyString) {
    delete fragment_json_;
  }
  if (fragment_json) {
    set_has_fragment_json();
    fragment_json_ = fragment_json;
  } else {
    clear_has_fragment_json();
    fragment_json_ = const_cast< ::std::string*>(&::google::protobuf::internal::kEmptyString);
  }
}

// optional bool leaf_fragment = 9;
inline bool PlanFragment::has_leaf_fragment() const {
  return (_has_bits_[0] & 0x00000040u) != 0;
}
inline void PlanFragment::set_has_leaf_fragment() {
  _has_bits_[0] |= 0x00000040u;
}
inline void PlanFragment::clear_has_leaf_fragment() {
  _has_bits_[0] &= ~0x00000040u;
}
inline void PlanFragment::clear_leaf_fragment() {
  leaf_fragment_ = false;
  clear_has_leaf_fragment();
}
inline bool PlanFragment::leaf_fragment() const {
  return leaf_fragment_;
}
inline void PlanFragment::set_leaf_fragment(bool value) {
  set_has_leaf_fragment();
  leaf_fragment_ = value;
}

// optional .exec.DrillbitEndpoint assignment = 10;
inline bool PlanFragment::has_assignment() const {
  return (_has_bits_[0] & 0x00000080u) != 0;
}
inline void PlanFragment::set_has_assignment() {
  _has_bits_[0] |= 0x00000080u;
}
inline void PlanFragment::clear_has_assignment() {
  _has_bits_[0] &= ~0x00000080u;
}
inline void PlanFragment::clear_assignment() {
  if (assignment_ != NULL) assignment_->::exec::DrillbitEndpoint::Clear();
  clear_has_assignment();
}
inline const ::exec::DrillbitEndpoint& PlanFragment::assignment() const {
  return assignment_ != NULL ? *assignment_ : *default_instance_->assignment_;
}
inline ::exec::DrillbitEndpoint* PlanFragment::mutable_assignment() {
  set_has_assignment();
  if (assignment_ == NULL) assignment_ = new ::exec::DrillbitEndpoint;
  return assignment_;
}
inline ::exec::DrillbitEndpoint* PlanFragment::release_assignment() {
  clear_has_assignment();
  ::exec::DrillbitEndpoint* temp = assignment_;
  assignment_ = NULL;
  return temp;
}
inline void PlanFragment::set_allocated_assignment(::exec::DrillbitEndpoint* assignment) {
  delete assignment_;
  assignment_ = assignment;
  if (assignment) {
    set_has_assignment();
  } else {
    clear_has_assignment();
  }
}

// optional .exec.DrillbitEndpoint foreman = 11;
inline bool PlanFragment::has_foreman() const {
  return (_has_bits_[0] & 0x00000100u) != 0;
}
inline void PlanFragment::set_has_foreman() {
  _has_bits_[0] |= 0x00000100u;
}
inline void PlanFragment::clear_has_foreman() {
  _has_bits_[0] &= ~0x00000100u;
}
inline void PlanFragment::clear_foreman() {
  if (foreman_ != NULL) foreman_->::exec::DrillbitEndpoint::Clear();
  clear_has_foreman();
}
inline const ::exec::DrillbitEndpoint& PlanFragment::foreman() const {
  return foreman_ != NULL ? *foreman_ : *default_instance_->foreman_;
}
inline ::exec::DrillbitEndpoint* PlanFragment::mutable_foreman() {
  set_has_foreman();
  if (foreman_ == NULL) foreman_ = new ::exec::DrillbitEndpoint;
  return foreman_;
}
inline ::exec::DrillbitEndpoint* PlanFragment::release_foreman() {
  clear_has_foreman();
  ::exec::DrillbitEndpoint* temp = foreman_;
  foreman_ = NULL;
  return temp;
}
inline void PlanFragment::set_allocated_foreman(::exec::DrillbitEndpoint* foreman) {
  delete foreman_;
  foreman_ = foreman;
  if (foreman) {
    set_has_foreman();
  } else {
    clear_has_foreman();
  }
}

// optional int64 mem_initial = 12 [default = 20000000];
inline bool PlanFragment::has_mem_initial() const {
  return (_has_bits_[0] & 0x00000200u) != 0;
}
inline void PlanFragment::set_has_mem_initial() {
  _has_bits_[0] |= 0x00000200u;
}
inline void PlanFragment::clear_has_mem_initial() {
  _has_bits_[0] &= ~0x00000200u;
}
inline void PlanFragment::clear_mem_initial() {
  mem_initial_ = GOOGLE_LONGLONG(20000000);
  clear_has_mem_initial();
}
inline ::google::protobuf::int64 PlanFragment::mem_initial() const {
  return mem_initial_;
}
inline void PlanFragment::set_mem_initial(::google::protobuf::int64 value) {
  set_has_mem_initial();
  mem_initial_ = value;
}

// optional int64 mem_max = 13 [default = 2000000000];
inline bool PlanFragment::has_mem_max() const {
  return (_has_bits_[0] & 0x00000400u) != 0;
}
inline void PlanFragment::set_has_mem_max() {
  _has_bits_[0] |= 0x00000400u;
}
inline void PlanFragment::clear_has_mem_max() {
  _has_bits_[0] &= ~0x00000400u;
}
inline void PlanFragment::clear_mem_max() {
  mem_max_ = GOOGLE_LONGLONG(2000000000);
  clear_has_mem_max();
}
inline ::google::protobuf::int64 PlanFragment::mem_max() const {
  return mem_max_;
}
inline void PlanFragment::set_mem_max(::google::protobuf::int64 value) {
  set_has_mem_max();
  mem_max_ = value;
}

// optional .exec.shared.UserCredentials credentials = 14;
inline bool PlanFragment::has_credentials() const {
  return (_has_bits_[0] & 0x00000800u) != 0;
}
inline void PlanFragment::set_has_credentials() {
  _has_bits_[0] |= 0x00000800u;
}
inline void PlanFragment::clear_has_credentials() {
  _has_bits_[0] &= ~0x00000800u;
}
inline void PlanFragment::clear_credentials() {
  if (credentials_ != NULL) credentials_->::exec::shared::UserCredentials::Clear();
  clear_has_credentials();
}
inline const ::exec::shared::UserCredentials& PlanFragment::credentials() const {
  return credentials_ != NULL ? *credentials_ : *default_instance_->credentials_;
}
inline ::exec::shared::UserCredentials* PlanFragment::mutable_credentials() {
  set_has_credentials();
  if (credentials_ == NULL) credentials_ = new ::exec::shared::UserCredentials;
  return credentials_;
}
inline ::exec::shared::UserCredentials* PlanFragment::release_credentials() {
  clear_has_credentials();
  ::exec::shared::UserCredentials* temp = credentials_;
  credentials_ = NULL;
  return temp;
}
inline void PlanFragment::set_allocated_credentials(::exec::shared::UserCredentials* credentials) {
  delete credentials_;
  credentials_ = credentials;
  if (credentials) {
    set_has_credentials();
  } else {
    clear_has_credentials();
  }
}

// optional string options_json = 15;
inline bool PlanFragment::has_options_json() const {
  return (_has_bits_[0] & 0x00001000u) != 0;
}
inline void PlanFragment::set_has_options_json() {
  _has_bits_[0] |= 0x00001000u;
}
inline void PlanFragment::clear_has_options_json() {
  _has_bits_[0] &= ~0x00001000u;
}
inline void PlanFragment::clear_options_json() {
  if (options_json_ != &::google::protobuf::internal::kEmptyString) {
    options_json_->clear();
  }
  clear_has_options_json();
}
inline const ::std::string& PlanFragment::options_json() const {
  return *options_json_;
}
inline void PlanFragment::set_options_json(const ::std::string& value) {
  set_has_options_json();
  if (options_json_ == &::google::protobuf::internal::kEmptyString) {
    options_json_ = new ::std::string;
  }
  options_json_->assign(value);
}
inline void PlanFragment::set_options_json(const char* value) {
  set_has_options_json();
  if (options_json_ == &::google::protobuf::internal::kEmptyString) {
    options_json_ = new ::std::string;
  }
  options_json_->assign(value);
}
inline void PlanFragment::set_options_json(const char* value, size_t size) {
  set_has_options_json();
  if (options_json_ == &::google::protobuf::internal::kEmptyString) {
    options_json_ = new ::std::string;
  }
  options_json_->assign(reinterpret_cast<const char*>(value), size);
}
inline ::std::string* PlanFragment::mutable_options_json() {
  set_has_options_json();
  if (options_json_ == &::google::protobuf::internal::kEmptyString) {
    options_json_ = new ::std::string;
  }
  return options_json_;
}
inline ::std::string* PlanFragment::release_options_json() {
  clear_has_options_json();
  if (options_json_ == &::google::protobuf::internal::kEmptyString) {
    return NULL;
  } else {
    ::std::string* temp = options_json_;
    options_json_ = const_cast< ::std::string*>(&::google::protobuf::internal::kEmptyString);
    return temp;
  }
}
inline void PlanFragment::set_allocated_options_json(::std::string* options_json) {
  if (options_json_ != &::google::protobuf::internal::kEmptyString) {
    delete options_json_;
  }
  if (options_json) {
    set_has_options_json();
    options_json_ = options_json;
  } else {
    clear_has_options_json();
    options_json_ = const_cast< ::std::string*>(&::google::protobuf::internal::kEmptyString);
  }
}

// optional .exec.bit.control.QueryContextInformation context = 16;
inline bool PlanFragment::has_context() const {
  return (_has_bits_[0] & 0x00002000u) != 0;
}
inline void PlanFragment::set_has_context() {
  _has_bits_[0] |= 0x00002000u;
}
inline void PlanFragment::clear_has_context() {
  _has_bits_[0] &= ~0x00002000u;
}
inline void PlanFragment::clear_context() {
  if (context_ != NULL) context_->::exec::bit::control::QueryContextInformation::Clear();
  clear_has_context();
}
inline const ::exec::bit::control::QueryContextInformation& PlanFragment::context() const {
  return context_ != NULL ? *context_ : *default_instance_->context_;
}
inline ::exec::bit::control::QueryContextInformation* PlanFragment::mutable_context() {
  set_has_context();
  if (context_ == NULL) context_ = new ::exec::bit::control::QueryContextInformation;
  return context_;
}
inline ::exec::bit::control::QueryContextInformation* PlanFragment::release_context() {
  clear_has_context();
  ::exec::bit::control::QueryContextInformation* temp = context_;
  context_ = NULL;
  return temp;
}
inline void PlanFragment::set_allocated_context(::exec::bit::control::QueryContextInformation* context) {
  delete context_;
  context_ = context;
  if (context) {
    set_has_context();
  } else {
    clear_has_context();
  }
}

// repeated .exec.bit.control.Collector collector = 17;
inline int PlanFragment::collector_size() const {
  return collector_.size();
}
inline void PlanFragment::clear_collector() {
  collector_.Clear();
}
inline const ::exec::bit::control::Collector& PlanFragment::collector(int index) const {
  return collector_.Get(index);
}
inline ::exec::bit::control::Collector* PlanFragment::mutable_collector(int index) {
  return collector_.Mutable(index);
}
inline ::exec::bit::control::Collector* PlanFragment::add_collector() {
  return collector_.Add();
}
inline const ::google::protobuf::RepeatedPtrField< ::exec::bit::control::Collector >&
PlanFragment::collector() const {
  return collector_;
}
inline ::google::protobuf::RepeatedPtrField< ::exec::bit::control::Collector >*
PlanFragment::mutable_collector() {
  return &collector_;
}

// -------------------------------------------------------------------

// Collector

// optional int32 opposite_major_fragment_id = 1;
inline bool Collector::has_opposite_major_fragment_id() const {
  return (_has_bits_[0] & 0x00000001u) != 0;
}
inline void Collector::set_has_opposite_major_fragment_id() {
  _has_bits_[0] |= 0x00000001u;
}
inline void Collector::clear_has_opposite_major_fragment_id() {
  _has_bits_[0] &= ~0x00000001u;
}
inline void Collector::clear_opposite_major_fragment_id() {
  opposite_major_fragment_id_ = 0;
  clear_has_opposite_major_fragment_id();
}
inline ::google::protobuf::int32 Collector::opposite_major_fragment_id() const {
  return opposite_major_fragment_id_;
}
inline void Collector::set_opposite_major_fragment_id(::google::protobuf::int32 value) {
  set_has_opposite_major_fragment_id();
  opposite_major_fragment_id_ = value;
}

// repeated int32 incoming_minor_fragment = 2 [packed = true];
inline int Collector::incoming_minor_fragment_size() const {
  return incoming_minor_fragment_.size();
}
inline void Collector::clear_incoming_minor_fragment() {
  incoming_minor_fragment_.Clear();
}
inline ::google::protobuf::int32 Collector::incoming_minor_fragment(int index) const {
  return incoming_minor_fragment_.Get(index);
}
inline void Collector::set_incoming_minor_fragment(int index, ::google::protobuf::int32 value) {
  incoming_minor_fragment_.Set(index, value);
}
inline void Collector::add_incoming_minor_fragment(::google::protobuf::int32 value) {
  incoming_minor_fragment_.Add(value);
}
inline const ::google::protobuf::RepeatedField< ::google::protobuf::int32 >&
Collector::incoming_minor_fragment() const {
  return incoming_minor_fragment_;
}
inline ::google::protobuf::RepeatedField< ::google::protobuf::int32 >*
Collector::mutable_incoming_minor_fragment() {
  return &incoming_minor_fragment_;
}

// optional bool supports_out_of_order = 3;
inline bool Collector::has_supports_out_of_order() const {
  return (_has_bits_[0] & 0x00000004u) != 0;
}
inline void Collector::set_has_supports_out_of_order() {
  _has_bits_[0] |= 0x00000004u;
}
inline void Collector::clear_has_supports_out_of_order() {
  _has_bits_[0] &= ~0x00000004u;
}
inline void Collector::clear_supports_out_of_order() {
  supports_out_of_order_ = false;
  clear_has_supports_out_of_order();
}
inline bool Collector::supports_out_of_order() const {
  return supports_out_of_order_;
}
inline void Collector::set_supports_out_of_order(bool value) {
  set_has_supports_out_of_order();
  supports_out_of_order_ = value;
}

// optional bool is_spooling = 4;
inline bool Collector::has_is_spooling() const {
  return (_has_bits_[0] & 0x00000008u) != 0;
}
inline void Collector::set_has_is_spooling() {
  _has_bits_[0] |= 0x00000008u;
}
inline void Collector::clear_has_is_spooling() {
  _has_bits_[0] &= ~0x00000008u;
}
inline void Collector::clear_is_spooling() {
  is_spooling_ = false;
  clear_has_is_spooling();
}
inline bool Collector::is_spooling() const {
  return is_spooling_;
}
inline void Collector::set_is_spooling(bool value) {
  set_has_is_spooling();
  is_spooling_ = value;
}

// -------------------------------------------------------------------

// QueryContextInformation

// optional int64 query_start_time = 1;
inline bool QueryContextInformation::has_query_start_time() const {
  return (_has_bits_[0] & 0x00000001u) != 0;
}
inline void QueryContextInformation::set_has_query_start_time() {
  _has_bits_[0] |= 0x00000001u;
}
inline void QueryContextInformation::clear_has_query_start_time() {
  _has_bits_[0] &= ~0x00000001u;
}
inline void QueryContextInformation::clear_query_start_time() {
  query_start_time_ = GOOGLE_LONGLONG(0);
  clear_has_query_start_time();
}
inline ::google::protobuf::int64 QueryContextInformation::query_start_time() const {
  return query_start_time_;
}
inline void QueryContextInformation::set_query_start_time(::google::protobuf::int64 value) {
  set_has_query_start_time();
  query_start_time_ = value;
}

// optional int32 time_zone = 2;
inline bool QueryContextInformation::has_time_zone() const {
  return (_has_bits_[0] & 0x00000002u) != 0;
}
inline void QueryContextInformation::set_has_time_zone() {
  _has_bits_[0] |= 0x00000002u;
}
inline void QueryContextInformation::clear_has_time_zone() {
  _has_bits_[0] &= ~0x00000002u;
}
inline void QueryContextInformation::clear_time_zone() {
  time_zone_ = 0;
  clear_has_time_zone();
}
inline ::google::protobuf::int32 QueryContextInformation::time_zone() const {
  return time_zone_;
}
inline void QueryContextInformation::set_time_zone(::google::protobuf::int32 value) {
  set_has_time_zone();
  time_zone_ = value;
}

// optional string default_schema_name = 3;
inline bool QueryContextInformation::has_default_schema_name() const {
  return (_has_bits_[0] & 0x00000004u) != 0;
}
inline void QueryContextInformation::set_has_default_schema_name() {
  _has_bits_[0] |= 0x00000004u;
}
inline void QueryContextInformation::clear_has_default_schema_name() {
  _has_bits_[0] &= ~0x00000004u;
}
inline void QueryContextInformation::clear_default_schema_name() {
  if (default_schema_name_ != &::google::protobuf::internal::kEmptyString) {
    default_schema_name_->clear();
  }
  clear_has_default_schema_name();
}
inline const ::std::string& QueryContextInformation::default_schema_name() const {
  return *default_schema_name_;
}
inline void QueryContextInformation::set_default_schema_name(const ::std::string& value) {
  set_has_default_schema_name();
  if (default_schema_name_ == &::google::protobuf::internal::kEmptyString) {
    default_schema_name_ = new ::std::string;
  }
  default_schema_name_->assign(value);
}
inline void QueryContextInformation::set_default_schema_name(const char* value) {
  set_has_default_schema_name();
  if (default_schema_name_ == &::google::protobuf::internal::kEmptyString) {
    default_schema_name_ = new ::std::string;
  }
  default_schema_name_->assign(value);
}
inline void QueryContextInformation::set_default_schema_name(const char* value, size_t size) {
  set_has_default_schema_name();
  if (default_schema_name_ == &::google::protobuf::internal::kEmptyString) {
    default_schema_name_ = new ::std::string;
  }
  default_schema_name_->assign(reinterpret_cast<const char*>(value), size);
}
inline ::std::string* QueryContextInformation::mutable_default_schema_name() {
  set_has_default_schema_name();
  if (default_schema_name_ == &::google::protobuf::internal::kEmptyString) {
    default_schema_name_ = new ::std::string;
  }
  return default_schema_name_;
}
inline ::std::string* QueryContextInformation::release_default_schema_name() {
  clear_has_default_schema_name();
  if (default_schema_name_ == &::google::protobuf::internal::kEmptyString) {
    return NULL;
  } else {
    ::std::string* temp = default_schema_name_;
    default_schema_name_ = const_cast< ::std::string*>(&::google::protobuf::internal::kEmptyString);
    return temp;
  }
}
inline void QueryContextInformation::set_allocated_default_schema_name(::std::string* default_schema_name) {
  if (default_schema_name_ != &::google::protobuf::internal::kEmptyString) {
    delete default_schema_name_;
  }
  if (default_schema_name) {
    set_has_default_schema_name();
    default_schema_name_ = default_schema_name;
  } else {
    clear_has_default_schema_name();
    default_schema_name_ = const_cast< ::std::string*>(&::google::protobuf::internal::kEmptyString);
  }
}

// optional string session_id = 4;
inline bool QueryContextInformation::has_session_id() const {
  return (_has_bits_[0] & 0x00000008u) != 0;
}
inline void QueryContextInformation::set_has_session_id() {
  _has_bits_[0] |= 0x00000008u;
}
inline void QueryContextInformation::clear_has_session_id() {
  _has_bits_[0] &= ~0x00000008u;
}
inline void QueryContextInformation::clear_session_id() {
  if (session_id_ != &::google::protobuf::internal::kEmptyString) {
    session_id_->clear();
  }
  clear_has_session_id();
}
inline const ::std::string& QueryContextInformation::session_id() const {
  return *session_id_;
}
inline void QueryContextInformation::set_session_id(const ::std::string& value) {
  set_has_session_id();
  if (session_id_ == &::google::protobuf::internal::kEmptyString) {
    session_id_ = new ::std::string;
  }
  session_id_->assign(value);
}
inline void QueryContextInformation::set_session_id(const char* value) {
  set_has_session_id();
  if (session_id_ == &::google::protobuf::internal::kEmptyString) {
    session_id_ = new ::std::string;
  }
  session_id_->assign(value);
}
inline void QueryContextInformation::set_session_id(const char* value, size_t size) {
  set_has_session_id();
  if (session_id_ == &::google::protobuf::internal::kEmptyString) {
    session_id_ = new ::std::string;
  }
  session_id_->assign(reinterpret_cast<const char*>(value), size);
}
inline ::std::string* QueryContextInformation::mutable_session_id() {
  set_has_session_id();
  if (session_id_ == &::google::protobuf::internal::kEmptyString) {
    session_id_ = new ::std::string;
  }
  return session_id_;
}
inline ::std::string* QueryContextInformation::release_session_id() {
  clear_has_session_id();
  if (session_id_ == &::google::protobuf::internal::kEmptyString) {
    return NULL;
  } else {
    ::std::string* temp = session_id_;
    session_id_ = const_cast< ::std::string*>(&::google::protobuf::internal::kEmptyString);
    return temp;
  }
}
inline void QueryContextInformation::set_allocated_session_id(::std::string* session_id) {
  if (session_id_ != &::google::protobuf::internal::kEmptyString) {
    delete session_id_;
  }
  if (session_id) {
    set_has_session_id();
    session_id_ = session_id;
  } else {
    clear_has_session_id();
    session_id_ = const_cast< ::std::string*>(&::google::protobuf::internal::kEmptyString);
  }
}

// -------------------------------------------------------------------

// WorkQueueStatus

// optional .exec.DrillbitEndpoint endpoint = 1;
inline bool WorkQueueStatus::has_endpoint() const {
  return (_has_bits_[0] & 0x00000001u) != 0;
}
inline void WorkQueueStatus::set_has_endpoint() {
  _has_bits_[0] |= 0x00000001u;
}
inline void WorkQueueStatus::clear_has_endpoint() {
  _has_bits_[0] &= ~0x00000001u;
}
inline void WorkQueueStatus::clear_endpoint() {
  if (endpoint_ != NULL) endpoint_->::exec::DrillbitEndpoint::Clear();
  clear_has_endpoint();
}
inline const ::exec::DrillbitEndpoint& WorkQueueStatus::endpoint() const {
  return endpoint_ != NULL ? *endpoint_ : *default_instance_->endpoint_;
}
inline ::exec::DrillbitEndpoint* WorkQueueStatus::mutable_endpoint() {
  set_has_endpoint();
  if (endpoint_ == NULL) endpoint_ = new ::exec::DrillbitEndpoint;
  return endpoint_;
}
inline ::exec::DrillbitEndpoint* WorkQueueStatus::release_endpoint() {
  clear_has_endpoint();
  ::exec::DrillbitEndpoint* temp = endpoint_;
  endpoint_ = NULL;
  return temp;
}
inline void WorkQueueStatus::set_allocated_endpoint(::exec::DrillbitEndpoint* endpoint) {
  delete endpoint_;
  endpoint_ = endpoint;
  if (endpoint) {
    set_has_endpoint();
  } else {
    clear_has_endpoint();
  }
}

// optional int32 queue_length = 2;
inline bool WorkQueueStatus::has_queue_length() const {
  return (_has_bits_[0] & 0x00000002u) != 0;
}
inline void WorkQueueStatus::set_has_queue_length() {
  _has_bits_[0] |= 0x00000002u;
}
inline void WorkQueueStatus::clear_has_queue_length() {
  _has_bits_[0] &= ~0x00000002u;
}
inline void WorkQueueStatus::clear_queue_length() {
  queue_length_ = 0;
  clear_has_queue_length();
}
inline ::google::protobuf::int32 WorkQueueStatus::queue_length() const {
  return queue_length_;
}
inline void WorkQueueStatus::set_queue_length(::google::protobuf::int32 value) {
  set_has_queue_length();
  queue_length_ = value;
}

// optional int64 report_time = 3;
inline bool WorkQueueStatus::has_report_time() const {
  return (_has_bits_[0] & 0x00000004u) != 0;
}
inline void WorkQueueStatus::set_has_report_time() {
  _has_bits_[0] |= 0x00000004u;
}
inline void WorkQueueStatus::clear_has_report_time() {
  _has_bits_[0] &= ~0x00000004u;
}
inline void WorkQueueStatus::clear_report_time() {
  report_time_ = GOOGLE_LONGLONG(0);
  clear_has_report_time();
}
inline ::google::protobuf::int64 WorkQueueStatus::report_time() const {
  return report_time_;
}
inline void WorkQueueStatus::set_report_time(::google::protobuf::int64 value) {
  set_has_report_time();
  report_time_ = value;
}

// -------------------------------------------------------------------

// FinishedReceiver

// optional .exec.bit.FragmentHandle receiver = 1;
inline bool FinishedReceiver::has_receiver() const {
  return (_has_bits_[0] & 0x00000001u) != 0;
}
inline void FinishedReceiver::set_has_receiver() {
  _has_bits_[0] |= 0x00000001u;
}
inline void FinishedReceiver::clear_has_receiver() {
  _has_bits_[0] &= ~0x00000001u;
}
inline void FinishedReceiver::clear_receiver() {
  if (receiver_ != NULL) receiver_->::exec::bit::FragmentHandle::Clear();
  clear_has_receiver();
}
inline const ::exec::bit::FragmentHandle& FinishedReceiver::receiver() const {
  return receiver_ != NULL ? *receiver_ : *default_instance_->receiver_;
}
inline ::exec::bit::FragmentHandle* FinishedReceiver::mutable_receiver() {
  set_has_receiver();
  if (receiver_ == NULL) receiver_ = new ::exec::bit::FragmentHandle;
  return receiver_;
}
inline ::exec::bit::FragmentHandle* FinishedReceiver::release_receiver() {
  clear_has_receiver();
  ::exec::bit::FragmentHandle* temp = receiver_;
  receiver_ = NULL;
  return temp;
}
inline void FinishedReceiver::set_allocated_receiver(::exec::bit::FragmentHandle* receiver) {
  delete receiver_;
  receiver_ = receiver;
  if (receiver) {
    set_has_receiver();
  } else {
    clear_has_receiver();
  }
}

// optional .exec.bit.FragmentHandle sender = 2;
inline bool FinishedReceiver::has_sender() const {
  return (_has_bits_[0] & 0x00000002u) != 0;
}
inline void FinishedReceiver::set_has_sender() {
  _has_bits_[0] |= 0x00000002u;
}
inline void FinishedReceiver::clear_has_sender() {
  _has_bits_[0] &= ~0x00000002u;
}
inline void FinishedReceiver::clear_sender() {
  if (sender_ != NULL) sender_->::exec::bit::FragmentHandle::Clear();
  clear_has_sender();
}
inline const ::exec::bit::FragmentHandle& FinishedReceiver::sender() const {
  return sender_ != NULL ? *sender_ : *default_instance_->sender_;
}
inline ::exec::bit::FragmentHandle* FinishedReceiver::mutable_sender() {
  set_has_sender();
  if (sender_ == NULL) sender_ = new ::exec::bit::FragmentHandle;
  return sender_;
}
inline ::exec::bit::FragmentHandle* FinishedReceiver::release_sender() {
  clear_has_sender();
  ::exec::bit::FragmentHandle* temp = sender_;
  sender_ = NULL;
  return temp;
}
inline void FinishedReceiver::set_allocated_sender(::exec::bit::FragmentHandle* sender) {
  delete sender_;
  sender_ = sender;
  if (sender) {
    set_has_sender();
  } else {
    clear_has_sender();
  }
}


// @@protoc_insertion_point(namespace_scope)

}  // namespace control
}  // namespace bit
}  // namespace exec

#ifndef SWIG
namespace google {
namespace protobuf {

template <>
inline const EnumDescriptor* GetEnumDescriptor< ::exec::bit::control::RpcType>() {
  return ::exec::bit::control::RpcType_descriptor();
}

}  // namespace google
}  // namespace protobuf
#endif  // SWIG

// @@protoc_insertion_point(global_scope)

#endif  // PROTOBUF_BitControl_2eproto__INCLUDED