cockroach: github.com/cockroachdb/cockroach/pkg/sql/rowexec Index | Files

package rowexec

import "github.com/cockroachdb/cockroach/pkg/sql/rowexec"

Index

Package Files

aggregator.go backfiller.go bulk_row_writer.go columnbackfiller.go countrows.go distinct.go hashjoiner.go indexbackfiller.go interleaved_reader_joiner.go inverted_expr_evaluator.go inverted_filterer.go inverted_joiner.go joinerbase.go joinreader.go joinreader_strategies.go mergejoiner.go noop.go ordinality.go processors.go project_set.go rowfetcher.go sample_aggregator.go sampler.go scrub_tablereader.go sorter.go stats.go stats.pb.go stream_group_accumulator.go stream_merger.go subquery.go tablereader.go values.go windower.go zigzagjoiner.go

Constants

const (

    // MaxMemoryTagSuffix is the tag suffix for the max memory used stat.
    MaxMemoryTagSuffix = "mem.max"
    // MaxDiskTagSuffix is the tag suffix for the max disk used stat.
    MaxDiskTagSuffix = "disk.max"
)
const (

    // MaxMemoryQueryPlanSuffix is the tag suffix for the max memory used.
    MaxMemoryQueryPlanSuffix = "max memory used"
    // MaxDiskQueryPlanSuffix is the tag suffix for the max disk used.
    MaxDiskQueryPlanSuffix = "max disk used"
)

Variables

var (
    ErrInvalidLengthStats = fmt.Errorf("proto: negative length found during unmarshaling")
    ErrIntOverflowStats   = fmt.Errorf("proto: integer overflow")
)
var CTASPlanResultTypes = []*types.T{
    types.Bytes,
}

CTASPlanResultTypes is the result types for EXPORT plans.

var NewBackupDataProcessor func(*execinfra.FlowCtx, int32, execinfrapb.BackupDataSpec, execinfra.RowReceiver) (execinfra.Processor, error)

NewBackupDataProcessor is implemented in the non-free (CCL) codebase and then injected here via runtime initialization.

var NewCSVWriterProcessor func(*execinfra.FlowCtx, int32, execinfrapb.CSVWriterSpec, execinfra.RowSource, execinfra.RowReceiver) (execinfra.Processor, error)

NewCSVWriterProcessor is implemented in the non-free (CCL) codebase and then injected here via runtime initialization.

var NewChangeAggregatorProcessor func(*execinfra.FlowCtx, int32, execinfrapb.ChangeAggregatorSpec, *execinfrapb.PostProcessSpec, execinfra.RowReceiver) (execinfra.Processor, error)

NewChangeAggregatorProcessor is implemented in the non-free (CCL) codebase and then injected here via runtime initialization.

var NewChangeFrontierProcessor func(*execinfra.FlowCtx, int32, execinfrapb.ChangeFrontierSpec, execinfra.RowSource, *execinfrapb.PostProcessSpec, execinfra.RowReceiver) (execinfra.Processor, error)

NewChangeFrontierProcessor is implemented in the non-free (CCL) codebase and then injected here via runtime initialization.

var NewReadImportDataProcessor func(*execinfra.FlowCtx, int32, execinfrapb.ReadImportDataSpec, execinfra.RowReceiver) (execinfra.Processor, error)

NewReadImportDataProcessor is implemented in the non-free (CCL) codebase and then injected here via runtime initialization.

var NewRestoreDataProcessor func(*execinfra.FlowCtx, int32, execinfrapb.RestoreDataSpec, execinfra.RowSource, execinfra.RowReceiver) (execinfra.Processor, error)

NewRestoreDataProcessor is implemented in the non-free (CCL) codebase and then injected here via runtime initialization.

var NewSplitAndScatterProcessor func(*execinfra.FlowCtx, int32, execinfrapb.SplitAndScatterSpec, execinfra.RowReceiver) (execinfra.Processor, error)

NewSplitAndScatterProcessor is implemented in the non-free (CCL) codebase and then injected here via runtime initialization.

var SampleAggregatorProgressInterval = 5 * time.Second

SampleAggregatorProgressInterval is the frequency at which the SampleAggregator processor will report progress. It is mutable for testing.

var SamplerProgressInterval = 10000

SamplerProgressInterval corresponds to the number of input rows after which the sampler will report progress by pushing a metadata record. It is mutable for testing.

var ScrubTypes = []*types.T{
    types.String,
    types.String,
    types.Jsonb,
}

ScrubTypes is the schema for TableReaders that are doing a SCRUB check. This schema is what TableReader output streams are overrided to for check. The column types correspond to: - Error type. - Primary key as a string, if it was obtainable. - JSON of all decoded column values.

TODO(joey): If we want a way find the key for the error, we will need additional data such as the key bytes and the table descriptor ID. Repair won't be possible without this.

