data

package
v1.2.0 Latest Latest
Warning

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

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

Documentation

Index

Constants

View Source 
const (
	Default_BitClientHandshake_Channel = shared.RpcChannel_BIT_DATA
)

Default values for BitClientHandshake fields.

Variables

View Source 
var (
	RpcType_name = map[int32]string{
		0: "HANDSHAKE",
		1: "ACK",
		2: "GOODBYE",
		3: "REQ_RECORD_BATCH",
		4: "SASL_MESSAGE",
		5: "REQ_RUNTIME_FILTER",
		6: "DATA_ACK_WITH_CREDIT",
	}
	RpcType_value = map[string]int32{
		"HANDSHAKE":            0,
		"ACK":                  1,
		"GOODBYE":              2,
		"REQ_RECORD_BATCH":     3,
		"SASL_MESSAGE":         4,
		"REQ_RUNTIME_FILTER":   5,
		"DATA_ACK_WITH_CREDIT": 6,
	}
)

Enum value maps for RpcType.

View Source 
var File_BitData_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type AckWithCredit 

type AckWithCredit struct {
	AllowedCredit *int32 `protobuf:"varint,1,opt,name=allowed_credit,json=allowedCredit" json:"allowed_credit,omitempty"` // the credit allowed the sender to send in batch granularity
	// contains filtered or unexported fields
}

func (*AckWithCredit) Descriptor deprecated 

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

Deprecated: Use AckWithCredit.ProtoReflect.Descriptor instead.

func (*AckWithCredit) GetAllowedCredit 

func (x *AckWithCredit) GetAllowedCredit() int32

func (*AckWithCredit) ProtoMessage 

func (*AckWithCredit) ProtoMessage()

func (*AckWithCredit) ProtoReflect 

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

func (*AckWithCredit) Reset 

func (x *AckWithCredit) Reset()

func (*AckWithCredit) String 

func (x *AckWithCredit) String() string

type BitClientHandshake 

type BitClientHandshake struct {
	RpcVersion *int32             `protobuf:"varint,1,opt,name=rpc_version,json=rpcVersion" json:"rpc_version,omitempty"`
	Channel    *shared.RpcChannel `protobuf:"varint,2,opt,name=channel,enum=exec.shared.RpcChannel,def=1" json:"channel,omitempty"`
	// contains filtered or unexported fields
}

func (*BitClientHandshake) Descriptor deprecated 

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

Deprecated: Use BitClientHandshake.ProtoReflect.Descriptor instead.

func (*BitClientHandshake) GetChannel 

func (x *BitClientHandshake) GetChannel() shared.RpcChannel

func (*BitClientHandshake) GetRpcVersion 

func (x *BitClientHandshake) GetRpcVersion() int32

func (*BitClientHandshake) ProtoMessage 

func (*BitClientHandshake) ProtoMessage()

func (*BitClientHandshake) ProtoReflect 

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

func (*BitClientHandshake) Reset 

func (x *BitClientHandshake) Reset()

func (*BitClientHandshake) String 

func (x *BitClientHandshake) String() string

type BitServerHandshake 

type BitServerHandshake struct {
	RpcVersion               *int32   `protobuf:"varint,1,opt,name=rpc_version,json=rpcVersion" json:"rpc_version,omitempty"`
	AuthenticationMechanisms []string `protobuf:"bytes,2,rep,name=authenticationMechanisms" json:"authenticationMechanisms,omitempty"`
	// contains filtered or unexported fields
}

func (*BitServerHandshake) Descriptor deprecated 

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

Deprecated: Use BitServerHandshake.ProtoReflect.Descriptor instead.

func (*BitServerHandshake) GetAuthenticationMechanisms 

func (x *BitServerHandshake) GetAuthenticationMechanisms() []string

func (*BitServerHandshake) GetRpcVersion 

func (x *BitServerHandshake) GetRpcVersion() int32

func (*BitServerHandshake) ProtoMessage 

func (*BitServerHandshake) ProtoMessage()

func (*BitServerHandshake) ProtoReflect 

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

func (*BitServerHandshake) Reset 

func (x *BitServerHandshake) Reset()

func (*BitServerHandshake) String 

func (x *BitServerHandshake) String() string

type FragmentRecordBatch 

type FragmentRecordBatch struct {
	QueryId                  *shared.QueryId        `protobuf:"bytes,1,opt,name=query_id,json=queryId" json:"query_id,omitempty"`
	ReceivingMajorFragmentId *int32                 `` /* 131-byte string literal not displayed */
	ReceivingMinorFragmentId []int32                `` /* 131-byte string literal not displayed */
	SendingMajorFragmentId   *int32                 `protobuf:"varint,4,opt,name=sending_major_fragment_id,json=sendingMajorFragmentId" json:"sending_major_fragment_id,omitempty"`
	SendingMinorFragmentId   *int32                 `protobuf:"varint,5,opt,name=sending_minor_fragment_id,json=sendingMinorFragmentId" json:"sending_minor_fragment_id,omitempty"`
	Def                      *shared.RecordBatchDef `protobuf:"bytes,6,opt,name=def" json:"def,omitempty"`
	IsLastBatch              *bool                  `protobuf:"varint,7,opt,name=isLastBatch" json:"isLastBatch,omitempty"`
	// contains filtered or unexported fields
}

func (*FragmentRecordBatch) Descriptor deprecated 

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

Deprecated: Use FragmentRecordBatch.ProtoReflect.Descriptor instead.

func (*FragmentRecordBatch) GetDef 

func (x *FragmentRecordBatch) GetDef() *shared.RecordBatchDef

func (*FragmentRecordBatch) GetIsLastBatch 

