shared

package
v1.2.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 21, 2022 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Default_QueryInfo_User      = string("-")
	Default_QueryInfo_QueueName = string("-")
)

Default values for QueryInfo fields.

View Source 
const (
	Default_QueryProfile_User      = string("-")
	Default_QueryProfile_QueueName = string("-")
)

Default values for QueryProfile fields.

Variables

View Source 
var (
	RpcChannel_name = map[int32]string{
		0: "BIT_CONTROL",
		1: "BIT_DATA",
		2: "USER",
	}
	RpcChannel_value = map[string]int32{
		"BIT_CONTROL": 0,
		"BIT_DATA":    1,
		"USER":        2,
	}
)

Enum value maps for RpcChannel.

View Source 
var (
	QueryType_name = map[int32]string{
		1: "SQL",
		2: "LOGICAL",
		3: "PHYSICAL",
		4: "EXECUTION",
		5: "PREPARED_STATEMENT",
	}
	QueryType_value = map[string]int32{
		"SQL":                1,
		"LOGICAL":            2,
		"PHYSICAL":           3,
		"EXECUTION":          4,
		"PREPARED_STATEMENT": 5,
	}
)

Enum value maps for QueryType.

View Source 
var (
	FragmentState_name = map[int32]string{
		0: "SENDING",
		1: "AWAITING_ALLOCATION",
		2: "RUNNING",
		3: "FINISHED",
		4: "CANCELLED",
		5: "FAILED",
		6: "CANCELLATION_REQUESTED",
	}
	FragmentState_value = map[string]int32{
		"SENDING":                0,
		"AWAITING_ALLOCATION":    1,
		"RUNNING":                2,
		"FINISHED":               3,
		"CANCELLED":              4,
		"FAILED":                 5,
		"CANCELLATION_REQUESTED": 6,
	}
)

Enum value maps for FragmentState.

View Source 
var (
	CoreOperatorType_name = map[int32]string{
		0:  "SINGLE_SENDER",
		1:  "BROADCAST_SENDER",
		2:  "FILTER",
		3:  "HASH_AGGREGATE",
		4:  "HASH_JOIN",
		5:  "MERGE_JOIN",
		6:  "HASH_PARTITION_SENDER",
		7:  "LIMIT",
		8:  "MERGING_RECEIVER",
		9:  "ORDERED_PARTITION_SENDER",
		10: "PROJECT",
		11: "UNORDERED_RECEIVER",
		12: "RANGE_PARTITION_SENDER",
		13: "SCREEN",
		14: "SELECTION_VECTOR_REMOVER",
		15: "STREAMING_AGGREGATE",
		16: "TOP_N_SORT",
		17: "EXTERNAL_SORT",
		18: "TRACE",
		19: "UNION",
		20: "OLD_SORT",
		21: "PARQUET_ROW_GROUP_SCAN",
		22: "HIVE_SUB_SCAN",
		23: "SYSTEM_TABLE_SCAN",
		24: "MOCK_SUB_SCAN",
		25: "PARQUET_WRITER",
		26: "DIRECT_SUB_SCAN",
		27: "TEXT_WRITER",
		28: "TEXT_SUB_SCAN",
		29: "JSON_SUB_SCAN",
		30: "INFO_SCHEMA_SUB_SCAN",
		31: "COMPLEX_TO_JSON",
		32: "PRODUCER_CONSUMER",
		33: "HBASE_SUB_SCAN",
		34: "WINDOW",
		35: "NESTED_LOOP_JOIN",
		36: "AVRO_SUB_SCAN",
		37: "PCAP_SUB_SCAN",
		38: "KAFKA_SUB_SCAN",
		39: "KUDU_SUB_SCAN",
		40: "FLATTEN",
		41: "LATERAL_JOIN",
		42: "UNNEST",
		43: "HIVE_DRILL_NATIVE_PARQUET_ROW_GROUP_SCAN",
		44: "JDBC_SCAN",
		45: "REGEX_SUB_SCAN",
		46: "MAPRDB_SUB_SCAN",
		47: "MONGO_SUB_SCAN",
		48: "KUDU_WRITER",
		49: "OPEN_TSDB_SUB_SCAN",
		50: "JSON_WRITER",
		51: "HTPPD_LOG_SUB_SCAN",
		52: "IMAGE_SUB_SCAN",
		53: "SEQUENCE_SUB_SCAN",
		54: "PARTITION_LIMIT",
		55: "PCAPNG_SUB_SCAN",
		56: "RUNTIME_FILTER",
		57: "ROWKEY_JOIN",
		58: "SYSLOG_SUB_SCAN",
		59: "STATISTICS_AGGREGATE",
		60: "UNPIVOT_MAPS",
		61: "STATISTICS_MERGE",
		62: "LTSV_SUB_SCAN",
		63: "HDF5_SUB_SCAN",
		64: "EXCEL_SUB_SCAN",
		65: "SHP_SUB_SCAN",
		66: "METADATA_HANDLER",
		67: "METADATA_CONTROLLER",
		68: "DRUID_SUB_SCAN",
		69: "SPSS_SUB_SCAN",
		70: "HTTP_SUB_SCAN",
	}
	CoreOperatorType_value = map[string]int32{
		"SINGLE_SENDER":            0,
		"BROADCAST_SENDER":         1,
		"FILTER":                   2,
		"HASH_AGGREGATE":           3,
		"HASH_JOIN":                4,
		"MERGE_JOIN":               5,
		"HASH_PARTITION_SENDER":    6,
		"LIMIT":                    7,
		"MERGING_RECEIVER":         8,
		"ORDERED_PARTITION_SENDER": 9,
		"PROJECT":                  10,
		"UNORDERED_RECEIVER":       11,
		"RANGE_PARTITION_SENDER":   12,
		"SCREEN":                   13,
		"SELECTION_VECTOR_REMOVER": 14,
		"STREAMING_AGGREGATE":      15,
		"TOP_N_SORT":               16,
		"EXTERNAL_SORT":            17,
		"TRACE":                    18,
		"UNION":                    19,
		"OLD_SORT":                 20,
		"PARQUET_ROW_GROUP_SCAN":   21,
		"HIVE_SUB_SCAN":            22,
		"SYSTEM_TABLE_SCAN":        23,
		"MOCK_SUB_SCAN":            24,
		"PARQUET_WRITER":           25,
		"DIRECT_SUB_SCAN":          26,
		"TEXT_WRITER":              27,
		"TEXT_SUB_SCAN":            28,
		"JSON_SUB_SCAN":            29,
		"INFO_SCHEMA_SUB_SCAN":     30,
		"COMPLEX_TO_JSON":          31,
		"PRODUCER_CONSUMER":        32,
		"HBASE_SUB_SCAN":           33,
		"WINDOW":                   34,
		"NESTED_LOOP_JOIN":         35,
		"AVRO_SUB_SCAN":            36,
		"PCAP_SUB_SCAN":            37,
		"KAFKA_SUB_SCAN":           38,
		"KUDU_SUB_SCAN":            39,
		"FLATTEN":                  40,
		"LATERAL_JOIN":             41,
		"UNNEST":                   42,
		"HIVE_DRILL_NATIVE_PARQUET_ROW_GROUP_SCAN": 43,
		"JDBC_SCAN":            44,
		"REGEX_SUB_SCAN":       45,
		"MAPRDB_SUB_SCAN":      46,
		"MONGO_SUB_SCAN":       47,
		"KUDU_WRITER":          48,
		"OPEN_TSDB_SUB_SCAN":   49,
		"JSON_WRITER":          50,
		"HTPPD_LOG_SUB_SCAN":   51,
		"IMAGE_SUB_SCAN":       52,
		"SEQUENCE_SUB_SCAN":    53,
		"PARTITION_LIMIT":      54,
		"PCAPNG_SUB_SCAN":      55,
		"RUNTIME_FILTER":       56,
		"ROWKEY_JOIN":          57,
		"SYSLOG_SUB_SCAN":      58,
		"STATISTICS_AGGREGATE": 59,
		"UNPIVOT_MAPS":         60,
		"STATISTICS_MERGE":     61,
		"LTSV_SUB_SCAN":        62,
		"HDF5_SUB_SCAN":        63,
		"EXCEL_SUB_SCAN":       64,
		"SHP_SUB_SCAN":         65,
		"METADATA_HANDLER":     66,
		"METADATA_CONTROLLER":  67,
		"DRUID_SUB_SCAN":       68,
		"SPSS_SUB_SCAN":        69,
		"HTTP_SUB_SCAN":        70,
	}
)

Enum value maps for CoreOperatorType.

