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 (*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 (*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

Jump to

Keyboard shortcuts

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