func (x *FragmentRecordBatch) GetIsLastBatch() bool

func (*FragmentRecordBatch) GetQueryId 

func (x *FragmentRecordBatch) GetQueryId() *shared.QueryId

func (*FragmentRecordBatch) GetReceivingMajorFragmentId 

func (x *FragmentRecordBatch) GetReceivingMajorFragmentId() int32

func (*FragmentRecordBatch) GetReceivingMinorFragmentId 

func (x *FragmentRecordBatch) GetReceivingMinorFragmentId() []int32

func (*FragmentRecordBatch) GetSendingMajorFragmentId 

func (x *FragmentRecordBatch) GetSendingMajorFragmentId() int32

func (*FragmentRecordBatch) GetSendingMinorFragmentId 

func (x *FragmentRecordBatch) GetSendingMinorFragmentId() int32

func (*FragmentRecordBatch) ProtoMessage 

func (*FragmentRecordBatch) ProtoMessage()

func (*FragmentRecordBatch) ProtoReflect 

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

func (*FragmentRecordBatch) Reset 

func (x *FragmentRecordBatch) Reset()

func (*FragmentRecordBatch) String 

func (x *FragmentRecordBatch) String() string

type RpcType 

type RpcType int32
const (
	RpcType_HANDSHAKE        RpcType = 0
	RpcType_ACK              RpcType = 1
	RpcType_GOODBYE          RpcType = 2
	RpcType_REQ_RECORD_BATCH RpcType = 3 // send record batch, returns Ack
	// both bit request and response
	RpcType_SASL_MESSAGE         RpcType = 4
	RpcType_REQ_RUNTIME_FILTER   RpcType = 5 // send runtime filter data from HashJoin to Foreman, from Foreman to Scan nodes.
	RpcType_DATA_ACK_WITH_CREDIT RpcType = 6 // a ack for data tunnel,with a runtime suggested credit as a response.
)

func (RpcType) Descriptor 

func (RpcType) Descriptor() protoreflect.EnumDescriptor

func (RpcType) Enum 

func (x RpcType) Enum() *RpcType

func (RpcType) EnumDescriptor deprecated 

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

Deprecated: Use RpcType.Descriptor instead.

func (RpcType) Number 

func (x RpcType) Number() protoreflect.EnumNumber

func (RpcType) String 

func (x RpcType) String() string

func (RpcType) Type 

func (RpcType) Type() protoreflect.EnumType

func (*RpcType) UnmarshalJSON deprecated 

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

Deprecated: Do not use.

type RuntimeFilterBDef 

type RuntimeFilterBDef struct {
	QueryId                *shared.QueryId `protobuf:"bytes,1,opt,name=query_id,json=queryId" json:"query_id,omitempty"`
	MajorFragmentId        *int32          `protobuf:"varint,2,opt,name=major_fragment_id,json=majorFragmentId" json:"major_fragment_id,omitempty"`
	MinorFragmentId        *int32          `protobuf:"varint,3,opt,name=minor_fragment_id,json=minorFragmentId" json:"minor_fragment_id,omitempty"`
	ToForeman              *bool           `protobuf:"varint,4,opt,name=to_foreman,json=toForeman" json:"to_foreman,omitempty"`          // true means sending to foreman,false means sending to scan nodes
	BloomFilterSizeInBytes []int32         ``                                                                                            /* 127-byte string literal not displayed */
	ProbeFields            []string        `protobuf:"bytes,6,rep,name=probe_fields,json=probeFields" json:"probe_fields,omitempty"`     // probe fields with corresponding BloomFilters
	HjOpId                 *int32          `protobuf:"varint,7,opt,name=hj_op_id,json=hjOpId" json:"hj_op_id,omitempty"`                 // the operator id of the HashJoin which generates this RuntimeFilter
	RfIdentifier           *int64          `protobuf:"varint,8,opt,name=rf_identifier,json=rfIdentifier" json:"rf_identifier,omitempty"` // the runtime filter identifier
	// contains filtered or unexported fields
}

func (*RuntimeFilterBDef) Descriptor deprecated 

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

Deprecated: Use RuntimeFilterBDef.ProtoReflect.Descriptor instead.

func (*RuntimeFilterBDef) GetBloomFilterSizeInBytes 

func (x *RuntimeFilterBDef) GetBloomFilterSizeInBytes() []int32

func (*RuntimeFilterBDef) GetHjOpId 

func (x *RuntimeFilterBDef) GetHjOpId() int32

func (*RuntimeFilterBDef) GetMajorFragmentId 

func (x *RuntimeFilterBDef) GetMajorFragmentId() int32

func (*RuntimeFilterBDef) GetMinorFragmentId 

func (x *RuntimeFilterBDef) GetMinorFragmentId() int32

func (*RuntimeFilterBDef) GetProbeFields 

func (x *RuntimeFilterBDef) GetProbeFields() []string

func (*RuntimeFilterBDef) GetQueryId 

func (x *RuntimeFilterBDef) GetQueryId() *shared.QueryId

func (*RuntimeFilterBDef) GetRfIdentifier 

func (x *RuntimeFilterBDef) GetRfIdentifier() int64

func (*RuntimeFilterBDef) GetToForeman 

func (x *RuntimeFilterBDef) GetToForeman() bool

func (*RuntimeFilterBDef) ProtoMessage 

func (*RuntimeFilterBDef) ProtoMessage()

func (*RuntimeFilterBDef) ProtoReflect 

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

func (*RuntimeFilterBDef) Reset 

func (x *RuntimeFilterBDef) Reset()

func (*RuntimeFilterBDef) String 

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