View Source 
var (
	SaslStatus_name = map[int32]string{
		0: "SASL_UNKNOWN",
		1: "SASL_START",
		2: "SASL_IN_PROGRESS",
		3: "SASL_SUCCESS",
		4: "SASL_FAILED",
	}
	SaslStatus_value = map[string]int32{
		"SASL_UNKNOWN":     0,
		"SASL_START":       1,
		"SASL_IN_PROGRESS": 2,
		"SASL_SUCCESS":     3,
		"SASL_FAILED":      4,
	}
)

Enum value maps for SaslStatus.

View Source 
var (
	DrillPBError_ErrorType_name = map[int32]string{
		0:  "CONNECTION",
		1:  "DATA_READ",
		2:  "DATA_WRITE",
		3:  "FUNCTION",
		4:  "PARSE",
		5:  "PERMISSION",
		6:  "PLAN",
		7:  "RESOURCE",
		8:  "SYSTEM",
		9:  "UNSUPPORTED_OPERATION",
		10: "VALIDATION",
		11: "EXECUTION_ERROR",
		12: "INTERNAL_ERROR",
		13: "UNSPECIFIED_ERROR",
	}
	DrillPBError_ErrorType_value = map[string]int32{
		"CONNECTION":            0,
		"DATA_READ":             1,
		"DATA_WRITE":            2,
		"FUNCTION":              3,
		"PARSE":                 4,
		"PERMISSION":            5,
		"PLAN":                  6,
		"RESOURCE":              7,
		"SYSTEM":                8,
		"UNSUPPORTED_OPERATION": 9,
		"VALIDATION":            10,
		"EXECUTION_ERROR":       11,
		"INTERNAL_ERROR":        12,
		"UNSPECIFIED_ERROR":     13,
	}
)

Enum value maps for DrillPBError_ErrorType.

View Source 
var (
	NamePart_Type_name = map[int32]string{
		0: "NAME",
		1: "ARRAY",
	}
	NamePart_Type_value = map[string]int32{
		"NAME":  0,
		"ARRAY": 1,
	}
)

Enum value maps for NamePart_Type.

View Source 
var (
	QueryResult_QueryState_name = map[int32]string{
		0: "STARTING",
		1: "RUNNING",
		2: "COMPLETED",
		3: "CANCELED",
		4: "FAILED",
		5: "CANCELLATION_REQUESTED",
		6: "ENQUEUED",
		7: "PREPARING",
		8: "PLANNING",
	}
	QueryResult_QueryState_value = map[string]int32{
		"STARTING":               0,
		"RUNNING":                1,
		"COMPLETED":              2,
		"CANCELED":               3,
		"FAILED":                 4,
		"CANCELLATION_REQUESTED": 5,
		"ENQUEUED":               6,
		"PREPARING":              7,
		"PLANNING":               8,
	}
)

Enum value maps for QueryResult_QueryState.

View Source 
var File_UserBitShared_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type CoreOperatorType 

type CoreOperatorType int32
const (
	CoreOperatorType_SINGLE_SENDER                            CoreOperatorType = 0
	CoreOperatorType_BROADCAST_SENDER                         CoreOperatorType = 1
	CoreOperatorType_FILTER                                   CoreOperatorType = 2
	CoreOperatorType_HASH_AGGREGATE                           CoreOperatorType = 3
	CoreOperatorType_HASH_JOIN                                CoreOperatorType = 4
	CoreOperatorType_MERGE_JOIN                               CoreOperatorType = 5
	CoreOperatorType_HASH_PARTITION_SENDER                    CoreOperatorType = 6
	CoreOperatorType_LIMIT                                    CoreOperatorType = 7
	CoreOperatorType_MERGING_RECEIVER                         CoreOperatorType = 8
	CoreOperatorType_ORDERED_PARTITION_SENDER                 CoreOperatorType = 9
	CoreOperatorType_PROJECT                                  CoreOperatorType = 10
	CoreOperatorType_UNORDERED_RECEIVER                       CoreOperatorType = 11
	CoreOperatorType_RANGE_PARTITION_SENDER                   CoreOperatorType = 12
	CoreOperatorType_SCREEN                                   CoreOperatorType = 13
	CoreOperatorType_SELECTION_VECTOR_REMOVER                 CoreOperatorType = 14
	CoreOperatorType_STREAMING_AGGREGATE                      CoreOperatorType = 15
	CoreOperatorType_TOP_N_SORT                               CoreOperatorType = 16
	CoreOperatorType_EXTERNAL_SORT                            CoreOperatorType = 17
	CoreOperatorType_TRACE                                    CoreOperatorType = 18
	CoreOperatorType_UNION                                    CoreOperatorType = 19
	CoreOperatorType_OLD_SORT                                 CoreOperatorType = 20
	CoreOperatorType_PARQUET_ROW_GROUP_SCAN                   CoreOperatorType = 21
	CoreOperatorType_HIVE_SUB_SCAN                            CoreOperatorType = 22
	CoreOperatorType_SYSTEM_TABLE_SCAN                        CoreOperatorType = 23
	CoreOperatorType_MOCK_SUB_SCAN                            CoreOperatorType = 24
	CoreOperatorType_PARQUET_WRITER                           CoreOperatorType = 25
	CoreOperatorType_DIRECT_SUB_SCAN                          CoreOperatorType = 26
	CoreOperatorType_TEXT_WRITER                              CoreOperatorType = 27
	CoreOperatorType_TEXT_SUB_SCAN                            CoreOperatorType = 28
	CoreOperatorType_JSON_SUB_SCAN                            CoreOperatorType = 29
	CoreOperatorType_INFO_SCHEMA_SUB_SCAN                     CoreOperatorType = 30
	CoreOperatorType_COMPLEX_TO_JSON                          CoreOperatorType = 31
	CoreOperatorType_PRODUCER_CONSUMER                        CoreOperatorType = 32
	CoreOperatorType_HBASE_SUB_SCAN                           CoreOperatorType = 33
	CoreOperatorType_WINDOW                                   CoreOperatorType = 34
	CoreOperatorType_NESTED_LOOP_JOIN                         CoreOperatorType = 35
	CoreOperatorType_AVRO_SUB_SCAN                            CoreOperatorType = 36
	CoreOperatorType_PCAP_SUB_SCAN                            CoreOperatorType = 37
	CoreOperatorType_KAFKA_SUB_SCAN                           CoreOperatorType = 38
	CoreOperatorType_KUDU_SUB_SCAN                            CoreOperatorType = 39
	CoreOperatorType_FLATTEN                                  CoreOperatorType = 40
	CoreOperatorType_LATERAL_JOIN                             CoreOperatorType = 41
	CoreOperatorType_UNNEST                                   CoreOperatorType = 42
	CoreOperatorType_HIVE_DRILL_NATIVE_PARQUET_ROW_GROUP_SCAN CoreOperatorType = 43
	CoreOperatorType_JDBC_SCAN                                CoreOperatorType = 44
	CoreOperatorType_REGEX_SUB_SCAN                           CoreOperatorType = 45
	CoreOperatorType_MAPRDB_SUB_SCAN                          CoreOperatorType = 46
	CoreOperatorType_MONGO_SUB_SCAN                           CoreOperatorType = 47
	CoreOperatorType_KUDU_WRITER                              CoreOperatorType = 48
	CoreOperatorType_OPEN_TSDB_SUB_SCAN                       CoreOperatorType = 49
	CoreOperatorType_JSON_WRITER                              CoreOperatorType = 50
	CoreOperatorType_HTPPD_LOG_SUB_SCAN                       CoreOperatorType = 51
	CoreOperatorType_IMAGE_SUB_SCAN                           CoreOperatorType = 52
	CoreOperatorType_SEQUENCE_SUB_SCAN                        CoreOperatorType = 53
	CoreOperatorType_PARTITION_LIMIT                          CoreOperatorType = 54
	CoreOperatorType_PCAPNG_SUB_SCAN                          CoreOperatorType = 55
	CoreOperatorType_RUNTIME_FILTER                           CoreOperatorType = 56
	CoreOperatorType_ROWKEY_JOIN                              CoreOperatorType = 57
	CoreOperatorType_SYSLOG_SUB_SCAN                          CoreOperatorType = 58
	CoreOperatorType_STATISTICS_AGGREGATE                     CoreOperatorType = 59
	CoreOperatorType_UNPIVOT_MAPS                             CoreOperatorType = 60
	CoreOperatorType_STATISTICS_MERGE                         CoreOperatorType = 61
	CoreOperatorType_LTSV_SUB_SCAN                            CoreOperatorType = 62
	CoreOperatorType_HDF5_SUB_SCAN                            CoreOperatorType = 63
	CoreOperatorType_EXCEL_SUB_SCAN                           CoreOperatorType = 64
	CoreOperatorType_SHP_SUB_SCAN                             CoreOperatorType = 65
	CoreOperatorType_METADATA_HANDLER                         CoreOperatorType = 66
	CoreOperatorType_METADATA_CONTROLLER                      CoreOperatorType = 67
	CoreOperatorType_DRUID_SUB_SCAN                           CoreOperatorType = 68
	CoreOperatorType_SPSS_SUB_SCAN                            CoreOperatorType = 69
	CoreOperatorType_HTTP_SUB_SCAN                            CoreOperatorType = 70
)

