drill-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sudhe...@apache.org
Subject [28/29] drill git commit: DRILL-4280: CORE (C++ protocol)
Date Sat, 25 Feb 2017 07:18:21 GMT
http://git-wip-us.apache.org/repos/asf/drill/blob/f9f99e08/contrib/native/client/src/protobuf/UserBitShared.pb.cc
----------------------------------------------------------------------
diff --git a/contrib/native/client/src/protobuf/UserBitShared.pb.cc b/contrib/native/client/src/protobuf/UserBitShared.pb.cc
index abd6b4e..2fcf116 100644
--- a/contrib/native/client/src/protobuf/UserBitShared.pb.cc
+++ b/contrib/native/client/src/protobuf/UserBitShared.pb.cc
@@ -87,10 +87,14 @@ const ::google::protobuf::internal::GeneratedMessageReflection*
 const ::google::protobuf::Descriptor* Jar_descriptor_ = NULL;
 const ::google::protobuf::internal::GeneratedMessageReflection*
   Jar_reflection_ = NULL;
+const ::google::protobuf::Descriptor* SaslMessage_descriptor_ = NULL;
+const ::google::protobuf::internal::GeneratedMessageReflection*
+  SaslMessage_reflection_ = NULL;
 const ::google::protobuf::EnumDescriptor* RpcChannel_descriptor_ = NULL;
 const ::google::protobuf::EnumDescriptor* QueryType_descriptor_ = NULL;
 const ::google::protobuf::EnumDescriptor* FragmentState_descriptor_ = NULL;
 const ::google::protobuf::EnumDescriptor* CoreOperatorType_descriptor_ = NULL;
+const ::google::protobuf::EnumDescriptor* SaslStatus_descriptor_ = NULL;
 
 }  // namespace
 
@@ -315,12 +319,13 @@ void protobuf_AssignDesc_UserBitShared_2eproto() {
       ::google::protobuf::MessageFactory::generated_factory(),
       sizeof(QueryData));
   QueryInfo_descriptor_ = file->message_type(12);