var SubqueryExecModeNames = map[SubqueryExecMode]string{
    SubqueryExecModeUnknown:           "<unknown>",
    SubqueryExecModeExists:            "exists",
    SubqueryExecModeAllRowsNormalized: "all rows normalized",
    SubqueryExecModeAllRows:           "all rows",
    SubqueryExecModeOneRow:            "one row",
}

SubqueryExecModeNames maps SubqueryExecMode values to human readable strings for EXPLAIN queries.

var TestingSamplerSleep time.Duration

TestingSamplerSleep introduces a sleep inside the sampler, every <samplerProgressInterval>. Used to simulate a heavily throttled run for testing.

func CompareEncDatumRowForMerge Uses

func CompareEncDatumRowForMerge(
    lhsTypes []*types.T,
    lhs, rhs sqlbase.EncDatumRow,
    leftOrdering, rightOrdering sqlbase.ColumnOrdering,
    nullEquality bool,
    da *sqlbase.DatumAlloc,
    evalCtx *tree.EvalContext,
) (int, error)

CompareEncDatumRowForMerge EncDatumRow compares two EncDatumRows for merging. When merging two streams and preserving the order (as in a MergeSort or a MergeJoin) compare the head of the streams, emitting the one that sorts first. It allows for the EncDatumRow to be nil if one of the streams is exhausted (and hence nil). CompareEncDatumRowForMerge returns 0 when both rows are nil, and a nil row is considered greater than any non-nil row. CompareEncDatumRowForMerge assumes that the two rows have the same columns in the same orders, but can handle different ordering directions. It takes a DatumAlloc which is used for decoding if any underlying EncDatum is not yet decoded.

func CreateWindowerSpecFunc Uses

func CreateWindowerSpecFunc(funcStr string) (execinfrapb.WindowerSpec_Func, error)

CreateWindowerSpecFunc creates a WindowerSpec_Func based on the function name or returns an error if unknown function name is provided.

func GetResumeSpans Uses

func GetResumeSpans(
    ctx context.Context,
    jobsRegistry *jobs.Registry,
    txn *kv.Txn,
    codec keys.SQLCodec,
    tableID descpb.ID,
    mutationID descpb.MutationID,
    filter backfill.MutationFilter,
) ([]roachpb.Span, *jobs.Job, int, error)

GetResumeSpans returns a ResumeSpanList from a job.

func NewProcessor Uses

func NewProcessor(
    ctx context.Context,
    flowCtx *execinfra.FlowCtx,
    processorID int32,
    core *execinfrapb.ProcessorCoreUnion,
    post *execinfrapb.PostProcessSpec,
    inputs []execinfra.RowSource,
    outputs []execinfra.RowReceiver,
    localProcessors []execinfra.LocalProcessor,
) (execinfra.Processor, error)

NewProcessor creates a new execinfra.Processor according to the provided core.

func SetResumeSpansInJob Uses

func SetResumeSpansInJob(
    ctx context.Context, spans []roachpb.Span, mutationIdx int, txn *kv.Txn, job *jobs.Job,
) error

SetResumeSpansInJob adds a list of resume spans into a job details field.

func TestingSetScannedRowProgressFrequency Uses

func TestingSetScannedRowProgressFrequency(val int64) func()

TestingSetScannedRowProgressFrequency changes the frequency at which row-scanned progress metadata is emitted by table readers.

func WriteResumeSpan Uses

func WriteResumeSpan(
    ctx context.Context,
    db *kv.DB,
    codec keys.SQLCodec,
    id descpb.ID,
    mutationID descpb.MutationID,
    filter backfill.MutationFilter,
    finished roachpb.Spans,
    jobsRegistry *jobs.Registry,
) error

WriteResumeSpan writes a checkpoint for the backfill work on origSpan. origSpan is the span of keys that were assigned to be backfilled, resume is the left over work from origSpan.

type AggregatorStats Uses

type AggregatorStats struct {
    InputStats      InputStats `protobuf:"bytes,1,opt,name=input_stats,json=inputStats,proto3" json:"input_stats"`
    MaxAllocatedMem int64      `protobuf:"varint,2,opt,name=max_allocated_mem,json=maxAllocatedMem,proto3" json:"max_allocated_mem,omitempty"`
}

AggregatorStats are the stats collected during an aggregator run.

func (*AggregatorStats) Descriptor Uses

func (*AggregatorStats) Descriptor() ([]byte, []int)

func (*AggregatorStats) Marshal Uses

func (m *AggregatorStats) Marshal() (dAtA []byte, err error)

func (*AggregatorStats) MarshalTo Uses

func (m *AggregatorStats) MarshalTo(dAtA []byte) (int, error)

func (*AggregatorStats) ProtoMessage Uses

func (*AggregatorStats) ProtoMessage()

func (*AggregatorStats) Reset Uses

func (m *AggregatorStats) Reset()

func (*AggregatorStats) Size Uses

func (m *AggregatorStats) Size() (n int)

func (*AggregatorStats) Stats Uses