func (CoreOperatorType) Descriptor 

func (CoreOperatorType) Descriptor() protoreflect.EnumDescriptor

func (CoreOperatorType) Enum 

func (x CoreOperatorType) Enum() *CoreOperatorType

func (CoreOperatorType) EnumDescriptor deprecated 

func (CoreOperatorType) EnumDescriptor() ([]byte, []int)

Deprecated: Use CoreOperatorType.Descriptor instead.

func (CoreOperatorType) Number 

func (x CoreOperatorType) Number() protoreflect.EnumNumber

func (CoreOperatorType) String 

func (x CoreOperatorType) String() string

func (CoreOperatorType) Type 

func (CoreOperatorType) Type() protoreflect.EnumType

func (*CoreOperatorType) UnmarshalJSON deprecated 

func (x *CoreOperatorType) UnmarshalJSON(b []byte) error

Deprecated: Do not use.

type DrillPBError 

type DrillPBError struct {
	ErrorId      *string                 `protobuf:"bytes,1,opt,name=error_id,json=errorId" json:"error_id,omitempty"` // for debug tracing purposes
	Endpoint     *exec.DrillbitEndpoint  `protobuf:"bytes,2,opt,name=endpoint" json:"endpoint,omitempty"`
	ErrorType    *DrillPBError_ErrorType `protobuf:"varint,3,opt,name=error_type,json=errorType,enum=exec.shared.DrillPBError_ErrorType" json:"error_type,omitempty"`
	Message      *string                 `protobuf:"bytes,4,opt,name=message" json:"message,omitempty"`
	Exception    *ExceptionWrapper       `protobuf:"bytes,5,opt,name=exception" json:"exception,omitempty"`
	ParsingError []*ParsingError         `protobuf:"bytes,6,rep,name=parsing_error,json=parsingError" json:"parsing_error,omitempty"` //optional, used when providing location of error within a piece of text.
	// contains filtered or unexported fields
}

func (*DrillPBError) Descriptor deprecated 

func (*DrillPBError) Descriptor() ([]byte, []int)

Deprecated: Use DrillPBError.ProtoReflect.Descriptor instead.

func (*DrillPBError) GetEndpoint 

func (x *DrillPBError) GetEndpoint() *exec.DrillbitEndpoint

func (*DrillPBError) GetErrorId 

func (x *DrillPBError) GetErrorId() string

func (*DrillPBError) GetErrorType 

func (x *DrillPBError) GetErrorType() DrillPBError_ErrorType

func (*DrillPBError) GetException 

func (x *DrillPBError) GetException() *ExceptionWrapper

func (*DrillPBError) GetMessage 

func (x *DrillPBError) GetMessage() string

func (*DrillPBError) GetParsingError 

func (x *DrillPBError) GetParsingError() []*ParsingError

func (*DrillPBError) ProtoMessage 

func (*DrillPBError) ProtoMessage()

func (*DrillPBError) ProtoReflect 

func (x *DrillPBError) ProtoReflect() protoreflect.Message

func (*DrillPBError) Reset 

func (x *DrillPBError) Reset()

func (*DrillPBError) String 

func (x *DrillPBError) String() string

type DrillPBError_ErrorType 

type DrillPBError_ErrorType int32
const (
	// equivalent to SQLClientInfoException
	// - handshake version error
	// - invalid schema
	DrillPBError_CONNECTION DrillPBError_ErrorType = 0
	// equivalent to SQLRecoverableException
	// - corrupt files: can't be read. FS read error
	// - parsing error due to incomplete or incorrectly written records
	DrillPBError_DATA_READ DrillPBError_ErrorType = 1
	// equivalent to SQLDataException
	// - data type unsupported by format
	DrillPBError_DATA_WRITE DrillPBError_ErrorType = 2
	// equivalent to SQLDataException
	// - Casting errors
	// - function not found for incoming types after implicit casting
	// - Flatten misuse
	DrillPBError_FUNCTION DrillPBError_ErrorType = 3
	// equivalent to SQLSyntaxErrorException
	// - typos
	// - missing table
	// - SQL keyword misuse
	// - function names/resolution
	DrillPBError_PARSE DrillPBError_ErrorType = 4
	// equivalent to SQLInvalidAuthorizationSpecException
	DrillPBError_PERMISSION DrillPBError_ErrorType = 5
	// equivalent to SQLNonTransientException
	DrillPBError_PLAN DrillPBError_ErrorType = 6
	// equivalent to SQLRecoverableException or SQLTransientException
	// - Recoverable: memory, disk
	// - Transient: network
	DrillPBError_RESOURCE DrillPBError_ErrorType = 7
	// equivalent to SQLNonTransientException.
	// - unexpected internal state
	// - uncategorized operation
	// general user action is to contact the Drill team for
	// assistance
	DrillPBError_SYSTEM DrillPBError_ErrorType = 8
	// equivalent to SQLFeatureNotSupportedException
	// - unimplemented feature, option, or execution path
	// - schema change in operator that does not support it
	DrillPBError_UNSUPPORTED_OPERATION DrillPBError_ErrorType = 9
	// SQL validation exception
	// - invalid schema path
	// - invalid entries in SQL tree
	DrillPBError_VALIDATION DrillPBError_ErrorType = 10
	// Execution exception
	//  - Internal errors not related to bad code
	DrillPBError_EXECUTION_ERROR DrillPBError_ErrorType = 11
	// Internal exception
	//  - Failed assertions
	//  - Other "this should not happen" cases
	DrillPBError_INTERNAL_ERROR DrillPBError_ErrorType = 12
	// Unspecified exception
	//  - Exception caught but cause is unknown
	// Indicates code that needs revisiting to move error reporting
	// closer to the cause.
	DrillPBError_UNSPECIFIED_ERROR DrillPBError_ErrorType = 13
)

func (DrillPBError_ErrorType) Descriptor 

func (DrillPBError_ErrorType) Descriptor() protoreflect.EnumDescriptor

func (DrillPBError_ErrorType) Enum 

func (x DrillPBError_ErrorType) Enum() *DrillPBError_ErrorType

func (DrillPBError_ErrorType) EnumDescriptor deprecated 

func (DrillPBError_ErrorType) EnumDescriptor() ([]byte, []int)

Deprecated: Use DrillPBError_ErrorType.Descriptor instead.

func (DrillPBError_ErrorType) Number 

func (x DrillPBError_ErrorType) Number() protoreflect.EnumNumber

func (DrillPBError_ErrorType) String 

func (x DrillPBError_ErrorType) String() string

func (DrillPBError_ErrorType) Type 

func (DrillPBError_ErrorType) Type() protoreflect.EnumType

func (*DrillPBError_ErrorType) UnmarshalJSON deprecated 

func (x *DrillPBError_ErrorType) UnmarshalJSON(b []byte) error

Deprecated: Do not use.

type ExceptionWrapper 

type ExceptionWrapper struct {
	ExceptionClass *string                     `protobuf:"bytes,1,opt,name=exception_class,json=exceptionClass" json:"exception_class,omitempty"`
	Message        *string                     `protobuf:"bytes,2,opt,name=message" json:"message,omitempty"`
	StackTrace     []*StackTraceElementWrapper `protobuf:"bytes,3,rep,name=stack_trace,json=stackTrace" json:"stack_trace,omitempty"`
	Cause          *ExceptionWrapper           `protobuf:"bytes,4,opt,name=cause" json:"cause,omitempty"`
	// contains filtered or unexported fields
}

func (*ExceptionWrapper) Descriptor deprecated 

func (*ExceptionWrapper) Descriptor() ([]byte, []int)

Deprecated: Use ExceptionWrapper.ProtoReflect.Descriptor instead.

func (*ExceptionWrapper) GetCause 

func (x *ExceptionWrapper) GetCause() *ExceptionWrapper

func (*ExceptionWrapper) GetExceptionClass 

func (x *ExceptionWrapper) GetExceptionClass() string

func (*ExceptionWrapper) GetMessage 

func (x *ExceptionWrapper) GetMessage() string

func (*ExceptionWrapper) GetStackTrace 

func (x *ExceptionWrapper) GetStackTrace() []*StackTraceElementWrapper

func (*ExceptionWrapper) ProtoMessage 

func (*ExceptionWrapper) ProtoMessage()

func (*ExceptionWrapper) ProtoReflect 

func (x *ExceptionWrapper) ProtoReflect() protoreflect.Message

func (*ExceptionWrapper) Reset 

func (x *ExceptionWrapper) Reset()