-  static const int QueryInfo_offsets_[5] = {
+  static const int QueryInfo_offsets_[6] = {
     GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(QueryInfo, query_),
     GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(QueryInfo, start_),
     GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(QueryInfo, state_),
     GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(QueryInfo, user_),
     GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(QueryInfo, foreman_),
+    GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(QueryInfo, options_json_),
   };
   QueryInfo_reflection_ =
     new ::google::protobuf::internal::GeneratedMessageReflection(
@@ -334,7 +339,7 @@ void protobuf_AssignDesc_UserBitShared_2eproto() {
       ::google::protobuf::MessageFactory::generated_factory(),
       sizeof(QueryInfo));
   QueryProfile_descriptor_ = file->message_type(13);
-  static const int QueryProfile_offsets_[16] = {
+  static const int QueryProfile_offsets_[17] = {
     GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(QueryProfile, id_),
     GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(QueryProfile, type_),
     GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(QueryProfile, start_),
@@ -351,6 +356,7 @@ void protobuf_AssignDesc_UserBitShared_2eproto() {
     GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(QueryProfile, verboseerror_),
     GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(QueryProfile, error_id_),
     GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(QueryProfile, error_node_),
+    GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(QueryProfile, options_json_),
   };
   QueryProfile_reflection_ =
     new ::google::protobuf::internal::GeneratedMessageReflection(
@@ -491,10 +497,28 @@ void protobuf_AssignDesc_UserBitShared_2eproto() {
       ::google::protobuf::DescriptorPool::generated_pool(),
       ::google::protobuf::MessageFactory::generated_factory(),
       sizeof(Jar));
+  SaslMessage_descriptor_ = file->message_type(21);
+  static const int SaslMessage_offsets_[3] = {
+    GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(SaslMessage, mechanism_),
+    GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(SaslMessage, data_),
+    GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(SaslMessage, status_),
+  };
+  SaslMessage_reflection_ =
+    new ::google::protobuf::internal::GeneratedMessageReflection(
+      SaslMessage_descriptor_,
+      SaslMessage::default_instance_,
+      SaslMessage_offsets_,
+      GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(SaslMessage, _has_bits_[0]),
+      GOOGLE_PROTOBUF_GENERATED_MESSAGE_FIELD_OFFSET(SaslMessage, _unknown_fields_),
+      -1,
+      ::google::protobuf::DescriptorPool::generated_pool(),
+      ::google::protobuf::MessageFactory::generated_factory(),
+      sizeof(SaslMessage));
   RpcChannel_descriptor_ = file->enum_type(0);
   QueryType_descriptor_ = file->enum_type(1);
   FragmentState_descriptor_ = file->enum_type(2);
   CoreOperatorType_descriptor_ = file->enum_type(3);
+  SaslStatus_descriptor_ = file->enum_type(4);
 }
 
 namespace {
@@ -549,6 +573,8 @@ void protobuf_RegisterTypes(const ::std::string&) {
     Registry_descriptor_, &Registry::default_instance());
   ::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage(
     Jar_descriptor_, &Jar::default_instance());
+  ::google::protobuf::MessageFactory::InternalRegisterGeneratedMessage(
+    SaslMessage_descriptor_, &SaslMessage::default_instance());
 }
 
 }  // namespace
@@ -598,6 +624,8 @@ void protobuf_ShutdownFile_UserBitShared_2eproto() {
   delete Registry_reflection_;
   delete Jar::default_instance_;
   delete Jar_reflection_;
+  delete SaslMessage::default_instance_;
+  delete SaslMessage_reflection_;
 }
 
 void protobuf_AddDesc_UserBitShared_2eproto() {
@@ -658,73 +686,79 @@ void protobuf_AddDesc_UserBitShared_2eproto() {
     "ENQUEUED\020\006\"p\n\tQueryData\022&\n\010query_id\030\001 \001("
     "\0132\024.exec.shared.QueryId\022\021\n\trow_count\030\002 \001"
     "(\005\022(\n\003def\030\003 \001(\0132\033.exec.shared.RecordBatc"
-    "hDef\"\227\001\n\tQueryInfo\022\r\n\005query\030\001 \001(\t\022\r\n\005sta"
+    "hDef\"\255\001\n\tQueryInfo\022\r\n\005query\030\001 \001(\t\022\r\n\005sta"
     "rt\030\002 \001(\003\0222\n\005state\030\003 \001(\0162#.exec.shared.Qu"
     "eryResult.QueryState\022\017\n\004user\030\004 \001(\t:\001-\022\'\n"
-    "\007foreman\030\005 \001(\0132\026.exec.DrillbitEndpoint\"\272"
-    "\003\n\014QueryProfile\022 \n\002id\030\001 \001(\0132\024.exec.share"
-    "d.QueryId\022$\n\004type\030\002 \001(\0162\026.exec.shared.Qu"
-    "eryType\022\r\n\005start\030\003 \001(\003\022\013\n\003end\030\004 \001(\003\022\r\n\005q"
-    "uery\030\005 \001(\t\022\014\n\004plan\030\006 \001(\t\022\'\n\007foreman\030\007 \001("
-    "\0132\026.exec.DrillbitEndpoint\0222\n\005state\030\010 \001(\016"
-    "2#.exec.shared.QueryResult.QueryState\022\027\n"
-    "\017total_fragments\030\t \001(\005\022\032\n\022finished_fragm"
-    "ents\030\n \001(\005\022;\n\020fragment_profile\030\013 \003(\0132!.e"
-    "xec.shared.MajorFragmentProfile\022\017\n\004user\030"
-    "\014 \001(\t:\001-\022\r\n\005error\030\r \001(\t\022\024\n\014verboseError\030"
-    "\016 \001(\t\022\020\n\010error_id\030\017 \001(\t\022\022\n\nerror_node\030\020 "
-    "\001(\t\"t\n\024MajorFragmentProfile\022\031\n\021major_fra"
-    "gment_id\030\001 \001(\005\022A\n\026minor_fragment_profile"
-    "\030\002 \003(\0132!.exec.shared.MinorFragmentProfil"
-    "e\"\350\002\n\024MinorFragmentProfile\022)\n\005state\030\001 \001("
-    "\0162\032.exec.shared.FragmentState\022(\n\005error\030\002"
-    " \001(\0132\031.exec.shared.DrillPBError\022\031\n\021minor"
-    "_fragment_id\030\003 \001(\005\0226\n\020operator_profile\030\004"
-    " \003(\0132\034.exec.shared.OperatorProfile\022\022\n\nst"
-    "art_time\030\005 \001(\003\022\020\n\010end_time\030\006 \001(\003\022\023\n\013memo"
-    "ry_used\030\007 \001(\003\022\027\n\017max_memory_used\030\010 \001(\003\022("
-    "\n\010endpoint\030\t \001(\0132\026.exec.DrillbitEndpoint"
-    "\022\023\n\013last_update\030\n \001(\003\022\025\n\rlast_progress\030\013"
-    " \001(\003\"\377\001\n\017OperatorProfile\0221\n\rinput_profil"
-    "e\030\001 \003(\0132\032.exec.shared.StreamProfile\022\023\n\013o"
-    "perator_id\030\003 \001(\005\022\025\n\roperator_type\030\004 \001(\005\022"
-    "\023\n\013setup_nanos\030\005 \001(\003\022\025\n\rprocess_nanos\030\006 "
-    "\001(\003\022#\n\033peak_local_memory_allocated\030\007 \001(\003"
-    "\022(\n\006metric\030\010 \003(\0132\030.exec.shared.MetricVal"
-    "ue\022\022\n\nwait_nanos\030\t \001(\003\"B\n\rStreamProfile\022"
-    "\017\n\007records\030\001 \001(\003\022\017\n\007batches\030\002 \001(\003\022\017\n\007sch"
-    "emas\030\003 \001(\003\"J\n\013MetricValue\022\021\n\tmetric_id\030\001"
-    " \001(\005\022\022\n\nlong_value\030\002 \001(\003\022\024\n\014double_value"
-    "\030\003 \001(\001\")\n\010Registry\022\035\n\003jar\030\001 \003(\0132\020.exec.s"
-    "hared.Jar\"/\n\003Jar\022\014\n\004name\030\001 \001(\t\022\032\n\022functi"
-    "on_signature\030\002 \003(\t*5\n\nRpcChannel\022\017\n\013BIT_"
-    "CONTROL\020\000\022\014\n\010BIT_DATA\020\001\022\010\n\004USER\020\002*V\n\tQue"
-    "ryType\022\007\n\003SQL\020\001\022\013\n\007LOGICAL\020\002\022\014\n\010PHYSICAL"
-    "\020\003\022\r\n\tEXECUTION\020\004\022\026\n\022PREPARED_STATEMENT\020"
-    "\005*\207\001\n\rFragmentState\022\013\n\007SENDING\020\000\022\027\n\023AWAI"
-    "TING_ALLOCATION\020\001\022\013\n\007RUNNING\020\002\022\014\n\010FINISH"
-    "ED\020\003\022\r\n\tCANCELLED\020\004\022\n\n\006FAILED\020\005\022\032\n\026CANCE"
-    "LLATION_REQUESTED\020\006*\335\005\n\020CoreOperatorType"
-    "\022\021\n\rSINGLE_SENDER\020\000\022\024\n\020BROADCAST_SENDER\020"
-    "\001\022\n\n\006FILTER\020\002\022\022\n\016HASH_AGGREGATE\020\003\022\r\n\tHAS"
-    "H_JOIN\020\004\022\016\n\nMERGE_JOIN\020\005\022\031\n\025HASH_PARTITI"
-    "ON_SENDER\020\006\022\t\n\005LIMIT\020\007\022\024\n\020MERGING_RECEIV"
-    "ER\020\010\022\034\n\030ORDERED_PARTITION_SENDER\020\t\022\013\n\007PR"
-    "OJECT\020\n\022\026\n\022UNORDERED_RECEIVER\020\013\022\020\n\014RANGE"
-    "_SENDER\020\014\022\n\n\006SCREEN\020\r\022\034\n\030SELECTION_VECTO"
-    "R_REMOVER\020\016\022\027\n\023STREAMING_AGGREGATE\020\017\022\016\n\n"
-    "TOP_N_SORT\020\020\022\021\n\rEXTERNAL_SORT\020\021\022\t\n\005TRACE"
-    "\020\022\022\t\n\005UNION\020\023\022\014\n\010OLD_SORT\020\024\022\032\n\026PARQUET_R"
-    "OW_GROUP_SCAN\020\025\022\021\n\rHIVE_SUB_SCAN\020\026\022\025\n\021SY"
-    "STEM_TABLE_SCAN\020\027\022\021\n\rMOCK_SUB_SCAN\020\030\022\022\n\016"
-    "PARQUET_WRITER\020\031\022\023\n\017DIRECT_SUB_SCAN\020\032\022\017\n"
-    "\013TEXT_WRITER\020\033\022\021\n\rTEXT_SUB_SCAN\020\034\022\021\n\rJSO"
-    "N_SUB_SCAN\020\035\022\030\n\024INFO_SCHEMA_SUB_SCAN\020\036\022\023"
-    "\n\017COMPLEX_TO_JSON\020\037\022\025\n\021PRODUCER_CONSUMER"
-    "\020 \022\022\n\016HBASE_SUB_SCAN\020!\022\n\n\006WINDOW\020\"\022\024\n\020NE"
-    "STED_LOOP_JOIN\020#\022\021\n\rAVRO_SUB_SCAN\020$B.\n\033o"
-    "rg.apache.drill.exec.protoB\rUserBitShare"
-    "dH\001", 4563);
+    "\007foreman\030\005 \001(\0132\026.exec.DrillbitEndpoint\022\024"
+    "\n\014options_json\030\006 \001(\t\"\320\003\n\014QueryProfile\022 \n"
+    "\002id\030\001 \001(\0132\024.exec.shared.QueryId\022$\n\004type\030"
+    "\002 \001(\0162\026.exec.shared.QueryType\022\r\n\005start\030\003"
+    " \001(\003\022\013\n\003end\030\004 \001(\003\022\r\n\005query\030\005 \001(\t\022\014\n\004plan"
+    "\030\006 \001(\t\022\'\n\007foreman\030\007 \001(\0132\026.exec.DrillbitE"
+    "ndpoint\0222\n\005state\030\010 \001(\0162#.exec.shared.Que"
+    "ryResult.QueryState\022\027\n\017total_fragments\030\t"
+    " \001(\005\022\032\n\022finished_fragments\030\n \001(\005\022;\n\020frag"
+    "ment_profile\030\013 \003(\0132!.exec.shared.MajorFr"
+    "agmentProfile\022\017\n\004user\030\014 \001(\t:\001-\022\r\n\005error\030"
+    "\r \001(\t\022\024\n\014verboseError\030\016 \001(\t\022\020\n\010error_id\030"
+    "\017 \001(\t\022\022\n\nerror_node\030\020 \001(\t\022\024\n\014options_jso"
+    "n\030\021 \001(\t\"t\n\024MajorFragmentProfile\022\031\n\021major"
+    "_fragment_id\030\001 \001(\005\022A\n\026minor_fragment_pro"
+    "file\030\002 \003(\0132!.exec.shared.MinorFragmentPr"
+    "ofile\"\350\002\n\024MinorFragmentProfile\022)\n\005state\030"
+    "\001 \001(\0162\032.exec.shared.FragmentState\022(\n\005err"
+    "or\030\002 \001(\0132\031.exec.shared.DrillPBError\022\031\n\021m"
+    "inor_fragment_id\030\003 \001(\005\0226\n\020operator_profi"
+    "le\030\004 \003(\0132\034.exec.shared.OperatorProfile\022\022"
+    "\n\nstart_time\030\005 \001(\003\022\020\n\010end_time\030\006 \001(\003\022\023\n\013"
+    "memory_used\030\007 \001(\003\022\027\n\017max_memory_used\030\010 \001"
+    "(\003\022(\n\010endpoint\030\t \001(\0132\026.exec.DrillbitEndp"
+    "oint\022\023\n\013last_update\030\n \001(\003\022\025\n\rlast_progre"
+    "ss\030\013 \001(\003\"\377\001\n\017OperatorProfile\0221\n\rinput_pr"
+    "ofile\030\001 \003(\0132\032.exec.shared.StreamProfile\022"
+    "\023\n\013operator_id\030\003 \001(\005\022\025\n\roperator_type\030\004 "
+    "\001(\005\022\023\n\013setup_nanos\030\005 \001(\003\022\025\n\rprocess_nano"
+    "s\030\006 \001(\003\022#\n\033peak_local_memory_allocated\030\007"
+    " \001(\003\022(\n\006metric\030\010 \003(\0132\030.exec.shared.Metri"
+    "cValue\022\022\n\nwait_nanos\030\t \001(\003\"B\n\rStreamProf"
+    "ile\022\017\n\007records\030\001 \001(\003\022\017\n\007batches\030\002 \001(\003\022\017\n"
+    "\007schemas\030\003 \001(\003\"J\n\013MetricValue\022\021\n\tmetric_"
+    "id\030\001 \001(\005\022\022\n\nlong_value\030\002 \001(\003\022\024\n\014double_v"
+    "alue\030\003 \001(\001\")\n\010Registry\022\035\n\003jar\030\001 \003(\0132\020.ex"
+    "ec.shared.Jar\"/\n\003Jar\022\014\n\004name\030\001 \001(\t\022\032\n\022fu"
+    "nction_signature\030\002 \003(\t\"W\n\013SaslMessage\022\021\n"
+    "\tmechanism\030\001 \001(\t\022\014\n\004data\030\002 \001(\014\022\'\n\006status"
+    "\030\003 \001(\0162\027.exec.shared.SaslStatus*5\n\nRpcCh"
+    "annel\022\017\n\013BIT_CONTROL\020\000\022\014\n\010BIT_DATA\020\001\022\010\n\004"
+    "USER\020\002*V\n\tQueryType\022\007\n\003SQL\020\001\022\013\n\007LOGICAL\020"
+    "\002\022\014\n\010PHYSICAL\020\003\022\r\n\tEXECUTION\020\004\022\026\n\022PREPAR"
+    "ED_STATEMENT\020\005*\207\001\n\rFragmentState\022\013\n\007SEND"
+    "ING\020\000\022\027\n\023AWAITING_ALLOCATION\020\001\022\013\n\007RUNNIN"
+    "G\020\002\022\014\n\010FINISHED\020\003\022\r\n\tCANCELLED\020\004\022\n\n\006FAIL"
+    "ED\020\005\022\032\n\026CANCELLATION_REQUESTED\020\006*\335\005\n\020Cor"
+    "eOperatorType\022\021\n\rSINGLE_SENDER\020\000\022\024\n\020BROA"
+    "DCAST_SENDER\020\001\022\n\n\006FILTER\020\002\022\022\n\016HASH_AGGRE"
+    "GATE\020\003\022\r\n\tHASH_JOIN\020\004\022\016\n\nMERGE_JOIN\020\005\022\031\n"
+    "\025HASH_PARTITION_SENDER\020\006\022\t\n\005LIMIT\020\007\022\024\n\020M"
+    "ERGING_RECEIVER\020\010\022\034\n\030ORDERED_PARTITION_S"
+    "ENDER\020\t\022\013\n\007PROJECT\020\n\022\026\n\022UNORDERED_RECEIV"
+    "ER\020\013\022\020\n\014RANGE_SENDER\020\014\022\n\n\006SCREEN\020\r\022\034\n\030SE"
+    "LECTION_VECTOR_REMOVER\020\016\022\027\n\023STREAMING_AG"
+    "GREGATE\020\017\022\016\n\nTOP_N_SORT\020\020\022\021\n\rEXTERNAL_SO"
+    "RT\020\021\022\t\n\005TRACE\020\022\022\t\n\005UNION\020\023\022\014\n\010OLD_SORT\020\024"
+    "\022\032\n\026PARQUET_ROW_GROUP_SCAN\020\025\022\021\n\rHIVE_SUB"
+    "_SCAN\020\026\022\025\n\021SYSTEM_TABLE_SCAN\020\027\022\021\n\rMOCK_S"
+    "UB_SCAN\020\030\022\022\n\016PARQUET_WRITER\020\031\022\023\n\017DIRECT_"
+    "SUB_SCAN\020\032\022\017\n\013TEXT_WRITER\020\033\022\021\n\rTEXT_SUB_"
+    "SCAN\020\034\022\021\n\rJSON_SUB_SCAN\020\035\022\030\n\024INFO_SCHEMA"
+    "_SUB_SCAN\020\036\022\023\n\017COMPLEX_TO_JSON\020\037\022\025\n\021PROD"
+    "UCER_CONSUMER\020 \022\022\n\016HBASE_SUB_SCAN\020!\022\n\n\006W"
+    "INDOW\020\"\022\024\n\020NESTED_LOOP_JOIN\020#\022\021\n\rAVRO_SU"
+    "B_SCAN\020$*g\n\nSaslStatus\022\020\n\014SASL_UNKNOWN\020\000"
+    "\022\016\n\nSASL_START\020\001\022\024\n\020SASL_IN_PROGRESS\020\002\022\020"
+    "\n\014SASL_SUCCESS\020\003\022\017\n\013SASL_FAILED\020\004B.\n\033org"
+    ".apache.drill.exec.protoB\rUserBitSharedH"
+    "\001", 4801);
   ::google::protobuf::MessageFactory::InternalRegisterGeneratedFile(
     "UserBitShared.proto", &protobuf_RegisterTypes);
   UserCredentials::default_instance_ = new UserCredentials();
@@ -752,6 +786,7 @@ void protobuf_AddDesc_UserBitShared_2eproto() {
   MetricValue::default_instance_ = new MetricValue();
   Registry::default_instance_ = new Registry();
   Jar::default_instance_ = new Jar();
+  SaslMessage::default_instance_ = new SaslMessage();
   UserCredentials::default_instance_->InitAsDefaultInstance();
   QueryId::default_instance_->InitAsDefaultInstance();
   DrillPBError::default_instance_->InitAsDefaultInstance();
@@ -773,6 +808,7 @@ void protobuf_AddDesc_UserBitShared_2eproto() {
   MetricValue::default_instance_->InitAsDefaultInstance();
   Registry::default_instance_->InitAsDefaultInstance();
   Jar::default_instance_->InitAsDefaultInstance();
+  SaslMessage::default_instance_->InitAsDefaultInstance();
   ::google::protobuf::internal::OnShutdown(&protobuf_ShutdownFile_UserBitShared_2eproto);
 }
 
@@ -882,6 +918,23 @@ bool CoreOperatorType_IsValid(int value) {
   }
 }
 
+const ::google::protobuf::EnumDescriptor* SaslStatus_descriptor() {
+  protobuf_AssignDescriptorsOnce();
+  return SaslStatus_descriptor_;
+}
+bool SaslStatus_IsValid(int value) {
+  switch(value) {
+    case 0:
+    case 1:
+    case 2:
+    case 3:
+    case 4:
+      return true;
+    default:
+      return false;
+  }
+}
+
 
 // ===================================================================
 
@@ -4887,6 +4940,7 @@ const int QueryInfo::kStartFieldNumber;
 const int QueryInfo::kStateFieldNumber;
 const int QueryInfo::kUserFieldNumber;
 const int QueryInfo::kForemanFieldNumber;
+const int QueryInfo::kOptionsJsonFieldNumber;
 #endif  // !_MSC_VER
 
 QueryInfo::QueryInfo()
@@ -4911,6 +4965,7 @@ void QueryInfo::SharedCtor() {
   state_ = 0;
   user_ = const_cast< ::std::string*>(_default_user_);
   foreman_ = NULL;
+  options_json_ = const_cast< ::std::string*>(&::google::protobuf::internal::kEmptyString);
   ::memset(_has_bits_, 0, sizeof(_has_bits_));
 }
 
@@ -4925,6 +4980,9 @@ void QueryInfo::SharedDtor() {
   if (user_ != _default_user_) {
     delete user_;
   }
+  if (options_json_ != &::google::protobuf::internal::kEmptyString) {
+    delete options_json_;
+  }
   if (this != default_instance_) {
     delete foreman_;
   }
@@ -4968,6 +5026,11 @@ void QueryInfo::Clear() {
     if (has_foreman()) {
       if (foreman_ != NULL) foreman_->::exec::DrillbitEndpoint::Clear();
     }
+    if (has_options_json()) {
+      if (options_json_ != &::google::protobuf::internal::kEmptyString) {
+        options_json_->clear();
+      }
+    }
   }
   ::memset(_has_bits_, 0, sizeof(_has_bits_));
   mutable_unknown_fields()->Clear();
@@ -5059,6 +5122,23 @@ bool QueryInfo::MergePartialFromCodedStream(
         } else {
           goto handle_uninterpreted;
         }
+        if (input->ExpectTag(50)) goto parse_options_json;
+        break;
+      }
+
+      // optional string options_json = 6;
+      case 6: {
+        if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
+            ::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
+         parse_options_json:
+          DO_(::google::protobuf::internal::WireFormatLite::ReadString(
+                input, this->mutable_options_json()));
+          ::google::protobuf::internal::WireFormat::VerifyUTF8String(
+            this->options_json().data(), this->options_json().length(),
+            ::google::protobuf::internal::WireFormat::PARSE);
+        } else {
+          goto handle_uninterpreted;
+        }
         if (input->ExpectAtEnd()) return true;
         break;
       }
@@ -5116,6 +5196,15 @@ void QueryInfo::SerializeWithCachedSizes(
       5, this->foreman(), output);
   }
 
+  // optional string options_json = 6;
+  if (has_options_json()) {
+    ::google::protobuf::internal::WireFormat::VerifyUTF8String(
+      this->options_json().data(), this->options_json().length(),
+      ::google::protobuf::internal::WireFormat::SERIALIZE);
+    ::google::protobuf::internal::WireFormatLite::WriteString(
+      6, this->options_json(), output);
+  }
+
   if (!unknown_fields().empty()) {
     ::google::protobuf::internal::WireFormat::SerializeUnknownFields(
         unknown_fields(), output);
@@ -5162,6 +5251,16 @@ void QueryInfo::SerializeWithCachedSizes(
         5, this->foreman(), target);
   }
 
+  // optional string options_json = 6;
+  if (has_options_json()) {
+    ::google::protobuf::internal::WireFormat::VerifyUTF8String(
+      this->options_json().data(), this->options_json().length(),
+      ::google::protobuf::internal::WireFormat::SERIALIZE);
+    target =
+      ::google::protobuf::internal::WireFormatLite::WriteStringToArray(
+        6, this->options_json(), target);
+  }
+
   if (!unknown_fields().empty()) {
     target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
         unknown_fields(), target);
@@ -5207,6 +5306,13 @@ int QueryInfo::ByteSize() const {
           this->foreman());
     }
 
