protos

package
v0.5.11-rc.2 Latest Latest
Warning

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

 Go to latest Published: Oct 8, 2024 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	EDateTimeFormat_name = map[int32]string{
		0: "DATE_TIME_FORMAT_UNSPECIFIED",
		1: "STRING_FORMAT",
		2: "YQL_FORMAT",
	}
	EDateTimeFormat_value = map[string]int32{
		"DATE_TIME_FORMAT_UNSPECIFIED": 0,
		"STRING_FORMAT":                1,
		"YQL_FORMAT":                   2,
	}
)

Enum value maps for EDateTimeFormat.

View Source 
var (
	TReadSplitsRequest_EMode_name = map[int32]string{
		0: "MODE_UNSPECIFIED",
		1: "ORDERED",
		2: "UNORDERED",
	}
	TReadSplitsRequest_EMode_value = map[string]int32{
		"MODE_UNSPECIFIED": 0,
		"ORDERED":          1,
		"UNORDERED":        2,
	}
)

Enum value maps for TReadSplitsRequest_EMode.

View Source 
var (
	TReadSplitsRequest_EFormat_name = map[int32]string{
		0: "FORMAT_UNSPECIFIED",
		2: "ARROW_IPC_STREAMING",
	}
	TReadSplitsRequest_EFormat_value = map[string]int32{
		"FORMAT_UNSPECIFIED":  0,
		"ARROW_IPC_STREAMING": 2,
	}
)

Enum value maps for TReadSplitsRequest_EFormat.

View Source 
var (
	TReadSplitsRequest_EFiltering_name = map[int32]string{
		0: "FILTERING_UNSPECIFIED",
		1: "FILTERING_OPTIONAL",
		2: "FILTERING_MANDATORY",
	}
	TReadSplitsRequest_EFiltering_value = map[string]int32{
		"FILTERING_UNSPECIFIED": 0,
		"FILTERING_OPTIONAL":    1,
		"FILTERING_MANDATORY":   2,
	}
)

Enum value maps for TReadSplitsRequest_EFiltering.

View Source 
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,
	}
)

Enum value maps for TExpression_TArithmeticalExpression_EOperation.

View Source 
var (
	TPredicate_TComparison_EOperation_name = map[int32]string{
		0: "COMPARISON_OPERATION_UNSPECIFIED",
		1: "L",
		2: "LE",
		3: "EQ",
		4: "NE",
		5: "GE",
		6: "G",
	}
	TPredicate_TComparison_EOperation_value = map[string]int32{
		"COMPARISON_OPERATION_UNSPECIFIED": 0,
		"L":                                1,
		"LE":                               2,
		"EQ":                               3,
		"NE":                               4,
		"GE":                               5,
		"G":                                6,
	}
)

Enum value maps for TPredicate_TComparison_EOperation.

View Source 
var File_ydb_library_yql_providers_generic_connector_api_service_protos_connector_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type EDateTimeFormat 

type EDateTimeFormat int32
const (
	EDateTimeFormat_DATE_TIME_FORMAT_UNSPECIFIED EDateTimeFormat = 0
	EDateTimeFormat_STRING_FORMAT                EDateTimeFormat = 1
	EDateTimeFormat_YQL_FORMAT                   EDateTimeFormat = 2
)

func (EDateTimeFormat) Descriptor 

func (EDateTimeFormat) Descriptor() protoreflect.EnumDescriptor

func (EDateTimeFormat) Enum 

func (x EDateTimeFormat) Enum() *EDateTimeFormat

func (EDateTimeFormat) EnumDescriptor deprecated 

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

Deprecated: Use EDateTimeFormat.Descriptor instead.

func (EDateTimeFormat) Number 

func (x EDateTimeFormat) Number() protoreflect.EnumNumber

func (EDateTimeFormat) String 

func (x EDateTimeFormat) String() string

func (EDateTimeFormat) Type 

func (EDateTimeFormat) Type() protoreflect.EnumType

type TAst 

