drill-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From amansi...@apache.org
Subject [1/6] drill git commit: DRILL-4335: Apache Drill should support network encryption.
Date Sat, 20 May 2017 23:52:42 GMT
Repository: drill
Updated Branches:
  refs/heads/master 416ec70a6 -> d11aba2e5


http://git-wip-us.apache.org/repos/asf/drill/blob/ce8bbc01/protocol/src/main/java/org/apache/drill/exec/proto/UserProtos.java
----------------------------------------------------------------------
diff --git a/protocol/src/main/java/org/apache/drill/exec/proto/UserProtos.java b/protocol/src/main/java/org/apache/drill/exec/proto/UserProtos.java
index aa12f96..32e3d9c 100644
--- a/protocol/src/main/java/org/apache/drill/exec/proto/UserProtos.java
+++ b/protocol/src/main/java/org/apache/drill/exec/proto/UserProtos.java
@@ -491,6 +491,10 @@ public final class UserProtos {
      * <code>SASL_AUTH = 1;</code>
      */
     SASL_AUTH(1, 1),
+    /**
+     * <code>SASL_PRIVACY = 2;</code>
+     */
+    SASL_PRIVACY(2, 2),
     ;
 
     /**
@@ -501,6 +505,10 @@ public final class UserProtos {
      * <code>SASL_AUTH = 1;</code>
      */
     public static final int SASL_AUTH_VALUE = 1;
+    /**
+     * <code>SASL_PRIVACY = 2;</code>
+     */
+    public static final int SASL_PRIVACY_VALUE = 2;
 
 
     public final int getNumber() { return value; }
@@ -509,6 +517,7 @@ public final class UserProtos {
       switch (value) {
         case 0: return UNKNOWN_SASL_SUPPORT;
         case 1: return SASL_AUTH;
+        case 2: return SASL_PRIVACY;
         default: return null;
       }
     }
@@ -9567,6 +9576,26 @@ public final class UserProtos {
      * <code>repeated .exec.user.RpcType supported_methods = 8;</code>
      */
     org.apache.drill.exec.proto.UserProtos.RpcType getSupportedMethods(int index);
+
+    // optional bool encrypted = 9;
+    /**
+     * <code>optional bool encrypted = 9;</code>
+     */
+    boolean hasEncrypted();
+    /**
+     * <code>optional bool encrypted = 9;</code>
+     */
+    boolean getEncrypted();
+
+    // optional int32 maxWrappedSize = 10;
+    /**
+     * <code>optional int32 maxWrappedSize = 10;</code>
+     */
+    boolean hasMaxWrappedSize();
+    /**
+     * <code>optional int32 maxWrappedSize = 10;</code>
+     */
+    int getMaxWrappedSize();
   }
   /**
    * Protobuf type {@code exec.user.BitToUserHandshake}
@@ -9699,6 +9728,16 @@ public final class UserProtos {
               input.popLimit(oldLimit);
               break;
             }
+            case 72: {
+              bitField0_ |= 0x00000020;
+              encrypted_ = input.readBool();
+              break;
+            }
+            case 80: {
+              bitField0_ |= 0x00000040;
+              maxWrappedSize_ = input.readInt32();
+              break;
+            }
           }
         }
       } catch (com.google.protobuf.InvalidProtocolBufferException e) {
@@ -9937,6 +9976,38 @@ public final class UserProtos {
       return supportedMethods_.get(index);
     }
 
+    // optional bool encrypted = 9;
+    public static final int ENCRYPTED_FIELD_NUMBER = 9;
+    private boolean encrypted_;
+    /**
+     * <code>optional bool encrypted = 9;</code>
+     */
+    public boolean hasEncrypted() {
+      return ((bitField0_ & 0x00000020) == 0x00000020);
+    }
+    /**
+     * <code>optional bool encrypted = 9;</code>
+     */
+    public boolean getEncrypted() {
+      return encrypted_;
+    }
+
+    // optional int32 maxWrappedSize = 10;
+    public static final int MAXWRAPPEDSIZE_FIELD_NUMBER = 10;
+    private int maxWrappedSize_;
+    /**
+     * <code>optional int32 maxWrappedSize = 10;</code>
+     */
+    public boolean hasMaxWrappedSize() {
+      return ((bitField0_ & 0x00000040) == 0x00000040);
+    }
+    /**
+     * <code>optional int32 maxWrappedSize = 10;</code>
+     */
+    public int getMaxWrappedSize() {
+      return maxWrappedSize_;
+    }
+
     private void initFields() {
       rpcVersion_ = 0;
       status_ = org.apache.drill.exec.proto.UserProtos.HandshakeStatus.SUCCESS;
@@ -9945,6 +10016,8 @@ public final class UserProtos {
       serverInfos_ = org.apache.drill.exec.proto.UserProtos.RpcEndpointInfos.getDefaultInstance();
       authenticationMechanisms_ = com.google.protobuf.LazyStringArrayList.EMPTY;
       supportedMethods_ = java.util.Collections.emptyList();
+      encrypted_ = false;
+      maxWrappedSize_ = 0;
     }
     private byte memoizedIsInitialized = -1;
     public final boolean isInitialized() {
@@ -9979,6 +10052,12 @@ public final class UserProtos {
       for (int i = 0; i < supportedMethods_.size(); i++) {
         output.writeEnum(8, supportedMethods_.get(i).getNumber());
       }
+      if (((bitField0_ & 0x00000020) == 0x00000020)) {
+        output.writeBool(9, encrypted_);
+      }
+      if (((bitField0_ & 0x00000040) == 0x00000040)) {
+        output.writeInt32(10, maxWrappedSize_);
+      }
       getUnknownFields().writeTo(output);
     }
 
@@ -10026,6 +10105,14 @@ public final class UserProtos {
         size += dataSize;
         size += 1 * supportedMethods_.size();
       }
+      if (((bitField0_ & 0x00000020) == 0x00000020)) {
+        size += com.google.protobuf.CodedOutputStream
+          .computeBoolSize(9, encrypted_);
+      }
+      if (((bitField0_ & 0x00000040) == 0x00000040)) {
+        size += com.google.protobuf.CodedOutputStream
+          .computeInt32Size(10, maxWrappedSize_);
+      }
       size += getUnknownFields().getSerializedSize();
       memoizedSerializedSize = size;
       return size;
@@ -10161,6 +10248,10 @@ public final class UserProtos {
         bitField0_ = (bitField0_ & ~0x00000020);
         supportedMethods_ = java.util.Collections.emptyList();
         bitField0_ = (bitField0_ & ~0x00000040);
+        encrypted_ = false;
+        bitField0_ = (bitField0_ & ~0x00000080);
+        maxWrappedSize_ = 0;
+        bitField0_ = (bitField0_ & ~0x00000100);
         return this;
       }
 
@@ -10224,6 +10315,14 @@ public final class UserProtos {
           bitField0_ = (bitField0_ & ~0x00000040);
         }
         result.supportedMethods_ = supportedMethods_;
+        if (((from_bitField0_ & 0x00000080) == 0x00000080)) {
+          to_bitField0_ |= 0x00000020;
+        }
+        result.encrypted_ = encrypted_;
+        if (((from_bitField0_ & 0x00000100) == 0x00000100)) {
+          to_bitField0_ |= 0x00000040;
+        }
+        result.maxWrappedSize_ = maxWrappedSize_;
         result.bitField0_ = to_bitField0_;
         onBuilt();
         return result;
@@ -10279,6 +10378,12 @@ public final class UserProtos {
           }
           onChanged();
         }
+        if (other.hasEncrypted()) {
+          setEncrypted(other.getEncrypted());
+        }
+        if (other.hasMaxWrappedSize()) {
+          setMaxWrappedSize(other.getMaxWrappedSize());
+        }
         this.mergeUnknownFields(other.getUnknownFields());
         return this;
       }
@@ -10805,6 +10910,72 @@ public final class UserProtos {
         return this;
       }
 
+      // optional bool encrypted = 9;
+      private boolean encrypted_ ;
+      /**
+       * <code>optional bool encrypted = 9;</code>
+       */
+      public boolean hasEncrypted() {
+        return ((bitField0_ & 0x00000080) == 0x00000080);
+      }
+      /**
+       * <code>optional bool encrypted = 9;</code>
+       */
+      public boolean getEncrypted() {
+        return encrypted_;
+      }
+      /**
+       * <code>optional bool encrypted = 9;</code>
+       */
+      public Builder setEncrypted(boolean value) {
+        bitField0_ |= 0x00000080;
+        encrypted_ = value;
+        onChanged();
+        return this;
+      }
+      /**
+       * <code>optional bool encrypted = 9;</code>
+       */
+      public Builder clearEncrypted() {
+        bitField0_ = (bitField0_ & ~0x00000080);
+        encrypted_ = false;
+        onChanged();
+        return this;
+      }
+
+      // optional int32 maxWrappedSize = 10;
+      private int maxWrappedSize_ ;
+      /**
+       * <code>optional int32 maxWrappedSize = 10;</code>
+       */
+      public boolean hasMaxWrappedSize() {
+        return ((bitField0_ & 0x00000100) == 0x00000100);
+      }
+      /**
+       * <code>optional int32 maxWrappedSize = 10;</code>
+       */
+      public int getMaxWrappedSize() {
+        return maxWrappedSize_;
+      }
+      /**
+       * <code>optional int32 maxWrappedSize = 10;</code>
+       */
+      public Builder setMaxWrappedSize(int value) {
+        bitField0_ |= 0x00000100;
+        maxWrappedSize_ = value;
+        onChanged();
+        return this;
+      }
+      /**
+       * <code>optional int32 maxWrappedSize = 10;</code>
+       */
+      public Builder clearMaxWrappedSize() {
+        bitField0_ = (bitField0_ & ~0x00000100);
+        maxWrappedSize_ = 0;
+        onChanged();
+        return this;
+      }
+
       // @@protoc_insertion_point(builder_scope:exec.user.BitToUserHandshake)
     }
 