+    // optional string options_json = 6;
+    if (has_options_json()) {
+      total_size += 1 +
+        ::google::protobuf::internal::WireFormatLite::StringSize(
+          this->options_json());
+    }
+
   }
   if (!unknown_fields().empty()) {
     total_size +=
@@ -5249,6 +5355,9 @@ void QueryInfo::MergeFrom(const QueryInfo& from) {
     if (from.has_foreman()) {
       mutable_foreman()->::exec::DrillbitEndpoint::MergeFrom(from.foreman());
     }
+    if (from.has_options_json()) {
+      set_options_json(from.options_json());
+    }
   }
   mutable_unknown_fields()->MergeFrom(from.unknown_fields());
 }
@@ -5277,6 +5386,7 @@ void QueryInfo::Swap(QueryInfo* other) {
     std::swap(state_, other->state_);
     std::swap(user_, other->user_);
     std::swap(foreman_, other->foreman_);
+    std::swap(options_json_, other->options_json_);
     std::swap(_has_bits_[0], other->_has_bits_[0]);
     _unknown_fields_.Swap(&other->_unknown_fields_);
     std::swap(_cached_size_, other->_cached_size_);
@@ -5312,6 +5422,7 @@ const int QueryProfile::kErrorFieldNumber;
 const int QueryProfile::kVerboseErrorFieldNumber;
 const int QueryProfile::kErrorIdFieldNumber;
 const int QueryProfile::kErrorNodeFieldNumber;
+const int QueryProfile::kOptionsJsonFieldNumber;
 #endif  // !_MSC_VER
 
 QueryProfile::QueryProfile()
@@ -5347,6 +5458,7 @@ void QueryProfile::SharedCtor() {
   verboseerror_ = const_cast< ::std::string*>(&::google::protobuf::internal::kEmptyString);
   error_id_ = const_cast< ::std::string*>(&::google::protobuf::internal::kEmptyString);
   error_node_ = const_cast< ::std::string*>(&::google::protobuf::internal::kEmptyString);
+  options_json_ = const_cast< ::std::string*>(&::google::protobuf::internal::kEmptyString);
   ::memset(_has_bits_, 0, sizeof(_has_bits_));
 }
 
@@ -5376,6 +5488,9 @@ void QueryProfile::SharedDtor() {
   if (error_node_ != &::google::protobuf::internal::kEmptyString) {
     delete error_node_;
   }
+  if (options_json_ != &::google::protobuf::internal::kEmptyString) {
+    delete options_json_;
+  }
   if (this != default_instance_) {
     delete id_;
     delete foreman_;
@@ -5455,6 +5570,13 @@ void QueryProfile::Clear() {
       }
     }
   }
+  if (_has_bits_[16 / 32] & (0xffu << (16 % 32))) {
+    if (has_options_json()) {
+      if (options_json_ != &::google::protobuf::internal::kEmptyString) {
+        options_json_->clear();
+      }
+    }
+  }
   fragment_profile_.Clear();
   ::memset(_has_bits_, 0, sizeof(_has_bits_));
   mutable_unknown_fields()->Clear();
@@ -5729,6 +5851,23 @@ bool QueryProfile::MergePartialFromCodedStream(
         } else {
           goto handle_uninterpreted;
         }
+        if (input->ExpectTag(138)) goto parse_options_json;
+        break;
+      }
+
+      // optional string options_json = 17;
+      case 17: {
+        if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
+            ::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
+         parse_options_json:
+          DO_(::google::protobuf::internal::WireFormatLite::ReadString(
+                input, this->mutable_options_json()));
+          ::google::protobuf::internal::WireFormat::VerifyUTF8String(
+            this->options_json().data(), this->options_json().length(),
+            ::google::protobuf::internal::WireFormat::PARSE);
+        } else {
+          goto handle_uninterpreted;
+        }
         if (input->ExpectAtEnd()) return true;
         break;
       }
@@ -5864,6 +6003,15 @@ void QueryProfile::SerializeWithCachedSizes(
       16, this->error_node(), output);
   }
 
+  // optional string options_json = 17;
+  if (has_options_json()) {
+    ::google::protobuf::internal::WireFormat::VerifyUTF8String(
+      this->options_json().data(), this->options_json().length(),
+      ::google::protobuf::internal::WireFormat::SERIALIZE);
+    ::google::protobuf::internal::WireFormatLite::WriteString(
+      17, this->options_json(), output);
+  }
+
   if (!unknown_fields().empty()) {
     ::google::protobuf::internal::WireFormat::SerializeUnknownFields(
         unknown_fields(), output);
@@ -5995,6 +6143,16 @@ void QueryProfile::SerializeWithCachedSizes(
         16, this->error_node(), target);
   }
 
+  // optional string options_json = 17;
+  if (has_options_json()) {
+    ::google::protobuf::internal::WireFormat::VerifyUTF8String(
+      this->options_json().data(), this->options_json().length(),
+      ::google::protobuf::internal::WireFormat::SERIALIZE);
+    target =
+      ::google::protobuf::internal::WireFormatLite::WriteStringToArray(
+        17, this->options_json(), target);
+  }
+
   if (!unknown_fields().empty()) {
     target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
         unknown_fields(), target);