type TAst struct {

	// Types that are assignable to Payload:
	//
	//	*TAst_Atom
	//	*TAst_List
	Payload isTAst_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

TAst is an internal representation of an YQL request. Advanced connectors may use it for the full-fledged implementations of the push down.

func (*TAst) Descriptor deprecated 

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

Deprecated: Use TAst.ProtoReflect.Descriptor instead.

func (*TAst) GetAtom 

func (x *TAst) GetAtom() []byte

func (*TAst) GetList 

func (x *TAst) GetList() *TAst_TList

func (*TAst) GetPayload 

func (m *TAst) GetPayload() isTAst_Payload

func (*TAst) ProtoMessage 

func (*TAst) ProtoMessage()

func (*TAst) ProtoReflect 

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

func (*TAst) Reset 

func (x *TAst) Reset()

func (*TAst) String 

func (x *TAst) String() string

type TAst_Atom 

type TAst_Atom struct {
	Atom []byte `protobuf:"bytes,1,opt,name=atom,proto3,oneof"`
}

type TAst_List 

type TAst_List struct {
	List *TAst_TList `protobuf:"bytes,2,opt,name=list,proto3,oneof"`
}

type TAst_TList 

type TAst_TList struct {
	Children []*TAst `protobuf:"bytes,1,rep,name=children,proto3" json:"children,omitempty"`
	// contains filtered or unexported fields
}

func (*TAst_TList) Descriptor deprecated 

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

Deprecated: Use TAst_TList.ProtoReflect.Descriptor instead.

func (*TAst_TList) GetChildren 

func (x *TAst_TList) GetChildren() []*TAst

func (*TAst_TList) ProtoMessage 

func (*TAst_TList) ProtoMessage()

func (*TAst_TList) ProtoReflect 

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

func (*TAst_TList) Reset 

func (x *TAst_TList) Reset()

func (*TAst_TList) String 

func (x *TAst_TList) String() string

type TContinuation 

type TContinuation struct {

	// Types that are assignable to Payload:
	//
	//	*TContinuation_Description
	Payload isTContinuation_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

Continuation is a special type useful for the request retry. In case if split reading was interrupted, the engine does not have to read all the split data from the very beginning, it can specify the location from where it wants to reread the data instead.

func (*TContinuation) Descriptor deprecated 

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

Deprecated: Use TContinuation.ProtoReflect.Descriptor instead.

func (*TContinuation) GetDescription 

func (x *TContinuation) GetDescription() []byte

func (*TContinuation) GetPayload 

func (m *TContinuation) GetPayload() isTContinuation_Payload

func (*TContinuation) ProtoMessage 

func (*TContinuation) ProtoMessage()

func (*TContinuation) ProtoReflect 

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

func (*TContinuation) Reset 

func (x *TContinuation) Reset()

func (*TContinuation) String 

func (x *TContinuation) String() string

type TContinuation_Description 

type TContinuation_Description struct {
	// In general description should be opaque to YQ.
	Description []byte `protobuf:"bytes,1,opt,name=description,proto3,oneof"`
}

type TDescribeTableRequest 

type TDescribeTableRequest struct {

	// Data source instance to connect
	DataSourceInstance *common.TDataSourceInstance `protobuf:"bytes,1,opt,name=data_source_instance,json=dataSourceInstance,proto3" json:"data_source_instance,omitempty"`
	// Table to describe
	Table string `protobuf:"bytes,2,opt,name=table,proto3" json:"table,omitempty"`
	// Rules for type mapping
	TypeMappingSettings *TTypeMappingSettings `protobuf:"bytes,3,opt,name=type_mapping_settings,json=typeMappingSettings,proto3" json:"type_mapping_settings,omitempty"`
	// contains filtered or unexported fields
}

TDescribeTableRequest requests table metadata

func (*TDescribeTableRequest) Descriptor deprecated 

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

Deprecated: Use TDescribeTableRequest.ProtoReflect.Descriptor instead.

func (*TDescribeTableRequest) GetDataSourceInstance 

func (x *TDescribeTableRequest) GetDataSourceInstance() *common.TDataSourceInstance

func (*TDescribeTableRequest) GetTable 

func (x *TDescribeTableRequest) GetTable() string

func (*TDescribeTableRequest) GetTypeMappingSettings 

func (x *TDescribeTableRequest) GetTypeMappingSettings() *TTypeMappingSettings

func (*TDescribeTableRequest) ProtoMessage 

func (*TDescribeTableRequest) ProtoMessage()

func (*TDescribeTableRequest) ProtoReflect 

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

func (*TDescribeTableRequest) Reset 

func (x *TDescribeTableRequest) Reset()

func (*TDescribeTableRequest) String 

func (x *TDescribeTableRequest) String() string

type TDescribeTableResponse 

type TDescribeTableResponse struct {

	// The whole schema of a table
	Schema *TSchema `protobuf:"bytes,1,opt,name=schema,proto3" json:"schema,omitempty"`
	// Call result
	Error *TError `protobuf:"bytes,100,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

TDescribeTableResponse returns table metadata

func (*TDescribeTableResponse) Descriptor deprecated 

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

Deprecated: Use TDescribeTableResponse.ProtoReflect.Descriptor instead.

func (*TDescribeTableResponse) GetError 

func (x *TDescribeTableResponse) GetError() *TError

func (*TDescribeTableResponse) GetSchema 

func (x *TDescribeTableResponse) GetSchema() *TSchema

func (*TDescribeTableResponse) ProtoMessage 

func (*TDescribeTableResponse) ProtoMessage()

func (*TDescribeTableResponse) ProtoReflect 

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

func (*TDescribeTableResponse) Reset 

func (x *TDescribeTableResponse) Reset()

func (*TDescribeTableResponse) String 

func (x *TDescribeTableResponse) String() string

type TError 

type TError struct {

	// High-level code
	Status Ydb.StatusIds_StatusCode `protobuf:"varint,1,opt,name=status,proto3,enum=Ydb.StatusIds_StatusCode" json:"status,omitempty"`
	// Error message
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// Detailed explanation of a problem;
	// must be empty if status == SUCCESS
	Issues []*Ydb_Issue.IssueMessage `protobuf:"bytes,3,rep,name=issues,proto3" json:"issues,omitempty"`
	// contains filtered or unexported fields
}

Special type to describe the result of any operation

func (*TError) Descriptor deprecated 

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

Deprecated: Use TError.ProtoReflect.Descriptor instead.

func (*TError) GetIssues 

func (x *TError) GetIssues() []*Ydb_Issue.IssueMessage

func (*TError) GetMessage 

func (x *TError) GetMessage() string

func (*TError) GetStatus 

func (x *TError) GetStatus() Ydb.StatusIds_StatusCode

func (*TError) ProtoMessage 

func (*TError) ProtoMessage()

func (*TError) ProtoReflect 

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

func (*TError) Reset 

func (x *TError) Reset()

func (*TError) String 

func (x *TError) String() string

type TExpression 

type TExpression struct {

	// Types that are assignable to Payload:
	//
	//	*TExpression_TypedValue
	//	*TExpression_Column
	//	*TExpression_ArithmeticalExpression
	//	*TExpression_Null
	Payload isTExpression_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

Expression with value Can be a column, a constant or a result of, for example, some arithmetical operation

func (*TExpression) Descriptor deprecated 

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

Deprecated: Use TExpression.ProtoReflect.Descriptor instead.

func (*TExpression) GetArithmeticalExpression 

func (x *TExpression) GetArithmeticalExpression() *TExpression_TArithmeticalExpression

func (*TExpression) GetColumn 

func (x *TExpression) GetColumn() string

func (*TExpression) GetNull 

func (x *TExpression) GetNull() *TExpression_TNull

func (*TExpression) GetPayload 

func (m *TExpression) GetPayload() isTExpression_Payload

func (*TExpression) GetTypedValue 

func (x *TExpression) GetTypedValue() *Ydb.TypedValue

func (*TExpression) ProtoMessage 

func (*TExpression) ProtoMessage()

func (*TExpression) ProtoReflect 

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

func (*TExpression) Reset 

func (x *TExpression) Reset()

func (*TExpression) String 

func (x *TExpression) String() string

type TExpression_ArithmeticalExpression 

type TExpression_ArithmeticalExpression struct {
	ArithmeticalExpression *TExpression_TArithmeticalExpression `protobuf:"bytes,3,opt,name=arithmetical_expression,json=arithmeticalExpression,proto3,oneof"`
}

type TExpression_Column 

type TExpression_Column struct {
	// A name of another column to compare with
	Column string `protobuf:"bytes,2,opt,name=column,proto3,oneof"`
}

type TExpression_Null 

type TExpression_Null struct {
	Null *TExpression_TNull `protobuf:"bytes,4,opt,name=null,proto3,oneof"`
}

type TExpression_TArithmeticalExpression 

type TExpression_TArithmeticalExpression struct {
	Operation  TExpression_TArithmeticalExpression_EOperation `` /* 145-byte string literal not displayed */
	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"`
	// contains filtered or unexported fields
}

func (*TExpression_TArithmeticalExpression) Descriptor deprecated 

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

Deprecated: Use TExpression_TArithmeticalExpression.ProtoReflect.Descriptor instead.

func (*TExpression_TArithmeticalExpression) GetLeftValue 

func (x *TExpression_TArithmeticalExpression) GetLeftValue() *TExpression

func (*TExpression_TArithmeticalExpression) GetOperation 

func (x *TExpression_TArithmeticalExpression) GetOperation() TExpression_TArithmeticalExpression_EOperation

func (*TExpression_TArithmeticalExpression) GetRightValue 

func (x *TExpression_TArithmeticalExpression) GetRightValue() *TExpression

func (*TExpression_TArithmeticalExpression) ProtoMessage 

func (*TExpression_TArithmeticalExpression) ProtoMessage()

func (*TExpression_TArithmeticalExpression) ProtoReflect 

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

func (*TExpression_TArithmeticalExpression) Reset 

func (x *TExpression_TArithmeticalExpression) Reset()

func (*TExpression_TArithmeticalExpression) String 

func (x *TExpression_TArithmeticalExpression) String() string

type TExpression_TArithmeticalExpression_EOperation 

type TExpression_TArithmeticalExpression_EOperation int32

An operation code. 

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
)

func (TExpression_TArithmeticalExpression_EOperation) Descriptor 

func (TExpression_TArithmeticalExpression_EOperation) Descriptor() protoreflect.EnumDescriptor

func (TExpression_TArithmeticalExpression_EOperation) Enum 

func (x TExpression_TArithmeticalExpression_EOperation) Enum() *TExpression_TArithmeticalExpression_EOperation

func (TExpression_TArithmeticalExpression_EOperation) EnumDescriptor deprecated 

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

Deprecated: Use TExpression_TArithmeticalExpression_EOperation.Descriptor instead.

func (TExpression_TArithmeticalExpression_EOperation) Number 

func (x TExpression_TArithmeticalExpression_EOperation) Number() protoreflect.EnumNumber

func (TExpression_TArithmeticalExpression_EOperation) String 

func (x TExpression_TArithmeticalExpression_EOperation) String() string

func (TExpression_TArithmeticalExpression_EOperation) Type 

func (TExpression_TArithmeticalExpression_EOperation) Type() protoreflect.EnumType

type TExpression_TNull 

type TExpression_TNull struct {
	// contains filtered or unexported fields
}

func (*TExpression_TNull) Descriptor deprecated 

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

Deprecated: Use TExpression_TNull.ProtoReflect.Descriptor instead.

func (*TExpression_TNull) ProtoMessage 

func (*TExpression_TNull) ProtoMessage()

func (*TExpression_TNull) ProtoReflect 

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

func (*TExpression_TNull) Reset 

func (x *TExpression_TNull) Reset()

func (*TExpression_TNull) String 

func (x *TExpression_TNull) String() string

type TExpression_TypedValue 

type TExpression_TypedValue struct {
	// A scalar value
	TypedValue *Ydb.TypedValue `protobuf:"bytes,1,opt,name=typed_value,json=typedValue,proto3,oneof"`
}

type TListSplitsRequest 

type TListSplitsRequest struct {

	// YQ engine may want to read data from different tables simultaneously.
	// Perhaps Connector will provide consistency guarantees across the tables some day.
	Selects []*TSelect `protobuf:"bytes,2,rep,name=selects,proto3" json:"selects,omitempty"`
	// Defines the number of splits (and, as a consequence, affects the size of the split).
	// If you don't want splitting, set 1.
	MaxSplitCount uint32 `protobuf:"varint,3,opt,name=max_split_count,json=maxSplitCount,proto3" json:"max_split_count,omitempty"`
	// Connector will try to divide the data into the splits of this size,
	// but the exact match is not guaranteed.
	// Also this setting can be overridden by max_split_count.
	SplitSize uint64 `protobuf:"varint,4,opt,name=split_size,json=splitSize,proto3" json:"split_size,omitempty"`
	// Sometimes YQ doesn't know the exact size of the data set,
	// so it asks Connector to split the data into the splits of $split_size,
	// and the $max_split_count = MaxUINT32.
	// But if the data is too large, and too many splits will be generated,
	// this may exceed the memory available for YQ.
	// In such case, it's better to fail fast. This limit helps to implement it:
	SplitNumberLimit uint64 `protobuf:"varint,5,opt,name=split_number_limit,json=splitNumberLimit,proto3" json:"split_number_limit,omitempty"`
	// contains filtered or unexported fields
}

TListSplitRequest asks Connector to split the requested data into elementary parts.

func (*TListSplitsRequest) Descriptor deprecated 

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

Deprecated: Use TListSplitsRequest.ProtoReflect.Descriptor instead.

func (*TListSplitsRequest) GetMaxSplitCount 

func (x *TListSplitsRequest) GetMaxSplitCount() uint32

func (*TListSplitsRequest) GetSelects 

func (x *TListSplitsRequest) GetSelects() []*TSelect

func (*TListSplitsRequest) GetSplitNumberLimit 

func (x *TListSplitsRequest) GetSplitNumberLimit() uint64

func (*TListSplitsRequest) GetSplitSize 

func (x *TListSplitsRequest) GetSplitSize() uint64

func (*TListSplitsRequest) ProtoMessage 

func (*TListSplitsRequest) ProtoMessage()

func (*TListSplitsRequest) ProtoReflect 

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

func (*TListSplitsRequest) Reset 

func (x *TListSplitsRequest) Reset()

func (*TListSplitsRequest) String 

func (x *TListSplitsRequest) String() string

type TListSplitsResponse 

type TListSplitsResponse struct {

	// the list of splits for concurrent reading
	Splits []*TSplit `protobuf:"bytes,1,rep,name=splits,proto3" json:"splits,omitempty"`
	// Call result
	Error *TError `protobuf:"bytes,100,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

TListSplitResponse returns the list of splits for a particular set of table partitions

func (*TListSplitsResponse) Descriptor deprecated 

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

Deprecated: Use TListSplitsResponse.ProtoReflect.Descriptor instead.

func (*TListSplitsResponse) GetError 

func (x *TListSplitsResponse) GetError() *TError

func (*TListSplitsResponse) GetSplits 

func (x *TListSplitsResponse) GetSplits() []*TSplit

func (*TListSplitsResponse) ProtoMessage 

func (*TListSplitsResponse) ProtoMessage()

func (*TListSplitsResponse) ProtoReflect 

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

func (*TListSplitsResponse) Reset 

func (x *TListSplitsResponse) Reset()

func (*TListSplitsResponse) String 

func (x *TListSplitsResponse) String() string

type TListTablesRequest 

type TListTablesRequest struct {

	// Data source instance to connect
	DataSourceInstance *common.TDataSourceInstance `protobuf:"bytes,1,opt,name=data_source_instance,json=dataSourceInstance,proto3" json:"data_source_instance,omitempty"`
	// There may be a huge number of tables in the data source,
	// and here are ways to extract only necessary ones:
	//
	// Types that are assignable to Filtering:
	//
	//	*TListTablesRequest_Pattern
	Filtering isTListTablesRequest_Filtering `protobuf_oneof:"filtering"`
	// contains filtered or unexported fields
}

TListTablesRequest requests the list of tables in a particular database of the data source

func (*TListTablesRequest) Descriptor deprecated 

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

Deprecated: Use TListTablesRequest.ProtoReflect.Descriptor instead.

func (*TListTablesRequest) GetDataSourceInstance 

func (x *TListTablesRequest) GetDataSourceInstance() *common.TDataSourceInstance

func (*TListTablesRequest) GetFiltering 

func (m *TListTablesRequest) GetFiltering() isTListTablesRequest_Filtering

func (*TListTablesRequest) GetPattern 

func (x *TListTablesRequest) GetPattern() string

func (*TListTablesRequest) ProtoMessage 

func (*TListTablesRequest) ProtoMessage()

func (*TListTablesRequest) ProtoReflect 

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

func (*TListTablesRequest) Reset 

func (x *TListTablesRequest) Reset()

func (*TListTablesRequest) String 

func (x *TListTablesRequest) String() string

type TListTablesRequest_Pattern 

type TListTablesRequest_Pattern struct {
	// Regexp to filter table names
	Pattern string `protobuf:"bytes,2,opt,name=pattern,proto3,oneof"`
}

type TListTablesResponse 

type TListTablesResponse struct {

	// Table names list
	Tables []string `protobuf:"bytes,1,rep,name=tables,proto3" json:"tables,omitempty"`
	// Call result
	Error *TError `protobuf:"bytes,100,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

TListTablesResponse returns the list of tables in a particular database of the data source

func (*TListTablesResponse) Descriptor deprecated 

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

Deprecated: Use TListTablesResponse.ProtoReflect.Descriptor instead.

func (*TListTablesResponse) GetError 

func (x *TListTablesResponse) GetError() *TError

func (*TListTablesResponse) GetTables 

func (x *TListTablesResponse) GetTables() []string

func (*TListTablesResponse) ProtoMessage 

func (*TListTablesResponse) ProtoMessage()

func (*TListTablesResponse) ProtoReflect 

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

func (*TListTablesResponse) Reset 

func (x *TListTablesResponse) Reset()

func (*TListTablesResponse) String 

func (x *TListTablesResponse) String() string

type TPredicate 

type TPredicate struct {

	// Types that are assignable to Payload:
	//
	//	*TPredicate_Negation
	//	*TPredicate_Conjunction
	//	*TPredicate_Disjunction
	//	*TPredicate_Between
	//	*TPredicate_In
	//	*TPredicate_IsNull
	//	*TPredicate_IsNotNull
	//	*TPredicate_Comparison
	//	*TPredicate_BoolExpression
	Payload isTPredicate_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

Predicate

func (*TPredicate) Descriptor deprecated 

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

Deprecated: Use TPredicate.ProtoReflect.Descriptor instead.

func (*TPredicate) GetBetween 

func (x *TPredicate) GetBetween() *TPredicate_TBetween

func (*TPredicate) GetBoolExpression 

func (x *TPredicate) GetBoolExpression() *TPredicate_TBoolExpression

func (*TPredicate) GetComparison 

func (x *TPredicate) GetComparison() *TPredicate_TComparison

func (*TPredicate) GetConjunction 

func (x *TPredicate) GetConjunction() *TPredicate_TConjunction

func (*TPredicate) GetDisjunction 

func (x *TPredicate) GetDisjunction() *TPredicate_TDisjunction

func (*TPredicate) GetIn 

func (x *TPredicate) GetIn() *TPredicate_TIn

func (*TPredicate) GetIsNotNull 

func (x *TPredicate) GetIsNotNull() *TPredicate_TIsNotNull

func (*TPredicate) GetIsNull 

func (x *TPredicate) GetIsNull() *TPredicate_TIsNull

func (*TPredicate) GetNegation 

func (x *TPredicate) GetNegation() *TPredicate_TNegation

func (*TPredicate) GetPayload 

func (m *TPredicate) GetPayload() isTPredicate_Payload

func (*TPredicate) ProtoMessage 

func (*TPredicate) ProtoMessage()

func (*TPredicate) ProtoReflect 

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

func (*TPredicate) Reset 

func (x *TPredicate) Reset()

func (*TPredicate) String 

func (x *TPredicate) String() string

type TPredicate_Between 

type TPredicate_Between struct {
	Between *TPredicate_TBetween `protobuf:"bytes,4,opt,name=between,proto3,oneof"`
}

type TPredicate_BoolExpression 

type TPredicate_BoolExpression struct {
	BoolExpression *TPredicate_TBoolExpression `protobuf:"bytes,9,opt,name=bool_expression,json=boolExpression,proto3,oneof"`
}

type TPredicate_Comparison 

type TPredicate_Comparison struct {
	Comparison *TPredicate_TComparison `protobuf:"bytes,8,opt,name=comparison,proto3,oneof"`
}

type TPredicate_Conjunction 

type TPredicate_Conjunction struct {
	Conjunction *TPredicate_TConjunction `protobuf:"bytes,2,opt,name=conjunction,proto3,oneof"`
}

type TPredicate_Disjunction 

type TPredicate_Disjunction struct {
	Disjunction *TPredicate_TDisjunction `protobuf:"bytes,3,opt,name=disjunction,proto3,oneof"`
}

type TPredicate_In 

type TPredicate_In struct {
	In *TPredicate_TIn `protobuf:"bytes,5,opt,name=in,proto3,oneof"`
}

type TPredicate_IsNotNull 

type TPredicate_IsNotNull struct {
	IsNotNull *TPredicate_TIsNotNull `protobuf:"bytes,7,opt,name=is_not_null,json=isNotNull,proto3,oneof"`
}

type TPredicate_IsNull 

type TPredicate_IsNull struct {
	IsNull *TPredicate_TIsNull `protobuf:"bytes,6,opt,name=is_null,json=isNull,proto3,oneof"`
}

type TPredicate_Negation 

type TPredicate_Negation struct {
	Negation *TPredicate_TNegation `protobuf:"bytes,1,opt,name=negation,proto3,oneof"`
}

type TPredicate_TBetween 

type TPredicate_TBetween struct {
	Value    *TExpression `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	Least    *TExpression `protobuf:"bytes,2,opt,name=least,proto3" json:"least,omitempty"`
	Greatest *TExpression `protobuf:"bytes,3,opt,name=greatest,proto3" json:"greatest,omitempty"`
	// contains filtered or unexported fields
}

"$column BETWEEN $least AND $greatest"

func (*TPredicate_TBetween) Descriptor deprecated 

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

Deprecated: Use TPredicate_TBetween.ProtoReflect.Descriptor instead.

func (*TPredicate_TBetween) GetGreatest 

func (x *TPredicate_TBetween) GetGreatest() *TExpression

func (*TPredicate_TBetween) GetLeast 

func (x *TPredicate_TBetween) GetLeast() *TExpression

func (*TPredicate_TBetween) GetValue 

func (x *TPredicate_TBetween) GetValue() *TExpression

func (*TPredicate_TBetween) ProtoMessage 

func (*TPredicate_TBetween) ProtoMessage()

func (*TPredicate_TBetween) ProtoReflect 

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

func (*TPredicate_TBetween) Reset 

func (x *TPredicate_TBetween) Reset()

func (*TPredicate_TBetween) String 

func (x *TPredicate_TBetween) String() string

type TPredicate_TBoolExpression 

type TPredicate_TBoolExpression struct {
	Value *TExpression `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

Expression wich has bool type For example, bool column

func (*TPredicate_TBoolExpression) Descriptor deprecated 

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

Deprecated: Use TPredicate_TBoolExpression.ProtoReflect.Descriptor instead.

func (*TPredicate_TBoolExpression) GetValue 

func (x *TPredicate_TBoolExpression) GetValue() *TExpression

func (*TPredicate_TBoolExpression) ProtoMessage 

func (*TPredicate_TBoolExpression) ProtoMessage()

func (*TPredicate_TBoolExpression) ProtoReflect 

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

func (*TPredicate_TBoolExpression) Reset 

func (x *TPredicate_TBoolExpression) Reset()

func (*TPredicate_TBoolExpression) String 

func (x *TPredicate_TBoolExpression) String() string

type TPredicate_TComparison 

type TPredicate_TComparison struct {
	Operation  TPredicate_TComparison_EOperation `` /* 132-byte string literal not displayed */
	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"`
	// contains filtered or unexported fields
}

A subset of comparators corresponding to the binary logical operators

func (*TPredicate_TComparison) Descriptor deprecated 

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

Deprecated: Use TPredicate_TComparison.ProtoReflect.Descriptor instead.

func (*TPredicate_TComparison) GetLeftValue 

func (x *TPredicate_TComparison) GetLeftValue() *TExpression

func (*TPredicate_TComparison) GetOperation 

func (x *TPredicate_TComparison) GetOperation() TPredicate_TComparison_EOperation

func (*TPredicate_TComparison) GetRightValue 

func (x *TPredicate_TComparison) GetRightValue() *TExpression

func (*TPredicate_TComparison) ProtoMessage 

func (*TPredicate_TComparison) ProtoMessage()

func (*TPredicate_TComparison) ProtoReflect 

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

func (*TPredicate_TComparison) Reset 

func (x *TPredicate_TComparison) Reset()

func (*TPredicate_TComparison) String 

func (x *TPredicate_TComparison) String() string

type TPredicate_TComparison_EOperation 

type TPredicate_TComparison_EOperation int32

An operation code. 

const (
	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"
)

func (TPredicate_TComparison_EOperation) Descriptor 

func (TPredicate_TComparison_EOperation) Descriptor() protoreflect.EnumDescriptor

func (TPredicate_TComparison_EOperation) Enum 

func (x TPredicate_TComparison_EOperation) Enum() *TPredicate_TComparison_EOperation

func (TPredicate_TComparison_EOperation) EnumDescriptor deprecated 

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

Deprecated: Use TPredicate_TComparison_EOperation.Descriptor instead.

func (TPredicate_TComparison_EOperation) Number 

func (x TPredicate_TComparison_EOperation) Number() protoreflect.EnumNumber

func (TPredicate_TComparison_EOperation) String 

func (x TPredicate_TComparison_EOperation) String() string

func (TPredicate_TComparison_EOperation) Type 

func (TPredicate_TComparison_EOperation) Type() protoreflect.EnumType

type TPredicate_TConjunction 

type TPredicate_TConjunction struct {
	Operands []*TPredicate `protobuf:"bytes,1,rep,name=operands,proto3" json:"operands,omitempty"`
	// contains filtered or unexported fields
}

AND

func (*TPredicate_TConjunction) Descriptor deprecated 

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

Deprecated: Use TPredicate_TConjunction.ProtoReflect.Descriptor instead.

func (*TPredicate_TConjunction) GetOperands 

func (x *TPredicate_TConjunction) GetOperands() []*TPredicate

func (*TPredicate_TConjunction) ProtoMessage 

func (*TPredicate_TConjunction) ProtoMessage()

func (*TPredicate_TConjunction) ProtoReflect 

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

func (*TPredicate_TConjunction) Reset 

func (x *TPredicate_TConjunction) Reset()

func (*TPredicate_TConjunction) String 

func (x *TPredicate_TConjunction) String() string

type TPredicate_TDisjunction 

type TPredicate_TDisjunction struct {
	Operands []*TPredicate `protobuf:"bytes,1,rep,name=operands,proto3" json:"operands,omitempty"`
	// contains filtered or unexported fields
}

OR

func (*TPredicate_TDisjunction) Descriptor deprecated 

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

Deprecated: Use TPredicate_TDisjunction.ProtoReflect.Descriptor instead.

func (*TPredicate_TDisjunction) GetOperands 

func (x *TPredicate_TDisjunction) GetOperands() []*TPredicate

func (*TPredicate_TDisjunction) ProtoMessage 

func (*TPredicate_TDisjunction) ProtoMessage()

func (*TPredicate_TDisjunction) ProtoReflect 

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

func (*TPredicate_TDisjunction) Reset 

func (x *TPredicate_TDisjunction) Reset()

func (*TPredicate_TDisjunction) String 

func (x *TPredicate_TDisjunction) String() string

type TPredicate_TIn 

type TPredicate_TIn struct {
	Value *TExpression   `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	Set   []*TExpression `protobuf:"bytes,2,rep,name=set,proto3" json:"set,omitempty"`
	// contains filtered or unexported fields
}

"$column IN $(set)"

func (*TPredicate_TIn) Descriptor deprecated 

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

Deprecated: Use TPredicate_TIn.ProtoReflect.Descriptor instead.

func (*TPredicate_TIn) GetSet 

func (x *TPredicate_TIn) GetSet() []*TExpression

func (*TPredicate_TIn) GetValue 

func (x *TPredicate_TIn) GetValue() *TExpression

func (*TPredicate_TIn) ProtoMessage 

func (*TPredicate_TIn) ProtoMessage()

func (*TPredicate_TIn) ProtoReflect 

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

func (*TPredicate_TIn) Reset 

func (x *TPredicate_TIn) Reset()

func (*TPredicate_TIn) String 

func (x *TPredicate_TIn) String() string

type TPredicate_TIsNotNull 

type TPredicate_TIsNotNull struct {
	Value *TExpression `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

"$column IS NOT NULL" TODO: maybe it is better to express with TNegation here

func (*TPredicate_TIsNotNull) Descriptor deprecated 

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

Deprecated: Use TPredicate_TIsNotNull.ProtoReflect.Descriptor instead.

func (*TPredicate_TIsNotNull) GetValue 

func (x *TPredicate_TIsNotNull) GetValue() *TExpression

func (*TPredicate_TIsNotNull) ProtoMessage 

func (*TPredicate_TIsNotNull) ProtoMessage()

func (*TPredicate_TIsNotNull) ProtoReflect 

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

func (*TPredicate_TIsNotNull) Reset 

func (x *TPredicate_TIsNotNull) Reset()

func (*TPredicate_TIsNotNull) String 

func (x *TPredicate_TIsNotNull) String() string

type TPredicate_TIsNull 

type TPredicate_TIsNull struct {
	Value *TExpression `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

"$column IS NULL"

func (*TPredicate_TIsNull) Descriptor deprecated 

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

Deprecated: Use TPredicate_TIsNull.ProtoReflect.Descriptor instead.

func (*TPredicate_TIsNull) GetValue 

func (x *TPredicate_TIsNull) GetValue() *TExpression

func (*TPredicate_TIsNull) ProtoMessage 

func (*TPredicate_TIsNull) ProtoMessage()

func (*TPredicate_TIsNull) ProtoReflect 

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

func (*TPredicate_TIsNull) Reset 

func (x *TPredicate_TIsNull) Reset()

func (*TPredicate_TIsNull) String 

func (x *TPredicate_TIsNull) String() string

type TPredicate_TNegation 

type TPredicate_TNegation struct {
	Operand *TPredicate `protobuf:"bytes,1,opt,name=operand,proto3" json:"operand,omitempty"`
	// contains filtered or unexported fields
}

NOT

func (*TPredicate_TNegation) Descriptor deprecated 

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

Deprecated: Use TPredicate_TNegation.ProtoReflect.Descriptor instead.

func (*TPredicate_TNegation) GetOperand 

func (x *TPredicate_TNegation) GetOperand() *TPredicate

func (*TPredicate_TNegation) ProtoMessage 

func (*TPredicate_TNegation) ProtoMessage()

func (*TPredicate_TNegation) ProtoReflect 

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

func (*TPredicate_TNegation) Reset 

func (x *TPredicate_TNegation) Reset()

func (*TPredicate_TNegation) String 

func (x *TPredicate_TNegation) String() string

type TReadSplitsRequest 

type TReadSplitsRequest struct {

	// Data source instance to connect.
	// Deprecated field: server implementations must rely on
	// TDataSourceInstance provided in each TSelect.
	//
	// Deprecated: Marked as deprecated in ydb/library/yql/providers/generic/connector/api/service/protos/connector.proto.
	DataSourceInstance *common.TDataSourceInstance `protobuf:"bytes,1,opt,name=data_source_instance,json=dataSourceInstance,proto3" json:"data_source_instance,omitempty"`
	// Splits that YQ engine would like to read.
	Splits []*TSplit `protobuf:"bytes,2,rep,name=splits,proto3" json:"splits,omitempty"`
	// Determines the mode of data extraction
	Mode TReadSplitsRequest_EMode `protobuf:"varint,3,opt,name=mode,proto3,enum=NYql.NConnector.NApi.TReadSplitsRequest_EMode" json:"mode,omitempty"`
	// Determines the format of data representation
	Format TReadSplitsRequest_EFormat `protobuf:"varint,4,opt,name=format,proto3,enum=NYql.NConnector.NApi.TReadSplitsRequest_EFormat" json:"format,omitempty"`
	// Specifies the location of split from where to start reading.
	// If stream has been recently interrupted, YQ may retry reading the split from the interrupted block
	// instead of reading the split from scratch.
	// If empty, the connector will return the split data from the very beginning.
	Continuation *TContinuation `protobuf:"bytes,6,opt,name=continuation,proto3" json:"continuation,omitempty"`
	// Determines various modes of server behavior in the context of predicate pushdown.
	// If not set, the default value is `FILTERING_OPTIONAL`.
	Filtering TReadSplitsRequest_EFiltering `` /* 128-byte string literal not displayed */
	// contains filtered or unexported fields
}

ReadDataRequest reads the data associated with a particular table split.

func (*TReadSplitsRequest) Descriptor deprecated 

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

Deprecated: Use TReadSplitsRequest.ProtoReflect.Descriptor instead.

func (*TReadSplitsRequest) GetContinuation 

func (x *TReadSplitsRequest) GetContinuation() *TContinuation

func (*TReadSplitsRequest) GetDataSourceInstance deprecated 

func (x *TReadSplitsRequest) GetDataSourceInstance() *common.TDataSourceInstance

Deprecated: Marked as deprecated in ydb/library/yql/providers/generic/connector/api/service/protos/connector.proto.

func (*TReadSplitsRequest) GetFiltering added in v0.5.11 

func (x *TReadSplitsRequest) GetFiltering() TReadSplitsRequest_EFiltering

func (*TReadSplitsRequest) GetFormat 

func (x *TReadSplitsRequest) GetFormat() TReadSplitsRequest_EFormat

func (*TReadSplitsRequest) GetMode 

func (x *TReadSplitsRequest) GetMode() TReadSplitsRequest_EMode

func (*TReadSplitsRequest) GetSplits 

func (x *TReadSplitsRequest) GetSplits() []*TSplit

func (*TReadSplitsRequest) ProtoMessage 

func (*TReadSplitsRequest) ProtoMessage()

func (*TReadSplitsRequest) ProtoReflect 

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

func (*TReadSplitsRequest) Reset 

func (x *TReadSplitsRequest) Reset()

func (*TReadSplitsRequest) String 

func (x *TReadSplitsRequest) String() string

type TReadSplitsRequest_EFiltering added in v0.5.11 

type TReadSplitsRequest_EFiltering int32
const (
	TReadSplitsRequest_FILTERING_UNSPECIFIED TReadSplitsRequest_EFiltering = 0
	// If Connector cannot push down the predicate to the data source completely
	// (due to the lack of data type support, for example), it doesn't apply filter at all
	// and returns the full result of `SELECT columns FROM table` (no WHERE clause).
	// It's YDB's duty to filter the output on its own side.
	TReadSplitsRequest_FILTERING_OPTIONAL TReadSplitsRequest_EFiltering = 1
	// If Connector cannot push down the predicate to the data source completely,
	// it terminates the request and returns an error.
	TReadSplitsRequest_FILTERING_MANDATORY TReadSplitsRequest_EFiltering = 2
)

func (TReadSplitsRequest_EFiltering) Descriptor added in v0.5.11 

func (TReadSplitsRequest_EFiltering) Descriptor() protoreflect.EnumDescriptor

func (TReadSplitsRequest_EFiltering) Enum added in v0.5.11 

func (x TReadSplitsRequest_EFiltering) Enum() *TReadSplitsRequest_EFiltering

func (TReadSplitsRequest_EFiltering) EnumDescriptor deprecated added in v0.5.11 

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

Deprecated: Use TReadSplitsRequest_EFiltering.Descriptor instead.

func (TReadSplitsRequest_EFiltering) Number added in v0.5.11 

func (x TReadSplitsRequest_EFiltering) Number() protoreflect.EnumNumber

func (TReadSplitsRequest_EFiltering) String added in v0.5.11 

func (x TReadSplitsRequest_EFiltering) String() string

func (TReadSplitsRequest_EFiltering) Type added in v0.5.11 

func (TReadSplitsRequest_EFiltering) Type() protoreflect.EnumType

type TReadSplitsRequest_EFormat 

type TReadSplitsRequest_EFormat int32
const (
	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
)

func (TReadSplitsRequest_EFormat) Descriptor 

func (TReadSplitsRequest_EFormat) Descriptor() protoreflect.EnumDescriptor

func (TReadSplitsRequest_EFormat) Enum 

func (x TReadSplitsRequest_EFormat) Enum() *TReadSplitsRequest_EFormat

func (TReadSplitsRequest_EFormat) EnumDescriptor deprecated 

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

Deprecated: Use TReadSplitsRequest_EFormat.Descriptor instead.

func (TReadSplitsRequest_EFormat) Number 

func (x TReadSplitsRequest_EFormat) Number() protoreflect.EnumNumber

func (TReadSplitsRequest_EFormat) String 

func (x TReadSplitsRequest_EFormat) String() string

func (TReadSplitsRequest_EFormat) Type 

func (TReadSplitsRequest_EFormat) Type() protoreflect.EnumType

type TReadSplitsRequest_EMode 

type TReadSplitsRequest_EMode int32
const (
	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
	// Connector may read different splits concurrently and send the split fragments to the response stream
	// as soon as the data is obtained from the data source. Thus the stream is multiplexed between splits.
	TReadSplitsRequest_UNORDERED TReadSplitsRequest_EMode = 2
)

func (TReadSplitsRequest_EMode) Descriptor 

func (TReadSplitsRequest_EMode) Descriptor() protoreflect.EnumDescriptor

func (TReadSplitsRequest_EMode) Enum 

func (x TReadSplitsRequest_EMode) Enum() *TReadSplitsRequest_EMode

func (TReadSplitsRequest_EMode) EnumDescriptor deprecated 

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

Deprecated: Use TReadSplitsRequest_EMode.Descriptor instead.

func (TReadSplitsRequest_EMode) Number 

func (x TReadSplitsRequest_EMode) Number() protoreflect.EnumNumber

func (TReadSplitsRequest_EMode) String 

func (x TReadSplitsRequest_EMode) String() string

func (TReadSplitsRequest_EMode) Type 

func (TReadSplitsRequest_EMode) Type() protoreflect.EnumType

type TReadSplitsResponse 

type TReadSplitsResponse struct {

	// There may be various formats to represent data
	//
	// Types that are assignable to Payload:
	//
	//	*TReadSplitsResponse_ColumnSet
	//	*TReadSplitsResponse_ArrowIpcStreaming
	Payload isTReadSplitsResponse_Payload `protobuf_oneof:"payload"`
	// Since multiple splits can be read within one request, it's important to
	// match the received data with the requested split.
	SplitIndexNumber uint32 `protobuf:"varint,3,opt,name=split_index_number,json=splitIndexNumber,proto3" json:"split_index_number,omitempty"`
	// Specifies the location where the next block starts.
	// If stream has been interrupted, YQ may retry reading using the Continuation message
	// received for the last time.
	Continuation *TContinuation              `protobuf:"bytes,4,opt,name=continuation,proto3" json:"continuation,omitempty"`
	Stats        *TReadSplitsResponse_TStats `protobuf:"bytes,5,opt,name=stats,proto3" json:"stats,omitempty"`
	// Call result
	Error *TError `protobuf:"bytes,100,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

ReadDataResponse returns the data corresponding to a particular split

func (*TReadSplitsResponse) Descriptor deprecated 

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

Deprecated: Use TReadSplitsResponse.ProtoReflect.Descriptor instead.

func (*TReadSplitsResponse) GetArrowIpcStreaming 

func (x *TReadSplitsResponse) GetArrowIpcStreaming() []byte

func (*TReadSplitsResponse) GetColumnSet 

func (x *TReadSplitsResponse) GetColumnSet() *TReadSplitsResponse_TColumnSet

func (*TReadSplitsResponse) GetContinuation 

func (x *TReadSplitsResponse) GetContinuation() *TContinuation

func (*TReadSplitsResponse) GetError 

func (x *TReadSplitsResponse) GetError() *TError

func (*TReadSplitsResponse) GetPayload 

func (m *TReadSplitsResponse) GetPayload() isTReadSplitsResponse_Payload

func (*TReadSplitsResponse) GetSplitIndexNumber 

func (x *TReadSplitsResponse) GetSplitIndexNumber() uint32

func (*TReadSplitsResponse) GetStats 

func (x *TReadSplitsResponse) GetStats() *TReadSplitsResponse_TStats

func (*TReadSplitsResponse) ProtoMessage 

func (*TReadSplitsResponse) ProtoMessage()

func (*TReadSplitsResponse) ProtoReflect 

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

func (*TReadSplitsResponse) Reset 

func (x *TReadSplitsResponse) Reset()

func (*TReadSplitsResponse) String 

func (x *TReadSplitsResponse) String() string

type TReadSplitsResponse_ArrowIpcStreaming 

type TReadSplitsResponse_ArrowIpcStreaming struct {
	// Data in Arrow IPC streaming format.
	ArrowIpcStreaming []byte `protobuf:"bytes,2,opt,name=arrow_ipc_streaming,json=arrowIpcStreaming,proto3,oneof"`
}

type TReadSplitsResponse_ColumnSet 

type TReadSplitsResponse_ColumnSet struct {
	// Columnar data in protobuf format with YDB types.
	// Use it only for debugging, don't use in production.
	ColumnSet *TReadSplitsResponse_TColumnSet `protobuf:"bytes,1,opt,name=column_set,json=columnSet,proto3,oneof"`
}

type TReadSplitsResponse_TColumnSet 

type TReadSplitsResponse_TColumnSet struct {
	Meta []*Ydb.Column                             `protobuf:"bytes,1,rep,name=meta,proto3" json:"meta,omitempty"`
	Data []*TReadSplitsResponse_TColumnSet_TColumn `protobuf:"bytes,2,rep,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

Protobuf columnar representation of data. Use it only for debugging, don't use in production.

func (*TReadSplitsResponse_TColumnSet) Descriptor deprecated 

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

Deprecated: Use TReadSplitsResponse_TColumnSet.ProtoReflect.Descriptor instead.

func (*TReadSplitsResponse_TColumnSet) GetData 

func (x *TReadSplitsResponse_TColumnSet) GetData() []*TReadSplitsResponse_TColumnSet_TColumn

func (*TReadSplitsResponse_TColumnSet) GetMeta 

func (x *TReadSplitsResponse_TColumnSet) GetMeta() []*Ydb.Column

func (*TReadSplitsResponse_TColumnSet) ProtoMessage 

func (*TReadSplitsResponse_TColumnSet) ProtoMessage()

func (*TReadSplitsResponse_TColumnSet) ProtoReflect 

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

func (*TReadSplitsResponse_TColumnSet) Reset 

func (x *TReadSplitsResponse_TColumnSet) Reset()

func (*TReadSplitsResponse_TColumnSet) String 

func (x *TReadSplitsResponse_TColumnSet) String() string

type TReadSplitsResponse_TColumnSet_TColumn 

type TReadSplitsResponse_TColumnSet_TColumn struct {
	Data []*Ydb.Value `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*TReadSplitsResponse_TColumnSet_TColumn) Descriptor deprecated 

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

Deprecated: Use TReadSplitsResponse_TColumnSet_TColumn.ProtoReflect.Descriptor instead.

func (*TReadSplitsResponse_TColumnSet_TColumn) GetData 

func (x *TReadSplitsResponse_TColumnSet_TColumn) GetData() []*Ydb.Value

func (*TReadSplitsResponse_TColumnSet_TColumn) ProtoMessage 

func (*TReadSplitsResponse_TColumnSet_TColumn) ProtoMessage()

func (*TReadSplitsResponse_TColumnSet_TColumn) ProtoReflect 

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

func (*TReadSplitsResponse_TColumnSet_TColumn) Reset 

func (x *TReadSplitsResponse_TColumnSet_TColumn) Reset()

func (*TReadSplitsResponse_TColumnSet_TColumn) String 

func (x *TReadSplitsResponse_TColumnSet_TColumn) String() string

type TReadSplitsResponse_TStats 

type TReadSplitsResponse_TStats struct {

	// Number of rows read from the data source in order to make this page.
	Rows uint64 `protobuf:"varint,1,opt,name=rows,proto3" json:"rows,omitempty"`
	// Number of bytes read from the data source in order to make this page.
	// (measured in terms of Go type system).
	Bytes uint64 `protobuf:"varint,2,opt,name=bytes,proto3" json:"bytes,omitempty"`
	// contains filtered or unexported fields
}

Contains information about the page (a particular block of data returned by the Connector within a ReadSplits stream).

func (*TReadSplitsResponse_TStats) Descriptor deprecated 

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

Deprecated: Use TReadSplitsResponse_TStats.ProtoReflect.Descriptor instead.

func (*TReadSplitsResponse_TStats) GetBytes 

func (x *TReadSplitsResponse_TStats) GetBytes() uint64

func (*TReadSplitsResponse_TStats) GetRows 

func (x *TReadSplitsResponse_TStats) GetRows() uint64

func (*TReadSplitsResponse_TStats) ProtoMessage 

func (*TReadSplitsResponse_TStats) ProtoMessage()

func (*TReadSplitsResponse_TStats) ProtoReflect 

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

func (*TReadSplitsResponse_TStats) Reset 

func (x *TReadSplitsResponse_TStats) Reset()

func (*TReadSplitsResponse_TStats) String 

func (x *TReadSplitsResponse_TStats) String() string

type TSchema 

type TSchema struct {

	// Columns with YQL types
	Columns []*Ydb.Column `protobuf:"bytes,1,rep,name=columns,proto3" json:"columns,omitempty"` // TODO: optional metadata?
	// contains filtered or unexported fields
}

TSchema represents the schema of the table

func (*TSchema) Descriptor deprecated 

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

Deprecated: Use TSchema.ProtoReflect.Descriptor instead.

func (*TSchema) GetColumns 

func (x *TSchema) GetColumns() []*Ydb.Column

func (*TSchema) ProtoMessage 

func (*TSchema) ProtoMessage()

func (*TSchema) ProtoReflect 

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

func (*TSchema) Reset 

func (x *TSchema) Reset()

func (*TSchema) String 

func (x *TSchema) String() string

type TSelect 

type TSelect struct {

	// Data source instance to connect
	DataSourceInstance *common.TDataSourceInstance `protobuf:"bytes,1,opt,name=data_source_instance,json=dataSourceInstance,proto3" json:"data_source_instance,omitempty"`
	// Transforms into SELECT $what.
	What *TSelect_TWhat `protobuf:"bytes,2,opt,name=what,proto3" json:"what,omitempty"`
	// Transforms into FROM $from
	From *TSelect_TFrom `protobuf:"bytes,3,opt,name=from,proto3" json:"from,omitempty"`
	// Transforms into WHERE $filter.
	// Optional field.
	Where *TSelect_TWhere `protobuf:"bytes,4,opt,name=where,proto3" json:"where,omitempty"`
	// Transforms into LIMIT $limit [OFFSET $offset].
	// Optional field.
	Limit *TSelect_TLimit `protobuf:"bytes,5,opt,name=limit,proto3" json:"limit,omitempty"`
	// For schemaless data sources, when it's hard for us to infer schema for the query result,
	// user can supply the schema himself.
	// Optional field that must be empty for schematized data sources.
	PredefinedSchema *TSchema `protobuf:"bytes,6,opt,name=predefined_schema,json=predefinedSchema,proto3" json:"predefined_schema,omitempty"`
	// contains filtered or unexported fields
}

Select describes what to read from the data source.

In RDBMS systems this call internally transforms into SQL expression using this template: SELECT $what FROM $from WHERE $filter LIMIT $limit [OFFSET $offset] TODO: support JOIN, ORDER BY, GROUP BY

func (*TSelect) Descriptor deprecated 

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

Deprecated: Use TSelect.ProtoReflect.Descriptor instead.

func (*TSelect) GetDataSourceInstance 

func (x *TSelect) GetDataSourceInstance() *common.TDataSourceInstance

func (*TSelect) GetFrom 

func (x *TSelect) GetFrom() *TSelect_TFrom

func (*TSelect) GetLimit 

func (x *TSelect) GetLimit() *TSelect_TLimit

func (*TSelect) GetPredefinedSchema 

func (x *TSelect) GetPredefinedSchema() *TSchema

func (*TSelect) GetWhat 

func (x *TSelect) GetWhat() *TSelect_TWhat

func (*TSelect) GetWhere 

func (x *TSelect) GetWhere() *TSelect_TWhere

func (*TSelect) ProtoMessage 

func (*TSelect) ProtoMessage()

func (*TSelect) ProtoReflect 

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

func (*TSelect) Reset 

func (x *TSelect) Reset()

func (*TSelect) String 

func (x *TSelect) String() string

type TSelect_TFrom 

type TSelect_TFrom struct {

	// Table name for RDBMs
	Table string `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"`
	// Unique identifier of an object stored within S3
	ObjectKey string `protobuf:"bytes,2,opt,name=object_key,json=objectKey,proto3" json:"object_key,omitempty"`
	// contains filtered or unexported fields
}

func (*TSelect_TFrom) Descriptor deprecated 

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

Deprecated: Use TSelect_TFrom.ProtoReflect.Descriptor instead.

func (*TSelect_TFrom) GetObjectKey 

func (x *TSelect_TFrom) GetObjectKey() string

func (*TSelect_TFrom) GetTable 

func (x *TSelect_TFrom) GetTable() string

func (*TSelect_TFrom) ProtoMessage 

func (*TSelect_TFrom) ProtoMessage()

func (*TSelect_TFrom) ProtoReflect 

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

func (*TSelect_TFrom) Reset 

func (x *TSelect_TFrom) Reset()

func (*TSelect_TFrom) String 

func (x *TSelect_TFrom) String() string

type TSelect_TLimit 

type TSelect_TLimit struct {
	Limit  uint64 `protobuf:"varint,1,opt,name=limit,proto3" json:"limit,omitempty"`
	Offset uint64 `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	// contains filtered or unexported fields
}

func (*TSelect_TLimit) Descriptor deprecated 

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

Deprecated: Use TSelect_TLimit.ProtoReflect.Descriptor instead.

func (*TSelect_TLimit) GetLimit 

func (x *TSelect_TLimit) GetLimit() uint64

func (*TSelect_TLimit) GetOffset 

func (x *TSelect_TLimit) GetOffset() uint64

func (*TSelect_TLimit) ProtoMessage 

func (*TSelect_TLimit) ProtoMessage()

func (*TSelect_TLimit) ProtoReflect 

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

func (*TSelect_TLimit) Reset 

func (x *TSelect_TLimit) Reset()

func (*TSelect_TLimit) String 

func (x *TSelect_TLimit) String() string

type TSelect_TWhat 

type TSelect_TWhat struct {

	// NOTE: this API intentionally makes it not possible to request 'SELECT *'.
	// YQ must provide all the column names explicitly.
	//
	// Еmpty list means that YQ wants to get empty tuples in the response.
	// On the connector's side this request will be transformed into something like
	// SELECT 1 FROM $table (...)
	Items []*TSelect_TWhat_TItem `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	// contains filtered or unexported fields
}

Describes what particularly to get from the data source

func (*TSelect_TWhat) Descriptor deprecated 

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

Deprecated: Use TSelect_TWhat.ProtoReflect.Descriptor instead.

func (*TSelect_TWhat) GetItems 

func (x *TSelect_TWhat) GetItems() []*TSelect_TWhat_TItem

func (*TSelect_TWhat) ProtoMessage 

func (*TSelect_TWhat) ProtoMessage()

func (*TSelect_TWhat) ProtoReflect 

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

func (*TSelect_TWhat) Reset 

func (x *TSelect_TWhat) Reset()

func (*TSelect_TWhat) String 

func (x *TSelect_TWhat) String() string

type TSelect_TWhat_TItem 

type TSelect_TWhat_TItem struct {

	// YQ can read particular table columns or call aggregate functions, for example.
	//
	// Types that are assignable to Payload:
	//
	//	*TSelect_TWhat_TItem_Column
	Payload isTSelect_TWhat_TItem_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

func (*TSelect_TWhat_TItem) Descriptor deprecated 

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

Deprecated: Use TSelect_TWhat_TItem.ProtoReflect.Descriptor instead.

func (*TSelect_TWhat_TItem) GetColumn 

func (x *TSelect_TWhat_TItem) GetColumn() *Ydb.Column

func (*TSelect_TWhat_TItem) GetPayload 

func (m *TSelect_TWhat_TItem) GetPayload() isTSelect_TWhat_TItem_Payload

func (*TSelect_TWhat_TItem) ProtoMessage 

func (*TSelect_TWhat_TItem) ProtoMessage()

func (*TSelect_TWhat_TItem) ProtoReflect 

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

func (*TSelect_TWhat_TItem) Reset 

func (x *TSelect_TWhat_TItem) Reset()

func (*TSelect_TWhat_TItem) String 

func (x *TSelect_TWhat_TItem) String() string

type TSelect_TWhat_TItem_Column 

type TSelect_TWhat_TItem_Column struct {
	// a column to read
	Column *Ydb.Column `protobuf:"bytes,1,opt,name=column,proto3,oneof"`
}

type TSelect_TWhere 

type TSelect_TWhere struct {

	// Strongly typed tree of predicates
	FilterTyped *TPredicate `protobuf:"bytes,1,opt,name=filter_typed,json=filterTyped,proto3" json:"filter_typed,omitempty"`
	// An internal representation of YQL request part describing filters.
	// Advanced connectors may use it for the full-fledged implementations of the push down.
	FilterRaw *TAst `protobuf:"bytes,2,opt,name=filter_raw,json=filterRaw,proto3" json:"filter_raw,omitempty"`
	// contains filtered or unexported fields
}

func (*TSelect_TWhere) Descriptor deprecated 

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

Deprecated: Use TSelect_TWhere.ProtoReflect.Descriptor instead.

func (*TSelect_TWhere) GetFilterRaw 

func (x *TSelect_TWhere) GetFilterRaw() *TAst

func (*TSelect_TWhere) GetFilterTyped 

func (x *TSelect_TWhere) GetFilterTyped() *TPredicate

func (*TSelect_TWhere) ProtoMessage 

func (*TSelect_TWhere) ProtoMessage()

func (*TSelect_TWhere) ProtoReflect 

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

func (*TSelect_TWhere) Reset 

func (x *TSelect_TWhere) Reset()

func (*TSelect_TWhere) String 

func (x *TSelect_TWhere) String() string

type TSplit 

type TSplit struct {

	// Every split contains the description of SELECT it was generated for.
	Select *TSelect `protobuf:"bytes,1,opt,name=select,proto3" json:"select,omitempty"`
	// Types that are assignable to Payload:
	//
	//	*TSplit_Description
	Payload isTSplit_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

Split is a certain part of a table. In general, it should be much smaller than a partition. It also represents a unit of a parallel work for YQ engine.

func (*TSplit) Descriptor deprecated 

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

Deprecated: Use TSplit.ProtoReflect.Descriptor instead.

func (*TSplit) GetDescription 

func (x *TSplit) GetDescription() []byte

func (*TSplit) GetPayload 

func (m *TSplit) GetPayload() isTSplit_Payload

func (*TSplit) GetSelect 

func (x *TSplit) GetSelect() *TSelect

func (*TSplit) ProtoMessage 

func (*TSplit) ProtoMessage()

func (*TSplit) ProtoReflect 

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

func (*TSplit) Reset 

func (x *TSplit) Reset()

func (*TSplit) String 

func (x *TSplit) String() string

type TSplit_Description 

type TSplit_Description struct {
	// Different data sources may use different ways to describe a split,
	// and we don't want YQ to dig into its internals (at least now),
	// so we make the description opaque for YQ.
	Description []byte `protobuf:"bytes,2,opt,name=description,proto3,oneof"`
}

type TTypeMappingSettings 

type TTypeMappingSettings struct {

	// Determines the format of date or time representation
	DateTimeFormat EDateTimeFormat `` /* 148-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*TTypeMappingSettings) Descriptor deprecated 

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

Deprecated: Use TTypeMappingSettings.ProtoReflect.Descriptor instead.

func (*TTypeMappingSettings) GetDateTimeFormat 

func (x *TTypeMappingSettings) GetDateTimeFormat() EDateTimeFormat

func (*TTypeMappingSettings) ProtoMessage 

func (*TTypeMappingSettings) ProtoMessage()

func (*TTypeMappingSettings) ProtoReflect 

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

func (*TTypeMappingSettings) Reset 

func (x *TTypeMappingSettings) Reset()

func (*TTypeMappingSettings) String 

func (x *TTypeMappingSettings) 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.