@@ -41665,198 +41836,200 @@ public final class UserProtos {
       "ed.QueryResult.QueryState\022&\n\010query_id\030\002 " +
       "\001(\0132\024.exec.shared.QueryId\0221\n\tfragments\030\003" +
       " \003(\0132\036.exec.bit.control.PlanFragment\022(\n\005" +
-      "error\030\004 \001(\0132\031.exec.shared.DrillPBError\"\200",
+      "error\030\004 \001(\0132\031.exec.shared.DrillPBError\"\253",
       "\002\n\022BitToUserHandshake\022\023\n\013rpc_version\030\002 \001" +
       "(\005\022*\n\006status\030\003 \001(\0162\032.exec.user.Handshake" +
       "Status\022\017\n\007errorId\030\004 \001(\t\022\024\n\014errorMessage\030" +
       "\005 \001(\t\0221\n\014server_infos\030\006 \001(\0132\033.exec.user." +
       "RpcEndpointInfos\022 \n\030authenticationMechan" +
       "isms\030\007 \003(\t\022-\n\021supported_methods\030\010 \003(\0162\022." +
-      "exec.user.RpcType\"-\n\nLikeFilter\022\017\n\007patte" +
-      "rn\030\001 \001(\t\022\016\n\006escape\030\002 \001(\t\"D\n\016GetCatalogsR" +
-      "eq\0222\n\023catalog_name_filter\030\001 \001(\0132\025.exec.u" +
-      "ser.LikeFilter\"M\n\017CatalogMetadata\022\024\n\014cat",
-      "alog_name\030\001 \001(\t\022\023\n\013description\030\002 \001(\t\022\017\n\007"
+
-      "connect\030\003 \001(\t\"\223\001\n\017GetCatalogsResp\022(\n\006sta" +
-      "tus\030\001 \001(\0162\030.exec.user.RequestStatus\022,\n\010c" +
-      "atalogs\030\002 \003(\0132\032.exec.user.CatalogMetadat" +
-      "a\022(\n\005error\030\003 \001(\0132\031.exec.shared.DrillPBEr" +
-      "ror\"v\n\rGetSchemasReq\0222\n\023catalog_name_fil" +
-      "ter\030\001 \001(\0132\025.exec.user.LikeFilter\0221\n\022sche" +
-      "ma_name_filter\030\002 \001(\0132\025.exec.user.LikeFil" +
-      "ter\"i\n\016SchemaMetadata\022\024\n\014catalog_name\030\001 " +
-      "\001(\t\022\023\n\013schema_name\030\002 \001(\t\022\r\n\005owner\030\003 \001(\t\022",
-      "\014\n\004type\030\004 \001(\t\022\017\n\007mutable\030\005 \001(\t\"\220\001\n\016GetSc"
+
-      "hemasResp\022(\n\006status\030\001 \001(\0162\030.exec.user.Re" +
-      "questStatus\022*\n\007schemas\030\002 \003(\0132\031.exec.user" +
-      ".SchemaMetadata\022(\n\005error\030\003 \001(\0132\031.exec.sh" +
-      "ared.DrillPBError\"\302\001\n\014GetTablesReq\0222\n\023ca" +
-      "talog_name_filter\030\001 \001(\0132\025.exec.user.Like" +
-      "Filter\0221\n\022schema_name_filter\030\002 \001(\0132\025.exe" +
-      "c.user.LikeFilter\0220\n\021table_name_filter\030\003" +
-      " \001(\0132\025.exec.user.LikeFilter\022\031\n\021table_typ" +
-      "e_filter\030\004 \003(\t\"\\\n\rTableMetadata\022\024\n\014catal",
-      "og_name\030\001 \001(\t\022\023\n\013schema_name\030\002 \001(\t\022\022\n\nta" +
-      "ble_name\030\003 \001(\t\022\014\n\004type\030\004 \001(\t\"\215\001\n\rGetTabl" +
-      "esResp\022(\n\006status\030\001 \001(\0162\030.exec.user.Reque" +
-      "stStatus\022(\n\006tables\030\002 \003(\0132\030.exec.user.Tab" +
-      "leMetadata\022(\n\005error\030\003 \001(\0132\031.exec.shared." +
-      "DrillPBError\"\333\001\n\rGetColumnsReq\0222\n\023catalo" +
-      "g_name_filter\030\001 \001(\0132\025.exec.user.LikeFilt" +
-      "er\0221\n\022schema_name_filter\030\002 \001(\0132\025.exec.us" +
-      "er.LikeFilter\0220\n\021table_name_filter\030\003 \001(\013" +
-      "2\025.exec.user.LikeFilter\0221\n\022column_name_f",
-      "ilter\030\004 \001(\0132\025.exec.user.LikeFilter\"\251\003\n\016C" +
-      "olumnMetadata\022\024\n\014catalog_name\030\001 \001(\t\022\023\n\013s" +
-      "chema_name\030\002 \001(\t\022\022\n\ntable_name\030\003 \001(\t\022\023\n\013" +
-      "column_name\030\004 \001(\t\022\030\n\020ordinal_position\030\005 " +
-      "\001(\005\022\025\n\rdefault_value\030\006 \001(\t\022\023\n\013is_nullabl" +
-      "e\030\007 \001(\010\022\021\n\tdata_type\030\010 \001(\t\022\027\n\017char_max_l"
+
-      "ength\030\t \001(\005\022\031\n\021char_octet_length\030\n \001(\005\022\031" +
-      "\n\021numeric_precision\030\013 \001(\005\022\037\n\027numeric_pre" +
-      "cision_radix\030\014 \001(\005\022\025\n\rnumeric_scale\030\r \001(" +
-      "\005\022\033\n\023date_time_precision\030\016 \001(\005\022\025\n\rinterv",
-      "al_type\030\017 \001(\t\022\032\n\022interval_precision\030\020 \001(" +
-      "\005\022\023\n\013column_size\030\021 \001(\005\"\220\001\n\016GetColumnsRes" +
-      "p\022(\n\006status\030\001 \001(\0162\030.exec.user.RequestSta" +
-      "tus\022*\n\007columns\030\002 \003(\0132\031.exec.user.ColumnM" +
-      "etadata\022(\n\005error\030\003 \001(\0132\031.exec.shared.Dri" +
-      "llPBError\"/\n\032CreatePreparedStatementReq\022" +
-      "\021\n\tsql_query\030\001 \001(\t\"\326\003\n\024ResultColumnMetad" +
-      "ata\022\024\n\014catalog_name\030\001 \001(\t\022\023\n\013schema_name" +
-      "\030\002 \001(\t\022\022\n\ntable_name\030\003 \001(\t\022\023\n\013column_nam" +
-      "e\030\004 \001(\t\022\r\n\005label\030\005 \001(\t\022\021\n\tdata_type\030\006 \001(",
-      "\t\022\023\n\013is_nullable\030\007 \001(\010\022\021\n\tprecision\030\010 \001("
+
-      "\005\022\r\n\005scale\030\t \001(\005\022\016\n\006signed\030\n \001(\010\022\024\n\014disp"
+
-      "lay_size\030\013 \001(\005\022\022\n\nis_aliased\030\014 \001(\010\0225\n\rse" +
-      "archability\030\r \001(\0162\036.exec.user.ColumnSear" +
-      "chability\0223\n\014updatability\030\016 \001(\0162\035.exec.u" +
-      "ser.ColumnUpdatability\022\026\n\016auto_increment" +
-      "\030\017 \001(\010\022\030\n\020case_sensitivity\030\020 \001(\010\022\020\n\010sort"
+
-      "able\030\021 \001(\010\022\022\n\nclass_name\030\022 \001(\t\022\023\n\013is_cur"
+
-      "rency\030\024 \001(\010\".\n\027PreparedStatementHandle\022\023" +
-      "\n\013server_info\030\001 \001(\014\"\200\001\n\021PreparedStatemen",
-      "t\0220\n\007columns\030\001 \003(\0132\037.exec.user.ResultCol" +
-      "umnMetadata\0229\n\rserver_handle\030\002 \001(\0132\".exe" +
-      "c.user.PreparedStatementHandle\"\253\001\n\033Creat" +
-      "ePreparedStatementResp\022(\n\006status\030\001 \001(\0162\030" +
-      ".exec.user.RequestStatus\0228\n\022prepared_sta" +
-      "tement\030\002 \001(\0132\034.exec.user.PreparedStateme" +
-      "nt\022(\n\005error\030\003 \001(\0132\031.exec.shared.DrillPBE" +
-      "rror\"\022\n\020GetServerMetaReq\"P\n\016ConvertSuppo" +
-      "rt\022\037\n\004from\030\001 \002(\0162\021.common.MinorType\022\035\n\002t" +
-      "o\030\002 \002(\0162\021.common.MinorType\"\223\001\n\021GetServer",
-      "MetaResp\022(\n\006status\030\001 \001(\0162\030.exec.user.Req" +
-      "uestStatus\022*\n\013server_meta\030\002 \001(\0132\025.exec.u" +
-      "ser.ServerMeta\022(\n\005error\030\003 \001(\0132\031.exec.sha" +
-      "red.DrillPBError\"\377\r\n\nServerMeta\022\035\n\025all_t" +
-      "ables_selectable\030\001 \001(\010\022%\n\035blob_included_" +
-      "in_max_row_size\030\002 \001(\010\022\030\n\020catalog_at_star" +
-      "t\030\003 \001(\010\022\031\n\021catalog_separator\030\004 \001(\t\022\024\n\014ca"
+
-      "talog_term\030\005 \001(\t\0222\n\017collate_support\030\006 \003(" +
-      "\0162\031.exec.user.CollateSupport\022!\n\031column_a" +
-      "liasing_supported\030\007 \001(\010\0222\n\017convert_suppo",
-      "rt\030\010 \003(\0132\031.exec.user.ConvertSupport\022E\n\031c" +
-      "orrelation_names_support\030\t \001(\0162\".exec.us" +
-      "er.CorrelationNamesSupport\022\033\n\023date_time_" +
-      "functions\030\n \003(\t\022F\n\032date_time_literals_su" +
-      "pport\030\013 \003(\0162\".exec.user.DateTimeLiterals" +
-      "Support\0223\n\020group_by_support\030\014 \001(\0162\031.exec" +
-      ".user.GroupBySupport\0226\n\021identifier_casin" +
-      "g\030\r \001(\0162\033.exec.user.IdentifierCasing\022\037\n\027" +
-      "identifier_quote_string\030\016 \001(\t\022$\n\034like_es" +
-      "cape_clause_supported\030\017 \001(\010\022!\n\031max_binar",
-      "y_literal_length\030\020 \001(\r\022\037\n\027max_catalog_na" +
-      "me_length\030\021 \001(\r\022\037\n\027max_char_literal_leng" +
-      "th\030\022 \001(\r\022\036\n\026max_column_name_length\030\023 \001(\r" +
-      "\022\037\n\027max_columns_in_group_by\030\024 \001(\r\022\037\n\027max" +
-      "_columns_in_order_by\030\025 \001(\r\022\035\n\025max_column" +
-      "s_in_select\030\026 \001(\r\022\036\n\026max_cursor_name_len" +
-      "gth\030\027 \001(\r\022\034\n\024max_logical_lob_size\030\030 \001(\r\022" +
-      "\024\n\014max_row_size\030\031 \001(\r\022\036\n\026max_schema_name" +
-      "_length\030\032 \001(\r\022\034\n\024max_statement_length\030\033 " +
-      "\001(\r\022\026\n\016max_statements\030\034 \001(\r\022\035\n\025max_table",
-      "_name_length\030\035 \001(\r\022\034\n\024max_tables_in_sele" +
-      "ct\030\036 \001(\r\022\034\n\024max_user_name_length\030\037 \001(\r\0220" +
-      "\n\016null_collation\030  \001(\0162\030.exec.user.NullC" +
-      "ollation\022&\n\036null_plus_non_null_equals_nu" +
-      "ll\030! \001(\010\022\031\n\021numeric_functions\030\" \003(\t\0223\n\020o" +
-      "rder_by_support\030# \003(\0162\031.exec.user.OrderB" +
-      "ySupport\0227\n\022outer_join_support\030$ \003(\0162\033.e" +
-      "xec.user.OuterJoinSupport\022=\n\030quoted_iden" +
-      "tifier_casing\030% \001(\0162\033.exec.user.Identifi" +
-      "erCasing\022\021\n\tread_only\030& \001(\010\022\023\n\013schema_te",
-      "rm\030\' \001(\t\022\034\n\024search_escape_string\030( \001(\t\022#" +
-      "\n\033select_for_update_supported\030) \001(\010\022\032\n\022s" +
-      "pecial_characters\030* \001(\t\022\024\n\014sql_keywords\030" +
-      "+ \003(\t\022\030\n\020string_functions\030, \003(\t\0224\n\020subqu" +
-      "ery_support\030- \003(\0162\032.exec.user.SubQuerySu" +
-      "pport\022\030\n\020system_functions\030. \003(\t\022\022\n\ntable" +
-      "_term\030/ \001(\t\022\035\n\025transaction_supported\0300 \001" +
-      "(\010\022.\n\runion_support\0301 \003(\0162\027.exec.user.Un" +
-      "ionSupport\"\353\001\n\010RunQuery\0221\n\014results_mode\030" +
-      "\001 \001(\0162\033.exec.user.QueryResultsMode\022$\n\004ty",
-      "pe\030\002 \001(\0162\026.exec.shared.QueryType\022\014\n\004plan" +
-      "\030\003 \001(\t\0221\n\tfragments\030\004 \003(\0132\036.exec.bit.con" +
-      "trol.PlanFragment\022E\n\031prepared_statement_" +
-      "handle\030\005 \001(\0132\".exec.user.PreparedStateme" +
-      "ntHandle*\320\003\n\007RpcType\022\r\n\tHANDSHAKE\020\000\022\007\n\003A" +
-      "CK\020\001\022\013\n\007GOODBYE\020\002\022\r\n\tRUN_QUERY\020\003\022\020\n\014CANC"
+
-      "EL_QUERY\020\004\022\023\n\017REQUEST_RESULTS\020\005\022\027\n\023RESUM" +
-      "E_PAUSED_QUERY\020\013\022\034\n\030GET_QUERY_PLAN_FRAGM" +
-      "ENTS\020\014\022\020\n\014GET_CATALOGS\020\016\022\017\n\013GET_SCHEMAS\020" +
-      "\017\022\016\n\nGET_TABLES\020\020\022\017\n\013GET_COLUMNS\020\021\022\035\n\031CR",
-      "EATE_PREPARED_STATEMENT\020\026\022\023\n\017GET_SERVER_" +
-      "META\020\010\022\016\n\nQUERY_DATA\020\006\022\020\n\014QUERY_HANDLE\020\007" +
-      "\022\030\n\024QUERY_PLAN_FRAGMENTS\020\r\022\014\n\010CATALOGS\020\022" +
-      "\022\013\n\007SCHEMAS\020\023\022\n\n\006TABLES\020\024\022\013\n\007COLUMNS\020\025\022\026"
+
-      "\n\022PREPARED_STATEMENT\020\027\022\017\n\013SERVER_META\020\t\022" +
-      "\020\n\014QUERY_RESULT\020\n\022\020\n\014SASL_MESSAGE\020\030*6\n\013S" +
-      "aslSupport\022\030\n\024UNKNOWN_SASL_SUPPORT\020\000\022\r\n\t" +
-      "SASL_AUTH\020\001*#\n\020QueryResultsMode\022\017\n\013STREA" +
-      "M_FULL\020\001*q\n\017HandshakeStatus\022\013\n\007SUCCESS\020\001" +
-      "\022\030\n\024RPC_VERSION_MISMATCH\020\002\022\017\n\013AUTH_FAILE",
-      "D\020\003\022\023\n\017UNKNOWN_FAILURE\020\004\022\021\n\rAUTH_REQUIRE" +
-      "D\020\005*D\n\rRequestStatus\022\022\n\016UNKNOWN_STATUS\020\000" +
-      "\022\006\n\002OK\020\001\022\n\n\006FAILED\020\002\022\013\n\007TIMEOUT\020\003*Y\n\023Col"
+
-      "umnSearchability\022\031\n\025UNKNOWN_SEARCHABILIT" +
-      "Y\020\000\022\010\n\004NONE\020\001\022\010\n\004CHAR\020\002\022\n\n\006NUMBER\020\003\022\007\n\003A"
+
-      "LL\020\004*K\n\022ColumnUpdatability\022\030\n\024UNKNOWN_UP" +
-      "DATABILITY\020\000\022\r\n\tREAD_ONLY\020\001\022\014\n\010WRITABLE\020" +
-      "\002*1\n\016CollateSupport\022\016\n\nCS_UNKNOWN\020\000\022\017\n\013C" +
-      "S_GROUP_BY\020\001*J\n\027CorrelationNamesSupport\022" +
-      "\013\n\007CN_NONE\020\001\022\026\n\022CN_DIFFERENT_NAMES\020\002\022\n\n\006",
-      "CN_ANY\020\003*\271\003\n\027DateTimeLiteralsSupport\022\016\n\n" +
-      "DL_UNKNOWN\020\000\022\013\n\007DL_DATE\020\001\022\013\n\007DL_TIME\020\002\022\020"
+
-      "\n\014DL_TIMESTAMP\020\003\022\024\n\020DL_INTERVAL_YEAR\020\004\022\025" +
-      "\n\021DL_INTERVAL_MONTH\020\005\022\023\n\017DL_INTERVAL_DAY" +
-      "\020\006\022\024\n\020DL_INTERVAL_HOUR\020\007\022\026\n\022DL_INTERVAL_" +
-      "MINUTE\020\010\022\026\n\022DL_INTERVAL_SECOND\020\t\022\035\n\031DL_I" +
-      "NTERVAL_YEAR_TO_MONTH\020\n\022\033\n\027DL_INTERVAL_D" +
-      "AY_TO_HOUR\020\013\022\035\n\031DL_INTERVAL_DAY_TO_MINUT" +
-      "E\020\014\022\035\n\031DL_INTERVAL_DAY_TO_SECOND\020\r\022\036\n\032DL" +
-      "_INTERVAL_HOUR_TO_MINUTE\020\016\022\036\n\032DL_INTERVA",
-      "L_HOUR_TO_SECOND\020\017\022 \n\034DL_INTERVAL_MINUTE" +
-      "_TO_SECOND\020\020*Y\n\016GroupBySupport\022\013\n\007GB_NON" +
-      "E\020\001\022\022\n\016GB_SELECT_ONLY\020\002\022\024\n\020GB_BEYOND_SEL" +
-      "ECT\020\003\022\020\n\014GB_UNRELATED\020\004*x\n\020IdentifierCas" +
-      "ing\022\016\n\nIC_UNKNOWN\020\000\022\023\n\017IC_STORES_LOWER\020\001" +
-      "\022\023\n\017IC_STORES_MIXED\020\002\022\023\n\017IC_STORES_UPPER" +
-      "\020\003\022\025\n\021IC_SUPPORTS_MIXED\020\004*X\n\rNullCollati" +
-      "on\022\016\n\nNC_UNKNOWN\020\000\022\017\n\013NC_AT_START\020\001\022\r\n\tN" +
-      "C_AT_END\020\002\022\013\n\007NC_HIGH\020\003\022\n\n\006NC_LOW\020\004*E\n\016O"
+
-      "rderBySupport\022\016\n\nOB_UNKNOWN\020\000\022\020\n\014OB_UNRE",
-      "LATED\020\001\022\021\n\rOB_EXPRESSION\020\002*\226\001\n\020OuterJoin" +
-      "Support\022\016\n\nOJ_UNKNOWN\020\000\022\013\n\007OJ_LEFT\020\001\022\014\n\010"
+
-      "OJ_RIGHT\020\002\022\013\n\007OJ_FULL\020\003\022\r\n\tOJ_NESTED\020\004\022\022"
+
-      "\n\016OJ_NOT_ORDERED\020\005\022\014\n\010OJ_INNER\020\006\022\031\n\025OJ_A" +
-      "LL_COMPARISON_OPS\020\007*\204\001\n\017SubQuerySupport\022" +
-      "\016\n\nSQ_UNKNOWN\020\000\022\021\n\rSQ_CORRELATED\020\001\022\024\n\020SQ" +
-      "_IN_COMPARISON\020\002\022\020\n\014SQ_IN_EXISTS\020\003\022\020\n\014SQ" +
-      "_IN_INSERT\020\004\022\024\n\020SQ_IN_QUANTIFIED\020\005*;\n\014Un" +
-      "ionSupport\022\r\n\tU_UNKNOWN\020\000\022\013\n\007U_UNION\020\001\022\017" +
-      "\n\013U_UNION_ALL\020\002B+\n\033org.apache.drill.exec",
-      ".protoB\nUserProtosH\001"
+      "exec.user.RpcType\022\021\n\tencrypted\030\t \001(\010\022\026\n\016" +
+      "maxWrappedSize\030\n \001(\005\"-\n\nLikeFilter\022\017\n\007pa" +
+      "ttern\030\001 \001(\t\022\016\n\006escape\030\002 \001(\t\"D\n\016GetCatalo" +
+      "gsReq\0222\n\023catalog_name_filter\030\001 \001(\0132\025.exe",
+      "c.user.LikeFilter\"M\n\017CatalogMetadata\022\024\n\014" +
+      "catalog_name\030\001 \001(\t\022\023\n\013description\030\002 \001(\t\022" +
+      "\017\n\007connect\030\003 \001(\t\"\223\001\n\017GetCatalogsResp\022(\n\006" +
+      "status\030\001 \001(\0162\030.exec.user.RequestStatus\022," +
+      "\n\010catalogs\030\002 \003(\0132\032.exec.user.CatalogMeta" +
+      "data\022(\n\005error\030\003 \001(\0132\031.exec.shared.DrillP" +
+      "BError\"v\n\rGetSchemasReq\0222\n\023catalog_name_" +
+      "filter\030\001 \001(\0132\025.exec.user.LikeFilter\0221\n\022s" +
+      "chema_name_filter\030\002 \001(\0132\025.exec.user.Like" +
+      "Filter\"i\n\016SchemaMetadata\022\024\n\014catalog_name",
+      "\030\001 \001(\t\022\023\n\013schema_name\030\002 \001(\t\022\r\n\005owner\030\003
\001" +
+      "(\t\022\014\n\004type\030\004 \001(\t\022\017\n\007mutable\030\005 \001(\t\"\220\001\n\016Ge"
+
+      "tSchemasResp\022(\n\006status\030\001 \001(\0162\030.exec.user" +
+      ".RequestStatus\022*\n\007schemas\030\002 \003(\0132\031.exec.u" +
+      "ser.SchemaMetadata\022(\n\005error\030\003 \001(\0132\031.exec" +
+      ".shared.DrillPBError\"\302\001\n\014GetTablesReq\0222\n" +
+      "\023catalog_name_filter\030\001 \001(\0132\025.exec.user.L" +
+      "ikeFilter\0221\n\022schema_name_filter\030\002 \001(\0132\025." +
+      "exec.user.LikeFilter\0220\n\021table_name_filte" +
+      "r\030\003 \001(\0132\025.exec.user.LikeFilter\022\031\n\021table_",
+      "type_filter\030\004 \003(\t\"\\\n\rTableMetadata\022\024\n\014ca" +
+      "talog_name\030\001 \001(\t\022\023\n\013schema_name\030\002 \001(\t\022\022\n" +
+      "\ntable_name\030\003 \001(\t\022\014\n\004type\030\004 \001(\t\"\215\001\n\rGetT"
+
+      "ablesResp\022(\n\006status\030\001 \001(\0162\030.exec.user.Re" +
+      "questStatus\022(\n\006tables\030\002 \003(\0132\030.exec.user." +
+      "TableMetadata\022(\n\005error\030\003 \001(\0132\031.exec.shar" +
+      "ed.DrillPBError\"\333\001\n\rGetColumnsReq\0222\n\023cat" +
+      "alog_name_filter\030\001 \001(\0132\025.exec.user.LikeF" +
+      "ilter\0221\n\022schema_name_filter\030\002 \001(\0132\025.exec" +
+      ".user.LikeFilter\0220\n\021table_name_filter\030\003 ",
+      "\001(\0132\025.exec.user.LikeFilter\0221\n\022column_nam" +
+      "e_filter\030\004 \001(\0132\025.exec.user.LikeFilter\"\251\003" +
+      "\n\016ColumnMetadata\022\024\n\014catalog_name\030\001 \001(\t\022\023" +
+      "\n\013schema_name\030\002 \001(\t\022\022\n\ntable_name\030\003 \001(\t\022" +
+      "\023\n\013column_name\030\004 \001(\t\022\030\n\020ordinal_position" +
+      "\030\005 \001(\005\022\025\n\rdefault_value\030\006 \001(\t\022\023\n\013is_null"
+
+      "able\030\007 \001(\010\022\021\n\tdata_type\030\010 \001(\t\022\027\n\017char_ma"
+
+      "x_length\030\t \001(\005\022\031\n\021char_octet_length\030\n \001(" +
+      "\005\022\031\n\021numeric_precision\030\013 \001(\005\022\037\n\027numeric_" +
+      "precision_radix\030\014 \001(\005\022\025\n\rnumeric_scale\030\r",
+      " \001(\005\022\033\n\023date_time_precision\030\016 \001(\005\022\025\n\rint" +
+      "erval_type\030\017 \001(\t\022\032\n\022interval_precision\030\020" +
+      " \001(\005\022\023\n\013column_size\030\021 \001(\005\"\220\001\n\016GetColumns" +
+      "Resp\022(\n\006status\030\001 \001(\0162\030.exec.user.Request" +
+      "Status\022*\n\007columns\030\002 \003(\0132\031.exec.user.Colu" +
+      "mnMetadata\022(\n\005error\030\003 \001(\0132\031.exec.shared." +
+      "DrillPBError\"/\n\032CreatePreparedStatementR" +
+      "eq\022\021\n\tsql_query\030\001 \001(\t\"\326\003\n\024ResultColumnMe" +
+      "tadata\022\024\n\014catalog_name\030\001 \001(\t\022\023\n\013schema_n" +
+      "ame\030\002 \001(\t\022\022\n\ntable_name\030\003 \001(\t\022\023\n\013column_",
+      "name\030\004 \001(\t\022\r\n\005label\030\005 \001(\t\022\021\n\tdata_type\030\006"
+
+      " \001(\t\022\023\n\013is_nullable\030\007 \001(\010\022\021\n\tprecision\030\010"
+
+      " \001(\005\022\r\n\005scale\030\t \001(\005\022\016\n\006signed\030\n \001(\010\022\024\n\014d"
+
+      "isplay_size\030\013 \001(\005\022\022\n\nis_aliased\030\014 \001(\010\0225\n" +
+      "\rsearchability\030\r \001(\0162\036.exec.user.ColumnS" +
+      "earchability\0223\n\014updatability\030\016 \001(\0162\035.exe" +
+      "c.user.ColumnUpdatability\022\026\n\016auto_increm" +
+      "ent\030\017 \001(\010\022\030\n\020case_sensitivity\030\020 \001(\010\022\020\n\010s"
+
+      "ortable\030\021 \001(\010\022\022\n\nclass_name\030\022 \001(\t\022\023\n\013is_"
+
+      "currency\030\024 \001(\010\".\n\027PreparedStatementHandl",
+      "e\022\023\n\013server_info\030\001 \001(\014\"\200\001\n\021PreparedState" +
+      "ment\0220\n\007columns\030\001 \003(\0132\037.exec.user.Result" +
+      "ColumnMetadata\0229\n\rserver_handle\030\002 \001(\0132\"." +
+      "exec.user.PreparedStatementHandle\"\253\001\n\033Cr" +
+      "eatePreparedStatementResp\022(\n\006status\030\001 \001(" +
+      "\0162\030.exec.user.RequestStatus\0228\n\022prepared_" +
+      "statement\030\002 \001(\0132\034.exec.user.PreparedStat" +
+      "ement\022(\n\005error\030\003 \001(\0132\031.exec.shared.Drill" +
+      "PBError\"\022\n\020GetServerMetaReq\"P\n\016ConvertSu" +
+      "pport\022\037\n\004from\030\001 \002(\0162\021.common.MinorType\022\035",
+      "\n\002to\030\002 \002(\0162\021.common.MinorType\"\223\001\n\021GetSer" +
+      "verMetaResp\022(\n\006status\030\001 \001(\0162\030.exec.user." +
+      "RequestStatus\022*\n\013server_meta\030\002 \001(\0132\025.exe" +
+      "c.user.ServerMeta\022(\n\005error\030\003 \001(\0132\031.exec." +
+      "shared.DrillPBError\"\377\r\n\nServerMeta\022\035\n\025al" +
+      "l_tables_selectable\030\001 \001(\010\022%\n\035blob_includ" +
+      "ed_in_max_row_size\030\002 \001(\010\022\030\n\020catalog_at_s" +
+      "tart\030\003 \001(\010\022\031\n\021catalog_separator\030\004 \001(\t\022\024\n" +
+      "\014catalog_term\030\005 \001(\t\0222\n\017collate_support\030\006" +
+      " \003(\0162\031.exec.user.CollateSupport\022!\n\031colum",
+      "n_aliasing_supported\030\007 \001(\010\0222\n\017convert_su" +
+      "pport\030\010 \003(\0132\031.exec.user.ConvertSupport\022E" +
+      "\n\031correlation_names_support\030\t \001(\0162\".exec" +
+      ".user.CorrelationNamesSupport\022\033\n\023date_ti" +
+      "me_functions\030\n \003(\t\022F\n\032date_time_literals" +
+      "_support\030\013 \003(\0162\".exec.user.DateTimeLiter" +
+      "alsSupport\0223\n\020group_by_support\030\014 \001(\0162\031.e" +
+      "xec.user.GroupBySupport\0226\n\021identifier_ca" +
+      "sing\030\r \001(\0162\033.exec.user.IdentifierCasing\022" +
+      "\037\n\027identifier_quote_string\030\016 \001(\t\022$\n\034like",
+      "_escape_clause_supported\030\017 \001(\010\022!\n\031max_bi" +
+      "nary_literal_length\030\020 \001(\r\022\037\n\027max_catalog" +
+      "_name_length\030\021 \001(\r\022\037\n\027max_char_literal_l" +
+      "ength\030\022 \001(\r\022\036\n\026max_column_name_length\030\023 " +
+      "\001(\r\022\037\n\027max_columns_in_group_by\030\024 \001(\r\022\037\n\027" +
+      "max_columns_in_order_by\030\025 \001(\r\022\035\n\025max_col" +
+      "umns_in_select\030\026 \001(\r\022\036\n\026max_cursor_name_" +
+      "length\030\027 \001(\r\022\034\n\024max_logical_lob_size\030\030 \001" +
+      "(\r\022\024\n\014max_row_size\030\031 \001(\r\022\036\n\026max_schema_n" +
+      "ame_length\030\032 \001(\r\022\034\n\024max_statement_length",
+      "\030\033 \001(\r\022\026\n\016max_statements\030\034 \001(\r\022\035\n\025max_ta"
+
+      "ble_name_length\030\035 \001(\r\022\034\n\024max_tables_in_s" +
+      "elect\030\036 \001(\r\022\034\n\024max_user_name_length\030\037 \001(" +
+      "\r\0220\n\016null_collation\030  \001(\0162\030.exec.user.Nu" +
+      "llCollation\022&\n\036null_plus_non_null_equals" +
+      "_null\030! \001(\010\022\031\n\021numeric_functions\030\" \003(\t\0223" +
+      "\n\020order_by_support\030# \003(\0162\031.exec.user.Ord" +
+      "erBySupport\0227\n\022outer_join_support\030$ \003(\0162" +
+      "\033.exec.user.OuterJoinSupport\022=\n\030quoted_i" +
+      "dentifier_casing\030% \001(\0162\033.exec.user.Ident",
+      "ifierCasing\022\021\n\tread_only\030& \001(\010\022\023\n\013schema" +
+      "_term\030\' \001(\t\022\034\n\024search_escape_string\030( \001(" +
+      "\t\022#\n\033select_for_update_supported\030) \001(\010\022\032" +
+      "\n\022special_characters\030* \001(\t\022\024\n\014sql_keywor" +
+      "ds\030+ \003(\t\022\030\n\020string_functions\030, \003(\t\0224\n\020su" +
+      "bquery_support\030- \003(\0162\032.exec.user.SubQuer" +
+      "ySupport\022\030\n\020system_functions\030. \003(\t\022\022\n\nta" +
+      "ble_term\030/ \001(\t\022\035\n\025transaction_supported\030" +
+      "0 \001(\010\022.\n\runion_support\0301 \003(\0162\027.exec.user" +
+      ".UnionSupport\"\353\001\n\010RunQuery\0221\n\014results_mo",
+      "de\030\001 \001(\0162\033.exec.user.QueryResultsMode\022$\n" +
+      "\004type\030\002 \001(\0162\026.exec.shared.QueryType\022\014\n\004p" +
+      "lan\030\003 \001(\t\0221\n\tfragments\030\004 \003(\0132\036.exec.bit." +
+      "control.PlanFragment\022E\n\031prepared_stateme" +
+      "nt_handle\030\005 \001(\0132\".exec.user.PreparedStat" +
+      "ementHandle*\320\003\n\007RpcType\022\r\n\tHANDSHAKE\020\000\022\007" +
+      "\n\003ACK\020\001\022\013\n\007GOODBYE\020\002\022\r\n\tRUN_QUERY\020\003\022\020\n\014C"
+
+      "ANCEL_QUERY\020\004\022\023\n\017REQUEST_RESULTS\020\005\022\027\n\023RE" +
+      "SUME_PAUSED_QUERY\020\013\022\034\n\030GET_QUERY_PLAN_FR" +
+      "AGMENTS\020\014\022\020\n\014GET_CATALOGS\020\016\022\017\n\013GET_SCHEM",
+      "AS\020\017\022\016\n\nGET_TABLES\020\020\022\017\n\013GET_COLUMNS\020\021\022\035\n"
+
+      "\031CREATE_PREPARED_STATEMENT\020\026\022\023\n\017GET_SERV" +
+      "ER_META\020\010\022\016\n\nQUERY_DATA\020\006\022\020\n\014QUERY_HANDL" +
+      "E\020\007\022\030\n\024QUERY_PLAN_FRAGMENTS\020\r\022\014\n\010CATALOG" +
+      "S\020\022\022\013\n\007SCHEMAS\020\023\022\n\n\006TABLES\020\024\022\013\n\007COLUMNS\020"
+
+      "\025\022\026\n\022PREPARED_STATEMENT\020\027\022\017\n\013SERVER_META" +
+      "\020\t\022\020\n\014QUERY_RESULT\020\n\022\020\n\014SASL_MESSAGE\020\030*H" +
+      "\n\013SaslSupport\022\030\n\024UNKNOWN_SASL_SUPPORT\020\000\022" +
+      "\r\n\tSASL_AUTH\020\001\022\020\n\014SASL_PRIVACY\020\002*#\n\020Quer" +
+      "yResultsMode\022\017\n\013STREAM_FULL\020\001*q\n\017Handsha",
+      "keStatus\022\013\n\007SUCCESS\020\001\022\030\n\024RPC_VERSION_MIS" +
+      "MATCH\020\002\022\017\n\013AUTH_FAILED\020\003\022\023\n\017UNKNOWN_FAIL" +
+      "URE\020\004\022\021\n\rAUTH_REQUIRED\020\005*D\n\rRequestStatu" +
+      "s\022\022\n\016UNKNOWN_STATUS\020\000\022\006\n\002OK\020\001\022\n\n\006FAILED\020"
+
+      "\002\022\013\n\007TIMEOUT\020\003*Y\n\023ColumnSearchability\022\031\n" +
+      "\025UNKNOWN_SEARCHABILITY\020\000\022\010\n\004NONE\020\001\022\010\n\004CH" +
+      "AR\020\002\022\n\n\006NUMBER\020\003\022\007\n\003ALL\020\004*K\n\022ColumnUpdat"
+
+      "ability\022\030\n\024UNKNOWN_UPDATABILITY\020\000\022\r\n\tREA" +
+      "D_ONLY\020\001\022\014\n\010WRITABLE\020\002*1\n\016CollateSupport" +
+      "\022\016\n\nCS_UNKNOWN\020\000\022\017\n\013CS_GROUP_BY\020\001*J\n\027Cor",
+      "relationNamesSupport\022\013\n\007CN_NONE\020\001\022\026\n\022CN_" +
+      "DIFFERENT_NAMES\020\002\022\n\n\006CN_ANY\020\003*\271\003\n\027DateTi" +
+      "meLiteralsSupport\022\016\n\nDL_UNKNOWN\020\000\022\013\n\007DL_" +
+      "DATE\020\001\022\013\n\007DL_TIME\020\002\022\020\n\014DL_TIMESTAMP\020\003\022\024\n"
+
+      "\020DL_INTERVAL_YEAR\020\004\022\025\n\021DL_INTERVAL_MONTH" +
+      "\020\005\022\023\n\017DL_INTERVAL_DAY\020\006\022\024\n\020DL_INTERVAL_H" +
+      "OUR\020\007\022\026\n\022DL_INTERVAL_MINUTE\020\010\022\026\n\022DL_INTE" +
+      "RVAL_SECOND\020\t\022\035\n\031DL_INTERVAL_YEAR_TO_MON" +
+      "TH\020\n\022\033\n\027DL_INTERVAL_DAY_TO_HOUR\020\013\022\035\n\031DL_" +
+      "INTERVAL_DAY_TO_MINUTE\020\014\022\035\n\031DL_INTERVAL_",
+      "DAY_TO_SECOND\020\r\022\036\n\032DL_INTERVAL_HOUR_TO_M" +
+      "INUTE\020\016\022\036\n\032DL_INTERVAL_HOUR_TO_SECOND\020\017\022" +
+      " \n\034DL_INTERVAL_MINUTE_TO_SECOND\020\020*Y\n\016Gro" +
+      "upBySupport\022\013\n\007GB_NONE\020\001\022\022\n\016GB_SELECT_ON" +
+      "LY\020\002\022\024\n\020GB_BEYOND_SELECT\020\003\022\020\n\014GB_UNRELAT" +
+      "ED\020\004*x\n\020IdentifierCasing\022\016\n\nIC_UNKNOWN\020\000" +
+      "\022\023\n\017IC_STORES_LOWER\020\001\022\023\n\017IC_STORES_MIXED" +
+      "\020\002\022\023\n\017IC_STORES_UPPER\020\003\022\025\n\021IC_SUPPORTS_M" +
+      "IXED\020\004*X\n\rNullCollation\022\016\n\nNC_UNKNOWN\020\000\022" +
+      "\017\n\013NC_AT_START\020\001\022\r\n\tNC_AT_END\020\002\022\013\n\007NC_HI",
+      "GH\020\003\022\n\n\006NC_LOW\020\004*E\n\016OrderBySupport\022\016\n\nOB" +
+      "_UNKNOWN\020\000\022\020\n\014OB_UNRELATED\020\001\022\021\n\rOB_EXPRE" +
+      "SSION\020\002*\226\001\n\020OuterJoinSupport\022\016\n\nOJ_UNKNO" +
+      "WN\020\000\022\013\n\007OJ_LEFT\020\001\022\014\n\010OJ_RIGHT\020\002\022\013\n\007OJ_FU"
+
+      "LL\020\003\022\r\n\tOJ_NESTED\020\004\022\022\n\016OJ_NOT_ORDERED\020\005\022" +
+      "\014\n\010OJ_INNER\020\006\022\031\n\025OJ_ALL_COMPARISON_OPS\020\007" +
+      "*\204\001\n\017SubQuerySupport\022\016\n\nSQ_UNKNOWN\020\000\022\021\n\r" +
+      "SQ_CORRELATED\020\001\022\024\n\020SQ_IN_COMPARISON\020\002\022\020\n" +
+      "\014SQ_IN_EXISTS\020\003\022\020\n\014SQ_IN_INSERT\020\004\022\024\n\020SQ_" +
+      "IN_QUANTIFIED\020\005*;\n\014UnionSupport\022\r\n\tU_UNK",
+      "NOWN\020\000\022\013\n\007U_UNION\020\001\022\017\n\013U_UNION_ALL\020\002B+\n\033"
+
+      "org.apache.drill.exec.protoB\nUserProtosH" +
+      "\001"
     };
     com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner assigner =
       new com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner() {
@@ -41910,7 +42083,7 @@ public final class UserProtos {
           internal_static_exec_user_BitToUserHandshake_fieldAccessorTable = new
             com.google.protobuf.GeneratedMessage.FieldAccessorTable(
               internal_static_exec_user_BitToUserHandshake_descriptor,
-              new java.lang.String[] { "RpcVersion", "Status", "ErrorId", "ErrorMessage",
"ServerInfos", "AuthenticationMechanisms", "SupportedMethods", });
+              new java.lang.String[] { "RpcVersion", "Status", "ErrorId", "ErrorMessage",
"ServerInfos", "AuthenticationMechanisms", "SupportedMethods", "Encrypted", "MaxWrappedSize",
});
           internal_static_exec_user_LikeFilter_descriptor =
             getDescriptor().getMessageTypes().get(8);
           internal_static_exec_user_LikeFilter_fieldAccessorTable = new

http://git-wip-us.apache.org/repos/asf/drill/blob/ce8bbc01/protocol/src/main/java/org/apache/drill/exec/proto/beans/BitToUserHandshake.java
----------------------------------------------------------------------
diff --git a/protocol/src/main/java/org/apache/drill/exec/proto/beans/BitToUserHandshake.java
b/protocol/src/main/java/org/apache/drill/exec/proto/beans/BitToUserHandshake.java
index 0cad1c0..c22519d 100644
--- a/protocol/src/main/java/org/apache/drill/exec/proto/beans/BitToUserHandshake.java
+++ b/protocol/src/main/java/org/apache/drill/exec/proto/beans/BitToUserHandshake.java
@@ -56,6 +56,8 @@ public final class BitToUserHandshake implements Externalizable, Message<BitToUs
     private RpcEndpointInfos serverInfos;
     private List<String> authenticationMechanisms;
     private List<RpcType> supportedMethods;
+    private Boolean encrypted;
+    private int maxWrappedSize;
 
     public BitToUserHandshake()
     {
@@ -155,6 +157,32 @@ public final class BitToUserHandshake implements Externalizable, Message<BitToUs
         return this;
     }
 
+    // encrypted
+
+    public Boolean getEncrypted()
+    {
+        return encrypted;
+    }
+
+    public BitToUserHandshake setEncrypted(Boolean encrypted)
+    {
+        this.encrypted = encrypted;
+        return this;
+    }
+
+    // maxWrappedSize
+
+    public int getMaxWrappedSize()
+    {
+        return maxWrappedSize;
+    }
+
+    public BitToUserHandshake setMaxWrappedSize(int maxWrappedSize)
+    {
+        this.maxWrappedSize = maxWrappedSize;
+        return this;
+    }
+
     // java serialization
 
     public void readExternal(ObjectInput in) throws IOException
@@ -235,6 +263,12 @@ public final class BitToUserHandshake implements Externalizable, Message<BitToUs
                         message.supportedMethods = new ArrayList<RpcType>();
                     message.supportedMethods.add(RpcType.valueOf(input.readEnum()));
                     break;
+                case 9:
+                    message.encrypted = input.readBool();
+                    break;
+                case 10:
+                    message.maxWrappedSize = input.readInt32();
+                    break;
                 default:
                     input.handleUnknownField(number, this);
             }   