@@ -6112,6 +6270,15 @@ int QueryProfile::ByteSize() const {
     }
 
   }
+  if (_has_bits_[16 / 32] & (0xffu << (16 % 32))) {
+    // optional string options_json = 17;
+    if (has_options_json()) {
+      total_size += 2 +
+        ::google::protobuf::internal::WireFormatLite::StringSize(
+          this->options_json());
+    }
+
+  }
   // repeated .exec.shared.MajorFragmentProfile fragment_profile = 11;
   total_size += 1 * this->fragment_profile_size();
   for (int i = 0; i < this->fragment_profile_size(); i++) {
@@ -6195,6 +6362,11 @@ void QueryProfile::MergeFrom(const QueryProfile& from) {
       set_error_node(from.error_node());
     }
   }
+  if (from._has_bits_[16 / 32] & (0xffu << (16 % 32))) {
+    if (from.has_options_json()) {
+      set_options_json(from.options_json());
+    }
+  }
   mutable_unknown_fields()->MergeFrom(from.unknown_fields());
 }
 
@@ -6233,6 +6405,7 @@ void QueryProfile::Swap(QueryProfile* other) {
     std::swap(verboseerror_, other->verboseerror_);
     std::swap(error_id_, other->error_id_);
     std::swap(error_node_, other->error_node_);
+    std::swap(options_json_, other->options_json_);
     std::swap(_has_bits_[0], other->_has_bits_[0]);
     _unknown_fields_.Swap(&other->_unknown_fields_);
     std::swap(_cached_size_, other->_cached_size_);
@@ -8665,6 +8838,325 @@ void Jar::Swap(Jar* other) {
 }
 
 
+// ===================================================================
+
+#ifndef _MSC_VER
+const int SaslMessage::kMechanismFieldNumber;
+const int SaslMessage::kDataFieldNumber;
+const int SaslMessage::kStatusFieldNumber;
+#endif  // !_MSC_VER
+
+SaslMessage::SaslMessage()
+  : ::google::protobuf::Message() {
+  SharedCtor();
+}
+
+void SaslMessage::InitAsDefaultInstance() {
+}
+
+SaslMessage::SaslMessage(const SaslMessage& from)
+  : ::google::protobuf::Message() {
+  SharedCtor();
+  MergeFrom(from);
+}
+
+void SaslMessage::SharedCtor() {
+  _cached_size_ = 0;
+  mechanism_ = const_cast< ::std::string*>(&::google::protobuf::internal::kEmptyString);
+  data_ = const_cast< ::std::string*>(&::google::protobuf::internal::kEmptyString);
+  status_ = 0;
+  ::memset(_has_bits_, 0, sizeof(_has_bits_));
+}
+
+SaslMessage::~SaslMessage() {
+  SharedDtor();
+}
+
+void SaslMessage::SharedDtor() {
+  if (mechanism_ != &::google::protobuf::internal::kEmptyString) {
+    delete mechanism_;
+  }
+  if (data_ != &::google::protobuf::internal::kEmptyString) {
+    delete data_;
+  }
+  if (this != default_instance_) {
+  }
+}
+
+void SaslMessage::SetCachedSize(int size) const {
+  GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
+  _cached_size_ = size;
+  GOOGLE_SAFE_CONCURRENT_WRITES_END();
+}
+const ::google::protobuf::Descriptor* SaslMessage::descriptor() {
+  protobuf_AssignDescriptorsOnce();
+  return SaslMessage_descriptor_;
+}
+
+const SaslMessage& SaslMessage::default_instance() {
+  if (default_instance_ == NULL) protobuf_AddDesc_UserBitShared_2eproto();
+  return *default_instance_;
+}
+
+SaslMessage* SaslMessage::default_instance_ = NULL;
+
+SaslMessage* SaslMessage::New() const {
+  return new SaslMessage;
+}
+
+void SaslMessage::Clear() {
+  if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
+    if (has_mechanism()) {
+      if (mechanism_ != &::google::protobuf::internal::kEmptyString) {
+        mechanism_->clear();
+      }
+    }
+    if (has_data()) {
+      if (data_ != &::google::protobuf::internal::kEmptyString) {
+        data_->clear();
+      }
+    }
+    status_ = 0;
+  }
+  ::memset(_has_bits_, 0, sizeof(_has_bits_));
+  mutable_unknown_fields()->Clear();
+}
+
+bool SaslMessage::MergePartialFromCodedStream(
+    ::google::protobuf::io::CodedInputStream* input) {
+#define DO_(EXPRESSION) if (!(EXPRESSION)) return false
+  ::google::protobuf::uint32 tag;
+  while ((tag = input->ReadTag()) != 0) {
+    switch (::google::protobuf::internal::WireFormatLite::GetTagFieldNumber(tag)) {
+      // optional string mechanism = 1;
+      case 1: {
+        if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
+            ::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
+          DO_(::google::protobuf::internal::WireFormatLite::ReadString(
+                input, this->mutable_mechanism()));
+          ::google::protobuf::internal::WireFormat::VerifyUTF8String(
+            this->mechanism().data(), this->mechanism().length(),
+            ::google::protobuf::internal::WireFormat::PARSE);
+        } else {
+          goto handle_uninterpreted;
+        }
+        if (input->ExpectTag(18)) goto parse_data;
+        break;
+      }
+
+      // optional bytes data = 2;
+      case 2: {
+        if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
+            ::google::protobuf::internal::WireFormatLite::WIRETYPE_LENGTH_DELIMITED) {
+         parse_data:
+          DO_(::google::protobuf::internal::WireFormatLite::ReadBytes(
+                input, this->mutable_data()));
+        } else {
+          goto handle_uninterpreted;
+        }
+        if (input->ExpectTag(24)) goto parse_status;
+        break;
+      }
+
+      // optional .exec.shared.SaslStatus status = 3;
+      case 3: {
+        if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
+            ::google::protobuf::internal::WireFormatLite::WIRETYPE_VARINT) {
+         parse_status:
+          int value;
+          DO_((::google::protobuf::internal::WireFormatLite::ReadPrimitive<
+                   int, ::google::protobuf::internal::WireFormatLite::TYPE_ENUM>(
+                 input, &value)));
+          if (::exec::shared::SaslStatus_IsValid(value)) {
+            set_status(static_cast< ::exec::shared::SaslStatus >(value));
+          } else {
+            mutable_unknown_fields()->AddVarint(3, value);
+          }
+        } else {
+          goto handle_uninterpreted;
+        }
+        if (input->ExpectAtEnd()) return true;
+        break;
+      }
+
+      default: {
+      handle_uninterpreted:
+        if (::google::protobuf::internal::WireFormatLite::GetTagWireType(tag) ==
+            ::google::protobuf::internal::WireFormatLite::WIRETYPE_END_GROUP) {
+          return true;
+        }
+        DO_(::google::protobuf::internal::WireFormat::SkipField(
+              input, tag, mutable_unknown_fields()));
+        break;
+      }
+    }
+  }
+  return true;
+#undef DO_
+}
+
+void SaslMessage::SerializeWithCachedSizes(
+    ::google::protobuf::io::CodedOutputStream* output) const {
+  // optional string mechanism = 1;
+  if (has_mechanism()) {
+    ::google::protobuf::internal::WireFormat::VerifyUTF8String(
+      this->mechanism().data(), this->mechanism().length(),
+      ::google::protobuf::internal::WireFormat::SERIALIZE);
+    ::google::protobuf::internal::WireFormatLite::WriteString(
+      1, this->mechanism(), output);
+  }
+
+  // optional bytes data = 2;
+  if (has_data()) {
+    ::google::protobuf::internal::WireFormatLite::WriteBytes(
+      2, this->data(), output);
+  }
+
+  // optional .exec.shared.SaslStatus status = 3;
+  if (has_status()) {
+    ::google::protobuf::internal::WireFormatLite::WriteEnum(
+      3, this->status(), output);
+  }
+
+  if (!unknown_fields().empty()) {
+    ::google::protobuf::internal::WireFormat::SerializeUnknownFields(
+        unknown_fields(), output);
+  }
+}
+
+::google::protobuf::uint8* SaslMessage::SerializeWithCachedSizesToArray(
+    ::google::protobuf::uint8* target) const {
+  // optional string mechanism = 1;
+  if (has_mechanism()) {
+    ::google::protobuf::internal::WireFormat::VerifyUTF8String(
+      this->mechanism().data(), this->mechanism().length(),
+      ::google::protobuf::internal::WireFormat::SERIALIZE);
+    target =
+      ::google::protobuf::internal::WireFormatLite::WriteStringToArray(
+        1, this->mechanism(), target);
+  }
+
+  // optional bytes data = 2;
+  if (has_data()) {
+    target =
+      ::google::protobuf::internal::WireFormatLite::WriteBytesToArray(
+        2, this->data(), target);
+  }
+
+  // optional .exec.shared.SaslStatus status = 3;
+  if (has_status()) {
+    target = ::google::protobuf::internal::WireFormatLite::WriteEnumToArray(
+      3, this->status(), target);
+  }
+
+  if (!unknown_fields().empty()) {
+    target = ::google::protobuf::internal::WireFormat::SerializeUnknownFieldsToArray(
+        unknown_fields(), target);
+  }
+  return target;
+}
+
+int SaslMessage::ByteSize() const {
+  int total_size = 0;
+
+  if (_has_bits_[0 / 32] & (0xffu << (0 % 32))) {
+    // optional string mechanism = 1;
+    if (has_mechanism()) {
+      total_size += 1 +
+        ::google::protobuf::internal::WireFormatLite::StringSize(
+          this->mechanism());
+    }
+
+    // optional bytes data = 2;
+    if (has_data()) {
+      total_size += 1 +
+        ::google::protobuf::internal::WireFormatLite::BytesSize(
+          this->data());
+    }
+
+    // optional .exec.shared.SaslStatus status = 3;
+    if (has_status()) {
+      total_size += 1 +
+        ::google::protobuf::internal::WireFormatLite::EnumSize(this->status());
+    }
+
+  }
+  if (!unknown_fields().empty()) {
+    total_size +=
+      ::google::protobuf::internal::WireFormat::ComputeUnknownFieldsSize(
+        unknown_fields());
+  }
+  GOOGLE_SAFE_CONCURRENT_WRITES_BEGIN();
+  _cached_size_ = total_size;
+  GOOGLE_SAFE_CONCURRENT_WRITES_END();
+  return total_size;
+}
+
+void SaslMessage::MergeFrom(const ::google::protobuf::Message& from) {
+  GOOGLE_CHECK_NE(&from, this);
+  const SaslMessage* source =
+    ::google::protobuf::internal::dynamic_cast_if_available<const SaslMessage*>(
+      &from);
+  if (source == NULL) {
+    ::google::protobuf::internal::ReflectionOps::Merge(from, this);
+  } else {
+    MergeFrom(*source);
+  }
+}
+
+void SaslMessage::MergeFrom(const SaslMessage& from) {
+  GOOGLE_CHECK_NE(&from, this);
+  if (from._has_bits_[0 / 32] & (0xffu << (0 % 32))) {
+    if (from.has_mechanism()) {
+      set_mechanism(from.mechanism());
+    }
+    if (from.has_data()) {
+      set_data(from.data());
+    }
+    if (from.has_status()) {
+      set_status(from.status());
+    }
+  }
+  mutable_unknown_fields()->MergeFrom(from.unknown_fields());
+}
+
+void SaslMessage::CopyFrom(const ::google::protobuf::Message& from) {
+  if (&from == this) return;
+  Clear();
+  MergeFrom(from);
+}
+
+void SaslMessage::CopyFrom(const SaslMessage& from) {
+  if (&from == this) return;
+  Clear();
+  MergeFrom(from);
+}
+
+bool SaslMessage::IsInitialized() const {
+
+  return true;
+}
+
+void SaslMessage::Swap(SaslMessage* other) {
+  if (other != this) {
+    std::swap(mechanism_, other->mechanism_);
+    std::swap(data_, other->data_);
+    std::swap(status_, other->status_);
+    std::swap(_has_bits_[0], other->_has_bits_[0]);
+    _unknown_fields_.Swap(&other->_unknown_fields_);
+    std::swap(_cached_size_, other->_cached_size_);
+  }
+}
+
+::google::protobuf::Metadata SaslMessage::GetMetadata() const {
+  protobuf_AssignDescriptorsOnce();
+  ::google::protobuf::Metadata metadata;
+  metadata.descriptor = SaslMessage_descriptor_;
+  metadata.reflection = SaslMessage_reflection_;
+  return metadata;
+}
+
+
 // @@protoc_insertion_point(namespace_scope)
 
 }  // namespace shared

