Regenerate connector protos

1 files changed, 666 insertions, 312 deletions

diff --git a/ydb/library/yql/providers/generic/connector/libgo/service/protos/connector.pb.go b/ydb/library/yql/providers/generic/connector/libgo/service/protos/connector.pb.go
index ff23d2be97..076b068f26 100644
--- a/ydb/library/yql/providers/generic/connector/libgo/service/protos/connector.pb.go
+++ b/ydb/library/yql/providers/generic/connector/libgo/service/protos/connector.pb.go
@@ -26,22 +26,22 @@ const (
 type EDateTimeFormat int32
 
 const (
-	EDateTimeFormat_RESERVED      EDateTimeFormat = 0
-	EDateTimeFormat_STRING_FORMAT EDateTimeFormat = 1
-	EDateTimeFormat_YQL_FORMAT    EDateTimeFormat = 2
+	EDateTimeFormat_DATE_TIME_FORMAT_UNSPECIFIED EDateTimeFormat = 0
+	EDateTimeFormat_STRING_FORMAT                EDateTimeFormat = 1
+	EDateTimeFormat_YQL_FORMAT                   EDateTimeFormat = 2
 )
 
 // Enum value maps for EDateTimeFormat.
 var (
 	EDateTimeFormat_name = map[int32]string{
-		0: "RESERVED",
+		0: "DATE_TIME_FORMAT_UNSPECIFIED",
 		1: "STRING_FORMAT",
 		2: "YQL_FORMAT",
 	}
 	EDateTimeFormat_value = map[string]int32{
-		"RESERVED":      0,
-		"STRING_FORMAT": 1,
-		"YQL_FORMAT":    2,
+		"DATE_TIME_FORMAT_UNSPECIFIED": 0,
+		"STRING_FORMAT":                1,
+		"YQL_FORMAT":                   2,
 	}
 )
 
@@ -75,7 +75,7 @@ func (EDateTimeFormat) EnumDescriptor() ([]byte, []int) {
 type TReadSplitsRequest_EMode int32
 
 const (
-	TReadSplitsRequest_MODE_RESERVED TReadSplitsRequest_EMode = 0
+	TReadSplitsRequest_MODE_UNSPECIFIED TReadSplitsRequest_EMode = 0
 	// Connector will read splits in a single thread one by one.
 	// The data will be returned in the order corresponding to the order of requested splits.
 	TReadSplitsRequest_ORDERED TReadSplitsRequest_EMode = 1
@@ -87,14 +87,14 @@ const (
 // Enum value maps for TReadSplitsRequest_EMode.
 var (
 	TReadSplitsRequest_EMode_name = map[int32]string{
-		0: "MODE_RESERVED",
+		0: "MODE_UNSPECIFIED",
 		1: "ORDERED",
 		2: "UNORDERED",
 	}
 	TReadSplitsRequest_EMode_value = map[string]int32{
-		"MODE_RESERVED": 0,
-		"ORDERED":       1,
-		"UNORDERED":     2,
+		"MODE_UNSPECIFIED": 0,
+		"ORDERED":          1,
+		"UNORDERED":        2,
 	}
 )
 
@@ -128,7 +128,7 @@ func (TReadSplitsRequest_EMode) EnumDescriptor() ([]byte, []int) {
 type TReadSplitsRequest_EFormat int32
 
 const (
-	TReadSplitsRequest_FORMAT_RESERVED TReadSplitsRequest_EFormat = 0
+	TReadSplitsRequest_FORMAT_UNSPECIFIED TReadSplitsRequest_EFormat = 0
 	// Arrow IPC Streaming format:
 	// https://arrow.apache.org/docs/format/Columnar.html#ipc-streaming-format
 	TReadSplitsRequest_ARROW_IPC_STREAMING TReadSplitsRequest_EFormat = 2
@@ -137,11 +137,11 @@ const (
 // Enum value maps for TReadSplitsRequest_EFormat.
 var (
 	TReadSplitsRequest_EFormat_name = map[int32]string{
-		0: "FORMAT_RESERVED",
+		0: "FORMAT_UNSPECIFIED",
 		2: "ARROW_IPC_STREAMING",
 	}
 	TReadSplitsRequest_EFormat_value = map[string]int32{
-		"FORMAT_RESERVED":     0,
+		"FORMAT_UNSPECIFIED":  0,
 		"ARROW_IPC_STREAMING": 2,
 	}
 )
@@ -174,22 +174,84 @@ func (TReadSplitsRequest_EFormat) EnumDescriptor() ([]byte, []int) {
 }
 
 // An operation code.
+type TExpression_TArithmeticalExpression_EOperation int32
+
+const (
+	TExpression_TArithmeticalExpression_EXPRESSION_OPERATION_UNSPECIFIED TExpression_TArithmeticalExpression_EOperation = 0
+	TExpression_TArithmeticalExpression_MUL                              TExpression_TArithmeticalExpression_EOperation = 1 // left_value * right_value
+	TExpression_TArithmeticalExpression_ADD                              TExpression_TArithmeticalExpression_EOperation = 2 // left_value + right_value
+	TExpression_TArithmeticalExpression_SUB                              TExpression_TArithmeticalExpression_EOperation = 3 // left_value - right_value
+	TExpression_TArithmeticalExpression_BIT_AND                          TExpression_TArithmeticalExpression_EOperation = 4 // left_value & right_value
+	TExpression_TArithmeticalExpression_BIT_OR                           TExpression_TArithmeticalExpression_EOperation = 5 // left_value | right_value
+	TExpression_TArithmeticalExpression_BIT_XOR                          TExpression_TArithmeticalExpression_EOperation = 6 // left_value ^ right_value
+)
+
+// Enum value maps for TExpression_TArithmeticalExpression_EOperation.
+var (
+	TExpression_TArithmeticalExpression_EOperation_name = map[int32]string{
+		0: "EXPRESSION_OPERATION_UNSPECIFIED",
+		1: "MUL",
+		2: "ADD",
+		3: "SUB",
+		4: "BIT_AND",
+		5: "BIT_OR",
+		6: "BIT_XOR",
+	}
+	TExpression_TArithmeticalExpression_EOperation_value = map[string]int32{
+		"EXPRESSION_OPERATION_UNSPECIFIED": 0,
+		"MUL":                              1,
+		"ADD":                              2,
+		"SUB":                              3,
+		"BIT_AND":                          4,
+		"BIT_OR":                           5,
+		"BIT_XOR":                          6,
+	}
+)
+
+func (x TExpression_TArithmeticalExpression_EOperation) Enum() *TExpression_TArithmeticalExpression_EOperation {
+	p := new(TExpression_TArithmeticalExpression_EOperation)
+	*p = x
+	return p
+}
+
+func (x TExpression_TArithmeticalExpression_EOperation) String() string {
+	return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
+}
+
+func (TExpression_TArithmeticalExpression_EOperation) Descriptor() protoreflect.EnumDescriptor {
+	return file_ydb_library_yql_providers_generic_connector_api_service_protos_connector_proto_enumTypes[3].Descriptor()
+}
+
+func (TExpression_TArithmeticalExpression_EOperation) Type() protoreflect.EnumType {
+	return &file_ydb_library_yql_providers_generic_connector_api_service_protos_connector_proto_enumTypes[3]
+}
+
+func (x TExpression_TArithmeticalExpression_EOperation) Number() protoreflect.EnumNumber {
+	return protoreflect.EnumNumber(x)
+}
+
+// Deprecated: Use TExpression_TArithmeticalExpression_EOperation.Descriptor instead.
+func (TExpression_TArithmeticalExpression_EOperation) EnumDescriptor() ([]byte, []int) {
+	return file_ydb_library_yql_providers_generic_connector_api_service_protos_connector_proto_rawDescGZIP(), []int{14, 0, 0}
+}
+
+// An operation code.
 type TPredicate_TComparison_EOperation int32
 
 const (
-	TPredicate_TComparison_RESERVED TPredicate_TComparison_EOperation = 0
-	TPredicate_TComparison_L        TPredicate_TComparison_EOperation = 1 // "$column < value"
-	TPredicate_TComparison_LE       TPredicate_TComparison_EOperation = 2 // "$column <= value"
-	TPredicate_TComparison_EQ       TPredicate_TComparison_EOperation = 3 // "$column = value"
-	TPredicate_TComparison_NE       TPredicate_TComparison_EOperation = 4 // "$column != value"
-	TPredicate_TComparison_GE       TPredicate_TComparison_EOperation = 5 // "$column >= value"
-	TPredicate_TComparison_G        TPredicate_TComparison_EOperation = 6 // "$column > value"
+	TPredicate_TComparison_COMPARISON_OPERATION_UNSPECIFIED TPredicate_TComparison_EOperation = 0
+	TPredicate_TComparison_L                                TPredicate_TComparison_EOperation = 1 // "$column < value"
+	TPredicate_TComparison_LE                               TPredicate_TComparison_EOperation = 2 // "$column <= value"
+	TPredicate_TComparison_EQ                               TPredicate_TComparison_EOperation = 3 // "$column = value"
+	TPredicate_TComparison_NE                               TPredicate_TComparison_EOperation = 4 // "$column != value"
+	TPredicate_TComparison_GE                               TPredicate_TComparison_EOperation = 5 // "$column >= value"
+	TPredicate_TComparison_G                                TPredicate_TComparison_EOperation = 6 // "$column > value"
 )
 
 // Enum value maps for TPredicate_TComparison_EOperation.
 var (
 	TPredicate_TComparison_EOperation_name = map[int32]string{
-		0: "RESERVED",
+		0: "COMPARISON_OPERATION_UNSPECIFIED",
 		1: "L",
 		2: "LE",
 		3: "EQ",
@@ -198,13 +260,13 @@ var (
 		6: "G",
 	}
 	TPredicate_TComparison_EOperation_value = map[string]int32{
-		"RESERVED": 0,
-		"L":        1,
-		"LE":       2,
-		"EQ":       3,
-		"NE":       4,
-		"GE":       5,
-		"G":        6,
+		"COMPARISON_OPERATION_UNSPECIFIED": 0,
+		"L":                                1,
+		"LE":                               2,
+		"EQ":                               3,
+		"NE":                               4,
+		"GE":                               5,
+		"G":                                6,
 	}
 )
 
@@ -219,11 +281,11 @@ func (x TPredicate_TComparison_EOperation) String() string {
 }
 
 func (TPredicate_TComparison_EOperation) Descriptor() protoreflect.EnumDescriptor {
-	return file_ydb_library_yql_providers_generic_connector_api_service_protos_connector_proto_enumTypes[3].Descriptor()
+	return file_ydb_library_yql_providers_generic_connector_api_service_protos_connector_proto_enumTypes[4].Descriptor()
 }
 
 func (TPredicate_TComparison_EOperation) Type() protoreflect.EnumType {
-	return &file_ydb_library_yql_providers_generic_connector_api_service_protos_connector_proto_enumTypes[3]
+	return &file_ydb_library_yql_providers_generic_connector_api_service_protos_connector_proto_enumTypes[4]
 }
 
 func (x TPredicate_TComparison_EOperation) Number() protoreflect.EnumNumber {
@@ -232,7 +294,7 @@ func (x TPredicate_TComparison_EOperation) Number() protoreflect.EnumNumber {
 
 // Deprecated: Use TPredicate_TComparison_EOperation.Descriptor instead.
 func (TPredicate_TComparison_EOperation) EnumDescriptor() ([]byte, []int) {
-	return file_ydb_library_yql_providers_generic_connector_api_service_protos_connector_proto_rawDescGZIP(), []int{15, 7, 0}
+	return file_ydb_library_yql_providers_generic_connector_api_service_protos_connector_proto_rawDescGZIP(), []int{15, 8, 0}
 }
 
 // TListTablesRequest requests the list of tables in a particular database of the data source
@@ -486,7 +548,7 @@ func (x *TTypeMappingSettings) GetDateTimeFormat() EDateTimeFormat {
 	if x != nil {
 		return x.DateTimeFormat
 	}
-	return EDateTimeFormat_RESERVED
+	return EDateTimeFormat_DATE_TIME_FORMAT_UNSPECIFIED
 }
 
 // TDescribeTableResponse returns table metadata
@@ -988,14 +1050,14 @@ func (x *TReadSplitsRequest) GetMode() TReadSplitsRequest_EMode {
 	if x != nil {
 		return x.Mode
 	}
-	return TReadSplitsRequest_MODE_RESERVED
+	return TReadSplitsRequest_MODE_UNSPECIFIED
 }
 
 func (x *TReadSplitsRequest) GetFormat() TReadSplitsRequest_EFormat {
 	if x != nil {
 		return x.Format
 	}
-	return TReadSplitsRequest_FORMAT_RESERVED
+	return TReadSplitsRequest_FORMAT_UNSPECIFIED
 }
 
 func (x *TReadSplitsRequest) GetPagination() *TPagination {
@@ -1297,6 +1359,8 @@ type TExpression struct {
 	//
 	//	*TExpression_TypedValue
 	//	*TExpression_Column
+	//	*TExpression_ArithmeticalExpression
+	//	*TExpression_Null
 	Payload isTExpression_Payload `protobuf_oneof:"payload"`
 }
 
@@ -1353,6 +1417,20 @@ func (x *TExpression) GetColumn() string {
 	return ""
 }
 
+func (x *TExpression) GetArithmeticalExpression() *TExpression_TArithmeticalExpression {
+	if x, ok := x.GetPayload().(*TExpression_ArithmeticalExpression); ok {
+		return x.ArithmeticalExpression
+	}
+	return nil
+}
+
+func (x *TExpression) GetNull() *TExpression_TNull {
+	if x, ok := x.GetPayload().(*TExpression_Null); ok {
+		return x.Null
+	}
+	return nil
+}
+
 type isTExpression_Payload interface {
 	isTExpression_Payload()
 }
@@ -1367,10 +1445,22 @@ type TExpression_Column struct {
 	Column string `protobuf:"bytes,2,opt,name=column,proto3,oneof"`
 }
 
+type TExpression_ArithmeticalExpression struct {
+	ArithmeticalExpression *TExpression_TArithmeticalExpression `protobuf:"bytes,3,opt,name=arithmetical_expression,json=arithmeticalExpression,proto3,oneof"`
+}
+
+type TExpression_Null struct {
+	Null *TExpression_TNull `protobuf:"bytes,4,opt,name=null,proto3,oneof"`
+}
+
 func (*TExpression_TypedValue) isTExpression_Payload() {}
 
 func (*TExpression_Column) isTExpression_Payload() {}
 
+func (*TExpression_ArithmeticalExpression) isTExpression_Payload() {}
+
+func (*TExpression_Null) isTExpression_Payload() {}
+
 // Predicate
 type TPredicate struct {
 	state         protoimpl.MessageState
@@ -1387,6 +1477,7 @@ type TPredicate struct {
 	//	*TPredicate_IsNull
 	//	*TPredicate_IsNotNull
 	//	*TPredicate_Comparison
+	//	*TPredicate_BoolExpression
 	Payload isTPredicate_Payload `protobuf_oneof:"payload"`
 }
 
@@ -1485,6 +1576,13 @@ func (x *TPredicate) GetComparison() *TPredicate_TComparison {
 	return nil
 }
 
+func (x *TPredicate) GetBoolExpression() *TPredicate_TBoolExpression {
+	if x, ok := x.GetPayload().(*TPredicate_BoolExpression); ok {
+		return x.BoolExpression
+	}
+	return nil
+}
+
 type isTPredicate_Payload interface {
 	isTPredicate_Payload()
 }
@@ -1521,6 +1619,10 @@ type TPredicate_Comparison struct {
 	Comparison *TPredicate_TComparison `protobuf:"bytes,8,opt,name=comparison,proto3,oneof"`
 }
 
+type TPredicate_BoolExpression struct {
+	BoolExpression *TPredicate_TBoolExpression `protobuf:"bytes,9,opt,name=bool_expression,json=boolExpression,proto3,oneof"`
+}
+
 func (*TPredicate_Negation) isTPredicate_Payload() {}
 
 func (*TPredicate_Conjunction) isTPredicate_Payload() {}
@@ -1537,6 +1639,8 @@ func (*TPredicate_IsNotNull) isTPredicate_Payload() {}
 
 func (*TPredicate_Comparison) isTPredicate_Payload() {}
 
+func (*TPredicate_BoolExpression) isTPredicate_Payload() {}
+
 // Special type to describe the result of any operation
 type TError struct {
 	state         protoimpl.MessageState
@@ -2077,6 +2181,107 @@ func (x *TReadSplitsResponse_TColumnSet_TColumn) GetData() []*Ydb.Value {
 	return nil
 }
 
+type TExpression_TArithmeticalExpression struct {
+	state         protoimpl.MessageState
+	sizeCache     protoimpl.SizeCache
+	unknownFields protoimpl.UnknownFields
+
+	Operation  TExpression_TArithmeticalExpression_EOperation `protobuf:"varint,1,opt,name=operation,proto3,enum=NYql.NConnector.NApi.TExpression_TArithmeticalExpression_EOperation" json:"operation,omitempty"`
+	LeftValue  *TExpression                                   `protobuf:"bytes,2,opt,name=left_value,json=leftValue,proto3" json:"left_value,omitempty"`
+	RightValue *TExpression                                   `protobuf:"bytes,3,opt,name=right_value,json=rightValue,proto3" json:"right_value,omitempty"`
+}
+
+func (x *TExpression_TArithmeticalExpression) Reset() {
+	*x = TExpression_TArithmeticalExpression{}
+	if protoimpl.UnsafeEnabled {
+		mi := &file_ydb_library_yql_providers_generic_connector_api_service_protos_connector_proto_msgTypes[25]
+		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+		ms.StoreMessageInfo(mi)
+	}
+}
+
+func (x *TExpression_TArithmeticalExpression) String() string {
+	return protoimpl.X.MessageStringOf(x)
+}
+
+func (*TExpression_TArithmeticalExpression) ProtoMessage() {}
+
+func (x *TExpression_TArithmeticalExpression) ProtoReflect() protoreflect.Message {
+	mi := &file_ydb_library_yql_providers_generic_connector_api_service_protos_connector_proto_msgTypes[25]
+	if protoimpl.UnsafeEnabled && x != nil {
+		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+		if ms.LoadMessageInfo() == nil {
+			ms.StoreMessageInfo(mi)
+		}
+		return ms
+	}
+	return mi.MessageOf(x)
+}
+
+// Deprecated: Use TExpression_TArithmeticalExpression.ProtoReflect.Descriptor instead.
+func (*TExpression_TArithmeticalExpression) Descriptor() ([]byte, []int) {
+	return file_ydb_library_yql_providers_generic_connector_api_service_protos_connector_proto_rawDescGZIP(), []int{14, 0}
+}
+
+func (x *TExpression_TArithmeticalExpression) GetOperation() TExpression_TArithmeticalExpression_EOperation {
+	if x != nil {
+		return x.Operation
+	}
+	return TExpression_TArithmeticalExpression_EXPRESSION_OPERATION_UNSPECIFIED
+}
+
+func (x *TExpression_TArithmeticalExpression) GetLeftValue() *TExpression {
+	if x != nil {
+		return x.LeftValue
+	}
+	return nil
+}
+
+func (x *TExpression_TArithmeticalExpression) GetRightValue() *TExpression {
+	if x != nil {
+		return x.RightValue
+	}
+	return nil
+}
+
+type TExpression_TNull struct {
+	state         protoimpl.MessageState
+	sizeCache     protoimpl.SizeCache
+	unknownFields protoimpl.UnknownFields
+}
+
+func (x *TExpression_TNull) Reset() {
+	*x = TExpression_TNull{}
+	if protoimpl.UnsafeEnabled {
+		mi := &file_ydb_library_yql_providers_generic_connector_api_service_protos_connector_proto_msgTypes[26]
+		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+		ms.StoreMessageInfo(mi)
+	}
+}
+
+func (x *TExpression_TNull) String() string {
+	return protoimpl.X.MessageStringOf(x)
+}
+
+func (*TExpression_TNull) ProtoMessage() {}
+
+func (x *TExpression_TNull) ProtoReflect() protoreflect.Message {
+	mi := &file_ydb_library_yql_providers_generic_connector_api_service_protos_connector_proto_msgTypes[26]
+	if protoimpl.UnsafeEnabled && x != nil {
+		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+		if ms.LoadMessageInfo() == nil {
+			ms.StoreMessageInfo(mi)
+		}
+		return ms
+	}
+	return mi.MessageOf(x)
+}
+
+// Deprecated: Use TExpression_TNull.ProtoReflect.Descriptor instead.
+func (*TExpression_TNull) Descriptor() ([]byte, []int) {
+	return file_ydb_library_yql_providers_generic_connector_api_service_protos_connector_proto_rawDescGZIP(), []int{14, 1}
+}
+
 // NOT
 type TPredicate_TNegation struct {
 	state         protoimpl.MessageState
@@ -2089,7 +2294,7 @@ type TPredicate_TNegation struct {
 func (x *TPredicate_TNegation) Reset() {
 	*x = TPredicate_TNegation{}
 	if protoimpl.UnsafeEnabled {
-		mi := &file_ydb_library_yql_providers_generic_connector_api_service_protos_connector_proto_msgTypes[25]
+		mi := &file_ydb_library_yql_providers_generic_connector_api_service_protos_connector_proto_msgTypes[27]
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		ms.StoreMessageInfo(mi)
 	}
@@ -2102,7 +2307,7 @@ func (x *TPredicate_TNegation) String() string {
 func (*TPredicate_TNegation) ProtoMessage() {}
 
 func (x *TPredicate_TNegation) ProtoReflect() protoreflect.Message {
-	mi := &file_ydb_library_yql_providers_generic_connector_api_service_protos_connector_proto_msgTypes[25]
+	mi := &file_ydb_library_yql_providers_generic_connector_api_service_protos_connector_proto_msgTypes[27]
 	if protoimpl.UnsafeEnabled && x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -2137,7 +2342,7 @@ type TPredicate_TConjunction struct {
 func (x *TPredicate_TConjunction) Reset() {
 	*x = TPredicate_TConjunction{}
 	if protoimpl.UnsafeEnabled {
-		mi := &file_ydb_library_yql_providers_generic_connector_api_service_protos_connector_proto_msgTypes[26]
+		mi := &file_ydb_library_yql_providers_generic_connector_api_service_protos_connector_proto_msgTypes[28]
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		ms.StoreMessageInfo(mi)
 	}
@@ -2150,7 +2355,7 @@ func (x *TPredicate_TConjunction) String() string {
 func (*TPredicate_TConjunction) ProtoMessage() {}
 
 func (x *TPredicate_TConjunction) ProtoReflect() protoreflect.Message {
-	mi := &file_ydb_library_yql_providers_generic_connector_api_service_protos_connector_proto_msgTypes[26]
+	mi := &file_ydb_library_yql_providers_generic_connector_api_service_protos_connector_proto_msgTypes[28]
 	if protoimpl.UnsafeEnabled && x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -2185,7 +2390,7 @@ type TPredicate_TDisjunction struct {
 func (x *TPredicate_TDisjunction) Reset() {
 	*x = TPredicate_TDisjunction{}
 	if protoimpl.UnsafeEnabled {
-		mi := &file_ydb_library_yql_providers_generic_connector_api_service_protos_connector_proto_msgTypes[27]
+		mi := &file_ydb_library_yql_providers_generic_connector_api_service_protos_connector_proto_msgTypes[29]
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		ms.StoreMessageInfo(mi)
 	}
@@ -2198,7 +2403,7 @@ func (x *TPredicate_TDisjunction) String() string {
 func (*TPredicate_TDisjunction) ProtoMessage() {}
 
 func (x *TPredicate_TDisjunction) ProtoReflect() protoreflect.Message {
-	mi := &file_ydb_library_yql_providers_generic_connector_api_service_protos_connector_proto_msgTypes[27]
+	mi := &file_ydb_library_yql_providers_generic_connector_api_service_protos_connector_proto_msgTypes[29]
 	if protoimpl.UnsafeEnabled && x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -2235,7 +2440,7 @@ type TPredicate_TBetween struct {
 func (x *TPredicate_TBetween) Reset() {
 	*x = TPredicate_TBetween{}
 	if protoimpl.UnsafeEnabled {
-		mi := &file_ydb_library_yql_providers_generic_connector_api_service_protos_connector_proto_msgTypes[28]
+		mi := &file_ydb_library_yql_providers_generic_connector_api_service_protos_connector_proto_msgTypes[30]
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		ms.StoreMessageInfo(mi)
 	}
@@ -2248,7 +2453,7 @@ func (x *TPredicate_TBetween) String() string {
 func (*TPredicate_TBetween) ProtoMessage() {}
 
 func (x *TPredicate_TBetween) ProtoReflect() protoreflect.Message {
-	mi := &file_ydb_library_yql_providers_generic_connector_api_service_protos_connector_proto_msgTypes[28]
+	mi := &file_ydb_library_yql_providers_generic_connector_api_service_protos_connector_proto_msgTypes[30]
 	if protoimpl.UnsafeEnabled && x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -2298,7 +2503,7 @@ type TPredicate_TIn struct {
 func (x *TPredicate_TIn) Reset() {
 	*x = TPredicate_TIn{}
 	if protoimpl.UnsafeEnabled {
-		mi := &file_ydb_library_yql_providers_generic_connector_api_service_protos_connector_proto_msgTypes[29]
+		mi := &file_ydb_library_yql_providers_generic_connector_api_service_protos_connector_proto_msgTypes[31]
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		ms.StoreMessageInfo(mi)
 	}
@@ -2311,7 +2516,7 @@ func (x *TPredicate_TIn) String() string {
 func (*TPredicate_TIn) ProtoMessage() {}
 
 func (x *TPredicate_TIn) ProtoReflect() protoreflect.Message {
-	mi := &file_ydb_library_yql_providers_generic_connector_api_service_protos_connector_proto_msgTypes[29]
+	mi := &file_ydb_library_yql_providers_generic_connector_api_service_protos_connector_proto_msgTypes[31]
 	if protoimpl.UnsafeEnabled && x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -2353,7 +2558,7 @@ type TPredicate_TIsNull struct {
 func (x *TPredicate_TIsNull) Reset() {
 	*x = TPredicate_TIsNull{}
 	if protoimpl.UnsafeEnabled {
-		mi := &file_ydb_library_yql_providers_generic_connector_api_service_protos_connector_proto_msgTypes[30]
+		mi := &file_ydb_library_yql_providers_generic_connector_api_service_protos_connector_proto_msgTypes[32]
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		ms.StoreMessageInfo(mi)
 	}
@@ -2366,7 +2571,7 @@ func (x *TPredicate_TIsNull) String() string {
 func (*TPredicate_TIsNull) ProtoMessage() {}
 
 func (x *TPredicate_TIsNull) ProtoReflect() protoreflect.Message {
-	mi := &file_ydb_library_yql_providers_generic_connector_api_service_protos_connector_proto_msgTypes[30]
+	mi := &file_ydb_library_yql_providers_generic_connector_api_service_protos_connector_proto_msgTypes[32]
 	if protoimpl.UnsafeEnabled && x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -2402,7 +2607,7 @@ type TPredicate_TIsNotNull struct {
 func (x *TPredicate_TIsNotNull) Reset() {
 	*x = TPredicate_TIsNotNull{}
 	if protoimpl.UnsafeEnabled {
-		mi := &file_ydb_library_yql_providers_generic_connector_api_service_protos_connector_proto_msgTypes[31]
+		mi := &file_ydb_library_yql_providers_generic_connector_api_service_protos_connector_proto_msgTypes[33]
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		ms.StoreMessageInfo(mi)
 	}
@@ -2415,7 +2620,7 @@ func (x *TPredicate_TIsNotNull) String() string {
 func (*TPredicate_TIsNotNull) ProtoMessage() {}
 
 func (x *TPredicate_TIsNotNull) ProtoReflect() protoreflect.Message {
-	mi := &file_ydb_library_yql_providers_generic_connector_api_service_protos_connector_proto_msgTypes[31]
+	mi := &file_ydb_library_yql_providers_generic_connector_api_service_protos_connector_proto_msgTypes[33]
 	if protoimpl.UnsafeEnabled && x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -2438,6 +2643,55 @@ func (x *TPredicate_TIsNotNull) GetValue() *TExpression {
 	return nil
 }
 
+// Expression wich has bool type
+// For example, bool column
+type TPredicate_TBoolExpression struct {
+	state         protoimpl.MessageState
+	sizeCache     protoimpl.SizeCache
+	unknownFields protoimpl.UnknownFields
+
+	Value *TExpression `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
+}
+
+func (x *TPredicate_TBoolExpression) Reset() {
+	*x = TPredicate_TBoolExpression{}
+	if protoimpl.UnsafeEnabled {
+		mi := &file_ydb_library_yql_providers_generic_connector_api_service_protos_connector_proto_msgTypes[34]
+		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+		ms.StoreMessageInfo(mi)
+	}
+}
+
+func (x *TPredicate_TBoolExpression) String() string {
+	return protoimpl.X.MessageStringOf(x)
+}
+
+func (*TPredicate_TBoolExpression) ProtoMessage() {}
+
+func (x *TPredicate_TBoolExpression) ProtoReflect() protoreflect.Message {
+	mi := &file_ydb_library_yql_providers_generic_connector_api_service_protos_connector_proto_msgTypes[34]
+	if protoimpl.UnsafeEnabled && x != nil {
+		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+		if ms.LoadMessageInfo() == nil {
+			ms.StoreMessageInfo(mi)
+		}
+		return ms
+	}
+	return mi.MessageOf(x)
+}
+
+// Deprecated: Use TPredicate_TBoolExpression.ProtoReflect.Descriptor instead.
+func (*TPredicate_TBoolExpression) Descriptor() ([]byte, []int) {
+	return file_ydb_library_yql_providers_generic_connector_api_service_protos_connector_proto_rawDescGZIP(), []int{15, 7}
+}
+
+func (x *TPredicate_TBoolExpression) GetValue() *TExpression {
+	if x != nil {
+		return x.Value
+	}
+	return nil
+}
+
 // A subset of comparators corresponding to the binary logical operators
 type TPredicate_TComparison struct {
 	state         protoimpl.MessageState
@@ -2452,7 +2706,7 @@ type TPredicate_TComparison struct {
 func (x *TPredicate_TComparison) Reset() {
 	*x = TPredicate_TComparison{}
 	if protoimpl.UnsafeEnabled {
-		mi := &file_ydb_library_yql_providers_generic_connector_api_service_protos_connector_proto_msgTypes[32]
+		mi := &file_ydb_library_yql_providers_generic_connector_api_service_protos_connector_proto_msgTypes[35]
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		ms.StoreMessageInfo(mi)
 	}
@@ -2465,7 +2719,7 @@ func (x *TPredicate_TComparison) String() string {
 func (*TPredicate_TComparison) ProtoMessage() {}
 
 func (x *TPredicate_TComparison) ProtoReflect() protoreflect.Message {
-	mi := &file_ydb_library_yql_providers_generic_connector_api_service_protos_connector_proto_msgTypes[32]
+	mi := &file_ydb_library_yql_providers_generic_connector_api_service_protos_connector_proto_msgTypes[35]
 	if protoimpl.UnsafeEnabled && x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -2478,14 +2732,14 @@ func (x *TPredicate_TComparison) ProtoReflect() protoreflect.Message {
 
 // Deprecated: Use TPredicate_TComparison.ProtoReflect.Descriptor instead.
 func (*TPredicate_TComparison) Descriptor() ([]byte, []int) {
-	return file_ydb_library_yql_providers_generic_connector_api_service_protos_connector_proto_rawDescGZIP(), []int{15, 7}
+	return file_ydb_library_yql_providers_generic_connector_api_service_protos_connector_proto_rawDescGZIP(), []int{15, 8}
 }
 
 func (x *TPredicate_TComparison) GetOperation() TPredicate_TComparison_EOperation {
 	if x != nil {
 		return x.Operation
 	}
-	return TPredicate_TComparison_RESERVED
+	return TPredicate_TComparison_COMPARISON_OPERATION_UNSPECIFIED
 }
 
 func (x *TPredicate_TComparison) GetLeftValue() *TExpression {
@@ -2513,7 +2767,7 @@ type TAst_TList struct {
 func (x *TAst_TList) Reset() {
 	*x = TAst_TList{}
 	if protoimpl.UnsafeEnabled {
-		mi := &file_ydb_library_yql_providers_generic_connector_api_service_protos_connector_proto_msgTypes[33]
+		mi := &file_ydb_library_yql_providers_generic_connector_api_service_protos_connector_proto_msgTypes[36]
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		ms.StoreMessageInfo(mi)
 	}
@@ -2526,7 +2780,7 @@ func (x *TAst_TList) String() string {
 func (*TAst_TList) ProtoMessage() {}
 
 func (x *TAst_TList) ProtoReflect() protoreflect.Message {
-	mi := &file_ydb_library_yql_providers_generic_connector_api_service_protos_connector_proto_msgTypes[33]
+	mi := &file_ydb_library_yql_providers_generic_connector_api_service_protos_connector_proto_msgTypes[36]
 	if protoimpl.UnsafeEnabled && x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -2691,7 +2945,7 @@ var file_ydb_library_yql_providers_generic_connector_api_service_protos_connecto
 	0x63, 0x74, 0x52, 0x06, 0x73, 0x65, 0x6c, 0x65, 0x63, 0x74, 0x12, 0x22, 0x0a, 0x0b, 0x64, 0x65,
 	0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0c, 0x48,
 	0x00, 0x52, 0x0b, 0x64, 0x65, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x42, 0x09,
-	0x0a, 0x07, 0x70, 0x61, 0x79, 0x6c, 0x6f, 0x61, 0x64, 0x22, 0xb8, 0x04, 0x0a, 0x12, 0x54, 0x52,
+	0x0a, 0x07, 0x70, 0x61, 0x79, 0x6c, 0x6f, 0x61, 0x64, 0x22, 0xbe, 0x04, 0x0a, 0x12, 0x54, 0x52,
 	0x65, 0x61, 0x64, 0x53, 0x70, 0x6c, 0x69, 0x74, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74,
 	0x12, 0x5b, 0x0a, 0x14, 0x64, 0x61, 0x74, 0x61, 0x5f, 0x73, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x5f,
 	0x69, 0x6e, 0x73, 0x74, 0x61, 0x6e, 0x63, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x29,
@@ -2719,61 +2973,97 @@ var file_ydb_library_yql_providers_generic_connector_api_service_protos_connecto
 	0x74, 0x69, 0x6f, 0x6e, 0x18, 0x06, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x23, 0x2e, 0x4e, 0x59, 0x71,
 	0x6c, 0x2e, 0x4e, 0x43, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x6f, 0x72, 0x2e, 0x4e, 0x41, 0x70,
 	0x69, 0x2e, 0x54, 0x43, 0x6f, 0x6e, 0x74, 0x69, 0x6e, 0x75, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x52,
-	0x0c, 0x63, 0x6f, 0x6e, 0x74, 0x69, 0x6e, 0x75, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x22, 0x36, 0x0a,
-	0x05, 0x45, 0x4d, 0x6f, 0x64, 0x65, 0x12, 0x11, 0x0a, 0x0d, 0x4d, 0x4f, 0x44, 0x45, 0x5f, 0x52,
-	0x45, 0x53, 0x45, 0x52, 0x56, 0x45, 0x44, 0x10, 0x00, 0x12, 0x0b, 0x0a, 0x07, 0x4f, 0x52, 0x44,
-	0x45, 0x52, 0x45, 0x44, 0x10, 0x01, 0x12, 0x0d, 0x0a, 0x09, 0x55, 0x4e, 0x4f, 0x52, 0x44, 0x45,
-	0x52, 0x45, 0x44, 0x10, 0x02, 0x22, 0x3d, 0x0a, 0x07, 0x45, 0x46, 0x6f, 0x72, 0x6d, 0x61, 0x74,
-	0x12, 0x13, 0x0a, 0x0f, 0x46, 0x4f, 0x52, 0x4d, 0x41, 0x54, 0x5f, 0x52, 0x45, 0x53, 0x45, 0x52,
-	0x56, 0x45, 0x44, 0x10, 0x00, 0x12, 0x17, 0x0a, 0x13, 0x41, 0x52, 0x52, 0x4f, 0x57, 0x5f, 0x49,
-	0x50, 0x43, 0x5f, 0x53, 0x54, 0x52, 0x45, 0x41, 0x4d, 0x49, 0x4e, 0x47, 0x10, 0x02, 0x22, 0x04,
-	0x08, 0x01, 0x10, 0x01, 0x22, 0x81, 0x04, 0x0a, 0x13, 0x54, 0x52, 0x65, 0x61, 0x64, 0x53, 0x70,
-	0x6c, 0x69, 0x74, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x55, 0x0a, 0x0a,
-	0x63, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x5f, 0x73, 0x65, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b,
-	0x32, 0x34, 0x2e, 0x4e, 0x59, 0x71, 0x6c, 0x2e, 0x4e, 0x43, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74,
-	0x6f, 0x72, 0x2e, 0x4e, 0x41, 0x70, 0x69, 0x2e, 0x54, 0x52, 0x65, 0x61, 0x64, 0x53, 0x70, 0x6c,
-	0x69, 0x74, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x2e, 0x54, 0x43, 0x6f, 0x6c,
-	0x75, 0x6d, 0x6e, 0x53, 0x65, 0x74, 0x48, 0x00, 0x52, 0x09, 0x63, 0x6f, 0x6c, 0x75, 0x6d, 0x6e,
-	0x53, 0x65, 0x74, 0x12, 0x30, 0x0a, 0x13, 0x61, 0x72, 0x72, 0x6f, 0x77, 0x5f, 0x69, 0x70, 0x63,
-	0x5f, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x69, 0x6e, 0x67, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0c,
-	0x48, 0x00, 0x52, 0x11, 0x61, 0x72, 0x72, 0x6f, 0x77, 0x49, 0x70, 0x63, 0x53, 0x74, 0x72, 0x65,
-	0x61, 0x6d, 0x69, 0x6e, 0x67, 0x12, 0x2c, 0x0a, 0x12, 0x73, 0x70, 0x6c, 0x69, 0x74, 0x5f, 0x69,
-	0x6e, 0x64, 0x65, 0x78, 0x5f, 0x6e, 0x75, 0x6d, 0x62, 0x65, 0x72, 0x18, 0x03, 0x20, 0x01, 0x28,
-	0x0d, 0x52, 0x10, 0x73, 0x70, 0x6c, 0x69, 0x74, 0x49, 0x6e, 0x64, 0x65, 0x78, 0x4e, 0x75, 0x6d,
-	0x62, 0x65, 0x72, 0x12, 0x47, 0x0a, 0x0c, 0x63, 0x6f, 0x6e, 0x74, 0x69, 0x6e, 0x75, 0x61, 0x74,
-	0x69, 0x6f, 0x6e, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x23, 0x2e, 0x4e, 0x59, 0x71, 0x6c,
+	0x0c, 0x63, 0x6f, 0x6e, 0x74, 0x69, 0x6e, 0x75, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x22, 0x39, 0x0a,
+	0x05, 0x45, 0x4d, 0x6f, 0x64, 0x65, 0x12, 0x14, 0x0a, 0x10, 0x4d, 0x4f, 0x44, 0x45, 0x5f, 0x55,
+	0x4e, 0x53, 0x50, 0x45, 0x43, 0x49, 0x46, 0x49, 0x45, 0x44, 0x10, 0x00, 0x12, 0x0b, 0x0a, 0x07,
+	0x4f, 0x52, 0x44, 0x45, 0x52, 0x45, 0x44, 0x10, 0x01, 0x12, 0x0d, 0x0a, 0x09, 0x55, 0x4e, 0x4f,
+	0x52, 0x44, 0x45, 0x52, 0x45, 0x44, 0x10, 0x02, 0x22, 0x40, 0x0a, 0x07, 0x45, 0x46, 0x6f, 0x72,
+	0x6d, 0x61, 0x74, 0x12, 0x16, 0x0a, 0x12, 0x46, 0x4f, 0x52, 0x4d, 0x41, 0x54, 0x5f, 0x55, 0x4e,
+	0x53, 0x50, 0x45, 0x43, 0x49, 0x46, 0x49, 0x45, 0x44, 0x10, 0x00, 0x12, 0x17, 0x0a, 0x13, 0x41,
+	0x52, 0x52, 0x4f, 0x57, 0x5f, 0x49, 0x50, 0x43, 0x5f, 0x53, 0x54, 0x52, 0x45, 0x41, 0x4d, 0x49,
+	0x4e, 0x47, 0x10, 0x02, 0x22, 0x04, 0x08, 0x01, 0x10, 0x01, 0x22, 0x81, 0x04, 0x0a, 0x13, 0x54,
+	0x52, 0x65, 0x61, 0x64, 0x53, 0x70, 0x6c, 0x69, 0x74, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e,
+	0x73, 0x65, 0x12, 0x55, 0x0a, 0x0a, 0x63, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x5f, 0x73, 0x65, 0x74,
+	0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x34, 0x2e, 0x4e, 0x59, 0x71, 0x6c, 0x2e, 0x4e, 0x43,
+	0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x6f, 0x72, 0x2e, 0x4e, 0x41, 0x70, 0x69, 0x2e, 0x54, 0x52,
+	0x65, 0x61, 0x64, 0x53, 0x70, 0x6c, 0x69, 0x74, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73,
+	0x65, 0x2e, 0x54, 0x43, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x53, 0x65, 0x74, 0x48, 0x00, 0x52, 0x09,
+	0x63, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x53, 0x65, 0x74, 0x12, 0x30, 0x0a, 0x13, 0x61, 0x72, 0x72,
+	0x6f, 0x77, 0x5f, 0x69, 0x70, 0x63, 0x5f, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x69, 0x6e, 0x67,
+	0x18, 0x02, 0x20, 0x01, 0x28, 0x0c, 0x48, 0x00, 0x52, 0x11, 0x61, 0x72, 0x72, 0x6f, 0x77, 0x49,
+	0x70, 0x63, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x69, 0x6e, 0x67, 0x12, 0x2c, 0x0a, 0x12, 0x73,
+	0x70, 0x6c, 0x69, 0x74, 0x5f, 0x69, 0x6e, 0x64, 0x65, 0x78, 0x5f, 0x6e, 0x75, 0x6d, 0x62, 0x65,
+	0x72, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x10, 0x73, 0x70, 0x6c, 0x69, 0x74, 0x49, 0x6e,
+	0x64, 0x65, 0x78, 0x4e, 0x75, 0x6d, 0x62, 0x65, 0x72, 0x12, 0x47, 0x0a, 0x0c, 0x63, 0x6f, 0x6e,
+	0x74, 0x69, 0x6e, 0x75, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0b, 0x32,
+	0x23, 0x2e, 0x4e, 0x59, 0x71, 0x6c, 0x2e, 0x4e, 0x43, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x6f,
+	0x72, 0x2e, 0x4e, 0x41, 0x70, 0x69, 0x2e, 0x54, 0x43, 0x6f, 0x6e, 0x74, 0x69, 0x6e, 0x75, 0x61,
+	0x74, 0x69, 0x6f, 0x6e, 0x52, 0x0c, 0x63, 0x6f, 0x6e, 0x74, 0x69, 0x6e, 0x75, 0x61, 0x74, 0x69,
+	0x6f, 0x6e, 0x12, 0x32, 0x0a, 0x05, 0x65, 0x72, 0x72, 0x6f, 0x72, 0x18, 0x64, 0x20, 0x01, 0x28,
+	0x0b, 0x32, 0x1c, 0x2e, 0x4e, 0x59, 0x71, 0x6c, 0x2e, 0x4e, 0x43, 0x6f, 0x6e, 0x6e, 0x65, 0x63,
+	0x74, 0x6f, 0x72, 0x2e, 0x4e, 0x41, 0x70, 0x69, 0x2e, 0x54, 0x45, 0x72, 0x72, 0x6f, 0x72, 0x52,
+	0x05, 0x65, 0x72, 0x72, 0x6f, 0x72, 0x1a, 0xaa, 0x01, 0x0a, 0x0a, 0x54, 0x43, 0x6f, 0x6c, 0x75,
+	0x6d, 0x6e, 0x53, 0x65, 0x74, 0x12, 0x1f, 0x0a, 0x04, 0x6d, 0x65, 0x74, 0x61, 0x18, 0x01, 0x20,
+	0x03, 0x28, 0x0b, 0x32, 0x0b, 0x2e, 0x59, 0x64, 0x62, 0x2e, 0x43, 0x6f, 0x6c, 0x75, 0x6d, 0x6e,
+	0x52, 0x04, 0x6d, 0x65, 0x74, 0x61, 0x12, 0x50, 0x0a, 0x04, 0x64, 0x61, 0x74, 0x61, 0x18, 0x02,
+	0x20, 0x03, 0x28, 0x0b, 0x32, 0x3c, 0x2e, 0x4e, 0x59, 0x71, 0x6c, 0x2e, 0x4e, 0x43, 0x6f, 0x6e,
+	0x6e, 0x65, 0x63, 0x74, 0x6f, 0x72, 0x2e, 0x4e, 0x41, 0x70, 0x69, 0x2e, 0x54, 0x52, 0x65, 0x61,
+	0x64, 0x53, 0x70, 0x6c, 0x69, 0x74, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x2e,
+	0x54, 0x43, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x53, 0x65, 0x74, 0x2e, 0x54, 0x43, 0x6f, 0x6c, 0x75,
+	0x6d, 0x6e, 0x52, 0x04, 0x64, 0x61, 0x74, 0x61, 0x1a, 0x29, 0x0a, 0x07, 0x54, 0x43, 0x6f, 0x6c,
+	0x75, 0x6d, 0x6e, 0x12, 0x1e, 0x0a, 0x04, 0x64, 0x61, 0x74, 0x61, 0x18, 0x01, 0x20, 0x03, 0x28,
+	0x0b, 0x32, 0x0a, 0x2e, 0x59, 0x64, 0x62, 0x2e, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x52, 0x04, 0x64,
+	0x61, 0x74, 0x61, 0x42, 0x09, 0x0a, 0x07, 0x70, 0x61, 0x79, 0x6c, 0x6f, 0x61, 0x64, 0x22, 0x37,
+	0x0a, 0x0b, 0x54, 0x50, 0x61, 0x67, 0x69, 0x6e, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x12, 0x0a,
+	0x04, 0x72, 0x6f, 0x77, 0x73, 0x18, 0x01, 0x20, 0x01, 0x28, 0x04, 0x52, 0x04, 0x72, 0x6f, 0x77,
+	0x73, 0x12, 0x14, 0x0a, 0x05, 0x62, 0x79, 0x74, 0x65, 0x73, 0x18, 0x02, 0x20, 0x01, 0x28, 0x04,
+	0x52, 0x05, 0x62, 0x79, 0x74, 0x65, 0x73, 0x22, 0x3e, 0x0a, 0x0d, 0x54, 0x43, 0x6f, 0x6e, 0x74,
+	0x69, 0x6e, 0x75, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x22, 0x0a, 0x0b, 0x64, 0x65, 0x73, 0x63,
+	0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0c, 0x48, 0x00, 0x52,
+	0x0b, 0x64, 0x65, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x42, 0x09, 0x0a, 0x07,
+	0x70, 0x61, 0x79, 0x6c, 0x6f, 0x61, 0x64, 0x22, 0x9f, 0x05, 0x0a, 0x0b, 0x54, 0x45, 0x78, 0x70,
+	0x72, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x12, 0x32, 0x0a, 0x0b, 0x74, 0x79, 0x70, 0x65, 0x64,
+	0x5f, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x0f, 0x2e, 0x59,
+	0x64, 0x62, 0x2e, 0x54, 0x79, 0x70, 0x65, 0x64, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x48, 0x00, 0x52,
+	0x0a, 0x74, 0x79, 0x70, 0x65, 0x64, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x12, 0x18, 0x0a, 0x06, 0x63,
+	0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x48, 0x00, 0x52, 0x06, 0x63,
+	0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x12, 0x74, 0x0a, 0x17, 0x61, 0x72, 0x69, 0x74, 0x68, 0x6d, 0x65,
+	0x74, 0x69, 0x63, 0x61, 0x6c, 0x5f, 0x65, 0x78, 0x70, 0x72, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e,
+	0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x39, 0x2e, 0x4e, 0x59, 0x71, 0x6c, 0x2e, 0x4e, 0x43,
+	0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x6f, 0x72, 0x2e, 0x4e, 0x41, 0x70, 0x69, 0x2e, 0x54, 0x45,
+	0x78, 0x70, 0x72, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x2e, 0x54, 0x41, 0x72, 0x69, 0x74, 0x68,
+	0x6d, 0x65, 0x74, 0x69, 0x63, 0x61, 0x6c, 0x45, 0x78, 0x70, 0x72, 0x65, 0x73, 0x73, 0x69, 0x6f,
+	0x6e, 0x48, 0x00, 0x52, 0x16, 0x61, 0x72, 0x69, 0x74, 0x68, 0x6d, 0x65, 0x74, 0x69, 0x63, 0x61,
+	0x6c, 0x45, 0x78, 0x70, 0x72, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x12, 0x3d, 0x0a, 0x04, 0x6e,
+	0x75, 0x6c, 0x6c, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x27, 0x2e, 0x4e, 0x59, 0x71, 0x6c,
 	0x2e, 0x4e, 0x43, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x6f, 0x72, 0x2e, 0x4e, 0x41, 0x70, 0x69,
-	0x2e, 0x54, 0x43, 0x6f, 0x6e, 0x74, 0x69, 0x6e, 0x75, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x0c,
-	0x63, 0x6f, 0x6e, 0x74, 0x69, 0x6e, 0x75, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x32, 0x0a, 0x05,
-	0x65, 0x72, 0x72, 0x6f, 0x72, 0x18, 0x64, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1c, 0x2e, 0x4e, 0x59,
-	0x71, 0x6c, 0x2e, 0x4e, 0x43, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x6f, 0x72, 0x2e, 0x4e, 0x41,
-	0x70, 0x69, 0x2e, 0x54, 0x45, 0x72, 0x72, 0x6f, 0x72, 0x52, 0x05, 0x65, 0x72, 0x72, 0x6f, 0x72,
-	0x1a, 0xaa, 0x01, 0x0a, 0x0a, 0x54, 0x43, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x53, 0x65, 0x74, 0x12,
-	0x1f, 0x0a, 0x04, 0x6d, 0x65, 0x74, 0x61, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x0b, 0x2e,
-	0x59, 0x64, 0x62, 0x2e, 0x43, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x52, 0x04, 0x6d, 0x65, 0x74, 0x61,
-	0x12, 0x50, 0x0a, 0x04, 0x64, 0x61, 0x74, 0x61, 0x18, 0x02, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x3c,
+	0x2e, 0x54, 0x45, 0x78, 0x70, 0x72, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x2e, 0x54, 0x4e, 0x75,
+	0x6c, 0x6c, 0x48, 0x00, 0x52, 0x04, 0x6e, 0x75, 0x6c, 0x6c, 0x1a, 0xf8, 0x02, 0x0a, 0x17, 0x54,
+	0x41, 0x72, 0x69, 0x74, 0x68, 0x6d, 0x65, 0x74, 0x69, 0x63, 0x61, 0x6c, 0x45, 0x78, 0x70, 0x72,
+	0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x12, 0x62, 0x0a, 0x09, 0x6f, 0x70, 0x65, 0x72, 0x61, 0x74,
+	0x69, 0x6f, 0x6e, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x44, 0x2e, 0x4e, 0x59, 0x71, 0x6c,
+	0x2e, 0x4e, 0x43, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x6f, 0x72, 0x2e, 0x4e, 0x41, 0x70, 0x69,
+	0x2e, 0x54, 0x45, 0x78, 0x70, 0x72, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x2e, 0x54, 0x41, 0x72,
+	0x69, 0x74, 0x68, 0x6d, 0x65, 0x74, 0x69, 0x63, 0x61, 0x6c, 0x45, 0x78, 0x70, 0x72, 0x65, 0x73,
+	0x73, 0x69, 0x6f, 0x6e, 0x2e, 0x45, 0x4f, 0x70, 0x65, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x52,
+	0x09, 0x6f, 0x70, 0x65, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x40, 0x0a, 0x0a, 0x6c, 0x65,
+	0x66, 0x74, 0x5f, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x21,
 	0x2e, 0x4e, 0x59, 0x71, 0x6c, 0x2e, 0x4e, 0x43, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x6f, 0x72,
-	0x2e, 0x4e, 0x41, 0x70, 0x69, 0x2e, 0x54, 0x52, 0x65, 0x61, 0x64, 0x53, 0x70, 0x6c, 0x69, 0x74,
-	0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x2e, 0x54, 0x43, 0x6f, 0x6c, 0x75, 0x6d,
-	0x6e, 0x53, 0x65, 0x74, 0x2e, 0x54, 0x43, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x52, 0x04, 0x64, 0x61,
-	0x74, 0x61, 0x1a, 0x29, 0x0a, 0x07, 0x54, 0x43, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x12, 0x1e, 0x0a,
-	0x04, 0x64, 0x61, 0x74, 0x61, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x0a, 0x2e, 0x59, 0x64,
-	0x62, 0x2e, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x52, 0x04, 0x64, 0x61, 0x74, 0x61, 0x42, 0x09, 0x0a,
-	0x07, 0x70, 0x61, 0x79, 0x6c, 0x6f, 0x61, 0x64, 0x22, 0x37, 0x0a, 0x0b, 0x54, 0x50, 0x61, 0x67,
-	0x69, 0x6e, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x12, 0x0a, 0x04, 0x72, 0x6f, 0x77, 0x73, 0x18,
-	0x01, 0x20, 0x01, 0x28, 0x04, 0x52, 0x04, 0x72, 0x6f, 0x77, 0x73, 0x12, 0x14, 0x0a, 0x05, 0x62,
-	0x79, 0x74, 0x65, 0x73, 0x18, 0x02, 0x20, 0x01, 0x28, 0x04, 0x52, 0x05, 0x62, 0x79, 0x74, 0x65,
-	0x73, 0x22, 0x3e, 0x0a, 0x0d, 0x54, 0x43, 0x6f, 0x6e, 0x74, 0x69, 0x6e, 0x75, 0x61, 0x74, 0x69,
-	0x6f, 0x6e, 0x12, 0x22, 0x0a, 0x0b, 0x64, 0x65, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f,
-	0x6e, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0c, 0x48, 0x00, 0x52, 0x0b, 0x64, 0x65, 0x73, 0x63, 0x72,
-	0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x42, 0x09, 0x0a, 0x07, 0x70, 0x61, 0x79, 0x6c, 0x6f, 0x61,
-	0x64, 0x22, 0x66, 0x0a, 0x0b, 0x54, 0x45, 0x78, 0x70, 0x72, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e,
-	0x12, 0x32, 0x0a, 0x0b, 0x74, 0x79, 0x70, 0x65, 0x64, 0x5f, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18,
-	0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x0f, 0x2e, 0x59, 0x64, 0x62, 0x2e, 0x54, 0x79, 0x70, 0x65,
-	0x64, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x48, 0x00, 0x52, 0x0a, 0x74, 0x79, 0x70, 0x65, 0x64, 0x56,
-	0x61, 0x6c, 0x75, 0x65, 0x12, 0x18, 0x0a, 0x06, 0x63, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x18, 0x02,
-	0x20, 0x01, 0x28, 0x09, 0x48, 0x00, 0x52, 0x06, 0x63, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x42, 0x09,
-	0x0a, 0x07, 0x70, 0x61, 0x79, 0x6c, 0x6f, 0x61, 0x64, 0x22, 0xc4, 0x0c, 0x0a, 0x0a, 0x54, 0x50,
+	0x2e, 0x4e, 0x41, 0x70, 0x69, 0x2e, 0x54, 0x45, 0x78, 0x70, 0x72, 0x65, 0x73, 0x73, 0x69, 0x6f,
+	0x6e, 0x52, 0x09, 0x6c, 0x65, 0x66, 0x74, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x12, 0x42, 0x0a, 0x0b,
+	0x72, 0x69, 0x67, 0x68, 0x74, 0x5f, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28,
+	0x0b, 0x32, 0x21, 0x2e, 0x4e, 0x59, 0x71, 0x6c, 0x2e, 0x4e, 0x43, 0x6f, 0x6e, 0x6e, 0x65, 0x63,
+	0x74, 0x6f, 0x72, 0x2e, 0x4e, 0x41, 0x70, 0x69, 0x2e, 0x54, 0x45, 0x78, 0x70, 0x72, 0x65, 0x73,
+	0x73, 0x69, 0x6f, 0x6e, 0x52, 0x0a, 0x72, 0x69, 0x67, 0x68, 0x74, 0x56, 0x61, 0x6c, 0x75, 0x65,
+	0x22, 0x73, 0x0a, 0x0a, 0x45, 0x4f, 0x70, 0x65, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x24,
+	0x0a, 0x20, 0x45, 0x58, 0x50, 0x52, 0x45, 0x53, 0x53, 0x49, 0x4f, 0x4e, 0x5f, 0x4f, 0x50, 0x45,
+	0x52, 0x41, 0x54, 0x49, 0x4f, 0x4e, 0x5f, 0x55, 0x4e, 0x53, 0x50, 0x45, 0x43, 0x49, 0x46, 0x49,
+	0x45, 0x44, 0x10, 0x00, 0x12, 0x07, 0x0a, 0x03, 0x4d, 0x55, 0x4c, 0x10, 0x01, 0x12, 0x07, 0x0a,
+	0x03, 0x41, 0x44, 0x44, 0x10, 0x02, 0x12, 0x07, 0x0a, 0x03, 0x53, 0x55, 0x42, 0x10, 0x03, 0x12,
+	0x0b, 0x0a, 0x07, 0x42, 0x49, 0x54, 0x5f, 0x41, 0x4e, 0x44, 0x10, 0x04, 0x12, 0x0a, 0x0a, 0x06,
+	0x42, 0x49, 0x54, 0x5f, 0x4f, 0x52, 0x10, 0x05, 0x12, 0x0b, 0x0a, 0x07, 0x42, 0x49, 0x54, 0x5f,
+	0x58, 0x4f, 0x52, 0x10, 0x06, 0x1a, 0x07, 0x0a, 0x05, 0x54, 0x4e, 0x75, 0x6c, 0x6c, 0x42, 0x09,
+	0x0a, 0x07, 0x70, 0x61, 0x79, 0x6c, 0x6f, 0x61, 0x64, 0x22, 0x85, 0x0e, 0x0a, 0x0a, 0x54, 0x50,
 	0x72, 0x65, 0x64, 0x69, 0x63, 0x61, 0x74, 0x65, 0x12, 0x48, 0x0a, 0x08, 0x6e, 0x65, 0x67, 0x61,
 	0x74, 0x69, 0x6f, 0x6e, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x2a, 0x2e, 0x4e, 0x59, 0x71,
 	0x6c, 0x2e, 0x4e, 0x43, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x6f, 0x72, 0x2e, 0x4e, 0x41, 0x70,
@@ -2811,98 +3101,112 @@ var file_ydb_library_yql_providers_generic_connector_api_service_protos_connecto
 	0x2c, 0x2e, 0x4e, 0x59, 0x71, 0x6c, 0x2e, 0x4e, 0x43, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x6f,
 	0x72, 0x2e, 0x4e, 0x41, 0x70, 0x69, 0x2e, 0x54, 0x50, 0x72, 0x65, 0x64, 0x69, 0x63, 0x61, 0x74,
 	0x65, 0x2e, 0x54, 0x43, 0x6f, 0x6d, 0x70, 0x61, 0x72, 0x69, 0x73, 0x6f, 0x6e, 0x48, 0x00, 0x52,
-	0x0a, 0x63, 0x6f, 0x6d, 0x70, 0x61, 0x72, 0x69, 0x73, 0x6f, 0x6e, 0x1a, 0x47, 0x0a, 0x09, 0x54,
-	0x4e, 0x65, 0x67, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x3a, 0x0a, 0x07, 0x6f, 0x70, 0x65, 0x72,
-	0x61, 0x6e, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x20, 0x2e, 0x4e, 0x59, 0x71, 0x6c,
-	0x2e, 0x4e, 0x43, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x6f, 0x72, 0x2e, 0x4e, 0x41, 0x70, 0x69,
-	0x2e, 0x54, 0x50, 0x72, 0x65, 0x64, 0x69, 0x63, 0x61, 0x74, 0x65, 0x52, 0x07, 0x6f, 0x70, 0x65,
-	0x72, 0x61, 0x6e, 0x64, 0x1a, 0x4c, 0x0a, 0x0c, 0x54, 0x43, 0x6f, 0x6e, 0x6a, 0x75, 0x6e, 0x63,
-	0x74, 0x69, 0x6f, 0x6e, 0x12, 0x3c, 0x0a, 0x08, 0x6f, 0x70, 0x65, 0x72, 0x61, 0x6e, 0x64, 0x73,
-	0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x20, 0x2e, 0x4e, 0x59, 0x71, 0x6c, 0x2e, 0x4e, 0x43,
-	0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x6f, 0x72, 0x2e, 0x4e, 0x41, 0x70, 0x69, 0x2e, 0x54, 0x50,
-	0x72, 0x65, 0x64, 0x69, 0x63, 0x61, 0x74, 0x65, 0x52, 0x08, 0x6f, 0x70, 0x65, 0x72, 0x61, 0x6e,
-	0x64, 0x73, 0x1a, 0x4c, 0x0a, 0x0c, 0x54, 0x44, 0x69, 0x73, 0x6a, 0x75, 0x6e, 0x63, 0x74, 0x69,
-	0x6f, 0x6e, 0x12, 0x3c, 0x0a, 0x08, 0x6f, 0x70, 0x65, 0x72, 0x61, 0x6e, 0x64, 0x73, 0x18, 0x01,
-	0x20, 0x03, 0x28, 0x0b, 0x32, 0x20, 0x2e, 0x4e, 0x59, 0x71, 0x6c, 0x2e, 0x4e, 0x43, 0x6f, 0x6e,
+	0x0a, 0x63, 0x6f, 0x6d, 0x70, 0x61, 0x72, 0x69, 0x73, 0x6f, 0x6e, 0x12, 0x5b, 0x0a, 0x0f, 0x62,
+	0x6f, 0x6f, 0x6c, 0x5f, 0x65, 0x78, 0x70, 0x72, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x18, 0x09,
+	0x20, 0x01, 0x28, 0x0b, 0x32, 0x30, 0x2e, 0x4e, 0x59, 0x71, 0x6c, 0x2e, 0x4e, 0x43, 0x6f, 0x6e,
 	0x6e, 0x65, 0x63, 0x74, 0x6f, 0x72, 0x2e, 0x4e, 0x41, 0x70, 0x69, 0x2e, 0x54, 0x50, 0x72, 0x65,
-	0x64, 0x69, 0x63, 0x61, 0x74, 0x65, 0x52, 0x08, 0x6f, 0x70, 0x65, 0x72, 0x61, 0x6e, 0x64, 0x73,
-	0x1a, 0xbb, 0x01, 0x0a, 0x08, 0x54, 0x42, 0x65, 0x74, 0x77, 0x65, 0x65, 0x6e, 0x12, 0x37, 0x0a,
-	0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x21, 0x2e, 0x4e,
-	0x59, 0x71, 0x6c, 0x2e, 0x4e, 0x43, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x6f, 0x72, 0x2e, 0x4e,
-	0x41, 0x70, 0x69, 0x2e, 0x54, 0x45, 0x78, 0x70, 0x72, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x52,
-	0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x12, 0x37, 0x0a, 0x05, 0x6c, 0x65, 0x61, 0x73, 0x74, 0x18,
-	0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x21, 0x2e, 0x4e, 0x59, 0x71, 0x6c, 0x2e, 0x4e, 0x43, 0x6f,
-	0x6e, 0x6e, 0x65, 0x63, 0x74, 0x6f, 0x72, 0x2e, 0x4e, 0x41, 0x70, 0x69, 0x2e, 0x54, 0x45, 0x78,
-	0x70, 0x72, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x52, 0x05, 0x6c, 0x65, 0x61, 0x73, 0x74, 0x12,
-	0x3d, 0x0a, 0x08, 0x67, 0x72, 0x65, 0x61, 0x74, 0x65, 0x73, 0x74, 0x18, 0x03, 0x20, 0x01, 0x28,
+	0x64, 0x69, 0x63, 0x61, 0x74, 0x65, 0x2e, 0x54, 0x42, 0x6f, 0x6f, 0x6c, 0x45, 0x78, 0x70, 0x72,
+	0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x48, 0x00, 0x52, 0x0e, 0x62, 0x6f, 0x6f, 0x6c, 0x45, 0x78,
+	0x70, 0x72, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x1a, 0x47, 0x0a, 0x09, 0x54, 0x4e, 0x65, 0x67,
+	0x61, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x3a, 0x0a, 0x07, 0x6f, 0x70, 0x65, 0x72, 0x61, 0x6e, 0x64,
+	0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x20, 0x2e, 0x4e, 0x59, 0x71, 0x6c, 0x2e, 0x4e, 0x43,
+	0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x6f, 0x72, 0x2e, 0x4e, 0x41, 0x70, 0x69, 0x2e, 0x54, 0x50,
+	0x72, 0x65, 0x64, 0x69, 0x63, 0x61, 0x74, 0x65, 0x52, 0x07, 0x6f, 0x70, 0x65, 0x72, 0x61, 0x6e,
+	0x64, 0x1a, 0x4c, 0x0a, 0x0c, 0x54, 0x43, 0x6f, 0x6e, 0x6a, 0x75, 0x6e, 0x63, 0x74, 0x69, 0x6f,
+	0x6e, 0x12, 0x3c, 0x0a, 0x08, 0x6f, 0x70, 0x65, 0x72, 0x61, 0x6e, 0x64, 0x73, 0x18, 0x01, 0x20,
+	0x03, 0x28, 0x0b, 0x32, 0x20, 0x2e, 0x4e, 0x59, 0x71, 0x6c, 0x2e, 0x4e, 0x43, 0x6f, 0x6e, 0x6e,
+	0x65, 0x63, 0x74, 0x6f, 0x72, 0x2e, 0x4e, 0x41, 0x70, 0x69, 0x2e, 0x54, 0x50, 0x72, 0x65, 0x64,
+	0x69, 0x63, 0x61, 0x74, 0x65, 0x52, 0x08, 0x6f, 0x70, 0x65, 0x72, 0x61, 0x6e, 0x64, 0x73, 0x1a,
+	0x4c, 0x0a, 0x0c, 0x54, 0x44, 0x69, 0x73, 0x6a, 0x75, 0x6e, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x12,
+	0x3c, 0x0a, 0x08, 0x6f, 0x70, 0x65, 0x72, 0x61, 0x6e, 0x64, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28,
+	0x0b, 0x32, 0x20, 0x2e, 0x4e, 0x59, 0x71, 0x6c, 0x2e, 0x4e, 0x43, 0x6f, 0x6e, 0x6e, 0x65, 0x63,
+	0x74, 0x6f, 0x72, 0x2e, 0x4e, 0x41, 0x70, 0x69, 0x2e, 0x54, 0x50, 0x72, 0x65, 0x64, 0x69, 0x63,
+	0x61, 0x74, 0x65, 0x52, 0x08, 0x6f, 0x70, 0x65, 0x72, 0x61, 0x6e, 0x64, 0x73, 0x1a, 0xbb, 0x01,
+	0x0a, 0x08, 0x54, 0x42, 0x65, 0x74, 0x77, 0x65, 0x65, 0x6e, 0x12, 0x37, 0x0a, 0x05, 0x76, 0x61,
+	0x6c, 0x75, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x21, 0x2e, 0x4e, 0x59, 0x71, 0x6c,
+	0x2e, 0x4e, 0x43, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x6f, 0x72, 0x2e, 0x4e, 0x41, 0x70, 0x69,
+	0x2e, 0x54, 0x45, 0x78, 0x70, 0x72, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x52, 0x05, 0x76, 0x61,
+	0x6c, 0x75, 0x65, 0x12, 0x37, 0x0a, 0x05, 0x6c, 0x65, 0x61, 0x73, 0x74, 0x18, 0x02, 0x20, 0x01,
+	0x28, 0x0b, 0x32, 0x21, 0x2e, 0x4e, 0x59, 0x71, 0x6c, 0x2e, 0x4e, 0x43, 0x6f, 0x6e, 0x6e, 0x65,
+	0x63, 0x74, 0x6f, 0x72, 0x2e, 0x4e, 0x41, 0x70, 0x69, 0x2e, 0x54, 0x45, 0x78, 0x70, 0x72, 0x65,
+	0x73, 0x73, 0x69, 0x6f, 0x6e, 0x52, 0x05, 0x6c, 0x65, 0x61, 0x73, 0x74, 0x12, 0x3d, 0x0a, 0x08,
+	0x67, 0x72, 0x65, 0x61, 0x74, 0x65, 0x73, 0x74, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x21,
+	0x2e, 0x4e, 0x59, 0x71, 0x6c, 0x2e, 0x4e, 0x43, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x6f, 0x72,
+	0x2e, 0x4e, 0x41, 0x70, 0x69, 0x2e, 0x54, 0x45, 0x78, 0x70, 0x72, 0x65, 0x73, 0x73, 0x69, 0x6f,
+	0x6e, 0x52, 0x08, 0x67, 0x72, 0x65, 0x61, 0x74, 0x65, 0x73, 0x74, 0x1a, 0x73, 0x0a, 0x03, 0x54,
+	0x49, 0x6e, 0x12, 0x37, 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28,
 	0x0b, 0x32, 0x21, 0x2e, 0x4e, 0x59, 0x71, 0x6c, 0x2e, 0x4e, 0x43, 0x6f, 0x6e, 0x6e, 0x65, 0x63,
 	0x74, 0x6f, 0x72, 0x2e, 0x4e, 0x41, 0x70, 0x69, 0x2e, 0x54, 0x45, 0x78, 0x70, 0x72, 0x65, 0x73,
-	0x73, 0x69, 0x6f, 0x6e, 0x52, 0x08, 0x67, 0x72, 0x65, 0x61, 0x74, 0x65, 0x73, 0x74, 0x1a, 0x73,
-	0x0a, 0x03, 0x54, 0x49, 0x6e, 0x12, 0x37, 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x01,
-	0x20, 0x01, 0x28, 0x0b, 0x32, 0x21, 0x2e, 0x4e, 0x59, 0x71, 0x6c, 0x2e, 0x4e, 0x43, 0x6f, 0x6e,
-	0x6e, 0x65, 0x63, 0x74, 0x6f, 0x72, 0x2e, 0x4e, 0x41, 0x70, 0x69, 0x2e, 0x54, 0x45, 0x78, 0x70,
-	0x72, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x12, 0x33,
-	0x0a, 0x03, 0x73, 0x65, 0x74, 0x18, 0x02, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x21, 0x2e, 0x4e, 0x59,
-	0x71, 0x6c, 0x2e, 0x4e, 0x43, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x6f, 0x72, 0x2e, 0x4e, 0x41,
-	0x70, 0x69, 0x2e, 0x54, 0x45, 0x78, 0x70, 0x72, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x52, 0x03,
-	0x73, 0x65, 0x74, 0x1a, 0x42, 0x0a, 0x07, 0x54, 0x49, 0x73, 0x4e, 0x75, 0x6c, 0x6c, 0x12, 0x37,
+	0x73, 0x69, 0x6f, 0x6e, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x12, 0x33, 0x0a, 0x03, 0x73,
+	0x65, 0x74, 0x18, 0x02, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x21, 0x2e, 0x4e, 0x59, 0x71, 0x6c, 0x2e,
+	0x4e, 0x43, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x6f, 0x72, 0x2e, 0x4e, 0x41, 0x70, 0x69, 0x2e,
+	0x54, 0x45, 0x78, 0x70, 0x72, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x52, 0x03, 0x73, 0x65, 0x74,
+	0x1a, 0x42, 0x0a, 0x07, 0x54, 0x49, 0x73, 0x4e, 0x75, 0x6c, 0x6c, 0x12, 0x37, 0x0a, 0x05, 0x76,
+	0x61, 0x6c, 0x75, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x21, 0x2e, 0x4e, 0x59, 0x71,
+	0x6c, 0x2e, 0x4e, 0x43, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x6f, 0x72, 0x2e, 0x4e, 0x41, 0x70,
+	0x69, 0x2e, 0x54, 0x45, 0x78, 0x70, 0x72, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x52, 0x05, 0x76,
+	0x61, 0x6c, 0x75, 0x65, 0x1a, 0x45, 0x0a, 0x0a, 0x54, 0x49, 0x73, 0x4e, 0x6f, 0x74, 0x4e, 0x75,
+	0x6c, 0x6c, 0x12, 0x37, 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28,
+	0x0b, 0x32, 0x21, 0x2e, 0x4e, 0x59, 0x71, 0x6c, 0x2e, 0x4e, 0x43, 0x6f, 0x6e, 0x6e, 0x65, 0x63,
+	0x74, 0x6f, 0x72, 0x2e, 0x4e, 0x41, 0x70, 0x69, 0x2e, 0x54, 0x45, 0x78, 0x70, 0x72, 0x65, 0x73,
+	0x73, 0x69, 0x6f, 0x6e, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x1a, 0x4a, 0x0a, 0x0f, 0x54,
+	0x42, 0x6f, 0x6f, 0x6c, 0x45, 0x78, 0x70, 0x72, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x12, 0x37,
 	0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x21, 0x2e,
 	0x4e, 0x59, 0x71, 0x6c, 0x2e, 0x4e, 0x43, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x6f, 0x72, 0x2e,
 	0x4e, 0x41, 0x70, 0x69, 0x2e, 0x54, 0x45, 0x78, 0x70, 0x72, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e,
-	0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x1a, 0x45, 0x0a, 0x0a, 0x54, 0x49, 0x73, 0x4e, 0x6f,
-	0x74, 0x4e, 0x75, 0x6c, 0x6c, 0x12, 0x37, 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x01,
-	0x20, 0x01, 0x28, 0x0b, 0x32, 0x21, 0x2e, 0x4e, 0x59, 0x71, 0x6c, 0x2e, 0x4e, 0x43, 0x6f, 0x6e,
-	0x6e, 0x65, 0x63, 0x74, 0x6f, 0x72, 0x2e, 0x4e, 0x41, 0x70, 0x69, 0x2e, 0x54, 0x45, 0x78, 0x70,
-	0x72, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x1a, 0xb4,
-	0x02, 0x0a, 0x0b, 0x54, 0x43, 0x6f, 0x6d, 0x70, 0x61, 0x72, 0x69, 0x73, 0x6f, 0x6e, 0x12, 0x55,
-	0x0a, 0x09, 0x6f, 0x70, 0x65, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x01, 0x20, 0x01, 0x28,
-	0x0e, 0x32, 0x37, 0x2e, 0x4e, 0x59, 0x71, 0x6c, 0x2e, 0x4e, 0x43, 0x6f, 0x6e, 0x6e, 0x65, 0x63,
-	0x74, 0x6f, 0x72, 0x2e, 0x4e, 0x41, 0x70, 0x69, 0x2e, 0x54, 0x50, 0x72, 0x65, 0x64, 0x69, 0x63,
-	0x61, 0x74, 0x65, 0x2e, 0x54, 0x43, 0x6f, 0x6d, 0x70, 0x61, 0x72, 0x69, 0x73, 0x6f, 0x6e, 0x2e,
-	0x45, 0x4f, 0x70, 0x65, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x09, 0x6f, 0x70, 0x65, 0x72,
-	0x61, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x40, 0x0a, 0x0a, 0x6c, 0x65, 0x66, 0x74, 0x5f, 0x76, 0x61,
-	0x6c, 0x75, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x21, 0x2e, 0x4e, 0x59, 0x71, 0x6c,
-	0x2e, 0x4e, 0x43, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x6f, 0x72, 0x2e, 0x4e, 0x41, 0x70, 0x69,
-	0x2e, 0x54, 0x45, 0x78, 0x70, 0x72, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x52, 0x09, 0x6c, 0x65,
-	0x66, 0x74, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x12, 0x42, 0x0a, 0x0b, 0x72, 0x69, 0x67, 0x68, 0x74,
-	0x5f, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x21, 0x2e, 0x4e,
+	0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x1a, 0xcc, 0x02, 0x0a, 0x0b, 0x54, 0x43, 0x6f, 0x6d,
+	0x70, 0x61, 0x72, 0x69, 0x73, 0x6f, 0x6e, 0x12, 0x55, 0x0a, 0x09, 0x6f, 0x70, 0x65, 0x72, 0x61,
+	0x74, 0x69, 0x6f, 0x6e, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x37, 0x2e, 0x4e, 0x59, 0x71,
+	0x6c, 0x2e, 0x4e, 0x43, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x6f, 0x72, 0x2e, 0x4e, 0x41, 0x70,
+	0x69, 0x2e, 0x54, 0x50, 0x72, 0x65, 0x64, 0x69, 0x63, 0x61, 0x74, 0x65, 0x2e, 0x54, 0x43, 0x6f,
+	0x6d, 0x70, 0x61, 0x72, 0x69, 0x73, 0x6f, 0x6e, 0x2e, 0x45, 0x4f, 0x70, 0x65, 0x72, 0x61, 0x74,
+	0x69, 0x6f, 0x6e, 0x52, 0x09, 0x6f, 0x70, 0x65, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x40,
+	0x0a, 0x0a, 0x6c, 0x65, 0x66, 0x74, 0x5f, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x02, 0x20, 0x01,
+	0x28, 0x0b, 0x32, 0x21, 0x2e, 0x4e, 0x59, 0x71, 0x6c, 0x2e, 0x4e, 0x43, 0x6f, 0x6e, 0x6e, 0x65,
+	0x63, 0x74, 0x6f, 0x72, 0x2e, 0x4e, 0x41, 0x70, 0x69, 0x2e, 0x54, 0x45, 0x78, 0x70, 0x72, 0x65,
+	0x73, 0x73, 0x69, 0x6f, 0x6e, 0x52, 0x09, 0x6c, 0x65, 0x66, 0x74, 0x56, 0x61, 0x6c, 0x75, 0x65,
+	0x12, 0x42, 0x0a, 0x0b, 0x72, 0x69, 0x67, 0x68, 0x74, 0x5f, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18,
+	0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x21, 0x2e, 0x4e, 0x59, 0x71, 0x6c, 0x2e, 0x4e, 0x43, 0x6f,
+	0x6e, 0x6e, 0x65, 0x63, 0x74, 0x6f, 0x72, 0x2e, 0x4e, 0x41, 0x70, 0x69, 0x2e, 0x54, 0x45, 0x78,
+	0x70, 0x72, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x52, 0x0a, 0x72, 0x69, 0x67, 0x68, 0x74, 0x56,
+	0x61, 0x6c, 0x75, 0x65, 0x22, 0x60, 0x0a, 0x0a, 0x45, 0x4f, 0x70, 0x65, 0x72, 0x61, 0x74, 0x69,
+	0x6f, 0x6e, 0x12, 0x24, 0x0a, 0x20, 0x43, 0x4f, 0x4d, 0x50, 0x41, 0x52, 0x49, 0x53, 0x4f, 0x4e,
+	0x5f, 0x4f, 0x50, 0x45, 0x52, 0x41, 0x54, 0x49, 0x4f, 0x4e, 0x5f, 0x55, 0x4e, 0x53, 0x50, 0x45,
+	0x43, 0x49, 0x46, 0x49, 0x45, 0x44, 0x10, 0x00, 0x12, 0x05, 0x0a, 0x01, 0x4c, 0x10, 0x01, 0x12,
+	0x06, 0x0a, 0x02, 0x4c, 0x45, 0x10, 0x02, 0x12, 0x06, 0x0a, 0x02, 0x45, 0x51, 0x10, 0x03, 0x12,
+	0x06, 0x0a, 0x02, 0x4e, 0x45, 0x10, 0x04, 0x12, 0x06, 0x0a, 0x02, 0x47, 0x45, 0x10, 0x05, 0x12,
+	0x05, 0x0a, 0x01, 0x47, 0x10, 0x06, 0x42, 0x09, 0x0a, 0x07, 0x70, 0x61, 0x79, 0x6c, 0x6f, 0x61,
+	0x64, 0x22, 0x86, 0x01, 0x0a, 0x06, 0x54, 0x45, 0x72, 0x72, 0x6f, 0x72, 0x12, 0x31, 0x0a, 0x06,
+	0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x19, 0x2e, 0x59,
+	0x64, 0x62, 0x2e, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x49, 0x64, 0x73, 0x2e, 0x53, 0x74, 0x61,
+	0x74, 0x75, 0x73, 0x43, 0x6f, 0x64, 0x65, 0x52, 0x06, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x12,
+	0x18, 0x0a, 0x07, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09,
+	0x52, 0x07, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x12, 0x2f, 0x0a, 0x06, 0x69, 0x73, 0x73,
+	0x75, 0x65, 0x73, 0x18, 0x03, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x17, 0x2e, 0x59, 0x64, 0x62, 0x2e,
+	0x49, 0x73, 0x73, 0x75, 0x65, 0x2e, 0x49, 0x73, 0x73, 0x75, 0x65, 0x4d, 0x65, 0x73, 0x73, 0x61,
+	0x67, 0x65, 0x52, 0x06, 0x69, 0x73, 0x73, 0x75, 0x65, 0x73, 0x22, 0xa0, 0x01, 0x0a, 0x04, 0x54,
+	0x41, 0x73, 0x74, 0x12, 0x14, 0x0a, 0x04, 0x61, 0x74, 0x6f, 0x6d, 0x18, 0x01, 0x20, 0x01, 0x28,
+	0x0c, 0x48, 0x00, 0x52, 0x04, 0x61, 0x74, 0x6f, 0x6d, 0x12, 0x36, 0x0a, 0x04, 0x6c, 0x69, 0x73,
+	0x74, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x20, 0x2e, 0x4e, 0x59, 0x71, 0x6c, 0x2e, 0x4e,
+	0x43, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x6f, 0x72, 0x2e, 0x4e, 0x41, 0x70, 0x69, 0x2e, 0x54,
+	0x41, 0x73, 0x74, 0x2e, 0x54, 0x4c, 0x69, 0x73, 0x74, 0x48, 0x00, 0x52, 0x04, 0x6c, 0x69, 0x73,
+	0x74, 0x1a, 0x3f, 0x0a, 0x05, 0x54, 0x4c, 0x69, 0x73, 0x74, 0x12, 0x36, 0x0a, 0x08, 0x63, 0x68,
+	0x69, 0x6c, 0x64, 0x72, 0x65, 0x6e, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x4e,
 	0x59, 0x71, 0x6c, 0x2e, 0x4e, 0x43, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x6f, 0x72, 0x2e, 0x4e,
-	0x41, 0x70, 0x69, 0x2e, 0x54, 0x45, 0x78, 0x70, 0x72, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x52,
-	0x0a, 0x72, 0x69, 0x67, 0x68, 0x74, 0x56, 0x61, 0x6c, 0x75, 0x65, 0x22, 0x48, 0x0a, 0x0a, 0x45,
-	0x4f, 0x70, 0x65, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x0c, 0x0a, 0x08, 0x52, 0x45, 0x53,
-	0x45, 0x52, 0x56, 0x45, 0x44, 0x10, 0x00, 0x12, 0x05, 0x0a, 0x01, 0x4c, 0x10, 0x01, 0x12, 0x06,
-	0x0a, 0x02, 0x4c, 0x45, 0x10, 0x02, 0x12, 0x06, 0x0a, 0x02, 0x45, 0x51, 0x10, 0x03, 0x12, 0x06,
-	0x0a, 0x02, 0x4e, 0x45, 0x10, 0x04, 0x12, 0x06, 0x0a, 0x02, 0x47, 0x45, 0x10, 0x05, 0x12, 0x05,
-	0x0a, 0x01, 0x47, 0x10, 0x06, 0x42, 0x09, 0x0a, 0x07, 0x70, 0x61, 0x79, 0x6c, 0x6f, 0x61, 0x64,
-	0x22, 0x86, 0x01, 0x0a, 0x06, 0x54, 0x45, 0x72, 0x72, 0x6f, 0x72, 0x12, 0x31, 0x0a, 0x06, 0x73,
-	0x74, 0x61, 0x74, 0x75, 0x73, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x19, 0x2e, 0x59, 0x64,
-	0x62, 0x2e, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x49, 0x64, 0x73, 0x2e, 0x53, 0x74, 0x61, 0x74,
-	0x75, 0x73, 0x43, 0x6f, 0x64, 0x65, 0x52, 0x06, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x12, 0x18,
-	0x0a, 0x07, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52,
-	0x07, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x12, 0x2f, 0x0a, 0x06, 0x69, 0x73, 0x73, 0x75,
-	0x65, 0x73, 0x18, 0x03, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x17, 0x2e, 0x59, 0x64, 0x62, 0x2e, 0x49,
-	0x73, 0x73, 0x75, 0x65, 0x2e, 0x49, 0x73, 0x73, 0x75, 0x65, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67,
-	0x65, 0x52, 0x06, 0x69, 0x73, 0x73, 0x75, 0x65, 0x73, 0x22, 0xa0, 0x01, 0x0a, 0x04, 0x54, 0x41,
-	0x73, 0x74, 0x12, 0x14, 0x0a, 0x04, 0x61, 0x74, 0x6f, 0x6d, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0c,
-	0x48, 0x00, 0x52, 0x04, 0x61, 0x74, 0x6f, 0x6d, 0x12, 0x36, 0x0a, 0x04, 0x6c, 0x69, 0x73, 0x74,
-	0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x20, 0x2e, 0x4e, 0x59, 0x71, 0x6c, 0x2e, 0x4e, 0x43,
-	0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x6f, 0x72, 0x2e, 0x4e, 0x41, 0x70, 0x69, 0x2e, 0x54, 0x41,
-	0x73, 0x74, 0x2e, 0x54, 0x4c, 0x69, 0x73, 0x74, 0x48, 0x00, 0x52, 0x04, 0x6c, 0x69, 0x73, 0x74,
-	0x1a, 0x3f, 0x0a, 0x05, 0x54, 0x4c, 0x69, 0x73, 0x74, 0x12, 0x36, 0x0a, 0x08, 0x63, 0x68, 0x69,
-	0x6c, 0x64, 0x72, 0x65, 0x6e, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x4e, 0x59,
-	0x71, 0x6c, 0x2e, 0x4e, 0x43, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x6f, 0x72, 0x2e, 0x4e, 0x41,
-	0x70, 0x69, 0x2e, 0x54, 0x41, 0x73, 0x74, 0x52, 0x08, 0x63, 0x68, 0x69, 0x6c, 0x64, 0x72, 0x65,
-	0x6e, 0x42, 0x09, 0x0a, 0x07, 0x70, 0x61, 0x79, 0x6c, 0x6f, 0x61, 0x64, 0x2a, 0x42, 0x0a, 0x0f,
-	0x45, 0x44, 0x61, 0x74, 0x65, 0x54, 0x69, 0x6d, 0x65, 0x46, 0x6f, 0x72, 0x6d, 0x61, 0x74, 0x12,
-	0x0c, 0x0a, 0x08, 0x52, 0x45, 0x53, 0x45, 0x52, 0x56, 0x45, 0x44, 0x10, 0x00, 0x12, 0x11, 0x0a,
-	0x0d, 0x53, 0x54, 0x52, 0x49, 0x4e, 0x47, 0x5f, 0x46, 0x4f, 0x52, 0x4d, 0x41, 0x54, 0x10, 0x01,
-	0x12, 0x0e, 0x0a, 0x0a, 0x59, 0x51, 0x4c, 0x5f, 0x46, 0x4f, 0x52, 0x4d, 0x41, 0x54, 0x10, 0x02,
-	0x42, 0x53, 0x5a, 0x51, 0x61, 0x2e, 0x79, 0x61, 0x6e, 0x64, 0x65, 0x78, 0x2d, 0x74, 0x65, 0x61,
-	0x6d, 0x2e, 0x72, 0x75, 0x2f, 0x79, 0x64, 0x62, 0x2f, 0x6c, 0x69, 0x62, 0x72, 0x61, 0x72, 0x79,
-	0x2f, 0x79, 0x71, 0x6c, 0x2f, 0x70, 0x72, 0x6f, 0x76, 0x69, 0x64, 0x65, 0x72, 0x73, 0x2f, 0x67,
-	0x65, 0x6e, 0x65, 0x72, 0x69, 0x63, 0x2f, 0x63, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x6f, 0x72,
-	0x2f, 0x6c, 0x69, 0x62, 0x67, 0x6f, 0x2f, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2f, 0x70,
-	0x72, 0x6f, 0x74, 0x6f, 0x73, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
+	0x41, 0x70, 0x69, 0x2e, 0x54, 0x41, 0x73, 0x74, 0x52, 0x08, 0x63, 0x68, 0x69, 0x6c, 0x64, 0x72,
+	0x65, 0x6e, 0x42, 0x09, 0x0a, 0x07, 0x70, 0x61, 0x79, 0x6c, 0x6f, 0x61, 0x64, 0x2a, 0x56, 0x0a,
+	0x0f, 0x45, 0x44, 0x61, 0x74, 0x65, 0x54, 0x69, 0x6d, 0x65, 0x46, 0x6f, 0x72, 0x6d, 0x61, 0x74,
+	0x12, 0x20, 0x0a, 0x1c, 0x44, 0x41, 0x54, 0x45, 0x5f, 0x54, 0x49, 0x4d, 0x45, 0x5f, 0x46, 0x4f,
+	0x52, 0x4d, 0x41, 0x54, 0x5f, 0x55, 0x4e, 0x53, 0x50, 0x45, 0x43, 0x49, 0x46, 0x49, 0x45, 0x44,
+	0x10, 0x00, 0x12, 0x11, 0x0a, 0x0d, 0x53, 0x54, 0x52, 0x49, 0x4e, 0x47, 0x5f, 0x46, 0x4f, 0x52,
+	0x4d, 0x41, 0x54, 0x10, 0x01, 0x12, 0x0e, 0x0a, 0x0a, 0x59, 0x51, 0x4c, 0x5f, 0x46, 0x4f, 0x52,
+	0x4d, 0x41, 0x54, 0x10, 0x02, 0x42, 0x53, 0x5a, 0x51, 0x61, 0x2e, 0x79, 0x61, 0x6e, 0x64, 0x65,
+	0x78, 0x2d, 0x74, 0x65, 0x61, 0x6d, 0x2e, 0x72, 0x75, 0x2f, 0x79, 0x64, 0x62, 0x2f, 0x6c, 0x69,
+	0x62, 0x72, 0x61, 0x72, 0x79, 0x2f, 0x79, 0x71, 0x6c, 0x2f, 0x70, 0x72, 0x6f, 0x76, 0x69, 0x64,
+	0x65, 0x72, 0x73, 0x2f, 0x67, 0x65, 0x6e, 0x65, 0x72, 0x69, 0x63, 0x2f, 0x63, 0x6f, 0x6e, 0x6e,
+	0x65, 0x63, 0x74, 0x6f, 0x72, 0x2f, 0x6c, 0x69, 0x62, 0x67, 0x6f, 0x2f, 0x73, 0x65, 0x72, 0x76,
+	0x69, 0x63, 0x65, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x73, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74,
+	0x6f, 0x33,
 }
 
 var (
@@ -2917,119 +3221,130 @@ func file_ydb_library_yql_providers_generic_connector_api_service_protos_connect
 	return file_ydb_library_yql_providers_generic_connector_api_service_protos_connector_proto_rawDescData
 }
 
-var file_ydb_library_yql_providers_generic_connector_api_service_protos_connector_proto_enumTypes = make([]protoimpl.EnumInfo, 4)
-var file_ydb_library_yql_providers_generic_connector_api_service_protos_connector_proto_msgTypes = make([]protoimpl.MessageInfo, 34)
+var file_ydb_library_yql_providers_generic_connector_api_service_protos_connector_proto_enumTypes = make([]protoimpl.EnumInfo, 5)
+var file_ydb_library_yql_providers_generic_connector_api_service_protos_connector_proto_msgTypes = make([]protoimpl.MessageInfo, 37)
 var file_ydb_library_yql_providers_generic_connector_api_service_protos_connector_proto_goTypes = []interface{}{
-	(EDateTimeFormat)(0),                           // 0: NYql.NConnector.NApi.EDateTimeFormat
-	(TReadSplitsRequest_EMode)(0),                  // 1: NYql.NConnector.NApi.TReadSplitsRequest.EMode
-	(TReadSplitsRequest_EFormat)(0),                // 2: NYql.NConnector.NApi.TReadSplitsRequest.EFormat
-	(TPredicate_TComparison_EOperation)(0),         // 3: NYql.NConnector.NApi.TPredicate.TComparison.EOperation
-	(*TListTablesRequest)(nil),                     // 4: NYql.NConnector.NApi.TListTablesRequest
-	(*TListTablesResponse)(nil),                    // 5: NYql.NConnector.NApi.TListTablesResponse
-	(*TDescribeTableRequest)(nil),                  // 6: NYql.NConnector.NApi.TDescribeTableRequest
-	(*TTypeMappingSettings)(nil),                   // 7: NYql.NConnector.NApi.TTypeMappingSettings
-	(*TDescribeTableResponse)(nil),                 // 8: NYql.NConnector.NApi.TDescribeTableResponse
-	(*TSchema)(nil),                                // 9: NYql.NConnector.NApi.TSchema
-	(*TListSplitsRequest)(nil),                     // 10: NYql.NConnector.NApi.TListSplitsRequest
-	(*TListSplitsResponse)(nil),                    // 11: NYql.NConnector.NApi.TListSplitsResponse
-	(*TSelect)(nil),                                // 12: NYql.NConnector.NApi.TSelect
-	(*TSplit)(nil),                                 // 13: NYql.NConnector.NApi.TSplit
-	(*TReadSplitsRequest)(nil),                     // 14: NYql.NConnector.NApi.TReadSplitsRequest
-	(*TReadSplitsResponse)(nil),                    // 15: NYql.NConnector.NApi.TReadSplitsResponse
-	(*TPagination)(nil),                            // 16: NYql.NConnector.NApi.TPagination
-	(*TContinuation)(nil),                          // 17: NYql.NConnector.NApi.TContinuation
-	(*TExpression)(nil),                            // 18: NYql.NConnector.NApi.TExpression
-	(*TPredicate)(nil),                             // 19: NYql.NConnector.NApi.TPredicate
-	(*TError)(nil),                                 // 20: NYql.NConnector.NApi.TError
-	(*TAst)(nil),                                   // 21: NYql.NConnector.NApi.TAst
-	(*TSelect_TWhat)(nil),                          // 22: NYql.NConnector.NApi.TSelect.TWhat
-	(*TSelect_TFrom)(nil),                          // 23: NYql.NConnector.NApi.TSelect.TFrom
-	(*TSelect_TWhere)(nil),                         // 24: NYql.NConnector.NApi.TSelect.TWhere
-	(*TSelect_TLimit)(nil),                         // 25: NYql.NConnector.NApi.TSelect.TLimit
-	(*TSelect_TWhat_TItem)(nil),                    // 26: NYql.NConnector.NApi.TSelect.TWhat.TItem
-	(*TReadSplitsResponse_TColumnSet)(nil),         // 27: NYql.NConnector.NApi.TReadSplitsResponse.TColumnSet
-	(*TReadSplitsResponse_TColumnSet_TColumn)(nil), // 28: NYql.NConnector.NApi.TReadSplitsResponse.TColumnSet.TColumn
-	(*TPredicate_TNegation)(nil),                   // 29: NYql.NConnector.NApi.TPredicate.TNegation
-	(*TPredicate_TConjunction)(nil),                // 30: NYql.NConnector.NApi.TPredicate.TConjunction
-	(*TPredicate_TDisjunction)(nil),                // 31: NYql.NConnector.NApi.TPredicate.TDisjunction
-	(*TPredicate_TBetween)(nil),                    // 32: NYql.NConnector.NApi.TPredicate.TBetween
-	(*TPredicate_TIn)(nil),                         // 33: NYql.NConnector.NApi.TPredicate.TIn
-	(*TPredicate_TIsNull)(nil),                     // 34: NYql.NConnector.NApi.TPredicate.TIsNull
-	(*TPredicate_TIsNotNull)(nil),                  // 35: NYql.NConnector.NApi.TPredicate.TIsNotNull
-	(*TPredicate_TComparison)(nil),                 // 36: NYql.NConnector.NApi.TPredicate.TComparison
-	(*TAst_TList)(nil),                             // 37: NYql.NConnector.NApi.TAst.TList
-	(*common.TDataSourceInstance)(nil),             // 38: NYql.NConnector.NApi.TDataSourceInstance
-	(*Ydb.Column)(nil),                             // 39: Ydb.Column
-	(*Ydb.TypedValue)(nil),                         // 40: Ydb.TypedValue
-	(Ydb.StatusIds_StatusCode)(0),                  // 41: Ydb.StatusIds.StatusCode
-	(*Ydb_Issue.IssueMessage)(nil),                 // 42: Ydb.Issue.IssueMessage
-	(*Ydb.Value)(nil),                              // 43: Ydb.Value
+	(EDateTimeFormat)(0),                                // 0: NYql.NConnector.NApi.EDateTimeFormat
+	(TReadSplitsRequest_EMode)(0),                       // 1: NYql.NConnector.NApi.TReadSplitsRequest.EMode
+	(TReadSplitsRequest_EFormat)(0),                     // 2: NYql.NConnector.NApi.TReadSplitsRequest.EFormat
+	(TExpression_TArithmeticalExpression_EOperation)(0), // 3: NYql.NConnector.NApi.TExpression.TArithmeticalExpression.EOperation
+	(TPredicate_TComparison_EOperation)(0),              // 4: NYql.NConnector.NApi.TPredicate.TComparison.EOperation
+	(*TListTablesRequest)(nil),                          // 5: NYql.NConnector.NApi.TListTablesRequest
+	(*TListTablesResponse)(nil),                         // 6: NYql.NConnector.NApi.TListTablesResponse
+	(*TDescribeTableRequest)(nil),                       // 7: NYql.NConnector.NApi.TDescribeTableRequest
+	(*TTypeMappingSettings)(nil),                        // 8: NYql.NConnector.NApi.TTypeMappingSettings
+	(*TDescribeTableResponse)(nil),                      // 9: NYql.NConnector.NApi.TDescribeTableResponse
+	(*TSchema)(nil),                                     // 10: NYql.NConnector.NApi.TSchema
+	(*TListSplitsRequest)(nil),                          // 11: NYql.NConnector.NApi.TListSplitsRequest
+	(*TListSplitsResponse)(nil),                         // 12: NYql.NConnector.NApi.TListSplitsResponse
+	(*TSelect)(nil),                                     // 13: NYql.NConnector.NApi.TSelect
+	(*TSplit)(nil),                                      // 14: NYql.NConnector.NApi.TSplit
+	(*TReadSplitsRequest)(nil),                          // 15: NYql.NConnector.NApi.TReadSplitsRequest
+	(*TReadSplitsResponse)(nil),                         // 16: NYql.NConnector.NApi.TReadSplitsResponse
+	(*TPagination)(nil),                                 // 17: NYql.NConnector.NApi.TPagination
+	(*TContinuation)(nil),                               // 18: NYql.NConnector.NApi.TContinuation
+	(*TExpression)(nil),                                 // 19: NYql.NConnector.NApi.TExpression
+	(*TPredicate)(nil),                                  // 20: NYql.NConnector.NApi.TPredicate
+	(*TError)(nil),                                      // 21: NYql.NConnector.NApi.TError
+	(*TAst)(nil),                                        // 22: NYql.NConnector.NApi.TAst
+	(*TSelect_TWhat)(nil),                               // 23: NYql.NConnector.NApi.TSelect.TWhat
+	(*TSelect_TFrom)(nil),                               // 24: NYql.NConnector.NApi.TSelect.TFrom
+	(*TSelect_TWhere)(nil),                              // 25: NYql.NConnector.NApi.TSelect.TWhere
+	(*TSelect_TLimit)(nil),                              // 26: NYql.NConnector.NApi.TSelect.TLimit
+	(*TSelect_TWhat_TItem)(nil),                         // 27: NYql.NConnector.NApi.TSelect.TWhat.TItem
+	(*TReadSplitsResponse_TColumnSet)(nil),              // 28: NYql.NConnector.NApi.TReadSplitsResponse.TColumnSet
+	(*TReadSplitsResponse_TColumnSet_TColumn)(nil),      // 29: NYql.NConnector.NApi.TReadSplitsResponse.TColumnSet.TColumn
+	(*TExpression_TArithmeticalExpression)(nil),         // 30: NYql.NConnector.NApi.TExpression.TArithmeticalExpression
+	(*TExpression_TNull)(nil),                           // 31: NYql.NConnector.NApi.TExpression.TNull
+	(*TPredicate_TNegation)(nil),                        // 32: NYql.NConnector.NApi.TPredicate.TNegation
+	(*TPredicate_TConjunction)(nil),                     // 33: NYql.NConnector.NApi.TPredicate.TConjunction
+	(*TPredicate_TDisjunction)(nil),                     // 34: NYql.NConnector.NApi.TPredicate.TDisjunction
+	(*TPredicate_TBetween)(nil),                         // 35: NYql.NConnector.NApi.TPredicate.TBetween
+	(*TPredicate_TIn)(nil),                              // 36: NYql.NConnector.NApi.TPredicate.TIn
+	(*TPredicate_TIsNull)(nil),                          // 37: NYql.NConnector.NApi.TPredicate.TIsNull
+	(*TPredicate_TIsNotNull)(nil),                       // 38: NYql.NConnector.NApi.TPredicate.TIsNotNull
+	(*TPredicate_TBoolExpression)(nil),                  // 39: NYql.NConnector.NApi.TPredicate.TBoolExpression
+	(*TPredicate_TComparison)(nil),                      // 40: NYql.NConnector.NApi.TPredicate.TComparison
+	(*TAst_TList)(nil),                                  // 41: NYql.NConnector.NApi.TAst.TList
+	(*common.TDataSourceInstance)(nil),                  // 42: NYql.NConnector.NApi.TDataSourceInstance
+	(*Ydb.Column)(nil),                                  // 43: Ydb.Column
+	(*Ydb.TypedValue)(nil),                              // 44: Ydb.TypedValue
+	(Ydb.StatusIds_StatusCode)(0),                       // 45: Ydb.StatusIds.StatusCode
+	(*Ydb_Issue.IssueMessage)(nil),                      // 46: Ydb.Issue.IssueMessage
+	(*Ydb.Value)(nil),                                   // 47: Ydb.Value
 }
 var file_ydb_library_yql_providers_generic_connector_api_service_protos_connector_proto_depIdxs = []int32{
-	38, // 0: NYql.NConnector.NApi.TListTablesRequest.data_source_instance:type_name -> NYql.NConnector.NApi.TDataSourceInstance
-	20, // 1: NYql.NConnector.NApi.TListTablesResponse.error:type_name -> NYql.NConnector.NApi.TError
-	38, // 2: NYql.NConnector.NApi.TDescribeTableRequest.data_source_instance:type_name -> NYql.NConnector.NApi.TDataSourceInstance
-	7,  // 3: NYql.NConnector.NApi.TDescribeTableRequest.type_mapping_settings:type_name -> NYql.NConnector.NApi.TTypeMappingSettings
+	42, // 0: NYql.NConnector.NApi.TListTablesRequest.data_source_instance:type_name -> NYql.NConnector.NApi.TDataSourceInstance
+	21, // 1: NYql.NConnector.NApi.TListTablesResponse.error:type_name -> NYql.NConnector.NApi.TError
+	42, // 2: NYql.NConnector.NApi.TDescribeTableRequest.data_source_instance:type_name -> NYql.NConnector.NApi.TDataSourceInstance
+	8,  // 3: NYql.NConnector.NApi.TDescribeTableRequest.type_mapping_settings:type_name -> NYql.NConnector.NApi.TTypeMappingSettings
 	0,  // 4: NYql.NConnector.NApi.TTypeMappingSettings.date_time_format:type_name -> NYql.NConnector.NApi.EDateTimeFormat
-	9,  // 5: NYql.NConnector.NApi.TDescribeTableResponse.schema:type_name -> NYql.NConnector.NApi.TSchema
-	20, // 6: NYql.NConnector.NApi.TDescribeTableResponse.error:type_name -> NYql.NConnector.NApi.TError
-	39, // 7: NYql.NConnector.NApi.TSchema.columns:type_name -> Ydb.Column
-	12, // 8: NYql.NConnector.NApi.TListSplitsRequest.selects:type_name -> NYql.NConnector.NApi.TSelect
-	13, // 9: NYql.NConnector.NApi.TListSplitsResponse.splits:type_name -> NYql.NConnector.NApi.TSplit
-	20, // 10: NYql.NConnector.NApi.TListSplitsResponse.error:type_name -> NYql.NConnector.NApi.TError
-	38, // 11: NYql.NConnector.NApi.TSelect.data_source_instance:type_name -> NYql.NConnector.NApi.TDataSourceInstance
-	22, // 12: NYql.NConnector.NApi.TSelect.what:type_name -> NYql.NConnector.NApi.TSelect.TWhat
-	23, // 13: NYql.NConnector.NApi.TSelect.from:type_name -> NYql.NConnector.NApi.TSelect.TFrom
-	24, // 14: NYql.NConnector.NApi.TSelect.where:type_name -> NYql.NConnector.NApi.TSelect.TWhere
-	25, // 15: NYql.NConnector.NApi.TSelect.limit:type_name -> NYql.NConnector.NApi.TSelect.TLimit
-	12, // 16: NYql.NConnector.NApi.TSplit.select:type_name -> NYql.NConnector.NApi.TSelect
-	38, // 17: NYql.NConnector.NApi.TReadSplitsRequest.data_source_instance:type_name -> NYql.NConnector.NApi.TDataSourceInstance
-	13, // 18: NYql.NConnector.NApi.TReadSplitsRequest.splits:type_name -> NYql.NConnector.NApi.TSplit
+	10, // 5: NYql.NConnector.NApi.TDescribeTableResponse.schema:type_name -> NYql.NConnector.NApi.TSchema
+	21, // 6: NYql.NConnector.NApi.TDescribeTableResponse.error:type_name -> NYql.NConnector.NApi.TError
+	43, // 7: NYql.NConnector.NApi.TSchema.columns:type_name -> Ydb.Column
+	13, // 8: NYql.NConnector.NApi.TListSplitsRequest.selects:type_name -> NYql.NConnector.NApi.TSelect
+	14, // 9: NYql.NConnector.NApi.TListSplitsResponse.splits:type_name -> NYql.NConnector.NApi.TSplit
+	21, // 10: NYql.NConnector.NApi.TListSplitsResponse.error:type_name -> NYql.NConnector.NApi.TError
+	42, // 11: NYql.NConnector.NApi.TSelect.data_source_instance:type_name -> NYql.NConnector.NApi.TDataSourceInstance
+	23, // 12: NYql.NConnector.NApi.TSelect.what:type_name -> NYql.NConnector.NApi.TSelect.TWhat
+	24, // 13: NYql.NConnector.NApi.TSelect.from:type_name -> NYql.NConnector.NApi.TSelect.TFrom
+	25, // 14: NYql.NConnector.NApi.TSelect.where:type_name -> NYql.NConnector.NApi.TSelect.TWhere
+	26, // 15: NYql.NConnector.NApi.TSelect.limit:type_name -> NYql.NConnector.NApi.TSelect.TLimit
+	13, // 16: NYql.NConnector.NApi.TSplit.select:type_name -> NYql.NConnector.NApi.TSelect
+	42, // 17: NYql.NConnector.NApi.TReadSplitsRequest.data_source_instance:type_name -> NYql.NConnector.NApi.TDataSourceInstance
+	14, // 18: NYql.NConnector.NApi.TReadSplitsRequest.splits:type_name -> NYql.NConnector.NApi.TSplit
 	1,  // 19: NYql.NConnector.NApi.TReadSplitsRequest.mode:type_name -> NYql.NConnector.NApi.TReadSplitsRequest.EMode
 	2,  // 20: NYql.NConnector.NApi.TReadSplitsRequest.format:type_name -> NYql.NConnector.NApi.TReadSplitsRequest.EFormat
-	16, // 21: NYql.NConnector.NApi.TReadSplitsRequest.pagination:type_name -> NYql.NConnector.NApi.TPagination
-	17, // 22: NYql.NConnector.NApi.TReadSplitsRequest.continuation:type_name -> NYql.NConnector.NApi.TContinuation
-	27, // 23: NYql.NConnector.NApi.TReadSplitsResponse.column_set:type_name -> NYql.NConnector.NApi.TReadSplitsResponse.TColumnSet
-	17, // 24: NYql.NConnector.NApi.TReadSplitsResponse.continuation:type_name -> NYql.NConnector.NApi.TContinuation
-	20, // 25: NYql.NConnector.NApi.TReadSplitsResponse.error:type_name -> NYql.NConnector.NApi.TError
-	40, // 26: NYql.NConnector.NApi.TExpression.typed_value:type_name -> Ydb.TypedValue
-	29, // 27: NYql.NConnector.NApi.TPredicate.negation:type_name -> NYql.NConnector.NApi.TPredicate.TNegation
-	30, // 28: NYql.NConnector.NApi.TPredicate.conjunction:type_name -> NYql.NConnector.NApi.TPredicate.TConjunction
-	31, // 29: NYql.NConnector.NApi.TPredicate.disjunction:type_name -> NYql.NConnector.NApi.TPredicate.TDisjunction
-	32, // 30: NYql.NConnector.NApi.TPredicate.between:type_name -> NYql.NConnector.NApi.TPredicate.TBetween
-	33, // 31: NYql.NConnector.NApi.TPredicate.in:type_name -> NYql.NConnector.NApi.TPredicate.TIn
-	34, // 32: NYql.NConnector.NApi.TPredicate.is_null:type_name -> NYql.NConnector.NApi.TPredicate.TIsNull
-	35, // 33: NYql.NConnector.NApi.TPredicate.is_not_null:type_name -> NYql.NConnector.NApi.TPredicate.TIsNotNull
-	36, // 34: NYql.NConnector.NApi.TPredicate.comparison:type_name -> NYql.NConnector.NApi.TPredicate.TComparison
-	41, // 35: NYql.NConnector.NApi.TError.status:type_name -> Ydb.StatusIds.StatusCode
-	42, // 36: NYql.NConnector.NApi.TError.issues:type_name -> Ydb.Issue.IssueMessage
-	37, // 37: NYql.NConnector.NApi.TAst.list:type_name -> NYql.NConnector.NApi.TAst.TList
-	26, // 38: NYql.NConnector.NApi.TSelect.TWhat.items:type_name -> NYql.NConnector.NApi.TSelect.TWhat.TItem
-	19, // 39: NYql.NConnector.NApi.TSelect.TWhere.filter_typed:type_name -> NYql.NConnector.NApi.TPredicate
-	21, // 40: NYql.NConnector.NApi.TSelect.TWhere.filter_raw:type_name -> NYql.NConnector.NApi.TAst
-	39, // 41: NYql.NConnector.NApi.TSelect.TWhat.TItem.column:type_name -> Ydb.Column
-	39, // 42: NYql.NConnector.NApi.TReadSplitsResponse.TColumnSet.meta:type_name -> Ydb.Column
-	28, // 43: NYql.NConnector.NApi.TReadSplitsResponse.TColumnSet.data:type_name -> NYql.NConnector.NApi.TReadSplitsResponse.TColumnSet.TColumn
-	43, // 44: NYql.NConnector.NApi.TReadSplitsResponse.TColumnSet.TColumn.data:type_name -> Ydb.Value
-	19, // 45: NYql.NConnector.NApi.TPredicate.TNegation.operand:type_name -> NYql.NConnector.NApi.TPredicate
-	19, // 46: NYql.NConnector.NApi.TPredicate.TConjunction.operands:type_name -> NYql.NConnector.NApi.TPredicate
-	19, // 47: NYql.NConnector.NApi.TPredicate.TDisjunction.operands:type_name -> NYql.NConnector.NApi.TPredicate
-	18, // 48: NYql.NConnector.NApi.TPredicate.TBetween.value:type_name -> NYql.NConnector.NApi.TExpression
-	18, // 49: NYql.NConnector.NApi.TPredicate.TBetween.least:type_name -> NYql.NConnector.NApi.TExpression
-	18, // 50: NYql.NConnector.NApi.TPredicate.TBetween.greatest:type_name -> NYql.NConnector.NApi.TExpression
-	18, // 51: NYql.NConnector.NApi.TPredicate.TIn.value:type_name -> NYql.NConnector.NApi.TExpression
-	18, // 52: NYql.NConnector.NApi.TPredicate.TIn.set:type_name -> NYql.NConnector.NApi.TExpression
-	18, // 53: NYql.NConnector.NApi.TPredicate.TIsNull.value:type_name -> NYql.NConnector.NApi.TExpression
-	18, // 54: NYql.NConnector.NApi.TPredicate.TIsNotNull.value:type_name -> NYql.NConnector.NApi.TExpression
-	3,  // 55: NYql.NConnector.NApi.TPredicate.TComparison.operation:type_name -> NYql.NConnector.NApi.TPredicate.TComparison.EOperation
-	18, // 56: NYql.NConnector.NApi.TPredicate.TComparison.left_value:type_name -> NYql.NConnector.NApi.TExpression
-	18, // 57: NYql.NConnector.NApi.TPredicate.TComparison.right_value:type_name -> NYql.NConnector.NApi.TExpression
-	21, // 58: NYql.NConnector.NApi.TAst.TList.children:type_name -> NYql.NConnector.NApi.TAst
-	59, // [59:59] is the sub-list for method output_type
-	59, // [59:59] is the sub-list for method input_type
-	59, // [59:59] is the sub-list for extension type_name
-	59, // [59:59] is the sub-list for extension extendee
-	0,  // [0:59] is the sub-list for field type_name
+	17, // 21: NYql.NConnector.NApi.TReadSplitsRequest.pagination:type_name -> NYql.NConnector.NApi.TPagination
+	18, // 22: NYql.NConnector.NApi.TReadSplitsRequest.continuation:type_name -> NYql.NConnector.NApi.TContinuation
+	28, // 23: NYql.NConnector.NApi.TReadSplitsResponse.column_set:type_name -> NYql.NConnector.NApi.TReadSplitsResponse.TColumnSet
+	18, // 24: NYql.NConnector.NApi.TReadSplitsResponse.continuation:type_name -> NYql.NConnector.NApi.TContinuation
+	21, // 25: NYql.NConnector.NApi.TReadSplitsResponse.error:type_name -> NYql.NConnector.NApi.TError
+	44, // 26: NYql.NConnector.NApi.TExpression.typed_value:type_name -> Ydb.TypedValue
+	30, // 27: NYql.NConnector.NApi.TExpression.arithmetical_expression:type_name -> NYql.NConnector.NApi.TExpression.TArithmeticalExpression
+	31, // 28: NYql.NConnector.NApi.TExpression.null:type_name -> NYql.NConnector.NApi.TExpression.TNull
+	32, // 29: NYql.NConnector.NApi.TPredicate.negation:type_name -> NYql.NConnector.NApi.TPredicate.TNegation
+	33, // 30: NYql.NConnector.NApi.TPredicate.conjunction:type_name -> NYql.NConnector.NApi.TPredicate.TConjunction
+	34, // 31: NYql.NConnector.NApi.TPredicate.disjunction:type_name -> NYql.NConnector.NApi.TPredicate.TDisjunction
+	35, // 32: NYql.NConnector.NApi.TPredicate.between:type_name -> NYql.NConnector.NApi.TPredicate.TBetween
+	36, // 33: NYql.NConnector.NApi.TPredicate.in:type_name -> NYql.NConnector.NApi.TPredicate.TIn
+	37, // 34: NYql.NConnector.NApi.TPredicate.is_null:type_name -> NYql.NConnector.NApi.TPredicate.TIsNull
+	38, // 35: NYql.NConnector.NApi.TPredicate.is_not_null:type_name -> NYql.NConnector.NApi.TPredicate.TIsNotNull
+	40, // 36: NYql.NConnector.NApi.TPredicate.comparison:type_name -> NYql.NConnector.NApi.TPredicate.TComparison
+	39, // 37: NYql.NConnector.NApi.TPredicate.bool_expression:type_name -> NYql.NConnector.NApi.TPredicate.TBoolExpression
+	45, // 38: NYql.NConnector.NApi.TError.status:type_name -> Ydb.StatusIds.StatusCode
+	46, // 39: NYql.NConnector.NApi.TError.issues:type_name -> Ydb.Issue.IssueMessage
+	41, // 40: NYql.NConnector.NApi.TAst.list:type_name -> NYql.NConnector.NApi.TAst.TList
+	27, // 41: NYql.NConnector.NApi.TSelect.TWhat.items:type_name -> NYql.NConnector.NApi.TSelect.TWhat.TItem
+	20, // 42: NYql.NConnector.NApi.TSelect.TWhere.filter_typed:type_name -> NYql.NConnector.NApi.TPredicate
+	22, // 43: NYql.NConnector.NApi.TSelect.TWhere.filter_raw:type_name -> NYql.NConnector.NApi.TAst
+	43, // 44: NYql.NConnector.NApi.TSelect.TWhat.TItem.column:type_name -> Ydb.Column
+	43, // 45: NYql.NConnector.NApi.TReadSplitsResponse.TColumnSet.meta:type_name -> Ydb.Column
+	29, // 46: NYql.NConnector.NApi.TReadSplitsResponse.TColumnSet.data:type_name -> NYql.NConnector.NApi.TReadSplitsResponse.TColumnSet.TColumn
+	47, // 47: NYql.NConnector.NApi.TReadSplitsResponse.TColumnSet.TColumn.data:type_name -> Ydb.Value
+	3,  // 48: NYql.NConnector.NApi.TExpression.TArithmeticalExpression.operation:type_name -> NYql.NConnector.NApi.TExpression.TArithmeticalExpression.EOperation
+	19, // 49: NYql.NConnector.NApi.TExpression.TArithmeticalExpression.left_value:type_name -> NYql.NConnector.NApi.TExpression
+	19, // 50: NYql.NConnector.NApi.TExpression.TArithmeticalExpression.right_value:type_name -> NYql.NConnector.NApi.TExpression
+	20, // 51: NYql.NConnector.NApi.TPredicate.TNegation.operand:type_name -> NYql.NConnector.NApi.TPredicate
+	20, // 52: NYql.NConnector.NApi.TPredicate.TConjunction.operands:type_name -> NYql.NConnector.NApi.TPredicate
+	20, // 53: NYql.NConnector.NApi.TPredicate.TDisjunction.operands:type_name -> NYql.NConnector.NApi.TPredicate
+	19, // 54: NYql.NConnector.NApi.TPredicate.TBetween.value:type_name -> NYql.NConnector.NApi.TExpression
+	19, // 55: NYql.NConnector.NApi.TPredicate.TBetween.least:type_name -> NYql.NConnector.NApi.TExpression
+	19, // 56: NYql.NConnector.NApi.TPredicate.TBetween.greatest:type_name -> NYql.NConnector.NApi.TExpression
+	19, // 57: NYql.NConnector.NApi.TPredicate.TIn.value:type_name -> NYql.NConnector.NApi.TExpression
+	19, // 58: NYql.NConnector.NApi.TPredicate.TIn.set:type_name -> NYql.NConnector.NApi.TExpression
+	19, // 59: NYql.NConnector.NApi.TPredicate.TIsNull.value:type_name -> NYql.NConnector.NApi.TExpression
+	19, // 60: NYql.NConnector.NApi.TPredicate.TIsNotNull.value:type_name -> NYql.NConnector.NApi.TExpression
+	19, // 61: NYql.NConnector.NApi.TPredicate.TBoolExpression.value:type_name -> NYql.NConnector.NApi.TExpression
+	4,  // 62: NYql.NConnector.NApi.TPredicate.TComparison.operation:type_name -> NYql.NConnector.NApi.TPredicate.TComparison.EOperation
+	19, // 63: NYql.NConnector.NApi.TPredicate.TComparison.left_value:type_name -> NYql.NConnector.NApi.TExpression
+	19, // 64: NYql.NConnector.NApi.TPredicate.TComparison.right_value:type_name -> NYql.NConnector.NApi.TExpression
+	22, // 65: NYql.NConnector.NApi.TAst.TList.children:type_name -> NYql.NConnector.NApi.TAst
+	66, // [66:66] is the sub-list for method output_type
+	66, // [66:66] is the sub-list for method input_type
+	66, // [66:66] is the sub-list for extension type_name
+	66, // [66:66] is the sub-list for extension extendee
+	0,  // [0:66] is the sub-list for field type_name
 }
 
 func init() {
@@ -3341,7 +3656,7 @@ func file_ydb_library_yql_providers_generic_connector_api_service_protos_connect
 			}
 		}
 		file_ydb_library_yql_providers_generic_connector_api_service_protos_connector_proto_msgTypes[25].Exporter = func(v interface{}, i int) interface{} {
-			switch v := v.(*TPredicate_TNegation); i {
+			switch v := v.(*TExpression_TArithmeticalExpression); i {
 			case 0:
 				return &v.state
 			case 1:
@@ -3353,7 +3668,7 @@ func file_ydb_library_yql_providers_generic_connector_api_service_protos_connect
 			}
 		}
 		file_ydb_library_yql_providers_generic_connector_api_service_protos_connector_proto_msgTypes[26].Exporter = func(v interface{}, i int) interface{} {
-			switch v := v.(*TPredicate_TConjunction); i {
+			switch v := v.(*TExpression_TNull); i {
 			case 0:
 				return &v.state
 			case 1:
@@ -3365,7 +3680,7 @@ func file_ydb_library_yql_providers_generic_connector_api_service_protos_connect
 			}
 		}
 		file_ydb_library_yql_providers_generic_connector_api_service_protos_connector_proto_msgTypes[27].Exporter = func(v interface{}, i int) interface{} {
-			switch v := v.(*TPredicate_TDisjunction); i {
+			switch v := v.(*TPredicate_TNegation); i {
 			case 0:
 				return &v.state
 			case 1:
@@ -3377,7 +3692,7 @@ func file_ydb_library_yql_providers_generic_connector_api_service_protos_connect
 			}
 		}
 		file_ydb_library_yql_providers_generic_connector_api_service_protos_connector_proto_msgTypes[28].Exporter = func(v interface{}, i int) interface{} {
-			switch v := v.(*TPredicate_TBetween); i {
+			switch v := v.(*TPredicate_TConjunction); i {
 			case 0:
 				return &v.state
 			case 1:
@@ -3389,7 +3704,7 @@ func file_ydb_library_yql_providers_generic_connector_api_service_protos_connect
 			}
 		}
 		file_ydb_library_yql_providers_generic_connector_api_service_protos_connector_proto_msgTypes[29].Exporter = func(v interface{}, i int) interface{} {
-			switch v := v.(*TPredicate_TIn); i {
+			switch v := v.(*TPredicate_TDisjunction); i {
 			case 0:
 				return &v.state
 			case 1:
@@ -3401,7 +3716,7 @@ func file_ydb_library_yql_providers_generic_connector_api_service_protos_connect
 			}
 		}
 		file_ydb_library_yql_providers_generic_connector_api_service_protos_connector_proto_msgTypes[30].Exporter = func(v interface{}, i int) interface{} {
-			switch v := v.(*TPredicate_TIsNull); i {
+			switch v := v.(*TPredicate_TBetween); i {
 			case 0:
 				return &v.state
 			case 1:
@@ -3413,7 +3728,7 @@ func file_ydb_library_yql_providers_generic_connector_api_service_protos_connect
 			}
 		}
 		file_ydb_library_yql_providers_generic_connector_api_service_protos_connector_proto_msgTypes[31].Exporter = func(v interface{}, i int) interface{} {
-			switch v := v.(*TPredicate_TIsNotNull); i {
+			switch v := v.(*TPredicate_TIn); i {
 			case 0:
 				return &v.state
 			case 1:
@@ -3425,7 +3740,7 @@ func file_ydb_library_yql_providers_generic_connector_api_service_protos_connect
 			}
 		}
 		file_ydb_library_yql_providers_generic_connector_api_service_protos_connector_proto_msgTypes[32].Exporter = func(v interface{}, i int) interface{} {
-			switch v := v.(*TPredicate_TComparison); i {
+			switch v := v.(*TPredicate_TIsNull); i {
 			case 0:
 				return &v.state
 			case 1:
@@ -3437,6 +3752,42 @@ func file_ydb_library_yql_providers_generic_connector_api_service_protos_connect
 			}
 		}
 		file_ydb_library_yql_providers_generic_connector_api_service_protos_connector_proto_msgTypes[33].Exporter = func(v interface{}, i int) interface{} {
+			switch v := v.(*TPredicate_TIsNotNull); i {
+			case 0:
+				return &v.state
+			case 1:
+				return &v.sizeCache
+			case 2:
+				return &v.unknownFields
+			default:
+				return nil
+			}
+		}
+		file_ydb_library_yql_providers_generic_connector_api_service_protos_connector_proto_msgTypes[34].Exporter = func(v interface{}, i int) interface{} {
+			switch v := v.(*TPredicate_TBoolExpression); i {
+			case 0:
+				return &v.state
+			case 1:
+				return &v.sizeCache
+			case 2:
+				return &v.unknownFields
+			default:
+				return nil
+			}
+		}
+		file_ydb_library_yql_providers_generic_connector_api_service_protos_connector_proto_msgTypes[35].Exporter = func(v interface{}, i int) interface{} {
+			switch v := v.(*TPredicate_TComparison); i {
+			case 0:
+				return &v.state
+			case 1:
+				return &v.sizeCache
+			case 2:
+				return &v.unknownFields
+			default:
+				return nil
+			}
+		}
+		file_ydb_library_yql_providers_generic_connector_api_service_protos_connector_proto_msgTypes[36].Exporter = func(v interface{}, i int) interface{} {
 			switch v := v.(*TAst_TList); i {
 			case 0:
 				return &v.state
@@ -3465,6 +3816,8 @@ func file_ydb_library_yql_providers_generic_connector_api_service_protos_connect
 	file_ydb_library_yql_providers_generic_connector_api_service_protos_connector_proto_msgTypes[14].OneofWrappers = []interface{}{
 		(*TExpression_TypedValue)(nil),
 		(*TExpression_Column)(nil),
+		(*TExpression_ArithmeticalExpression)(nil),
+		(*TExpression_Null)(nil),
 	}
 	file_ydb_library_yql_providers_generic_connector_api_service_protos_connector_proto_msgTypes[15].OneofWrappers = []interface{}{
 		(*TPredicate_Negation)(nil),
@@ -3475,6 +3828,7 @@ func file_ydb_library_yql_providers_generic_connector_api_service_protos_connect
 		(*TPredicate_IsNull)(nil),
 		(*TPredicate_IsNotNull)(nil),
 		(*TPredicate_Comparison)(nil),
+		(*TPredicate_BoolExpression)(nil),
 	}
 	file_ydb_library_yql_providers_generic_connector_api_service_protos_connector_proto_msgTypes[17].OneofWrappers = []interface{}{
 		(*TAst_Atom)(nil),
@@ -3488,8 +3842,8 @@ func file_ydb_library_yql_providers_generic_connector_api_service_protos_connect
 		File: protoimpl.DescBuilder{
 			GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
 			RawDescriptor: file_ydb_library_yql_providers_generic_connector_api_service_protos_connector_proto_rawDesc,
-			NumEnums:      4,
-			NumMessages:   34,
+			NumEnums:      5,
+			NumMessages:   37,
 			NumExtensions: 0,
 			NumServices:   0,
 		},