func (as *AggregatorStats) Stats() map[string]string

Stats implements the SpanStats interface.

func (*AggregatorStats) StatsForQueryPlan Uses

func (as *AggregatorStats) StatsForQueryPlan() []string

StatsForQueryPlan implements the DistSQLSpanStats interface.

func (*AggregatorStats) String Uses

func (m *AggregatorStats) String() string

func (*AggregatorStats) Unmarshal Uses

func (m *AggregatorStats) Unmarshal(dAtA []byte) error

func (*AggregatorStats) XXX_DiscardUnknown Uses

func (m *AggregatorStats) XXX_DiscardUnknown()

func (*AggregatorStats) XXX_Marshal Uses

func (m *AggregatorStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AggregatorStats) XXX_Merge Uses

func (dst *AggregatorStats) XXX_Merge(src proto.Message)

func (*AggregatorStats) XXX_Size Uses

func (m *AggregatorStats) XXX_Size() int

func (*AggregatorStats) XXX_Unmarshal Uses

func (m *AggregatorStats) XXX_Unmarshal(b []byte) error

type DistinctStats Uses

type DistinctStats struct {
    InputStats      InputStats `protobuf:"bytes,1,opt,name=input_stats,json=inputStats,proto3" json:"input_stats"`
    MaxAllocatedMem int64      `protobuf:"varint,2,opt,name=max_allocated_mem,json=maxAllocatedMem,proto3" json:"max_allocated_mem,omitempty"`
}

DistinctStats are the stats collected during a distinct run.

func (*DistinctStats) Descriptor Uses

func (*DistinctStats) Descriptor() ([]byte, []int)

func (*DistinctStats) Marshal Uses

func (m *DistinctStats) Marshal() (dAtA []byte, err error)

func (*DistinctStats) MarshalTo Uses

func (m *DistinctStats) MarshalTo(dAtA []byte) (int, error)

func (*DistinctStats) ProtoMessage Uses

func (*DistinctStats) ProtoMessage()

func (*DistinctStats) Reset Uses

func (m *DistinctStats) Reset()

func (*DistinctStats) Size Uses

func (m *DistinctStats) Size() (n int)

func (*DistinctStats) Stats Uses

func (ds *DistinctStats) Stats() map[string]string

Stats implements the SpanStats interface.

func (*DistinctStats) StatsForQueryPlan Uses

func (ds *DistinctStats) StatsForQueryPlan() []string

StatsForQueryPlan implements the DistSQLSpanStats interface.

func (*DistinctStats) String Uses

func (m *DistinctStats) String() string

func (*DistinctStats) Unmarshal Uses

func (m *DistinctStats) Unmarshal(dAtA []byte) error

func (*DistinctStats) XXX_DiscardUnknown Uses

func (m *DistinctStats) XXX_DiscardUnknown()

func (*DistinctStats) XXX_Marshal Uses

func (m *DistinctStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DistinctStats) XXX_Merge Uses

func (dst *DistinctStats) XXX_Merge(src proto.Message)

func (*DistinctStats) XXX_Size Uses

func (m *DistinctStats) XXX_Size() int

func (*DistinctStats) XXX_Unmarshal Uses

func (m *DistinctStats) XXX_Unmarshal(b []byte) error

type HashJoinerStats Uses

type HashJoinerStats struct {
    LeftInputStats   InputStats `protobuf:"bytes,1,opt,name=left_input_stats,json=leftInputStats,proto3" json:"left_input_stats"`
    RightInputStats  InputStats `protobuf:"bytes,2,opt,name=right_input_stats,json=rightInputStats,proto3" json:"right_input_stats"`
    StoredSide       string     `protobuf:"bytes,3,opt,name=stored_side,json=storedSide,proto3" json:"stored_side,omitempty"`
    MaxAllocatedMem  int64      `protobuf:"varint,4,opt,name=max_allocated_mem,json=maxAllocatedMem,proto3" json:"max_allocated_mem,omitempty"`
    MaxAllocatedDisk int64      `protobuf:"varint,5,opt,name=max_allocated_disk,json=maxAllocatedDisk,proto3" json:"max_allocated_disk,omitempty"`
}

HashJoinerStats are the stats collected during a hashJoiner run.

func (*HashJoinerStats) Descriptor Uses

func (*HashJoinerStats) Descriptor() ([]byte, []int)

func (*HashJoinerStats) Marshal Uses

func (m *HashJoinerStats) Marshal() (dAtA []byte, err error)

func (*HashJoinerStats) MarshalTo Uses

func (m *HashJoinerStats) MarshalTo(dAtA []byte) (int, error)

func (*HashJoinerStats) ProtoMessage Uses

func (*HashJoinerStats) ProtoMessage()

func (*HashJoinerStats) Reset Uses

func (m *HashJoinerStats) Reset()

func (*HashJoinerStats) Size Uses

func (m *HashJoinerStats) Size() (n int)

func (*HashJoinerStats) Stats Uses