http://git-wip-us.apache.org/repos/asf/drill/blob/f9f99e08/contrib/native/client/src/protobuf/UserBitShared.pb.h
----------------------------------------------------------------------
diff --git a/contrib/native/client/src/protobuf/UserBitShared.pb.h b/contrib/native/client/src/protobuf/UserBitShared.pb.h
index 82db444..a2d0607 100644
--- a/contrib/native/client/src/protobuf/UserBitShared.pb.h
+++ b/contrib/native/client/src/protobuf/UserBitShared.pb.h
@@ -59,6 +59,7 @@ class StreamProfile;
 class MetricValue;
 class Registry;
 class Jar;
+class SaslMessage;
 
 enum DrillPBError_ErrorType {
   DrillPBError_ErrorType_CONNECTION = 0,
@@ -251,6 +252,28 @@ inline bool CoreOperatorType_Parse(
   return ::google::protobuf::internal::ParseNamedEnum<CoreOperatorType>(
     CoreOperatorType_descriptor(), name, value);
 }
+enum SaslStatus {
+  SASL_UNKNOWN = 0,
+  SASL_START = 1,
+  SASL_IN_PROGRESS = 2,
+  SASL_SUCCESS = 3,
+  SASL_FAILED = 4
+};
+bool SaslStatus_IsValid(int value);
+const SaslStatus SaslStatus_MIN = SASL_UNKNOWN;
+const SaslStatus SaslStatus_MAX = SASL_FAILED;
+const int SaslStatus_ARRAYSIZE = SaslStatus_MAX + 1;
+
+const ::google::protobuf::EnumDescriptor* SaslStatus_descriptor();
+inline const ::std::string& SaslStatus_Name(SaslStatus value) {
+  return ::google::protobuf::internal::NameOfEnum(
+    SaslStatus_descriptor(), value);
+}
+inline bool SaslStatus_Parse(
+    const ::std::string& name, SaslStatus* value) {
+  return ::google::protobuf::internal::ParseNamedEnum<SaslStatus>(
+    SaslStatus_descriptor(), name, value);
+}
 // ===================================================================
 
 class UserCredentials : public ::google::protobuf::Message {
@@ -1802,6 +1825,18 @@ class QueryInfo : public ::google::protobuf::Message {
   inline ::exec::DrillbitEndpoint* release_foreman();
   inline void set_allocated_foreman(::exec::DrillbitEndpoint* foreman);
 
+  // optional string options_json = 6;
+  inline bool has_options_json() const;
+  inline void clear_options_json();
+  static const int kOptionsJsonFieldNumber = 6;
+  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);
+
   // @@protoc_insertion_point(class_scope:exec.shared.QueryInfo)
  private:
   inline void set_has_query();
@@ -1814,6 +1849,8 @@ class QueryInfo : public ::google::protobuf::Message {
   inline void clear_has_user();
   inline void set_has_foreman();
   inline void clear_has_foreman();
+  inline void set_has_options_json();
+  inline void clear_has_options_json();
 
   ::google::protobuf::UnknownFieldSet _unknown_fields_;
 
@@ -1822,10 +1859,11 @@ class QueryInfo : public ::google::protobuf::Message {
   ::std::string* user_;
   static ::std::string* _default_user_;
   ::exec::DrillbitEndpoint* foreman_;
+  ::std::string* options_json_;
   int state_;
 
   mutable int _cached_size_;
-  ::google::protobuf::uint32 _has_bits_[(5 + 31) / 32];
+  ::google::protobuf::uint32 _has_bits_[(6 + 31) / 32];
 
   friend void  protobuf_AddDesc_UserBitShared_2eproto();
   friend void protobuf_AssignDesc_UserBitShared_2eproto();
@@ -2046,6 +2084,18 @@ class QueryProfile : public ::google::protobuf::Message {
   inline ::std::string* release_error_node();
   inline void set_allocated_error_node(::std::string* error_node);
 
+  // optional string options_json = 17;
+  inline bool has_options_json() const;
+  inline void clear_options_json();
+  static const int kOptionsJsonFieldNumber = 17;
+  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);
+
   // @@protoc_insertion_point(class_scope:exec.shared.QueryProfile)
  private:
   inline void set_has_id();
@@ -2078,6 +2128,8 @@ class QueryProfile : public ::google::protobuf::Message {
   inline void clear_has_error_id();
   inline void set_has_error_node();
   inline void clear_has_error_node();
+  inline void set_has_options_json();
+  inline void clear_has_options_json();
 
   ::google::protobuf::UnknownFieldSet _unknown_fields_;
 
@@ -2098,9 +2150,10 @@ class QueryProfile : public ::google::protobuf::Message {
   ::std::string* verboseerror_;
   ::std::string* error_id_;
   ::std::string* error_node_;
+  ::std::string* options_json_;
 
   mutable int _cached_size_;
-  ::google::protobuf::uint32 _has_bits_[(16 + 31) / 32];
+  ::google::protobuf::uint32 _has_bits_[(17 + 31) / 32];
 
   friend void  protobuf_AddDesc_UserBitShared_2eproto();
   friend void protobuf_AssignDesc_UserBitShared_2eproto();
@@ -2944,6 +2997,118 @@ class Jar : public ::google::protobuf::Message {
   void InitAsDefaultInstance();
   static Jar* default_instance_;
 };
+// -------------------------------------------------------------------
+
+class SaslMessage : public ::google::protobuf::Message {
+ public:
+  SaslMessage();
+  virtual ~SaslMessage();
+
+  SaslMessage(const SaslMessage& from);
+
+  inline SaslMessage& operator=(const SaslMessage& 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 SaslMessage& default_instance();
+
+  void Swap(SaslMessage* other);
+
+  // implements Message ----------------------------------------------
+
+  SaslMessage* New() const;
+  void CopyFrom(const ::google::protobuf::Message& from);
+  void MergeFrom(const ::google::protobuf::Message& from);
+  void CopyFrom(const SaslMessage& from);
+  void MergeFrom(const SaslMessage& 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 string mechanism = 1;
+  inline bool has_mechanism() const;
+  inline void clear_mechanism();
+  static const int kMechanismFieldNumber = 1;
+  inline const ::std::string& mechanism() const;
+  inline void set_mechanism(const ::std::string& value);
+  inline void set_mechanism(const char* value);
+  inline void set_mechanism(const char* value, size_t size);
+  inline ::std::string* mutable_mechanism();
+  inline ::std::string* release_mechanism();
+  inline void set_allocated_mechanism(::std::string* mechanism);
+
+  // optional bytes data = 2;
+  inline bool has_data() const;
+  inline void clear_data();
+  static const int kDataFieldNumber = 2;
+  inline const ::std::string& data() const;
+  inline void set_data(const ::std::string& value);
+  inline void set_data(const char* value);
+  inline void set_data(const void* value, size_t size);
+  inline ::std::string* mutable_data();
+  inline ::std::string* release_data();
+  inline void set_allocated_data(::std::string* data);
+
+  // optional .exec.shared.SaslStatus status = 3;
+  inline bool has_status() const;
+  inline void clear_status();
+  static const int kStatusFieldNumber = 3;
+  inline ::exec::shared::SaslStatus status() const;
+  inline void set_status(::exec::shared::SaslStatus value);
+
+  // @@protoc_insertion_point(class_scope:exec.shared.SaslMessage)
+ private:
+  inline void set_has_mechanism();
+  inline void clear_has_mechanism();
+  inline void set_has_data();
+  inline void clear_has_data();
+  inline void set_has_status();
+  inline void clear_has_status();
+
+  ::google::protobuf::UnknownFieldSet _unknown_fields_;
+
+  ::std::string* mechanism_;
+  ::std::string* data_;
+  int status_;
+
+  mutable int _cached_size_;
+  ::google::protobuf::uint32 _has_bits_[(3 + 31) / 32];
+
+  friend void  protobuf_AddDesc_UserBitShared_2eproto();
+  friend void protobuf_AssignDesc_UserBitShared_2eproto();
+  friend void protobuf_ShutdownFile_UserBitShared_2eproto();
+
+  void InitAsDefaultInstance();
+  static SaslMessage* default_instance_;
+};
 // ===================================================================
 
 
@@ -4740,6 +4905,76 @@ inline void QueryInfo::set_allocated_foreman(::exec::DrillbitEndpoint* foreman)
   }
 }
 
+// optional string options_json = 6;
+inline bool QueryInfo::has_options_json() const {
+  return (_has_bits_[0] & 0x00000020u) != 0;
+}
+inline void QueryInfo::set_has_options_json() {
+  _has_bits_[0] |= 0x00000020u;
+}
+inline void QueryInfo::clear_has_options_json() {
+  _has_bits_[0] &= ~0x00000020u;
+}
+inline void QueryInfo::clear_options_json() {
+  if (options_json_ != &::google::protobuf::internal::kEmptyString) {
+    options_json_->clear();
+  }
+  clear_has_options_json();
+}
+inline const ::std::string& QueryInfo::options_json() const {
+  return *options_json_;
+}
+inline void QueryInfo::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 QueryInfo::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 QueryInfo::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* QueryInfo::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* QueryInfo::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 QueryInfo::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);
+  }
+}
+
 // -------------------------------------------------------------------
 
 // QueryProfile
@@ -5469,6 +5704,76 @@ inline void QueryProfile::set_allocated_error_node(::std::string* error_node) {
   }
 }
 
+// optional string options_json = 17;
+inline bool QueryProfile::has_options_json() const {
+  return (_has_bits_[0] & 0x00010000u) != 0;
+}
+inline void QueryProfile::set_has_options_json() {
+  _has_bits_[0] |= 0x00010000u;
+}
+inline void QueryProfile::clear_has_options_json() {
+  _has_bits_[0] &= ~0x00010000u;
+}
+inline void QueryProfile::clear_options_json() {
+  if (options_json_ != &::google::protobuf::internal::kEmptyString) {
+    options_json_->clear();
+  }
+  clear_has_options_json();
+}
+inline const ::std::string& QueryProfile::options_json() const {
+  return *options_json_;
+}
+inline void QueryProfile::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 QueryProfile::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 QueryProfile::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* QueryProfile::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* QueryProfile::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 QueryProfile::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);
+  }
+}
+
 // -------------------------------------------------------------------
 
 // MajorFragmentProfile
