Versions in this module Expand all Collapse all v0 v0.16.1 Sep 22, 2022 Changes in this version + var GoUnusedProtection__ int + var TExecProgress_NumCompletedScanRanges_DEFAULT int64 + var TExecProgress_TotalScanRanges_DEFAULT int64 + var TExecStats_CPUTimeNs_DEFAULT int64 + var TExecStats_Cardinality_DEFAULT int64 + var TExecStats_LatencyNs_DEFAULT int64 + var TExecStats_MemoryUsed_DEFAULT int64 + var TExecSummary_ErrorLogs_DEFAULT []string + var TExecSummary_ExchToSenderMap_DEFAULT map[int32]int32 + var TExecSummary_IsQueued_DEFAULT bool + var TExecSummary_Nodes_DEFAULT []*TPlanNodeExecSummary + var TExecSummary_QueuedReason_DEFAULT string + var TExecSummary_Status_DEFAULT *status.TStatus + var TPlanNodeExecSummary_ExecStats_DEFAULT []*TExecStats + var TPlanNodeExecSummary_IsBroadcast_DEFAULT bool + var TPlanNodeExecSummary_LabelDetail_DEFAULT string + var TPlanNodeExecSummary_NumHosts_DEFAULT int32 + type TExecProgress struct + NumCompletedScanRanges *int64 + TotalScanRanges *int64 + var TExecSummary_Progress_DEFAULT *TExecProgress + func NewTExecProgress() *TExecProgress + func (p *TExecProgress) Equals(other *TExecProgress) bool + func (p *TExecProgress) GetNumCompletedScanRanges() int64 + func (p *TExecProgress) GetTotalScanRanges() int64 + func (p *TExecProgress) IsSetNumCompletedScanRanges() bool + func (p *TExecProgress) IsSetTotalScanRanges() bool + func (p *TExecProgress) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TExecProgress) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TExecProgress) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TExecProgress) String() string + func (p *TExecProgress) Write(ctx context.Context, oprot thrift.TProtocol) error + type TExecState int64 + const TExecState_CANCELLED + const TExecState_FAILED + const TExecState_FINISHED + const TExecState_PLANNING + const TExecState_QUEUED + const TExecState_REGISTERED + const TExecState_RUNNING + func TExecStateFromString(s string) (TExecState, error) + func TExecStatePtr(v TExecState) *TExecState + func (p *TExecState) Scan(value interface{}) error + func (p *TExecState) UnmarshalText(text []byte) error + func (p *TExecState) Value() (driver.Value, error) + func (p TExecState) MarshalText() ([]byte, error) + func (p TExecState) String() string + type TExecStats struct + CPUTimeNs *int64 + Cardinality *int64 + LatencyNs *int64 + MemoryUsed *int64 + var TPlanNodeExecSummary_EstimatedStats_DEFAULT *TExecStats + func NewTExecStats() *TExecStats + func (p *TExecStats) Equals(other *TExecStats) bool + func (p *TExecStats) GetCPUTimeNs() int64 + func (p *TExecStats) GetCardinality() int64 + func (p *TExecStats) GetLatencyNs() int64 + func (p *TExecStats) GetMemoryUsed() int64 + func (p *TExecStats) IsSetCPUTimeNs() bool + func (p *TExecStats) IsSetCardinality() bool + func (p *TExecStats) IsSetLatencyNs() bool + func (p *TExecStats) IsSetMemoryUsed() bool + func (p *TExecStats) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TExecStats) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TExecStats) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TExecStats) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *TExecStats) ReadField4(ctx context.Context, iprot thrift.TProtocol) error + func (p *TExecStats) String() string + func (p *TExecStats) Write(ctx context.Context, oprot thrift.TProtocol) error + type TExecSummary struct + ErrorLogs []string + ExchToSenderMap map[int32]int32 + IsQueued *bool + Nodes []*TPlanNodeExecSummary + Progress *TExecProgress + QueuedReason *string + State TExecState + Status *status.TStatus + func NewTExecSummary() *TExecSummary + func (p *TExecSummary) Equals(other *TExecSummary) bool + func (p *TExecSummary) GetErrorLogs() []string + func (p *TExecSummary) GetExchToSenderMap() map[int32]int32 + func (p *TExecSummary) GetIsQueued() bool + func (p *TExecSummary) GetNodes() []*TPlanNodeExecSummary + func (p *TExecSummary) GetProgress() *TExecProgress + func (p *TExecSummary) GetQueuedReason() string + func (p *TExecSummary) GetState() TExecState + func (p *TExecSummary) GetStatus() *status.TStatus + func (p *TExecSummary) IsSetErrorLogs() bool + func (p *TExecSummary) IsSetExchToSenderMap() bool + func (p *TExecSummary) IsSetIsQueued() bool + func (p *TExecSummary) IsSetNodes() bool + func (p *TExecSummary) IsSetProgress() bool + func (p *TExecSummary) IsSetQueuedReason() bool + func (p *TExecSummary) IsSetStatus() bool + func (p *TExecSummary) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TExecSummary) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TExecSummary) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TExecSummary) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *TExecSummary) ReadField4(ctx context.Context, iprot thrift.TProtocol) error + func (p *TExecSummary) ReadField5(ctx context.Context, iprot thrift.TProtocol) error + func (p *TExecSummary) ReadField6(ctx context.Context, iprot thrift.TProtocol) error + func (p *TExecSummary) ReadField7(ctx context.Context, iprot thrift.TProtocol) error + func (p *TExecSummary) ReadField8(ctx context.Context, iprot thrift.TProtocol) error + func (p *TExecSummary) String() string + func (p *TExecSummary) Write(ctx context.Context, oprot thrift.TProtocol) error + type TPlanNodeExecSummary struct + EstimatedStats *TExecStats + ExecStats []*TExecStats + FragmentIdx types.TFragmentIdx + IsBroadcast *bool + Label string + LabelDetail *string + NodeID types.TPlanNodeId + NumChildren int32 + NumHosts *int32 + func NewTPlanNodeExecSummary() *TPlanNodeExecSummary + func (p *TPlanNodeExecSummary) Equals(other *TPlanNodeExecSummary) bool + func (p *TPlanNodeExecSummary) GetEstimatedStats() *TExecStats + func (p *TPlanNodeExecSummary) GetExecStats() []*TExecStats + func (p *TPlanNodeExecSummary) GetFragmentIdx() types.TFragmentIdx + func (p *TPlanNodeExecSummary) GetIsBroadcast() bool + func (p *TPlanNodeExecSummary) GetLabel() string + func (p *TPlanNodeExecSummary) GetLabelDetail() string + func (p *TPlanNodeExecSummary) GetNodeID() types.TPlanNodeId + func (p *TPlanNodeExecSummary) GetNumChildren() int32 + func (p *TPlanNodeExecSummary) GetNumHosts() int32 + func (p *TPlanNodeExecSummary) IsSetEstimatedStats() bool + func (p *TPlanNodeExecSummary) IsSetExecStats() bool + func (p *TPlanNodeExecSummary) IsSetIsBroadcast() bool + func (p *TPlanNodeExecSummary) IsSetLabelDetail() bool + func (p *TPlanNodeExecSummary) IsSetNumHosts() bool + func (p *TPlanNodeExecSummary) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TPlanNodeExecSummary) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TPlanNodeExecSummary) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TPlanNodeExecSummary) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *TPlanNodeExecSummary) ReadField4(ctx context.Context, iprot thrift.TProtocol) error + func (p *TPlanNodeExecSummary) ReadField5(ctx context.Context, iprot thrift.TProtocol) error + func (p *TPlanNodeExecSummary) ReadField6(ctx context.Context, iprot thrift.TProtocol) error + func (p *TPlanNodeExecSummary) ReadField7(ctx context.Context, iprot thrift.TProtocol) error + func (p *TPlanNodeExecSummary) ReadField8(ctx context.Context, iprot thrift.TProtocol) error + func (p *TPlanNodeExecSummary) ReadField9(ctx context.Context, iprot thrift.TProtocol) error + func (p *TPlanNodeExecSummary) String() string + func (p *TPlanNodeExecSummary) Write(ctx context.Context, oprot thrift.TProtocol) error
Go to main page