func (*ExceptionWrapper) String 

func (x *ExceptionWrapper) String() string

type FragmentState 

type FragmentState int32
const (
	FragmentState_SENDING                FragmentState = 0
	FragmentState_AWAITING_ALLOCATION    FragmentState = 1
	FragmentState_RUNNING                FragmentState = 2
	FragmentState_FINISHED               FragmentState = 3
	FragmentState_CANCELLED              FragmentState = 4
	FragmentState_FAILED                 FragmentState = 5
	FragmentState_CANCELLATION_REQUESTED FragmentState = 6
)

func (FragmentState) Descriptor 

func (FragmentState) Descriptor() protoreflect.EnumDescriptor

func (FragmentState) Enum 

func (x FragmentState) Enum() *FragmentState

func (FragmentState) EnumDescriptor deprecated 

func (FragmentState) EnumDescriptor() ([]byte, []int)

Deprecated: Use FragmentState.Descriptor instead.

func (FragmentState) Number 

func (x FragmentState) Number() protoreflect.EnumNumber

func (FragmentState) String 

func (x FragmentState) String() string

func (FragmentState) Type 

func (FragmentState) Type() protoreflect.EnumType

func (*FragmentState) UnmarshalJSON deprecated 

func (x *FragmentState) UnmarshalJSON(b []byte) error

Deprecated: Do not use.

type Jar 