@@ -6275,6 +6580,173 @@ Jar::mutable_function_signature() {
   return &function_signature_;
 }
 
+// -------------------------------------------------------------------
+
+// SaslMessage
+
+// optional string mechanism = 1;
+inline bool SaslMessage::has_mechanism() const {
+  return (_has_bits_[0] & 0x00000001u) != 0;
+}
+inline void SaslMessage::set_has_mechanism() {
+  _has_bits_[0] |= 0x00000001u;
+}
+inline void SaslMessage::clear_has_mechanism() {
+  _has_bits_[0] &= ~0x00000001u;
+}
+inline void SaslMessage::clear_mechanism() {
+  if (mechanism_ != &::google::protobuf::internal::kEmptyString) {
+    mechanism_->clear();
+  }
+  clear_has_mechanism();
+}
+inline const ::std::string& SaslMessage::mechanism() const {
+  return *mechanism_;
+}
+inline void SaslMessage::set_mechanism(const ::std::string& value) {
+  set_has_mechanism();
+  if (mechanism_ == &::google::protobuf::internal::kEmptyString) {
+    mechanism_ = new ::std::string;
+  }
+  mechanism_->assign(value);
+}
+inline void SaslMessage::set_mechanism(const char* value) {
+  set_has_mechanism();
+  if (mechanism_ == &::google::protobuf::internal::kEmptyString) {
+    mechanism_ = new ::std::string;
+  }
+  mechanism_->assign(value);
+}
+inline void SaslMessage::set_mechanism(const char* value, size_t size) {
+  set_has_mechanism();
+  if (mechanism_ == &::google::protobuf::internal::kEmptyString) {
+    mechanism_ = new ::std::string;
+  }
+  mechanism_->assign(reinterpret_cast<const char*>(value), size);
+}
+inline ::std::string* SaslMessage::mutable_mechanism() {
+  set_has_mechanism();
+  if (mechanism_ == &::google::protobuf::internal::kEmptyString) {
+    mechanism_ = new ::std::string;
+  }
+  return mechanism_;
+}
+inline ::std::string* SaslMessage::release_mechanism() {
+  clear_has_mechanism();
+  if (mechanism_ == &::google::protobuf::internal::kEmptyString) {
+    return NULL;
+  } else {
+    ::std::string* temp = mechanism_;
+    mechanism_ = const_cast< ::std::string*>(&::google::protobuf::internal::kEmptyString);
+    return temp;
+  }
+}
+inline void SaslMessage::set_allocated_mechanism(::std::string* mechanism) {
+  if (mechanism_ != &::google::protobuf::internal::kEmptyString) {
+    delete mechanism_;
+  }
+  if (mechanism) {
+    set_has_mechanism();
+    mechanism_ = mechanism;
+  } else {
+    clear_has_mechanism();
+    mechanism_ = const_cast< ::std::string*>(&::google::protobuf::internal::kEmptyString);
+  }
+}
+
+// optional bytes data = 2;
+inline bool SaslMessage::has_data() const {
+  return (_has_bits_[0] & 0x00000002u) != 0;
+}
+inline void SaslMessage::set_has_data() {
+  _has_bits_[0] |= 0x00000002u;
+}
+inline void SaslMessage::clear_has_data() {
+  _has_bits_[0] &= ~0x00000002u;
+}
+inline void SaslMessage::clear_data() {
+  if (data_ != &::google::protobuf::internal::kEmptyString) {
+    data_->clear();
+  }
+  clear_has_data();
+}
+inline const ::std::string& SaslMessage::data() const {
+  return *data_;
+}
+inline void SaslMessage::set_data(const ::std::string& value) {
+  set_has_data();
+  if (data_ == &::google::protobuf::internal::kEmptyString) {
+    data_ = new ::std::string;
+  }
+  data_->assign(value);
+}
+inline void SaslMessage::set_data(const char* value) {
+  set_has_data();
+  if (data_ == &::google::protobuf::internal::kEmptyString) {
+    data_ = new ::std::string;
+  }
+  data_->assign(value);
+}
+inline void SaslMessage::set_data(const void* value, size_t size) {
+  set_has_data();
+  if (data_ == &::google::protobuf::internal::kEmptyString) {
+    data_ = new ::std::string;
+  }
+  data_->assign(reinterpret_cast<const char*>(value), size);
+}
+inline ::std::string* SaslMessage::mutable_data() {
+  set_has_data();
+  if (data_ == &::google::protobuf::internal::kEmptyString) {
+    data_ = new ::std::string;
+  }
+  return data_;
+}
+inline ::std::string* SaslMessage::release_data() {
+  clear_has_data();
+  if (data_ == &::google::protobuf::internal::kEmptyString) {
+    return NULL;
+  } else {
+    ::std::string* temp = data_;
+    data_ = const_cast< ::std::string*>(&::google::protobuf::internal::kEmptyString);
+    return temp;
+  }
+}
+inline void SaslMessage::set_allocated_data(::std::string* data) {
+  if (data_ != &::google::protobuf::internal::kEmptyString) {
+    delete data_;
+  }
+  if (data) {
+    set_has_data();
+    data_ = data;
+  } else {
+    clear_has_data();
+    data_ = const_cast< ::std::string*>(&::google::protobuf::internal::kEmptyString);
+  }
+}
+
+// optional .exec.shared.SaslStatus status = 3;
+inline bool SaslMessage::has_status() const {
+  return (_has_bits_[0] & 0x00000004u) != 0;
+}
+inline void SaslMessage::set_has_status() {
+  _has_bits_[0] |= 0x00000004u;
+}
+inline void SaslMessage::clear_has_status() {
+  _has_bits_[0] &= ~0x00000004u;
+}
+inline void SaslMessage::clear_status() {
+  status_ = 0;
+  clear_has_status();
+}
+inline ::exec::shared::SaslStatus SaslMessage::status() const {
+  return static_cast< ::exec::shared::SaslStatus >(status_);
+}
+inline void SaslMessage::set_status(::exec::shared::SaslStatus value) {
+  assert(::exec::shared::SaslStatus_IsValid(value));
+  set_has_status();
+  status_ = value;
+}
+
 
 // @@protoc_insertion_point(namespace_scope)
 
@@ -6313,6 +6785,10 @@ template <>
 inline const EnumDescriptor* GetEnumDescriptor< ::exec::shared::CoreOperatorType>() {
   return ::exec::shared::CoreOperatorType_descriptor();
 }
+template <>
+inline const EnumDescriptor* GetEnumDescriptor< ::exec::shared::SaslStatus>() {
+  return ::exec::shared::SaslStatus_descriptor();
+}
 
 }  // namespace google
 }  // namespace protobuf


Mime
View raw message