execstats

package
v1.2.1 Latest Latest
Warning

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

 Go to latest Published: Feb 16, 2022 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var GoUnusedProtection__ int
View Source 
var TExecStats_CPUTimeNs_DEFAULT int64
View Source 
var TExecStats_Cardinality_DEFAULT int64
View Source 
var TExecStats_LatencyNs_DEFAULT int64
View Source 
var TExecStats_MemoryUsed_DEFAULT int64
View Source 
var TExecSummary_ErrorLogs_DEFAULT []string
View Source 
var TExecSummary_ExchToSenderMap_DEFAULT map[int32]int32
View Source 
var TExecSummary_Nodes_DEFAULT []*TPlanNodeExecSummary
View Source 
var TExecSummary_Status_DEFAULT *status.TStatus
View Source 
var TPlanNodeExecSummary_ExecStats_DEFAULT []*TExecStats
View Source 
var TPlanNodeExecSummary_IsActive_DEFAULT []bool
View Source 
var TPlanNodeExecSummary_IsBroadcast_DEFAULT bool
View Source 
var TPlanNodeExecSummary_LabelDetail_DEFAULT string

Functions

This section is empty.

Types

type TExecState 

type TExecState int64
const (
	TExecState_REGISTERED TExecState = 0
	TExecState_PLANNING   TExecState = 1
	TExecState_QUEUED     TExecState = 2
	TExecState_RUNNING    TExecState = 3
	TExecState_FINISHED   TExecState = 4
	TExecState_CANCELLED  TExecState = 5
	TExecState_FAILED     TExecState = 6
)

func TExecStateFromString 

func TExecStateFromString(s string) (TExecState, error)

func TExecStatePtr 

func TExecStatePtr(v TExecState) *TExecState

func (TExecState) MarshalText 

func (p TExecState) MarshalText() ([]byte, error)

func (*TExecState) Scan 

func (p *TExecState) Scan(value interface{}) error

func (TExecState) String 

func (p TExecState) String() string

func (*TExecState) UnmarshalText 

func (p *TExecState) UnmarshalText(text []byte) error

func (*TExecState) Value 

func (p *TExecState) Value() (driver.Value, error)

type TExecStats 

type TExecStats struct {
	LatencyNs   *int64 `thrift:"latency_ns,1" db:"latency_ns" json:"latency_ns,omitempty"`
	CPUTimeNs   *int64 `thrift:"cpu_time_ns,2" db:"cpu_time_ns" json:"cpu_time_ns,omitempty"`
	Cardinality *int64 `thrift:"cardinality,3" db:"cardinality" json:"cardinality,omitempty"`
	MemoryUsed  *int64 `thrift:"memory_used,4" db:"memory_used" json:"memory_used,omitempty"`
}

Attributes:

  • LatencyNs
  • CPUTimeNs
  • Cardinality
  • MemoryUsed
var TPlanNodeExecSummary_EstimatedStats_DEFAULT *TExecStats

func NewTExecStats 

func NewTExecStats() *TExecStats

func (*TExecStats) GetCPUTimeNs 

func (p *TExecStats) GetCPUTimeNs() int64

func (*TExecStats) GetCardinality 

func (p *TExecStats) GetCardinality() int64

func (*TExecStats) GetLatencyNs 

func (p *TExecStats) GetLatencyNs() int64

func (*TExecStats) GetMemoryUsed 

func (p *TExecStats) GetMemoryUsed() int64

func (*TExecStats) IsSetCPUTimeNs 

func (p *TExecStats) IsSetCPUTimeNs() bool

func (*TExecStats) IsSetCardinality 

func (p *TExecStats) IsSetCardinality() bool

func (*TExecStats) IsSetLatencyNs 

func (p *TExecStats) IsSetLatencyNs() bool

func (*TExecStats) IsSetMemoryUsed 

func (p *TExecStats) IsSetMemoryUsed() bool

func (*TExecStats) Read 

func (p *TExecStats) Read(iprot thrift.TProtocol) error

func (*TExecStats) ReadField1 

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

func (*TExecStats) ReadField2 

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

func (*TExecStats) ReadField3 

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

func (*TExecStats) ReadField4 

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

func (*TExecStats) String 

func (p *TExecStats) String() string

func (*TExecStats) Write 

func (p *TExecStats) Write(oprot thrift.TProtocol) error

type TExecSummary 

type TExecSummary struct {
	State           TExecState              `thrift:"state,1,required" db:"state" json:"state"`
	Status          *status.TStatus         `thrift:"status,2" db:"status" json:"status,omitempty"`
	Nodes           []*TPlanNodeExecSummary `thrift:"nodes,3" db:"nodes" json:"nodes,omitempty"`
	ExchToSenderMap map[int32]int32         `thrift:"exch_to_sender_map,4" db:"exch_to_sender_map" json:"exch_to_sender_map,omitempty"`
	ErrorLogs       []string                `thrift:"error_logs,5" db:"error_logs" json:"error_logs,omitempty"`
}

Attributes:

  • State
  • Status
  • Nodes
  • ExchToSenderMap
  • ErrorLogs

func NewTExecSummary 

func NewTExecSummary() *TExecSummary

func (*TExecSummary) GetErrorLogs 

func (p *TExecSummary) GetErrorLogs() []string

func (*TExecSummary) GetExchToSenderMap 

func (p *TExecSummary) GetExchToSenderMap() map[int32]int32

func (*TExecSummary) GetNodes 

func (p *TExecSummary) GetNodes() []*TPlanNodeExecSummary

func (*TExecSummary) GetState 

func (p *TExecSummary) GetState() TExecState

func (*TExecSummary) GetStatus 

func (p *TExecSummary) GetStatus() *status.TStatus

func (*TExecSummary) IsSetErrorLogs 

func (p *TExecSummary) IsSetErrorLogs() bool

func (*TExecSummary) IsSetExchToSenderMap 

func (p *TExecSummary) IsSetExchToSenderMap() bool

func (*TExecSummary) IsSetNodes 

func (p *TExecSummary) IsSetNodes() bool

func (*TExecSummary) IsSetStatus 

func (p *TExecSummary) IsSetStatus() bool

func (*TExecSummary) Read 

func (p *TExecSummary) Read(iprot thrift.TProtocol) error

func (*TExecSummary) ReadField1 

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

func (*TExecSummary) ReadField2 

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

func (*TExecSummary) ReadField3 

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

func (*TExecSummary) ReadField4 

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

func (*TExecSummary) ReadField5 

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

func (*TExecSummary) String 

func (p *TExecSummary) String() string

func (*TExecSummary) Write 

func (p *TExecSummary) Write(oprot thrift.TProtocol) error

type TPlanNodeExecSummary 

type TPlanNodeExecSummary struct {
	NodeID         types.TPlanNodeId `thrift:"node_id,1,required" db:"node_id" json:"node_id"`
	FragmentID     int32             `thrift:"fragment_id,2,required" db:"fragment_id" json:"fragment_id"`
	Label          string            `thrift:"label,3,required" db:"label" json:"label"`
	LabelDetail    *string           `thrift:"label_detail,4" db:"label_detail" json:"label_detail,omitempty"`
	NumChildren    int32             `thrift:"num_children,5,required" db:"num_children" json:"num_children"`
	EstimatedStats *TExecStats       `thrift:"estimated_stats,6" db:"estimated_stats" json:"estimated_stats,omitempty"`
	ExecStats      []*TExecStats     `thrift:"exec_stats,7" db:"exec_stats" json:"exec_stats,omitempty"`
	IsActive       []bool            `thrift:"is_active,8" db:"is_active" json:"is_active,omitempty"`
	IsBroadcast    *bool             `thrift:"is_broadcast,9" db:"is_broadcast" json:"is_broadcast,omitempty"`
}

Attributes:

  • NodeID
  • FragmentID
  • Label
  • LabelDetail
  • NumChildren
  • EstimatedStats
  • ExecStats
  • IsActive
  • IsBroadcast

func NewTPlanNodeExecSummary 

func NewTPlanNodeExecSummary() *TPlanNodeExecSummary

func (*TPlanNodeExecSummary) GetEstimatedStats 

func (p *TPlanNodeExecSummary) GetEstimatedStats() *TExecStats

func (*TPlanNodeExecSummary) GetExecStats 

func (p *TPlanNodeExecSummary) GetExecStats() []*TExecStats

func (*TPlanNodeExecSummary) GetFragmentID 

func (p *TPlanNodeExecSummary) GetFragmentID() int32

func (*TPlanNodeExecSummary) GetIsActive 

func (p *TPlanNodeExecSummary) GetIsActive() []bool

func (*TPlanNodeExecSummary) GetIsBroadcast 

func (p *TPlanNodeExecSummary) GetIsBroadcast() bool

func (*TPlanNodeExecSummary) GetLabel 

func (p *TPlanNodeExecSummary) GetLabel() string

func (*TPlanNodeExecSummary) GetLabelDetail 

func (p *TPlanNodeExecSummary) GetLabelDetail() string

func (*TPlanNodeExecSummary) GetNodeID 

func (p *TPlanNodeExecSummary) GetNodeID() types.TPlanNodeId

func (*TPlanNodeExecSummary) GetNumChildren 

func (p *TPlanNodeExecSummary) GetNumChildren() int32

func (*TPlanNodeExecSummary) IsSetEstimatedStats 

func (p *TPlanNodeExecSummary) IsSetEstimatedStats() bool

func (*TPlanNodeExecSummary) IsSetExecStats 

func (p *TPlanNodeExecSummary) IsSetExecStats() bool

func (*TPlanNodeExecSummary) IsSetIsActive 

func (p *TPlanNodeExecSummary) IsSetIsActive() bool

func (*TPlanNodeExecSummary) IsSetIsBroadcast 

func (p *TPlanNodeExecSummary) IsSetIsBroadcast() bool

func (*TPlanNodeExecSummary) IsSetLabelDetail 

func (p *TPlanNodeExecSummary) IsSetLabelDetail() bool

func (*TPlanNodeExecSummary) Read 

func (p *TPlanNodeExecSummary) Read(iprot thrift.TProtocol) error

func (*TPlanNodeExecSummary) ReadField1 

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

func (*TPlanNodeExecSummary) ReadField2 

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

func (*TPlanNodeExecSummary) ReadField3 

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

func (*TPlanNodeExecSummary) ReadField4 

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

func (*TPlanNodeExecSummary) ReadField5 

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

func (*TPlanNodeExecSummary) ReadField6 

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

func (*TPlanNodeExecSummary) ReadField7 

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

func (*TPlanNodeExecSummary) ReadField8 

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

func (*TPlanNodeExecSummary) ReadField9 

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

func (*TPlanNodeExecSummary) String 

func (p *TPlanNodeExecSummary) String() string

func (*TPlanNodeExecSummary) Write 

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

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.