func (hjs *HashJoinerStats) Stats() map[string]string

Stats implements the SpanStats interface.

func (*HashJoinerStats) StatsForQueryPlan Uses

func (hjs *HashJoinerStats) StatsForQueryPlan() []string

StatsForQueryPlan implements the DistSQLSpanStats interface.

func (*HashJoinerStats) String Uses

func (m *HashJoinerStats) String() string

func (*HashJoinerStats) Unmarshal Uses

func (m *HashJoinerStats) Unmarshal(dAtA []byte) error

func (*HashJoinerStats) XXX_DiscardUnknown Uses

func (m *HashJoinerStats) XXX_DiscardUnknown()

func (*HashJoinerStats) XXX_Marshal Uses

func (m *HashJoinerStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HashJoinerStats) XXX_Merge Uses

func (dst *HashJoinerStats) XXX_Merge(src proto.Message)

func (*HashJoinerStats) XXX_Size Uses

func (m *HashJoinerStats) XXX_Size() int

func (*HashJoinerStats) XXX_Unmarshal Uses

func (m *HashJoinerStats) XXX_Unmarshal(b []byte) error

type InputStats Uses

type InputStats struct {
    // num_rows is the number of rows received from the input.
    NumRows int64 `protobuf:"varint,1,opt,name=num_rows,json=numRows,proto3" json:"num_rows,omitempty"`
    // Duration in nanoseconds of the cumulative time spent stalled.
    StallTime time.Duration `protobuf:"bytes,8,opt,name=stall_time,json=stallTime,proto3,stdduration" json:"stall_time"`
}

InputStats represents the stats collected from an input.

func (*InputStats) Descriptor Uses

func (*InputStats) Descriptor() ([]byte, []int)

func (*InputStats) Marshal Uses

func (m *InputStats) Marshal() (dAtA []byte, err error)

func (*InputStats) MarshalTo Uses

func (m *InputStats) MarshalTo(dAtA []byte) (int, error)

func (*InputStats) ProtoMessage Uses

func (*InputStats) ProtoMessage()

func (*InputStats) Reset Uses

func (m *InputStats) Reset()

func (InputStats) RoundStallTime Uses

func (is InputStats) RoundStallTime() time.Duration

RoundStallTime returns the InputStats' StallTime rounded to the nearest time.Millisecond.

func (*InputStats) Size Uses

func (m *InputStats) Size() (n int)

func (InputStats) Stats Uses

func (is InputStats) Stats(prefix string) map[string]string

