protos

package
v0.1.0 Latest Latest
Warning

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

Go to latest
Published: Dec 22, 2023 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 (
	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) Enum

func (x EDateTimeFormat) Enum() *EDateTimeFormat

func (EDateTimeFormat) EnumDescriptor deprecated

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

Deprecated: Use EDateTimeFormat.Descriptor instead.

func (EDateTimeFormat) Number

func (EDateTimeFormat) String

func (x EDateTimeFormat) String() string

func (EDateTimeFormat) Type

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 (*TExpression_TArithmeticalExpression) GetOperation

func (*TExpression_TArithmeticalExpression) GetRightValue

func (*TExpression_TArithmeticalExpression) ProtoMessage

func (*TExpression_TArithmeticalExpression) ProtoMessage()

func (*TExpression_TArithmeticalExpression) ProtoReflect

func (*TExpression_TArithmeticalExpression) Reset

func (*TExpression_TArithmeticalExpression) 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) Enum

func (TExpression_TArithmeticalExpression_EOperation) EnumDescriptor deprecated

Deprecated: Use TExpression_TArithmeticalExpression_EOperation.Descriptor instead.

func (TExpression_TArithmeticalExpression_EOperation) Number

func (TExpression_TArithmeticalExpression_EOperation) String

func (TExpression_TArithmeticalExpression_EOperation) Type

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 (*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 (*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) Enum

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 (TPredicate_TComparison_EOperation) String

func (TPredicate_TComparison_EOperation) Type

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
	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"`
	// 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

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

func (*TReadSplitsRequest) GetFormat

func (*TReadSplitsRequest) GetMode

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_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) Enum

func (TReadSplitsRequest_EFormat) EnumDescriptor deprecated

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

Deprecated: Use TReadSplitsRequest_EFormat.Descriptor instead.

func (TReadSplitsRequest_EFormat) Number

func (TReadSplitsRequest_EFormat) String

func (TReadSplitsRequest_EFormat) Type

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) Enum

func (TReadSplitsRequest_EMode) EnumDescriptor deprecated

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

Deprecated: Use TReadSplitsRequest_EMode.Descriptor instead.

func (TReadSplitsRequest_EMode) Number

func (TReadSplitsRequest_EMode) String

func (x TReadSplitsRequest_EMode) String() string

func (TReadSplitsRequest_EMode) Type

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 (*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 (*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 (*TReadSplitsResponse_TColumnSet) GetMeta

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

func (*TReadSplitsResponse_TColumnSet) ProtoMessage

func (*TReadSplitsResponse_TColumnSet) ProtoMessage()

func (*TReadSplitsResponse_TColumnSet) ProtoReflect

func (*TReadSplitsResponse_TColumnSet) Reset

func (x *TReadSplitsResponse_TColumnSet) Reset()

func (*TReadSplitsResponse_TColumnSet) 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 (*TReadSplitsResponse_TColumnSet_TColumn) ProtoMessage

func (*TReadSplitsResponse_TColumnSet_TColumn) ProtoReflect

func (*TReadSplitsResponse_TColumnSet_TColumn) Reset

func (*TReadSplitsResponse_TColumnSet_TColumn) 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 (*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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL