execstats

package
v0.16.1 Latest Latest
Warning

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

 Go to latest Published: Sep 22, 2022 License: Apache-2.0 Imports: 9 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var GoUnusedProtection__ int
View Source 
var TExecProgress_NumCompletedScanRanges_DEFAULT int64
View Source 
var TExecProgress_TotalScanRanges_DEFAULT int64
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_IsQueued_DEFAULT bool
View Source 
var TExecSummary_Nodes_DEFAULT []*TPlanNodeExecSummary
View Source 
var TExecSummary_QueuedReason_DEFAULT string
View Source 
var TExecSummary_Status_DEFAULT *status.TStatus
View Source 
var TPlanNodeExecSummary_ExecStats_DEFAULT []*TExecStats
View Source 
var TPlanNodeExecSummary_IsBroadcast_DEFAULT bool
View Source 
var TPlanNodeExecSummary_LabelDetail_DEFAULT string
View Source 
var TPlanNodeExecSummary_NumHosts_DEFAULT int32

Functions

This section is empty.

Types

type TExecProgress 

type TExecProgress struct {
	TotalScanRanges        *int64 `thrift:"total_scan_ranges,1" db:"total_scan_ranges" json:"total_scan_ranges,omitempty"`
	NumCompletedScanRanges *int64 `thrift:"num_completed_scan_ranges,2" db:"num_completed_scan_ranges" json:"num_completed_scan_ranges,omitempty"`
}

Attributes:

  • TotalScanRanges
  • NumCompletedScanRanges
var TExecSummary_Progress_DEFAULT *TExecProgress

func NewTExecProgress 

func NewTExecProgress() *TExecProgress

func (*TExecProgress) Equals 

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

func (*TExecProgress) GetNumCompletedScanRanges 

func (p *TExecProgress) GetNumCompletedScanRanges() int64

func (*TExecProgress) GetTotalScanRanges 

func (p *TExecProgress) GetTotalScanRanges() int64

func (*TExecProgress) IsSetNumCompletedScanRanges 

func (p *TExecProgress) IsSetNumCompletedScanRanges() bool

func (*TExecProgress) IsSetTotalScanRanges 

func (p *TExecProgress) IsSetTotalScanRanges() bool

func (*TExecProgress) Read 

func (p *TExecProgress) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TExecProgress) ReadField1 

func (p *TExecProgress) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TExecProgress) ReadField2 

func (p *TExecProgress) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TExecProgress) String 

func (p *TExecProgress) String() string

func (*TExecProgress) Write 

func (p *TExecProgress) Write(ctx context.Context, oprot thrift.TProtocol) error

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

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

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(ctx context.Context, iprot thrift.TProtocol) error

func (*TExecStats) ReadField1 

func (p *TExecStats) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TExecStats) ReadField2 

func (p *TExecStats) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TExecStats) ReadField3 

func (p *TExecStats) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*TExecStats) ReadField4 

func (p *TExecStats) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

func (*TExecStats) String 

func (p *TExecStats) String() string

func (*TExecStats) Write 

func (p *TExecStats) Write(ctx context.Context, 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"`
	Progress        *TExecProgress          `thrift:"progress,6" db:"progress" json:"progress,omitempty"`
	IsQueued        *bool                   `thrift:"is_queued,7" db:"is_queued" json:"is_queued,omitempty"`
	QueuedReason    *string                 `thrift:"queued_reason,8" db:"queued_reason" json:"queued_reason,omitempty"`
}

Attributes:

  • State
  • Status
  • Nodes
  • ExchToSenderMap
  • ErrorLogs
  • Progress
  • IsQueued
  • QueuedReason

func NewTExecSummary 

func NewTExecSummary() *TExecSummary

func (*TExecSummary) Equals 

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

func (*TExecSummary) GetErrorLogs 

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

func (*TExecSummary) GetExchToSenderMap 

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

func (*TExecSummary) GetIsQueued 

func (p *TExecSummary) GetIsQueued() bool

func (*TExecSummary) GetNodes 

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

func (*TExecSummary) GetProgress 

func (p *TExecSummary) GetProgress() *TExecProgress

func (*TExecSummary) GetQueuedReason 

func (p *TExecSummary) GetQueuedReason() string

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

func (p *TExecSummary) IsSetIsQueued() bool

func (*TExecSummary) IsSetNodes 

func (p *TExecSummary) IsSetNodes() bool

func (*TExecSummary) IsSetProgress 

func (p *TExecSummary) IsSetProgress() bool

func (*TExecSummary) IsSetQueuedReason 

func (p *TExecSummary) IsSetQueuedReason() bool

func (*TExecSummary) IsSetStatus 

func (p *TExecSummary) IsSetStatus() bool

func (*TExecSummary) Read 

func (p *TExecSummary) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TExecSummary) ReadField1 

func (p *TExecSummary) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TExecSummary) ReadField2 

func (p *TExecSummary) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TExecSummary) ReadField3 

func (p *TExecSummary) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*TExecSummary) ReadField4 

func (p *TExecSummary) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

func (*TExecSummary) ReadField5 

func (p *TExecSummary) ReadField5(ctx context.Context, iprot thrift.TProtocol) error

func (*TExecSummary) ReadField6 

func (p *TExecSummary) ReadField6(ctx context.Context, iprot thrift.TProtocol) error

func (*TExecSummary) ReadField7 

func (p *TExecSummary) ReadField7(ctx context.Context, iprot thrift.TProtocol) error

func (*TExecSummary) ReadField8 

func (p *TExecSummary) ReadField8(ctx context.Context, iprot thrift.TProtocol) error

func (*TExecSummary) String 

func (p *TExecSummary) String() string

func (*TExecSummary) Write 

func (p *TExecSummary) Write(ctx context.Context, oprot thrift.TProtocol) error

type TPlanNodeExecSummary 

type TPlanNodeExecSummary struct {
	NodeID         types.TPlanNodeId  `thrift:"node_id,1,required" db:"node_id" json:"node_id"`
	FragmentIdx    types.TFragmentIdx `thrift:"fragment_idx,2,required" db:"fragment_idx" json:"fragment_idx"`
	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"`
	IsBroadcast    *bool              `thrift:"is_broadcast,8" db:"is_broadcast" json:"is_broadcast,omitempty"`
	NumHosts       *int32             `thrift:"num_hosts,9" db:"num_hosts" json:"num_hosts,omitempty"`
}

Attributes:

  • NodeID
  • FragmentIdx
  • Label
  • LabelDetail
  • NumChildren
  • EstimatedStats
  • ExecStats
  • IsBroadcast
  • NumHosts

func NewTPlanNodeExecSummary 

func NewTPlanNodeExecSummary() *TPlanNodeExecSummary

func (*TPlanNodeExecSummary) Equals 

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

func (*TPlanNodeExecSummary) GetEstimatedStats 

func (p *TPlanNodeExecSummary) GetEstimatedStats() *TExecStats

func (*TPlanNodeExecSummary) GetExecStats 

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

func (*TPlanNodeExecSummary) GetFragmentIdx 

func (p *TPlanNodeExecSummary) GetFragmentIdx() types.TFragmentIdx

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

func (p *TPlanNodeExecSummary) GetNumHosts() int32

func (*TPlanNodeExecSummary) IsSetEstimatedStats 

func (p *TPlanNodeExecSummary) IsSetEstimatedStats() bool

func (*TPlanNodeExecSummary) IsSetExecStats 

func (p *TPlanNodeExecSummary) IsSetExecStats() bool

func (*TPlanNodeExecSummary) IsSetIsBroadcast 

func (p *TPlanNodeExecSummary) IsSetIsBroadcast() bool

func (*TPlanNodeExecSummary) IsSetLabelDetail 

func (p *TPlanNodeExecSummary) IsSetLabelDetail() bool

func (*TPlanNodeExecSummary) IsSetNumHosts 

func (p *TPlanNodeExecSummary) IsSetNumHosts() bool

func (*TPlanNodeExecSummary) Read 

func (p *TPlanNodeExecSummary) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TPlanNodeExecSummary) ReadField1 

func (p *TPlanNodeExecSummary) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TPlanNodeExecSummary) ReadField2 

func (p *TPlanNodeExecSummary) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TPlanNodeExecSummary) ReadField3 

func (p *TPlanNodeExecSummary) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*TPlanNodeExecSummary) ReadField4 

func (p *TPlanNodeExecSummary) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

func (*TPlanNodeExecSummary) ReadField5 

func (p *TPlanNodeExecSummary) ReadField5(ctx context.Context, iprot thrift.TProtocol) error

func (*TPlanNodeExecSummary) ReadField6 

func (p *TPlanNodeExecSummary) ReadField6(ctx context.Context, iprot thrift.TProtocol) error

func (*TPlanNodeExecSummary) ReadField7 

func (p *TPlanNodeExecSummary) ReadField7(ctx context.Context, iprot thrift.TProtocol) error

func (*TPlanNodeExecSummary) ReadField8 

func (p *TPlanNodeExecSummary) ReadField8(ctx context.Context, iprot thrift.TProtocol) error

func (*TPlanNodeExecSummary) ReadField9 

func (p *TPlanNodeExecSummary) ReadField9(ctx context.Context, iprot thrift.TProtocol) error

func (*TPlanNodeExecSummary) String 

func (p *TPlanNodeExecSummary) String() string

func (*TPlanNodeExecSummary) Write 

func (p *TPlanNodeExecSummary) Write(ctx context.Context, 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.