Stats is a utility method that returns a map of the InputStats` stats to output to a trace as tags. The given prefix is prefixed to the keys.

func (InputStats) StatsForQueryPlan Uses

func (is InputStats) StatsForQueryPlan(prefix string) []string

StatsForQueryPlan is a utility method that returns a list of the InputStats' stats to output on a query plan. The given prefix is prefixed to each element in the returned list.

func (*InputStats) String Uses

func (m *InputStats) String() string

func (*InputStats) Unmarshal Uses

func (m *InputStats) Unmarshal(dAtA []byte) error

func (*InputStats) XXX_DiscardUnknown Uses

func (m *InputStats) XXX_DiscardUnknown()

func (*InputStats) XXX_Marshal Uses

func (m *InputStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*InputStats) XXX_Merge Uses

func (dst *InputStats) XXX_Merge(src proto.Message)

func (*InputStats) XXX_Size Uses

func (m *InputStats) XXX_Size() int

func (*InputStats) XXX_Unmarshal Uses

func (m *InputStats) XXX_Unmarshal(b []byte) error

type InvertedFiltererStats Uses

type InvertedFiltererStats struct {
    InputStats       InputStats `protobuf:"bytes,1,opt,name=input_stats,json=inputStats,proto3" json:"input_stats"`
    MaxAllocatedMem  int64      `protobuf:"varint,2,opt,name=max_allocated_mem,json=maxAllocatedMem,proto3" json:"max_allocated_mem,omitempty"`
    MaxAllocatedDisk int64      `protobuf:"varint,3,opt,name=max_allocated_disk,json=maxAllocatedDisk,proto3" json:"max_allocated_disk,omitempty"`
}

InvertedFiltererStats are the stats collected during an inverted filterer run.

func (*InvertedFiltererStats) Descriptor Uses

func (*InvertedFiltererStats) Descriptor() ([]byte, []int)

func (*InvertedFiltererStats) Marshal Uses

func (m *InvertedFiltererStats) Marshal() (dAtA []byte, err error)

func (*InvertedFiltererStats) MarshalTo Uses

func (m *InvertedFiltererStats) MarshalTo(dAtA []byte) (int, error)

func (*InvertedFiltererStats) ProtoMessage Uses

func (*InvertedFiltererStats) ProtoMessage()

func (*InvertedFiltererStats) Reset Uses

func (m *InvertedFiltererStats) Reset()

func (*InvertedFiltererStats) Size Uses

func (m *InvertedFiltererStats) Size() (n int)

func (*InvertedFiltererStats) Stats Uses

func (ifs *InvertedFiltererStats) Stats() map[string]string

Stats implements the SpanStats interface.

func (*InvertedFiltererStats) StatsForQueryPlan Uses

func (ifs *InvertedFiltererStats) StatsForQueryPlan() []string

StatsForQueryPlan implements the DistSQLSpanStats interface.

func (*InvertedFiltererStats) String Uses

func (m *InvertedFiltererStats) String() string

func (*InvertedFiltererStats) Unmarshal Uses

func (m *InvertedFiltererStats) Unmarshal(dAtA []byte) error

func (*InvertedFiltererStats) XXX_DiscardUnknown Uses

func (m *InvertedFiltererStats) XXX_DiscardUnknown()

func (*InvertedFiltererStats) XXX_Marshal Uses

func (m *InvertedFiltererStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*InvertedFiltererStats) XXX_Merge Uses

func (dst *InvertedFiltererStats) XXX_Merge(src proto.Message)

func (*InvertedFiltererStats) XXX_Size Uses

func (m *InvertedFiltererStats) XXX_Size() int

func (*InvertedFiltererStats) XXX_Unmarshal Uses

func (m *InvertedFiltererStats) XXX_Unmarshal(b []byte) error

type InvertedJoinerStats Uses

type InvertedJoinerStats struct {
    InputStats       InputStats `protobuf:"bytes,1,opt,name=input_stats,json=inputStats,proto3" json:"input_stats"`
    IndexScanStats   InputStats `protobuf:"bytes,2,opt,name=index_scan_stats,json=indexScanStats,proto3" json:"index_scan_stats"`
    MaxAllocatedMem  int64      `protobuf:"varint,3,opt,name=max_allocated_mem,json=maxAllocatedMem,proto3" json:"max_allocated_mem,omitempty"`
    MaxAllocatedDisk int64      `protobuf:"varint,4,opt,name=max_allocated_disk,json=maxAllocatedDisk,proto3" json:"max_allocated_disk,omitempty"`
}

InvertedJoinerStats are the stats collected during an invertedJoiner run.

func (*InvertedJoinerStats) Descriptor Uses

func (*InvertedJoinerStats) Descriptor() ([]byte, []int)

func (*InvertedJoinerStats) Marshal Uses

func (m *InvertedJoinerStats) Marshal() (dAtA []byte, err error)

func (*InvertedJoinerStats) MarshalTo Uses

func (m *InvertedJoinerStats) MarshalTo(dAtA []byte) (int, error)

func (*InvertedJoinerStats) ProtoMessage Uses

func (*InvertedJoinerStats) ProtoMessage()

func (*InvertedJoinerStats) Reset Uses

func (m *InvertedJoinerStats) Reset()

func (*InvertedJoinerStats) Size Uses

func (m *InvertedJoinerStats) Size() (n int)

func (*InvertedJoinerStats) Stats Uses

func (ijs *InvertedJoinerStats) Stats() map[string]string

Stats implements the SpanStats interface.

func (*InvertedJoinerStats) StatsForQueryPlan Uses

func (ijs *InvertedJoinerStats) StatsForQueryPlan() []string

StatsForQueryPlan implements the DistSQLSpanStats interface.

func (*InvertedJoinerStats) String Uses

func (m *InvertedJoinerStats) String() string

func (*InvertedJoinerStats) Unmarshal Uses

func (m *InvertedJoinerStats) Unmarshal(dAtA []byte) error

func (*InvertedJoinerStats) XXX_DiscardUnknown Uses

func (m *InvertedJoinerStats) XXX_DiscardUnknown()

func (*InvertedJoinerStats) XXX_Marshal Uses

func (m *InvertedJoinerStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*InvertedJoinerStats) XXX_Merge Uses

func (dst *InvertedJoinerStats) XXX_Merge(src proto.Message)

func (*InvertedJoinerStats) XXX_Size Uses

func (m *InvertedJoinerStats) XXX_Size() int

func (*InvertedJoinerStats) XXX_Unmarshal Uses

func (m *InvertedJoinerStats) XXX_Unmarshal(b []byte) error

type JoinReaderStats Uses

type JoinReaderStats struct {
    InputStats       InputStats `protobuf:"bytes,1,opt,name=input_stats,json=inputStats,proto3" json:"input_stats"`
    IndexLookupStats InputStats `protobuf:"bytes,2,opt,name=index_lookup_stats,json=indexLookupStats,proto3" json:"index_lookup_stats"`
}

JoinReaderStats are the stats collected during a JoinReader run.

func (*JoinReaderStats) Descriptor Uses

func (*JoinReaderStats) Descriptor() ([]byte, []int)

func (*JoinReaderStats) Marshal Uses

func (m *JoinReaderStats) Marshal() (dAtA []byte, err error)

func (*JoinReaderStats) MarshalTo Uses

func (m *JoinReaderStats) MarshalTo(dAtA []byte) (int, error)

func (*JoinReaderStats) ProtoMessage Uses

func (*JoinReaderStats) ProtoMessage()

func (*JoinReaderStats) Reset Uses

func (m *JoinReaderStats) Reset()

func (*JoinReaderStats) Size Uses

func (m *JoinReaderStats) Size() (n int)

func (*JoinReaderStats) Stats Uses

func (jrs *JoinReaderStats) Stats() map[string]string

Stats implements the SpanStats interface.

func (*JoinReaderStats) StatsForQueryPlan Uses

func (jrs *JoinReaderStats) StatsForQueryPlan() []string

StatsForQueryPlan implements the DistSQLSpanStats interface.

func (*JoinReaderStats) String Uses

func (m *JoinReaderStats) String() string

func (*JoinReaderStats) Unmarshal Uses

func (m *JoinReaderStats) Unmarshal(dAtA []byte) error

func (*JoinReaderStats) XXX_DiscardUnknown Uses

func (m *JoinReaderStats) XXX_DiscardUnknown()

func (*JoinReaderStats) XXX_Marshal Uses

func (m *JoinReaderStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*JoinReaderStats) XXX_Merge Uses

func (dst *JoinReaderStats) XXX_Merge(src proto.Message)

func (*JoinReaderStats) XXX_Size Uses

func (m *JoinReaderStats) XXX_Size() int

func (*JoinReaderStats) XXX_Unmarshal Uses

func (m *JoinReaderStats) XXX_Unmarshal(b []byte) error

type KeyIndex Uses

type KeyIndex = int

KeyIndex is used as a set element. It is already de-duped.

type MergeJoinerStats Uses

type MergeJoinerStats struct {
    LeftInputStats  InputStats `protobuf:"bytes,1,opt,name=left_input_stats,json=leftInputStats,proto3" json:"left_input_stats"`
    RightInputStats InputStats `protobuf:"bytes,2,opt,name=right_input_stats,json=rightInputStats,proto3" json:"right_input_stats"`
    MaxAllocatedMem int64      `protobuf:"varint,3,opt,name=max_allocated_mem,json=maxAllocatedMem,proto3" json:"max_allocated_mem,omitempty"`
}

MergeJoinerStats are the stats collected during a mergeJoiner run.

func (*MergeJoinerStats) Descriptor Uses

func (*MergeJoinerStats) Descriptor() ([]byte, []int)

func (*MergeJoinerStats) Marshal Uses

func (m *MergeJoinerStats) Marshal() (dAtA []byte, err error)

func (*MergeJoinerStats) MarshalTo Uses

func (m *MergeJoinerStats) MarshalTo(dAtA []byte) (int, error)

func (*MergeJoinerStats) ProtoMessage Uses

func (*MergeJoinerStats) ProtoMessage()

func (*MergeJoinerStats) Reset Uses

func (m *MergeJoinerStats) Reset()

func (*MergeJoinerStats) Size Uses

func (m *MergeJoinerStats) Size() (n int)

func (*MergeJoinerStats) Stats Uses

func (mjs *MergeJoinerStats) Stats() map[string]string

Stats implements the SpanStats interface.

func (*MergeJoinerStats) StatsForQueryPlan Uses

func (mjs *MergeJoinerStats) StatsForQueryPlan() []string

StatsForQueryPlan implements the DistSQLSpanStats interface.

func (*MergeJoinerStats) String Uses

func (m *MergeJoinerStats) String() string

func (*MergeJoinerStats) Unmarshal Uses

func (m *MergeJoinerStats) Unmarshal(dAtA []byte) error

func (*MergeJoinerStats) XXX_DiscardUnknown Uses

func (m *MergeJoinerStats) XXX_DiscardUnknown()

func (*MergeJoinerStats) XXX_Marshal Uses

func (m *MergeJoinerStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MergeJoinerStats) XXX_Merge Uses

func (dst *MergeJoinerStats) XXX_Merge(src proto.Message)

func (*MergeJoinerStats) XXX_Size Uses

func (m *MergeJoinerStats) XXX_Size() int

func (*MergeJoinerStats) XXX_Unmarshal Uses

func (m *MergeJoinerStats) XXX_Unmarshal(b []byte) error

type OrdinalityStats Uses

type OrdinalityStats struct {
    InputStats InputStats `protobuf:"bytes,1,opt,name=input_stats,json=inputStats,proto3" json:"input_stats"`
}

OrdinalityStats are the stats collected during a WITH ORDINALITY run.

func (*OrdinalityStats) Descriptor Uses

func (*OrdinalityStats) Descriptor() ([]byte, []int)

func (*OrdinalityStats) Marshal Uses

func (m *OrdinalityStats) Marshal() (dAtA []byte, err error)

func (*OrdinalityStats) MarshalTo Uses

func (m *OrdinalityStats) MarshalTo(dAtA []byte) (int, error)

func (*OrdinalityStats) ProtoMessage Uses

func (*OrdinalityStats) ProtoMessage()

func (*OrdinalityStats) Reset Uses

func (m *OrdinalityStats) Reset()

func (*OrdinalityStats) Size Uses

func (m *OrdinalityStats) Size() (n int)

func (*OrdinalityStats) Stats Uses

func (os *OrdinalityStats) Stats() map[string]string

Stats implements the SpanStats interface.

func (*OrdinalityStats) StatsForQueryPlan Uses

func (os *OrdinalityStats) StatsForQueryPlan() []string

StatsForQueryPlan implements the DistSQLSpanStats interface.

func (*OrdinalityStats) String Uses

func (m *OrdinalityStats) String() string

func (*OrdinalityStats) Unmarshal Uses

func (m *OrdinalityStats) Unmarshal(dAtA []byte) error

func (*OrdinalityStats) XXX_DiscardUnknown Uses

func (m *OrdinalityStats) XXX_DiscardUnknown()

func (*OrdinalityStats) XXX_Marshal Uses

func (m *OrdinalityStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OrdinalityStats) XXX_Merge Uses

func (dst *OrdinalityStats) XXX_Merge(src proto.Message)

func (*OrdinalityStats) XXX_Size Uses

func (m *OrdinalityStats) XXX_Size() int

func (*OrdinalityStats) XXX_Unmarshal Uses

func (m *OrdinalityStats) XXX_Unmarshal(b []byte) error

type SorterStats Uses

type SorterStats struct {
    InputStats       InputStats `protobuf:"bytes,1,opt,name=input_stats,json=inputStats,proto3" json:"input_stats"`
    MaxAllocatedMem  int64      `protobuf:"varint,2,opt,name=max_allocated_mem,json=maxAllocatedMem,proto3" json:"max_allocated_mem,omitempty"`
    MaxAllocatedDisk int64      `protobuf:"varint,3,opt,name=max_allocated_disk,json=maxAllocatedDisk,proto3" json:"max_allocated_disk,omitempty"`
}

SorterStats are the stats collected during a sorter run.

func (*SorterStats) Descriptor Uses

func (*SorterStats) Descriptor() ([]byte, []int)

func (*SorterStats) Marshal Uses

func (m *SorterStats) Marshal() (dAtA []byte, err error)

func (*SorterStats) MarshalTo Uses

func (m *SorterStats) MarshalTo(dAtA []byte) (int, error)

func (*SorterStats) ProtoMessage Uses

func (*SorterStats) ProtoMessage()

func (*SorterStats) Reset Uses

func (m *SorterStats) Reset()

func (*SorterStats) Size Uses

func (m *SorterStats) Size() (n int)

func (*SorterStats) Stats Uses

func (ss *SorterStats) Stats() map[string]string

Stats implements the SpanStats interface.

func (*SorterStats) StatsForQueryPlan Uses

func (ss *SorterStats) StatsForQueryPlan() []string

StatsForQueryPlan implements the DistSQLSpanStats interface.

func (*SorterStats) String Uses

func (m *SorterStats) String() string

func (*SorterStats) Unmarshal Uses

func (m *SorterStats) Unmarshal(dAtA []byte) error

func (*SorterStats) XXX_DiscardUnknown Uses

func (m *SorterStats) XXX_DiscardUnknown()

func (*SorterStats) XXX_Marshal Uses

func (m *SorterStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SorterStats) XXX_Merge Uses

func (dst *SorterStats) XXX_Merge(src proto.Message)

func (*SorterStats) XXX_Size Uses

func (m *SorterStats) XXX_Size() int

func (*SorterStats) XXX_Unmarshal Uses

func (m *SorterStats) XXX_Unmarshal(b []byte) error

type SubqueryExecMode Uses

type SubqueryExecMode int

SubqueryExecMode is an enum to indicate the type of a subquery.

const (
    // SubqueryExecModeUnknown is the default value, and is only used to indicate
    // a subquery that was improperly initialized.
    SubqueryExecModeUnknown SubqueryExecMode = iota
    // SubqueryExecModeExists indicates that the subquery is an argument to
    // EXISTS. Result type is Bool.
    SubqueryExecModeExists
    // SubqueryExecModeAllRowsNormalized indicates that the subquery is an
    // argument to IN, ANY, SOME, or ALL. Any number of rows are
    // expected. The result type is tuple of rows. As a special case, if
    // there is only one column selected, the result is a tuple of the
    // selected values (instead of a tuple of 1-tuples).
    SubqueryExecModeAllRowsNormalized
    // SubqueryExecModeAllRows indicates that the subquery is an
    // argument to an ARRAY constructor. Any number of rows are expected, and
    // exactly one column is expected. Result type is a tuple
    // of selected values.
    SubqueryExecModeAllRows
    // SubqueryExecModeOneRow indicates that the subquery is an argument to
    // another function. At most 1 row is expected. The result type is a tuple of
    // columns, unless there is exactly 1 column in which case the result type is
    // that column's type. If there are no rows, the result is NULL.
    SubqueryExecModeOneRow
)

type TableReaderStats Uses

type TableReaderStats struct {
    InputStats InputStats `protobuf:"bytes,1,opt,name=input_stats,json=inputStats,proto3" json:"input_stats"`
    BytesRead  int64      `protobuf:"varint,2,opt,name=bytes_read,json=bytesRead,proto3" json:"bytes_read,omitempty"`
}

TableReaderStats are the stats collected during a tableReader run.

func (*TableReaderStats) Descriptor Uses

func (*TableReaderStats) Descriptor() ([]byte, []int)

func (*TableReaderStats) Marshal Uses

func (m *TableReaderStats) Marshal() (dAtA []byte, err error)

func (*TableReaderStats) MarshalTo Uses

func (m *TableReaderStats) MarshalTo(dAtA []byte) (int, error)

func (*TableReaderStats) ProtoMessage Uses

func (*TableReaderStats) ProtoMessage()

func (*TableReaderStats) Reset Uses

func (m *TableReaderStats) Reset()

func (*TableReaderStats) Size Uses

func (m *TableReaderStats) Size() (n int)

func (*TableReaderStats) Stats Uses

func (trs *TableReaderStats) Stats() map[string]string

Stats implements the SpanStats interface.

func (*TableReaderStats) StatsForQueryPlan Uses

func (trs *TableReaderStats) StatsForQueryPlan() []string

StatsForQueryPlan implements the DistSQLSpanStats interface.

func (*TableReaderStats) String Uses

func (m *TableReaderStats) String() string

func (*TableReaderStats) Unmarshal Uses

func (m *TableReaderStats) Unmarshal(dAtA []byte) error

func (*TableReaderStats) XXX_DiscardUnknown Uses

func (m *TableReaderStats) XXX_DiscardUnknown()

func (*TableReaderStats) XXX_Marshal Uses

func (m *TableReaderStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TableReaderStats) XXX_Merge Uses

func (dst *TableReaderStats) XXX_Merge(src proto.Message)

func (*TableReaderStats) XXX_Size Uses

func (m *TableReaderStats) XXX_Size() int

func (*TableReaderStats) XXX_Unmarshal Uses

func (m *TableReaderStats) XXX_Unmarshal(b []byte) error

type WindowerStats Uses

type WindowerStats struct {
    InputStats       InputStats `protobuf:"bytes,1,opt,name=input_stats,json=inputStats,proto3" json:"input_stats"`
    MaxAllocatedMem  int64      `protobuf:"varint,2,opt,name=max_allocated_mem,json=maxAllocatedMem,proto3" json:"max_allocated_mem,omitempty"`
    MaxAllocatedDisk int64      `protobuf:"varint,3,opt,name=max_allocated_disk,json=maxAllocatedDisk,proto3" json:"max_allocated_disk,omitempty"`
}

WindowerStats are the stats collected during a windower run.

func (*WindowerStats) Descriptor Uses

func (*WindowerStats) Descriptor() ([]byte, []int)

func (*WindowerStats) Marshal Uses

func (m *WindowerStats) Marshal() (dAtA []byte, err error)

func (*WindowerStats) MarshalTo Uses

func (m *WindowerStats) MarshalTo(dAtA []byte) (int, error)

func (*WindowerStats) ProtoMessage Uses

func (*WindowerStats) ProtoMessage()

func (*WindowerStats) Reset Uses

func (m *WindowerStats) Reset()

func (*WindowerStats) Size Uses

func (m *WindowerStats) Size() (n int)

func (*WindowerStats) Stats Uses

func (ws *WindowerStats) Stats() map[string]string

Stats implements the SpanStats interface.

func (*WindowerStats) StatsForQueryPlan Uses

func (ws *WindowerStats) StatsForQueryPlan() []string

StatsForQueryPlan implements the DistSQLSpanStats interface.

func (*WindowerStats) String Uses

func (m *WindowerStats) String() string

func (*WindowerStats) Unmarshal Uses

func (m *WindowerStats) Unmarshal(dAtA []byte) error

func (*WindowerStats) XXX_DiscardUnknown Uses

func (m *WindowerStats) XXX_DiscardUnknown()

func (*WindowerStats) XXX_Marshal Uses

func (m *WindowerStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WindowerStats) XXX_Merge Uses

func (dst *WindowerStats) XXX_Merge(src proto.Message)

func (*WindowerStats) XXX_Size Uses

func (m *WindowerStats) XXX_Size() int

func (*WindowerStats) XXX_Unmarshal Uses

func (m *WindowerStats) XXX_Unmarshal(b []byte) error

Package rowexec imports 60 packages (graph) and is imported by 15 packages. Updated 2020-08-12. Refresh now. Tools for package owners.