execstats

package

Go to main page

Versions in this module

v0

v0.16.0

Sep 22, 2022

Changes in this version

type TExecProgress

+ func (p *TExecProgress) Equals(other *TExecProgress) bool

type TExecStats

+ func (p *TExecStats) Equals(other *TExecStats) bool

type TExecSummary

+ func (p *TExecSummary) Equals(other *TExecSummary) bool

type TPlanNodeExecSummary

+ func (p *TPlanNodeExecSummary) Equals(other *TPlanNodeExecSummary) bool

v0.13.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) GetNumCompletedScanRanges() int64

+ func (p *TExecProgress) GetTotalScanRanges() int64

+ func (p *TExecProgress) IsSetNumCompletedScanRanges() bool

+ func (p *TExecProgress) IsSetTotalScanRanges() bool

+ func (p *TExecProgress) Read(iprot thrift.TProtocol) error

+ func (p *TExecProgress) ReadField1(iprot thrift.TProtocol) error

+ func (p *TExecProgress) ReadField2(iprot thrift.TProtocol) error

+ func (p *TExecProgress) String() string

+ func (p *TExecProgress) Write(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) 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(iprot thrift.TProtocol) error

+ func (p *TExecStats) ReadField1(iprot thrift.TProtocol) error

+ func (p *TExecStats) ReadField2(iprot thrift.TProtocol) error

+ func (p *TExecStats) ReadField3(iprot thrift.TProtocol) error

+ func (p *TExecStats) ReadField4(iprot thrift.TProtocol) error

+ func (p *TExecStats) String() string

+ func (p *TExecStats) Write(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) 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(iprot thrift.TProtocol) error

+ func (p *TExecSummary) ReadField1(iprot thrift.TProtocol) error

+ func (p *TExecSummary) ReadField2(iprot thrift.TProtocol) error

+ func (p *TExecSummary) ReadField3(iprot thrift.TProtocol) error

+ func (p *TExecSummary) ReadField4(iprot thrift.TProtocol) error

+ func (p *TExecSummary) ReadField5(iprot thrift.TProtocol) error

+ func (p *TExecSummary) ReadField6(iprot thrift.TProtocol) error

+ func (p *TExecSummary) ReadField7(iprot thrift.TProtocol) error

+ func (p *TExecSummary) ReadField8(iprot thrift.TProtocol) error

+ func (p *TExecSummary) String() string

+ func (p *TExecSummary) Write(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) 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(iprot thrift.TProtocol) error

+ func (p *TPlanNodeExecSummary) ReadField1(iprot thrift.TProtocol) error

+ func (p *TPlanNodeExecSummary) ReadField2(iprot thrift.TProtocol) error

+ func (p *TPlanNodeExecSummary) ReadField3(iprot thrift.TProtocol) error

+ func (p *TPlanNodeExecSummary) ReadField4(iprot thrift.TProtocol) error

+ func (p *TPlanNodeExecSummary) ReadField5(iprot thrift.TProtocol) error

+ func (p *TPlanNodeExecSummary) ReadField6(iprot thrift.TProtocol) error

+ func (p *TPlanNodeExecSummary) ReadField7(iprot thrift.TProtocol) error

+ func (p *TPlanNodeExecSummary) ReadField8(iprot thrift.TProtocol) error

+ func (p *TPlanNodeExecSummary) ReadField9(iprot thrift.TProtocol) error

+ func (p *TPlanNodeExecSummary) String() string

+ func (p *TPlanNodeExecSummary) Write(oprot thrift.TProtocol) error

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