type Jar struct {
	Name              *string  `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	FunctionSignature []string `protobuf:"bytes,2,rep,name=function_signature,json=functionSignature" json:"function_signature,omitempty"`
	// contains filtered or unexported fields
}

Jar contains jar name and list of function signatures. Function signature is concatenation of function name and its input parameters.

func (*Jar) Descriptor deprecated 

func (*Jar) Descriptor() ([]byte, []int)

Deprecated: Use Jar.ProtoReflect.Descriptor instead.

func (*Jar) GetFunctionSignature 

func (x *Jar) GetFunctionSignature() []string

func (*Jar) GetName 

func (x *Jar) GetName() string

func (*Jar) ProtoMessage 

func (*Jar) ProtoMessage()

func (*Jar) ProtoReflect 

func (x *Jar) ProtoReflect() protoreflect.Message

func (*Jar) Reset 

func (x *Jar) Reset()

func (*Jar) String 

func (x *Jar) String() string

type MajorFragmentProfile 

type MajorFragmentProfile struct {
	MajorFragmentId      *int32                  `protobuf:"varint,1,opt,name=major_fragment_id,json=majorFragmentId" json:"major_fragment_id,omitempty"`
	MinorFragmentProfile []*MinorFragmentProfile `protobuf:"bytes,2,rep,name=minor_fragment_profile,json=minorFragmentProfile" json:"minor_fragment_profile,omitempty"`
	// contains filtered or unexported fields
}

func (*MajorFragmentProfile) Descriptor deprecated 

func (*MajorFragmentProfile) Descriptor() ([]byte, []int)

Deprecated: Use MajorFragmentProfile.ProtoReflect.Descriptor instead.

func (*MajorFragmentProfile) GetMajorFragmentId 

func (x *MajorFragmentProfile) GetMajorFragmentId() int32

func (*MajorFragmentProfile) GetMinorFragmentProfile 

func (x *MajorFragmentProfile) GetMinorFragmentProfile() []*MinorFragmentProfile

func (*MajorFragmentProfile) ProtoMessage 

func (*MajorFragmentProfile) ProtoMessage()

func (*MajorFragmentProfile) ProtoReflect 

func (x *MajorFragmentProfile) ProtoReflect() protoreflect.Message

func (*MajorFragmentProfile) Reset 

func (x *MajorFragmentProfile) Reset()

func (*MajorFragmentProfile) String 

func (x *MajorFragmentProfile) String() string

type MetricValue 

type MetricValue struct {
	MetricId    *int32   `protobuf:"varint,1,opt,name=metric_id,json=metricId" json:"metric_id,omitempty"`
	LongValue   *int64   `protobuf:"varint,2,opt,name=long_value,json=longValue" json:"long_value,omitempty"`
	DoubleValue *float64 `protobuf:"fixed64,3,opt,name=double_value,json=doubleValue" json:"double_value,omitempty"`
	// contains filtered or unexported fields
}

func (*MetricValue) Descriptor deprecated 

func (*MetricValue) Descriptor() ([]byte, []int)

Deprecated: Use MetricValue.ProtoReflect.Descriptor instead.

func (*MetricValue) GetDoubleValue 

func (x *MetricValue) GetDoubleValue() float64

func (*MetricValue) GetLongValue 

func (x *MetricValue) GetLongValue() int64

func (*MetricValue) GetMetricId 

func (x *MetricValue) GetMetricId() int32

func (*MetricValue) ProtoMessage 

func (*MetricValue) ProtoMessage()

func (*MetricValue) ProtoReflect 

func (x *MetricValue) ProtoReflect() protoreflect.Message

func (*MetricValue) Reset 

func (x *MetricValue) Reset()

func (*MetricValue) String 

func (x *MetricValue) String() string

type MinorFragmentProfile 

type MinorFragmentProfile struct {
	State           *FragmentState         `protobuf:"varint,1,opt,name=state,enum=exec.shared.FragmentState" json:"state,omitempty"`
	Error           *DrillPBError          `protobuf:"bytes,2,opt,name=error" json:"error,omitempty"`
	MinorFragmentId *int32                 `protobuf:"varint,3,opt,name=minor_fragment_id,json=minorFragmentId" json:"minor_fragment_id,omitempty"`
	OperatorProfile []*OperatorProfile     `protobuf:"bytes,4,rep,name=operator_profile,json=operatorProfile" json:"operator_profile,omitempty"`
	StartTime       *int64                 `protobuf:"varint,5,opt,name=start_time,json=startTime" json:"start_time,omitempty"`
	EndTime         *int64                 `protobuf:"varint,6,opt,name=end_time,json=endTime" json:"end_time,omitempty"`
	MemoryUsed      *int64                 `protobuf:"varint,7,opt,name=memory_used,json=memoryUsed" json:"memory_used,omitempty"`
	MaxMemoryUsed   *int64                 `protobuf:"varint,8,opt,name=max_memory_used,json=maxMemoryUsed" json:"max_memory_used,omitempty"`
	Endpoint        *exec.DrillbitEndpoint `protobuf:"bytes,9,opt,name=endpoint" json:"endpoint,omitempty"`
	LastUpdate      *int64                 `protobuf:"varint,10,opt,name=last_update,json=lastUpdate" json:"last_update,omitempty"`
	LastProgress    *int64                 `protobuf:"varint,11,opt,name=last_progress,json=lastProgress" json:"last_progress,omitempty"`
	// contains filtered or unexported fields
}

func (*MinorFragmentProfile) Descriptor deprecated 

func (*MinorFragmentProfile) Descriptor() ([]byte, []int)

Deprecated: Use MinorFragmentProfile.ProtoReflect.Descriptor instead.

func (*MinorFragmentProfile) GetEndTime 

func (x *MinorFragmentProfile) GetEndTime() int64

func (*MinorFragmentProfile) GetEndpoint 

func (x *MinorFragmentProfile) GetEndpoint() *exec.DrillbitEndpoint

func (*MinorFragmentProfile) GetError 

func (x *MinorFragmentProfile) GetError() *DrillPBError

func (*MinorFragmentProfile) GetLastProgress 

func (x *MinorFragmentProfile) GetLastProgress() int64

func (*MinorFragmentProfile) GetLastUpdate 

func (x *MinorFragmentProfile) GetLastUpdate() int64

func (*MinorFragmentProfile) GetMaxMemoryUsed 

func (x *MinorFragmentProfile) GetMaxMemoryUsed() int64

func (*MinorFragmentProfile) GetMemoryUsed 

func (x *MinorFragmentProfile) GetMemoryUsed() int64

func (*MinorFragmentProfile) GetMinorFragmentId 

func (x *MinorFragmentProfile) GetMinorFragmentId() int32

func (*MinorFragmentProfile) GetOperatorProfile 

func (x *MinorFragmentProfile) GetOperatorProfile() []*OperatorProfile

func (*MinorFragmentProfile) GetStartTime 

func (x *MinorFragmentProfile) GetStartTime() int64

func (*MinorFragmentProfile) GetState 

func (x *MinorFragmentProfile) GetState() FragmentState

func (*MinorFragmentProfile) ProtoMessage 

func (*MinorFragmentProfile) ProtoMessage()

func (*MinorFragmentProfile) ProtoReflect 

func (x *MinorFragmentProfile) ProtoReflect() protoreflect.Message

func (*MinorFragmentProfile) Reset 

func (x *MinorFragmentProfile) Reset()

func (*MinorFragmentProfile) String 

func (x *MinorFragmentProfile) String() string

type NamePart 

type NamePart struct {
	Type  *NamePart_Type `protobuf:"varint,1,opt,name=type,enum=exec.shared.NamePart_Type" json:"type,omitempty"`
	Name  *string        `protobuf:"bytes,2,opt,name=name" json:"name,omitempty"`
	Child *NamePart      `protobuf:"bytes,3,opt,name=child" json:"child,omitempty"`
	// contains filtered or unexported fields
}

func (*NamePart) Descriptor deprecated 

func (*NamePart) Descriptor() ([]byte, []int)

Deprecated: Use NamePart.ProtoReflect.Descriptor instead.

func (*NamePart) GetChild 

func (x *NamePart) GetChild() *NamePart

func (*NamePart) GetName 

func (x *NamePart) GetName() string

func (*NamePart) GetType 

func (x *NamePart) GetType() NamePart_Type

func (*NamePart) ProtoMessage 

func (*NamePart) ProtoMessage()

func (*NamePart) ProtoReflect 

func (x *NamePart) ProtoReflect() protoreflect.Message

func (*NamePart) Reset 

func (x *NamePart) Reset()

func (*NamePart) String 

func (x *NamePart) String() string

type NamePart_Type 

type NamePart_Type int32
const (
	NamePart_NAME  NamePart_Type = 0
	NamePart_ARRAY NamePart_Type = 1
)

func (NamePart_Type) Descriptor 

func (NamePart_Type) Descriptor() protoreflect.EnumDescriptor

func (NamePart_Type) Enum 

func (x NamePart_Type) Enum() *NamePart_Type

func (NamePart_Type) EnumDescriptor deprecated 

func (NamePart_Type) EnumDescriptor() ([]byte, []int)

Deprecated: Use NamePart_Type.Descriptor instead.

func (NamePart_Type) Number 

func (x NamePart_Type) Number() protoreflect.EnumNumber

func (NamePart_Type) String 

func (x NamePart_Type) String() string

func (NamePart_Type) Type 

func (NamePart_Type) Type() protoreflect.EnumType

func (*NamePart_Type) UnmarshalJSON deprecated 

func (x *NamePart_Type) UnmarshalJSON(b []byte) error

Deprecated: Do not use.

type NodeStatus 

type NodeStatus struct {
	NodeId          *int32 `protobuf:"varint,1,opt,name=node_id,json=nodeId" json:"node_id,omitempty"`
	MemoryFootprint *int64 `protobuf:"varint,2,opt,name=memory_footprint,json=memoryFootprint" json:"memory_footprint,omitempty"`
	// contains filtered or unexported fields
}

func (*NodeStatus) Descriptor deprecated 

func (*NodeStatus) Descriptor() ([]byte, []int)

Deprecated: Use NodeStatus.ProtoReflect.Descriptor instead.

func (*NodeStatus) GetMemoryFootprint 

func (x *NodeStatus) GetMemoryFootprint() int64

func (*NodeStatus) GetNodeId 

func (x *NodeStatus) GetNodeId() int32

func (*NodeStatus) ProtoMessage 

func (*NodeStatus) ProtoMessage()

func (*NodeStatus) ProtoReflect 

func (x *NodeStatus) ProtoReflect() protoreflect.Message

func (*NodeStatus) Reset 

func (x *NodeStatus) Reset()

func (*NodeStatus) String 

func (x *NodeStatus) String() string

type OperatorProfile 

type OperatorProfile struct {
	InputProfile             []*StreamProfile `protobuf:"bytes,1,rep,name=input_profile,json=inputProfile" json:"input_profile,omitempty"`
	OperatorId               *int32           `protobuf:"varint,3,opt,name=operator_id,json=operatorId" json:"operator_id,omitempty"`
	OperatorType             *int32           `protobuf:"varint,4,opt,name=operator_type,json=operatorType" json:"operator_type,omitempty"`
	SetupNanos               *int64           `protobuf:"varint,5,opt,name=setup_nanos,json=setupNanos" json:"setup_nanos,omitempty"`
	ProcessNanos             *int64           `protobuf:"varint,6,opt,name=process_nanos,json=processNanos" json:"process_nanos,omitempty"`
	PeakLocalMemoryAllocated *int64           `` /* 131-byte string literal not displayed */
	Metric                   []*MetricValue   `protobuf:"bytes,8,rep,name=metric" json:"metric,omitempty"`
	WaitNanos                *int64           `protobuf:"varint,9,opt,name=wait_nanos,json=waitNanos" json:"wait_nanos,omitempty"`
	// contains filtered or unexported fields
}

func (*OperatorProfile) Descriptor deprecated 

func (*OperatorProfile) Descriptor() ([]byte, []int)

Deprecated: Use OperatorProfile.ProtoReflect.Descriptor instead.

func (*OperatorProfile) GetInputProfile 

func (x *OperatorProfile) GetInputProfile() []*StreamProfile

func (*OperatorProfile) GetMetric 

func (x *OperatorProfile) GetMetric() []*MetricValue

func (*OperatorProfile) GetOperatorId 

func (x *OperatorProfile) GetOperatorId() int32

func (*OperatorProfile) GetOperatorType 

func (x *OperatorProfile) GetOperatorType() int32

func (*OperatorProfile) GetPeakLocalMemoryAllocated 

func (x *OperatorProfile) GetPeakLocalMemoryAllocated() int64

func (*OperatorProfile) GetProcessNanos 

func (x *OperatorProfile) GetProcessNanos() int64

func (*OperatorProfile) GetSetupNanos 

func (x *OperatorProfile) GetSetupNanos() int64

func (*OperatorProfile) GetWaitNanos 

func (x *OperatorProfile) GetWaitNanos() int64

func (*OperatorProfile) ProtoMessage 

func (*OperatorProfile) ProtoMessage()

func (*OperatorProfile) ProtoReflect 

func (x *OperatorProfile) ProtoReflect() protoreflect.Message

func (*OperatorProfile) Reset 

func (x *OperatorProfile) Reset()

func (*OperatorProfile) String 

func (x *OperatorProfile) String() string

type ParsingError 

type ParsingError struct {
	StartColumn *int32 `protobuf:"varint,2,opt,name=start_column,json=startColumn" json:"start_column,omitempty"`
	StartRow    *int32 `protobuf:"varint,3,opt,name=start_row,json=startRow" json:"start_row,omitempty"`
	EndColumn   *int32 `protobuf:"varint,4,opt,name=end_column,json=endColumn" json:"end_column,omitempty"`
	EndRow      *int32 `protobuf:"varint,5,opt,name=end_row,json=endRow" json:"end_row,omitempty"`
	// contains filtered or unexported fields
}

func (*ParsingError) Descriptor deprecated 

func (*ParsingError) Descriptor() ([]byte, []int)

Deprecated: Use ParsingError.ProtoReflect.Descriptor instead.

func (*ParsingError) GetEndColumn 

func (x *ParsingError) GetEndColumn() int32

func (*ParsingError) GetEndRow 

func (x *ParsingError) GetEndRow() int32

func (*ParsingError) GetStartColumn 

func (x *ParsingError) GetStartColumn() int32

func (*ParsingError) GetStartRow 

func (x *ParsingError) GetStartRow() int32

func (*ParsingError) ProtoMessage 

func (*ParsingError) ProtoMessage()

func (*ParsingError) ProtoReflect 

func (x *ParsingError) ProtoReflect() protoreflect.Message

func (*ParsingError) Reset 

func (x *ParsingError) Reset()

func (*ParsingError) String 

func (x *ParsingError) String() string

type QueryData 

type QueryData struct {
	QueryId           *QueryId        `protobuf:"bytes,1,opt,name=query_id,json=queryId" json:"query_id,omitempty"`
	RowCount          *int32          `protobuf:"varint,2,opt,name=row_count,json=rowCount" json:"row_count,omitempty"`
	Def               *RecordBatchDef `protobuf:"bytes,3,opt,name=def" json:"def,omitempty"`
	AffectedRowsCount *int32          `protobuf:"varint,4,opt,name=affected_rows_count,json=affectedRowsCount" json:"affected_rows_count,omitempty"`
	// contains filtered or unexported fields
}

Used by the server when sending query result data batches to the client

func (*QueryData) Descriptor deprecated 

func (*QueryData) Descriptor() ([]byte, []int)

Deprecated: Use QueryData.ProtoReflect.Descriptor instead.

func (*QueryData) GetAffectedRowsCount 

func (x *QueryData) GetAffectedRowsCount() int32

func (*QueryData) GetDef 

func (x *QueryData) GetDef() *RecordBatchDef

func (*QueryData) GetQueryId 

func (x *QueryData) GetQueryId() *QueryId

func (*QueryData) GetRowCount 

func (x *QueryData) GetRowCount() int32

func (*QueryData) ProtoMessage 

func (*QueryData) ProtoMessage()

func (*QueryData) ProtoReflect 

func (x *QueryData) ProtoReflect() protoreflect.Message

func (*QueryData) Reset 

func (x *QueryData) Reset()

func (*QueryData) String 

func (x *QueryData) String() string

type QueryId 

type QueryId struct {
	Part1 *int64 `protobuf:"fixed64,1,opt,name=part1" json:"part1,omitempty"`
	Part2 *int64 `protobuf:"fixed64,2,opt,name=part2" json:"part2,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryId) Descriptor deprecated 

func (*QueryId) Descriptor() ([]byte, []int)

Deprecated: Use QueryId.ProtoReflect.Descriptor instead.

func (*QueryId) GetPart1 

func (x *QueryId) GetPart1() int64

func (*QueryId) GetPart2 

func (x *QueryId) GetPart2() int64

func (*QueryId) ProtoMessage 

func (*QueryId) ProtoMessage()

func (*QueryId) ProtoReflect 

func (x *QueryId) ProtoReflect() protoreflect.Message

func (*QueryId) Reset 

func (x *QueryId) Reset()

func (*QueryId) String 

func (x *QueryId) String() string

type QueryInfo 

type QueryInfo struct {
	Query       *string                 `protobuf:"bytes,1,opt,name=query" json:"query,omitempty"`
	Start       *int64                  `protobuf:"varint,2,opt,name=start" json:"start,omitempty"`
	State       *QueryResult_QueryState `protobuf:"varint,3,opt,name=state,enum=exec.shared.QueryResult_QueryState" json:"state,omitempty"`
	User        *string                 `protobuf:"bytes,4,opt,name=user,def=-" json:"user,omitempty"`
	Foreman     *exec.DrillbitEndpoint  `protobuf:"bytes,5,opt,name=foreman" json:"foreman,omitempty"`
	OptionsJson *string                 `protobuf:"bytes,6,opt,name=options_json,json=optionsJson" json:"options_json,omitempty"`
	TotalCost   *float64                `protobuf:"fixed64,7,opt,name=total_cost,json=totalCost" json:"total_cost,omitempty"`
	QueueName   *string                 `protobuf:"bytes,8,opt,name=queue_name,json=queueName,def=-" json:"queue_name,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryInfo) Descriptor deprecated 

func (*QueryInfo) Descriptor() ([]byte, []int)

Deprecated: Use QueryInfo.ProtoReflect.Descriptor instead.

func (*QueryInfo) GetForeman 

func (x *QueryInfo) GetForeman() *exec.DrillbitEndpoint

func (*QueryInfo) GetOptionsJson 

func (x *QueryInfo) GetOptionsJson() string

func (*QueryInfo) GetQuery 

func (x *QueryInfo) GetQuery() string

func (*QueryInfo) GetQueueName 

func (x *QueryInfo) GetQueueName() string

func (*QueryInfo) GetStart 

func (x *QueryInfo) GetStart() int64

func (*QueryInfo) GetState 

func (x *QueryInfo) GetState() QueryResult_QueryState

func (*QueryInfo) GetTotalCost 

func (x *QueryInfo) GetTotalCost() float64

func (*QueryInfo) GetUser 

func (x *QueryInfo) GetUser() string

func (*QueryInfo) ProtoMessage 

func (*QueryInfo) ProtoMessage()

func (*QueryInfo) ProtoReflect 

func (x *QueryInfo) ProtoReflect() protoreflect.Message

func (*QueryInfo) Reset 

func (x *QueryInfo) Reset()

func (*QueryInfo) String 

func (x *QueryInfo) String() string

type QueryProfile 

type QueryProfile struct {
	Id                *QueryId                `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
	Type              *QueryType              `protobuf:"varint,2,opt,name=type,enum=exec.shared.QueryType" json:"type,omitempty"`
	Start             *int64                  `protobuf:"varint,3,opt,name=start" json:"start,omitempty"`
	End               *int64                  `protobuf:"varint,4,opt,name=end" json:"end,omitempty"`
	Query             *string                 `protobuf:"bytes,5,opt,name=query" json:"query,omitempty"`
	Plan              *string                 `protobuf:"bytes,6,opt,name=plan" json:"plan,omitempty"`
	Foreman           *exec.DrillbitEndpoint  `protobuf:"bytes,7,opt,name=foreman" json:"foreman,omitempty"`
	State             *QueryResult_QueryState `protobuf:"varint,8,opt,name=state,enum=exec.shared.QueryResult_QueryState" json:"state,omitempty"`
	TotalFragments    *int32                  `protobuf:"varint,9,opt,name=total_fragments,json=totalFragments" json:"total_fragments,omitempty"`
	FinishedFragments *int32                  `protobuf:"varint,10,opt,name=finished_fragments,json=finishedFragments" json:"finished_fragments,omitempty"`
	FragmentProfile   []*MajorFragmentProfile `protobuf:"bytes,11,rep,name=fragment_profile,json=fragmentProfile" json:"fragment_profile,omitempty"`
	User              *string                 `protobuf:"bytes,12,opt,name=user,def=-" json:"user,omitempty"`
	Error             *string                 `protobuf:"bytes,13,opt,name=error" json:"error,omitempty"`
	VerboseError      *string                 `protobuf:"bytes,14,opt,name=verboseError" json:"verboseError,omitempty"`
	ErrorId           *string                 `protobuf:"bytes,15,opt,name=error_id,json=errorId" json:"error_id,omitempty"`
	ErrorNode         *string                 `protobuf:"bytes,16,opt,name=error_node,json=errorNode" json:"error_node,omitempty"`
	OptionsJson       *string                 `protobuf:"bytes,17,opt,name=options_json,json=optionsJson" json:"options_json,omitempty"`
	PlanEnd           *int64                  `protobuf:"varint,18,opt,name=planEnd" json:"planEnd,omitempty"`
	QueueWaitEnd      *int64                  `protobuf:"varint,19,opt,name=queueWaitEnd" json:"queueWaitEnd,omitempty"`
	TotalCost         *float64                `protobuf:"fixed64,20,opt,name=total_cost,json=totalCost" json:"total_cost,omitempty"`
	QueueName         *string                 `protobuf:"bytes,21,opt,name=queue_name,json=queueName,def=-" json:"queue_name,omitempty"`
	QueryId           *string                 `protobuf:"bytes,22,opt,name=queryId" json:"queryId,omitempty"`
	AutoLimit         *int32                  `protobuf:"varint,23,opt,name=autoLimit" json:"autoLimit,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryProfile) Descriptor deprecated 

func (*QueryProfile) Descriptor() ([]byte, []int)

Deprecated: Use QueryProfile.ProtoReflect.Descriptor instead.

func (*QueryProfile) GetAutoLimit 

func (x *QueryProfile) GetAutoLimit() int32

func (*QueryProfile) GetEnd 

func (x *QueryProfile) GetEnd() int64

func (*QueryProfile) GetError 

func (x *QueryProfile) GetError() string

func (*QueryProfile) GetErrorId 

func (x *QueryProfile) GetErrorId() string

func (*QueryProfile) GetErrorNode 

func (x *QueryProfile) GetErrorNode() string

func (*QueryProfile) GetFinishedFragments 

func (x *QueryProfile) GetFinishedFragments() int32

func (*QueryProfile) GetForeman 

func (x *QueryProfile) GetForeman() *exec.DrillbitEndpoint

func (*QueryProfile) GetFragmentProfile 

func (x *QueryProfile) GetFragmentProfile() []*MajorFragmentProfile

func (*QueryProfile) GetId 

func (x *QueryProfile) GetId() *QueryId

func (*QueryProfile) GetOptionsJson 

func (x *QueryProfile) GetOptionsJson() string

func (*QueryProfile) GetPlan 

func (x *QueryProfile) GetPlan() string

func (*QueryProfile) GetPlanEnd 

func (x *QueryProfile) GetPlanEnd() int64

func (*QueryProfile) GetQuery 

func (x *QueryProfile) GetQuery() string

func (*QueryProfile) GetQueryId 

func (x *QueryProfile) GetQueryId() string

func (*QueryProfile) GetQueueName 

func (x *QueryProfile) GetQueueName() string

func (*QueryProfile) GetQueueWaitEnd 

func (x *QueryProfile) GetQueueWaitEnd() int64

func (*QueryProfile) GetStart 

func (x *QueryProfile) GetStart() int64

func (*QueryProfile) GetState 

func (x *QueryProfile) GetState() QueryResult_QueryState

func (*QueryProfile) GetTotalCost 

func (x *QueryProfile) GetTotalCost() float64

func (*QueryProfile) GetTotalFragments 

func (x *QueryProfile) GetTotalFragments() int32

func (*QueryProfile) GetType 

func (x *QueryProfile) GetType() QueryType

func (*QueryProfile) GetUser 

func (x *QueryProfile) GetUser() string

func (*QueryProfile) GetVerboseError 

func (x *QueryProfile) GetVerboseError() string

func (*QueryProfile) ProtoMessage 

func (*QueryProfile) ProtoMessage()

func (*QueryProfile) ProtoReflect 

func (x *QueryProfile) ProtoReflect() protoreflect.Message

func (*QueryProfile) Reset 

func (x *QueryProfile) Reset()

func (*QueryProfile) String 

func (x *QueryProfile) String() string

type QueryResult 

type QueryResult struct {
	QueryState *QueryResult_QueryState `protobuf:"varint,1,opt,name=query_state,json=queryState,enum=exec.shared.QueryResult_QueryState" json:"query_state,omitempty"`
	QueryId    *QueryId                `protobuf:"bytes,2,opt,name=query_id,json=queryId" json:"query_id,omitempty"`
	Error      []*DrillPBError         `protobuf:"bytes,3,rep,name=error" json:"error,omitempty"`
	// contains filtered or unexported fields
}

Used by the server to report informations about the query state to the client

func (*QueryResult) Descriptor deprecated 

func (*QueryResult) Descriptor() ([]byte, []int)

Deprecated: Use QueryResult.ProtoReflect.Descriptor instead.

func (*QueryResult) GetError 

func (x *QueryResult) GetError() []*DrillPBError

func (*QueryResult) GetQueryId 

func (x *QueryResult) GetQueryId() *QueryId

func (*QueryResult) GetQueryState 

func (x *QueryResult) GetQueryState() QueryResult_QueryState

func (*QueryResult) ProtoMessage 

func (*QueryResult) ProtoMessage()

func (*QueryResult) ProtoReflect 

func (x *QueryResult) ProtoReflect() protoreflect.Message

func (*QueryResult) Reset 

func (x *QueryResult) Reset()

func (*QueryResult) String 

func (x *QueryResult) String() string

type QueryResult_QueryState 

type QueryResult_QueryState int32
const (
	QueryResult_STARTING               QueryResult_QueryState = 0 // query has been scheduled for execution. This is post-enqueued.
	QueryResult_RUNNING                QueryResult_QueryState = 1
	QueryResult_COMPLETED              QueryResult_QueryState = 2 // query has completed successfully
	QueryResult_CANCELED               QueryResult_QueryState = 3 // query has been cancelled, and all cleanup is complete
	QueryResult_FAILED                 QueryResult_QueryState = 4
	QueryResult_CANCELLATION_REQUESTED QueryResult_QueryState = 5 // cancellation has been requested, and is being processed
	QueryResult_ENQUEUED               QueryResult_QueryState = 6 // query has been enqueued. this is pre-starting.
	QueryResult_PREPARING              QueryResult_QueryState = 7 // query is at preparation stage, foreman is initializing
	QueryResult_PLANNING               QueryResult_QueryState = 8 // query is at planning stage (includes logical or / and physical planning)
)

func (QueryResult_QueryState) Descriptor 

func (QueryResult_QueryState) Descriptor() protoreflect.EnumDescriptor

func (QueryResult_QueryState) Enum 

func (x QueryResult_QueryState) Enum() *QueryResult_QueryState

func (QueryResult_QueryState) EnumDescriptor deprecated 

func (QueryResult_QueryState) EnumDescriptor() ([]byte, []int)

Deprecated: Use QueryResult_QueryState.Descriptor instead.

func (QueryResult_QueryState) Number 

func (x QueryResult_QueryState) Number() protoreflect.EnumNumber

func (QueryResult_QueryState) String 

func (x QueryResult_QueryState) String() string

func (QueryResult_QueryState) Type 

func (QueryResult_QueryState) Type() protoreflect.EnumType

func (*QueryResult_QueryState) UnmarshalJSON deprecated 

func (x *QueryResult_QueryState) UnmarshalJSON(b []byte) error

Deprecated: Do not use.

type QueryType 

type QueryType int32
const (
	QueryType_SQL       QueryType = 1
	QueryType_LOGICAL   QueryType = 2
	QueryType_PHYSICAL  QueryType = 3
	QueryType_EXECUTION QueryType = 4
	// Input is a prepared statement
	QueryType_PREPARED_STATEMENT QueryType = 5
)

func (QueryType) Descriptor 

func (QueryType) Descriptor() protoreflect.EnumDescriptor

func (QueryType) Enum 

func (x QueryType) Enum() *QueryType

func (QueryType) EnumDescriptor deprecated 

func (QueryType) EnumDescriptor() ([]byte, []int)

Deprecated: Use QueryType.Descriptor instead.

func (QueryType) Number 

func (x QueryType) Number() protoreflect.EnumNumber

func (QueryType) String 

func (x QueryType) String() string

func (QueryType) Type 

func (QueryType) Type() protoreflect.EnumType

func (*QueryType) UnmarshalJSON deprecated 

func (x *QueryType) UnmarshalJSON(b []byte) error

Deprecated: Do not use.

type RecordBatchDef 

type RecordBatchDef struct {
	RecordCount                   *int32             `protobuf:"varint,1,opt,name=record_count,json=recordCount" json:"record_count,omitempty"`
	Field                         []*SerializedField `protobuf:"bytes,2,rep,name=field" json:"field,omitempty"`
	CarriesTwoByteSelectionVector *bool              `` /* 148-byte string literal not displayed */
	// The value is set when result set is disabled and its value corresponds to number
	// of rows affected by query (see JDBC java.sql.ResultSet#getUpdateCount())
	AffectedRowsCount *int32 `protobuf:"varint,4,opt,name=affected_rows_count,json=affectedRowsCount" json:"affected_rows_count,omitempty"`
	// contains filtered or unexported fields
}

func (*RecordBatchDef) Descriptor deprecated 

func (*RecordBatchDef) Descriptor() ([]byte, []int)

Deprecated: Use RecordBatchDef.ProtoReflect.Descriptor instead.

func (*RecordBatchDef) GetAffectedRowsCount 

func (x *RecordBatchDef) GetAffectedRowsCount() int32

func (*RecordBatchDef) GetCarriesTwoByteSelectionVector 

func (x *RecordBatchDef) GetCarriesTwoByteSelectionVector() bool

func (*RecordBatchDef) GetField 

func (x *RecordBatchDef) GetField() []*SerializedField

func (*RecordBatchDef) GetRecordCount 

func (x *RecordBatchDef) GetRecordCount() int32

func (*RecordBatchDef) ProtoMessage 

func (*RecordBatchDef) ProtoMessage()

func (*RecordBatchDef) ProtoReflect 

func (x *RecordBatchDef) ProtoReflect() protoreflect.Message

func (*RecordBatchDef) Reset 

func (x *RecordBatchDef) Reset()

func (*RecordBatchDef) String 

func (x *RecordBatchDef) String() string

type Registry 

type Registry struct {
	Jar []*Jar `protobuf:"bytes,1,rep,name=jar" json:"jar,omitempty"`
	// contains filtered or unexported fields
}

Registry that contains list of jars, each jar contains its name and list of function signatures. Structure example: REGISTRY -> Jar1.jar -> upper(VARCHAR-REQUIRED) -> upper(VARCHAR-OPTIONAL)

-> Jar2.jar -> lower(VARCHAR-REQUIRED) -> lower(VARCHAR-OPTIONAL)

func (*Registry) Descriptor deprecated 

func (*Registry) Descriptor() ([]byte, []int)

Deprecated: Use Registry.ProtoReflect.Descriptor instead.

func (*Registry) GetJar 

func (x *Registry) GetJar() []*Jar

func (*Registry) ProtoMessage 

func (*Registry) ProtoMessage()

func (*Registry) ProtoReflect 

func (x *Registry) ProtoReflect() protoreflect.Message

func (*Registry) Reset 

func (x *Registry) Reset()

func (*Registry) String 

func (x *Registry) String() string

type RpcChannel 

type RpcChannel int32
const (
	RpcChannel_BIT_CONTROL RpcChannel = 0
	RpcChannel_BIT_DATA    RpcChannel = 1
	RpcChannel_USER        RpcChannel = 2
)

func (RpcChannel) Descriptor 

func (RpcChannel) Descriptor() protoreflect.EnumDescriptor

func (RpcChannel) Enum 

func (x RpcChannel) Enum() *RpcChannel

func (RpcChannel) EnumDescriptor deprecated 

func (RpcChannel) EnumDescriptor() ([]byte, []int)

Deprecated: Use RpcChannel.Descriptor instead.

func (RpcChannel) Number 

func (x RpcChannel) Number() protoreflect.EnumNumber

func (RpcChannel) String 

func (x RpcChannel) String() string

func (RpcChannel) Type 

func (RpcChannel) Type() protoreflect.EnumType

func (*RpcChannel) UnmarshalJSON deprecated 

func (x *RpcChannel) UnmarshalJSON(b []byte) error

Deprecated: Do not use.

type SaslMessage 

type SaslMessage struct {
	Mechanism *string     `protobuf:"bytes,1,opt,name=mechanism" json:"mechanism,omitempty"`
	Data      []byte      `protobuf:"bytes,2,opt,name=data" json:"data,omitempty"`
	Status    *SaslStatus `protobuf:"varint,3,opt,name=status,enum=exec.shared.SaslStatus" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*SaslMessage) Descriptor deprecated 

func (*SaslMessage) Descriptor() ([]byte, []int)

Deprecated: Use SaslMessage.ProtoReflect.Descriptor instead.

func (*SaslMessage) GetData 

func (x *SaslMessage) GetData() []byte

func (*SaslMessage) GetMechanism 

func (x *SaslMessage) GetMechanism() string

func (*SaslMessage) GetStatus 

func (x *SaslMessage) GetStatus() SaslStatus

func (*SaslMessage) ProtoMessage 

func (*SaslMessage) ProtoMessage()

func (*SaslMessage) ProtoReflect 

func (x *SaslMessage) ProtoReflect() protoreflect.Message

func (*SaslMessage) Reset 

func (x *SaslMessage) Reset()

func (*SaslMessage) String 

func (x *SaslMessage) String() string

type SaslStatus 

type SaslStatus int32
const (
	SaslStatus_SASL_UNKNOWN     SaslStatus = 0
	SaslStatus_SASL_START       SaslStatus = 1
	SaslStatus_SASL_IN_PROGRESS SaslStatus = 2
	SaslStatus_SASL_SUCCESS     SaslStatus = 3
	SaslStatus_SASL_FAILED      SaslStatus = 4
)

func (SaslStatus) Descriptor 

func (SaslStatus) Descriptor() protoreflect.EnumDescriptor

func (SaslStatus) Enum 

func (x SaslStatus) Enum() *SaslStatus

func (SaslStatus) EnumDescriptor deprecated 

func (SaslStatus) EnumDescriptor() ([]byte, []int)

Deprecated: Use SaslStatus.Descriptor instead.

func (SaslStatus) Number 

func (x SaslStatus) Number() protoreflect.EnumNumber

func (SaslStatus) String 

func (x SaslStatus) String() string

func (SaslStatus) Type 

func (SaslStatus) Type() protoreflect.EnumType

func (*SaslStatus) UnmarshalJSON deprecated 

func (x *SaslStatus) UnmarshalJSON(b []byte) error

Deprecated: Do not use.

type SerializedField 

type SerializedField struct {
	MajorType     *common.MajorType  `protobuf:"bytes,1,opt,name=major_type,json=majorType" json:"major_type,omitempty"` // the type associated with this field.
	NamePart      *NamePart          `protobuf:"bytes,2,opt,name=name_part,json=namePart" json:"name_part,omitempty"`
	Child         []*SerializedField `protobuf:"bytes,3,rep,name=child" json:"child,omitempty"` // only in the cases of type == MAP or REPEAT_MAP or REPEATED_LIST
	ValueCount    *int32             `protobuf:"varint,4,opt,name=value_count,json=valueCount" json:"value_count,omitempty"`
	VarByteLength *int32             `protobuf:"varint,5,opt,name=var_byte_length,json=varByteLength" json:"var_byte_length,omitempty"`
	BufferLength  *int32             `protobuf:"varint,7,opt,name=buffer_length,json=bufferLength" json:"buffer_length,omitempty"`
	// contains filtered or unexported fields
}

func (*SerializedField) Descriptor deprecated 

func (*SerializedField) Descriptor() ([]byte, []int)

Deprecated: Use SerializedField.ProtoReflect.Descriptor instead.

func (*SerializedField) GetBufferLength 

func (x *SerializedField) GetBufferLength() int32

func (*SerializedField) GetChild 

func (x *SerializedField) GetChild() []*SerializedField

func (*SerializedField) GetMajorType 

func (x *SerializedField) GetMajorType() *common.MajorType

func (*SerializedField) GetNamePart 

func (x *SerializedField) GetNamePart() *NamePart

func (*SerializedField) GetValueCount 

func (x *SerializedField) GetValueCount() int32

func (*SerializedField) GetVarByteLength 

func (x *SerializedField) GetVarByteLength() int32

func (*SerializedField) ProtoMessage 

func (*SerializedField) ProtoMessage()

func (*SerializedField) ProtoReflect 

func (x *SerializedField) ProtoReflect() protoreflect.Message

func (*SerializedField) Reset 

func (x *SerializedField) Reset()

func (*SerializedField) String 

func (x *SerializedField) String() string

type StackTraceElementWrapper 

type StackTraceElementWrapper struct {
	ClassName      *string `protobuf:"bytes,1,opt,name=class_name,json=className" json:"class_name,omitempty"`
	FileName       *string `protobuf:"bytes,2,opt,name=file_name,json=fileName" json:"file_name,omitempty"`
	LineNumber     *int32  `protobuf:"varint,3,opt,name=line_number,json=lineNumber" json:"line_number,omitempty"`
	MethodName     *string `protobuf:"bytes,4,opt,name=method_name,json=methodName" json:"method_name,omitempty"`
	IsNativeMethod *bool   `protobuf:"varint,5,opt,name=is_native_method,json=isNativeMethod" json:"is_native_method,omitempty"`
	// contains filtered or unexported fields
}

func (*StackTraceElementWrapper) Descriptor deprecated 

func (*StackTraceElementWrapper) Descriptor() ([]byte, []int)

Deprecated: Use StackTraceElementWrapper.ProtoReflect.Descriptor instead.

func (*StackTraceElementWrapper) GetClassName 

func (x *StackTraceElementWrapper) GetClassName() string

func (*StackTraceElementWrapper) GetFileName 

func (x *StackTraceElementWrapper) GetFileName() string

func (*StackTraceElementWrapper) GetIsNativeMethod 

func (x *StackTraceElementWrapper) GetIsNativeMethod() bool

func (*StackTraceElementWrapper) GetLineNumber 

func (x *StackTraceElementWrapper) GetLineNumber() int32

func (*StackTraceElementWrapper) GetMethodName 

func (x *StackTraceElementWrapper) GetMethodName() string

func (*StackTraceElementWrapper) ProtoMessage 

func (*StackTraceElementWrapper) ProtoMessage()

func (*StackTraceElementWrapper) ProtoReflect 

func (x *StackTraceElementWrapper) ProtoReflect() protoreflect.Message

func (*StackTraceElementWrapper) Reset 

func (x *StackTraceElementWrapper) Reset()

func (*StackTraceElementWrapper) String 

func (x *StackTraceElementWrapper) String() string

type StreamProfile 

type StreamProfile struct {
	Records *int64 `protobuf:"varint,1,opt,name=records" json:"records,omitempty"`
	Batches *int64 `protobuf:"varint,2,opt,name=batches" json:"batches,omitempty"`
	Schemas *int64 `protobuf:"varint,3,opt,name=schemas" json:"schemas,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamProfile) Descriptor deprecated 

func (*StreamProfile) Descriptor() ([]byte, []int)

Deprecated: Use StreamProfile.ProtoReflect.Descriptor instead.

func (*StreamProfile) GetBatches 

func (x *StreamProfile) GetBatches() int64

func (*StreamProfile) GetRecords 

func (x *StreamProfile) GetRecords() int64

func (*StreamProfile) GetSchemas 

func (x *StreamProfile) GetSchemas() int64

func (*StreamProfile) ProtoMessage 

func (*StreamProfile) ProtoMessage()

func (*StreamProfile) ProtoReflect 

func (x *StreamProfile) ProtoReflect() protoreflect.Message

func (*StreamProfile) Reset 

func (x *StreamProfile) Reset()

func (*StreamProfile) String 

func (x *StreamProfile) String() string

type UserCredentials 

type UserCredentials struct {
	UserName *string `protobuf:"bytes,1,opt,name=user_name,json=userName" json:"user_name,omitempty"`
	// contains filtered or unexported fields
}

func (*UserCredentials) Descriptor deprecated 

func (*UserCredentials) Descriptor() ([]byte, []int)

Deprecated: Use UserCredentials.ProtoReflect.Descriptor instead.

func (*UserCredentials) GetUserName 

func (x *UserCredentials) GetUserName() string

func (*UserCredentials) ProtoMessage 

func (*UserCredentials) ProtoMessage()

func (*UserCredentials) ProtoReflect 

func (x *UserCredentials) ProtoReflect() protoreflect.Message

func (*UserCredentials) Reset 

func (x *UserCredentials) Reset()

func (*UserCredentials) String 

func (x *UserCredentials) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.