@@ -277,6 +311,12 @@ public final class BitToUserHandshake implements Externalizable, Message<BitToUs
                     output.writeEnum(8, supportedMethods.number, true);
             }
         }
+
+        if(message.encrypted != null)
+            output.writeBool(9, message.encrypted, false);
+
+        if(message.maxWrappedSize != 0)
+            output.writeInt32(10, message.maxWrappedSize, false);
     }
 
     public String getFieldName(int number)
@@ -290,6 +330,8 @@ public final class BitToUserHandshake implements Externalizable, Message<BitToUs
             case 6: return "serverInfos";
             case 7: return "authenticationMechanisms";
             case 8: return "supportedMethods";
+            case 9: return "encrypted";
+            case 10: return "maxWrappedSize";
             default: return null;
         }
     }
@@ -310,6 +352,8 @@ public final class BitToUserHandshake implements Externalizable, Message<BitToUs
         __fieldMap.put("serverInfos", 6);
         __fieldMap.put("authenticationMechanisms", 7);
         __fieldMap.put("supportedMethods", 8);
+        __fieldMap.put("encrypted", 9);
+        __fieldMap.put("maxWrappedSize", 10);
     }
     
 }

http://git-wip-us.apache.org/repos/asf/drill/blob/ce8bbc01/protocol/src/main/java/org/apache/drill/exec/proto/beans/SaslSupport.java
----------------------------------------------------------------------
diff --git a/protocol/src/main/java/org/apache/drill/exec/proto/beans/SaslSupport.java b/protocol/src/main/java/org/apache/drill/exec/proto/beans/SaslSupport.java
index 8a5aa73..8a668eb 100644
--- a/protocol/src/main/java/org/apache/drill/exec/proto/beans/SaslSupport.java
+++ b/protocol/src/main/java/org/apache/drill/exec/proto/beans/SaslSupport.java
@@ -23,7 +23,8 @@ package org.apache.drill.exec.proto.beans;
 public enum SaslSupport implements com.dyuproject.protostuff.EnumLite<SaslSupport>
 {
     UNKNOWN_SASL_SUPPORT(0),
-    SASL_AUTH(1);
+    SASL_AUTH(1),
+    SASL_PRIVACY(2);
     
     public final int number;
     
@@ -43,6 +44,7 @@ public enum SaslSupport implements com.dyuproject.protostuff.EnumLite<SaslSuppor
         {
             case 0: return UNKNOWN_SASL_SUPPORT;
             case 1: return SASL_AUTH;
+            case 2: return SASL_PRIVACY;
             default: return null;
         }
     }

http://git-wip-us.apache.org/repos/asf/drill/blob/ce8bbc01/protocol/src/main/protobuf/User.proto
----------------------------------------------------------------------
diff --git a/protocol/src/main/protobuf/User.proto b/protocol/src/main/protobuf/User.proto
index 4b722b3..2af8b26 100644
--- a/protocol/src/main/protobuf/User.proto
+++ b/protocol/src/main/protobuf/User.proto
@@ -70,6 +70,7 @@ message RpcEndpointInfos {
 enum SaslSupport {
   UNKNOWN_SASL_SUPPORT = 0;
   SASL_AUTH = 1;
+  SASL_PRIVACY = 2;
 }
 
 message UserToBitHandshake {
@@ -124,6 +125,8 @@ message BitToUserHandshake {
   optional RpcEndpointInfos server_infos = 6;
   repeated string authenticationMechanisms = 7;
   repeated RpcType supported_methods = 8;
+  optional bool encrypted = 9;
+  optional int32 maxWrappedSize = 10;
 }
 
 /*


Mime
View raw message