Versions in this module Expand all Collapse all v1 v1.0.0 Aug 23, 2023 v0 v0.1.0 Aug 23, 2023 Changes in this version + const LoadDataVarKey + const LoadStatsVarKey + const LockStatsVarKey + const PlanReplayerDumpVarKey + const PlanReplayerLoadVarKey + const UnlockStatsVarKey + var ErrAdminCheckTable = dbterror.ClassExecutor.NewStd(mysql.ErrAdminCheckTable) + var ErrBRIEBackupFailed = dbterror.ClassExecutor.NewStd(mysql.ErrBRIEBackupFailed) + var ErrBRIEExportFailed = dbterror.ClassExecutor.NewStd(mysql.ErrBRIEExportFailed) + var ErrBRIEImportFailed = dbterror.ClassExecutor.NewStd(mysql.ErrBRIEImportFailed) + var ErrBRIERestoreFailed = dbterror.ClassExecutor.NewStd(mysql.ErrBRIERestoreFailed) + var ErrBadDB = dbterror.ClassExecutor.NewStd(mysql.ErrBadDB) + var ErrBatchInsertFail = dbterror.ClassExecutor.NewStd(mysql.ErrBatchInsertFail) + var ErrBuildExecutor = dbterror.ClassExecutor.NewStd(mysql.ErrBuildExecutor) + var ErrCTEMaxRecursionDepth = dbterror.ClassExecutor.NewStd(mysql.ErrCTEMaxRecursionDepth) + var ErrCannotUser = dbterror.ClassExecutor.NewStd(mysql.ErrCannotUser) + var ErrCantChangeTxCharacteristics = dbterror.ClassExecutor.NewStd(mysql.ErrCantChangeTxCharacteristics) + var ErrCantCreateUserWithGrant = dbterror.ClassExecutor.NewStd(mysql.ErrCantCreateUserWithGrant) + var ErrColumnsNotMatched = dbterror.ClassExecutor.NewStd(mysql.ErrColumnNotMatched) + var ErrDBaccessDenied = dbterror.ClassExecutor.NewStd(mysql.ErrDBaccessDenied) + var ErrDeadlock = dbterror.ClassExecutor.NewStd(mysql.ErrLockDeadlock) + var ErrDynamicPrivilegeNotRegistered = dbterror.ClassExecutor.NewStd(mysql.ErrDynamicPrivilegeNotRegistered) + var ErrExistsInHistoryPassword = dbterror.ClassExecutor.NewStd(mysql.ErrExistsInHistoryPassword) + var ErrForeignKeyCascadeDepthExceeded = dbterror.ClassExecutor.NewStd(mysql.ErrForeignKeyCascadeDepthExceeded) + var ErrFuncNotEnabled = dbterror.ClassExecutor.NewStdErr(mysql.ErrNotSupportedYet, parser_mysql.Message(...)) + var ErrGetStartTS = dbterror.ClassExecutor.NewStd(mysql.ErrGetStartTS) + var ErrGrantRole = dbterror.ClassExecutor.NewStd(mysql.ErrGrantRole) + var ErrIllegalGrantForTable = dbterror.ClassExecutor.NewStd(mysql.ErrIllegalGrantForTable) + var ErrIllegalPrivilegeLevel = dbterror.ClassExecutor.NewStd(mysql.ErrIllegalPrivilegeLevel) + var ErrInstanceScope = dbterror.ClassExecutor.NewStd(mysql.ErrInstanceScope) + var ErrInvalidSplitRegionRanges = dbterror.ClassExecutor.NewStd(mysql.ErrInvalidSplitRegionRanges) + var ErrLazyUniquenessCheckFailure = dbterror.ClassExecutor.NewStd(mysql.ErrLazyUniquenessCheckFailure) + var ErrNotSupportedWithSem = dbterror.ClassOptimizer.NewStd(mysql.ErrNotSupportedWithSem) + var ErrPasswordExpireAnonymousUser = dbterror.ClassExecutor.NewStd(mysql.ErrPasswordExpireAnonymousUser) + var ErrPasswordFormat = dbterror.ClassExecutor.NewStd(mysql.ErrPasswordFormat) + var ErrPasswordNoMatch = dbterror.ClassExecutor.NewStd(mysql.ErrPasswordNoMatch) + var ErrPluginIsNotLoaded = dbterror.ClassExecutor.NewStd(mysql.ErrPluginIsNotLoaded) + var ErrPrepareDDL = dbterror.ClassExecutor.NewStd(mysql.ErrPrepareDDL) + var ErrPrepareMulti = dbterror.ClassExecutor.NewStd(mysql.ErrPrepareMulti) + var ErrPsManyParam = dbterror.ClassExecutor.NewStd(mysql.ErrPsManyParam) + var ErrQueryInterrupted = dbterror.ClassExecutor.NewStd(mysql.ErrQueryInterrupted) + var ErrResultIsEmpty = dbterror.ClassExecutor.NewStd(mysql.ErrResultIsEmpty) + var ErrRoleNotGranted = dbterror.ClassPrivilege.NewStd(mysql.ErrRoleNotGranted) + var ErrSavepointNotSupportedWithBinlog = errors.New("SAVEPOINT is not supported when binlog is enabled") + var ErrSetPasswordAuthPlugin = dbterror.ClassExecutor.NewStd(mysql.ErrSetPasswordAuthPlugin) + var ErrSettingNoopVariable = dbterror.ClassExecutor.NewStd(mysql.ErrSettingNoopVariable) + var ErrSubqueryMoreThan1Row = dbterror.ClassExecutor.NewStd(mysql.ErrSubqueryNo1Row) + var ErrTableaccessDenied = dbterror.ClassExecutor.NewStd(mysql.ErrTableaccessDenied) + var ErrUnknownPlan = dbterror.ClassExecutor.NewStd(mysql.ErrUnknownPlan) + var ErrUnsupportedPs = dbterror.ClassExecutor.NewStd(mysql.ErrUnsupportedPs) + var ErrViewInvalid = dbterror.ClassExecutor.NewStd(mysql.ErrViewInvalid) + var ErrWrongObject = dbterror.ClassExecutor.NewStd(mysql.ErrWrongObject) + var ErrWrongStringLength = dbterror.ClassDDL.NewStd(mysql.ErrWrongStringLength) + var ErrWrongUsage = dbterror.ClassExecutor.NewStd(mysql.ErrWrongUsage) + var GlobalAnalyzeMemoryTracker *memory.Tracker + var GlobalDiskUsageTracker *disk.Tracker + var GlobalMemoryUsageTracker *memory.Tracker + var LookupTableTaskChannelSize int32 = 50 + var MaxRegionSampleSize = int64(1000) + var ParseSlowLogBatchSize = 64 + var QueryReplacer = strings.NewReplacer("\r", " ", "\n", " ", "\t", " ") + var RandSeed = int64(1) + var ShardCount = 320 + var TableStatsCacheExpiry = 3 * time.Second + var TestSetConfigHTTPHandlerKey stringutil.StringerStr = "TestSetConfigHTTPHandlerKey" + var TestSetConfigServerInfoKey stringutil.StringerStr = "TestSetConfigServerInfoKey" + var TestShowClusterConfigKey stringutil.StringerStr = "TestShowClusterConfigKey" + func AddNewAnalyzeJob(ctx sessionctx.Context, job *statistics.AnalyzeJob) + func ConstructResultOfShowCreateDatabase(ctx sessionctx.Context, dbInfo *model.DBInfo, ifNotExists bool, ...) (err error) + func ConstructResultOfShowCreatePlacementPolicy(policyInfo *model.PolicyInfo) string + func ConstructResultOfShowCreateSequence(ctx sessionctx.Context, tableInfo *model.TableInfo, buf *bytes.Buffer) + func ConstructResultOfShowCreateTable(ctx sessionctx.Context, tableInfo *model.TableInfo, ...) (err error) + func ConvertConfigItem2JSON(ctx sessionctx.Context, key string, val expression.Expression) (body string, err error) + func CountStmtNode(stmtNode ast.StmtNode, inRestrictedSQL bool) + func DecodeRowValToChunk(sctx sessionctx.Context, schema *expression.Schema, tblInfo *model.TableInfo, ...) error + func DumpRealOutfile(realBuf, lineBuf []byte, v float64, tp *types.FieldType) ([]byte, []byte) + func EncodeUniqueIndexKey(ctx sessionctx.Context, tblInfo *model.TableInfo, idxInfo *model.IndexInfo, ...) (_ []byte, err error) + func EncodeUniqueIndexValuesForKey(ctx sessionctx.Context, tblInfo *model.TableInfo, idxInfo *model.IndexInfo, ...) (_ []byte, err error) + func FinishAnalyzeJob(sctx sessionctx.Context, job *statistics.AnalyzeJob, analyzeErr error) + func FinishAnalyzeMergeJob(sctx sessionctx.Context, job *statistics.AnalyzeJob, analyzeErr error) + func FormatSQL(sql string) stringutil.StringerFunc + func GenCascadeDeleteAST(schema, table, idx model.CIStr, cols []*model.ColumnInfo, ...) *ast.DeleteStmt + func GenCascadeSetNullAST(schema, table, idx model.CIStr, cols []*model.ColumnInfo, ...) *ast.UpdateStmt + func GenCascadeUpdateAST(schema, table, idx model.CIStr, cols []*model.ColumnInfo, ...) *ast.UpdateStmt + func GetDropOrTruncateTableInfoFromJobs(jobs []*model.Job, gcSafePoint uint64, dom *domain.Domain, ...) (bool, error) + func GetEncodedPlan(stmtCtx *stmtctx.StatementContext, genHint bool) (encodedPlan, hintStr string) + func GetLackHandles(expectedHandles []kv.Handle, obtainedHandlesMap *kv.HandleMap) []kv.Handle + func GetResultRowsCount(stmtCtx *stmtctx.StatementContext, p plannercore.Plan) int64 + func IsFastPlan(p plannercore.Plan) bool + func JoinerType(j joiner) plannercore.JoinType + func LoadExprPushdownBlacklist(sctx sessionctx.Context) (err error) + func LoadOptRuleBlacklist(ctx context.Context, sctx sessionctx.Context) (err error) + func LockKeys(ctx context.Context, sctx sessionctx.Context, lockWaitTime int64, ...) error + func MockNewCacheTableSnapShot(snapshot kv.Snapshot, memBuffer kv.MemBuffer) *cacheTableSnapshot + func NewAnalyzeResultsNotifyWaitGroupWrapper(notify chan *statistics.AnalyzeResults) *analyzeResultsNotifyWaitGroupWrapper + func NewProfileBuilder(sctx sessionctx.Context, start, end time.Time, tp string) (*profileBuilder, error) + func NewRowDecoder(ctx sessionctx.Context, schema *expression.Schema, tbl *model.TableInfo) *rowcodec.ChunkDecoder + func Next(ctx context.Context, e Executor, req *chunk.Chunk) error + func ParseTime(s string) (time.Time, error) + func ResetContextOfStmt(ctx sessionctx.Context, s ast.StmtNode) (err error) + func ResetUpdateStmtCtx(sc *stmtctx.StatementContext, stmt *ast.UpdateStmt, vars *variable.SessionVars) + func SetFromString(value string) []string + func StartAnalyzeJob(sctx sessionctx.Context, job *statistics.AnalyzeJob) + func UpdateAnalyzeJob(sctx sessionctx.Context, job *statistics.AnalyzeJob, rowCount int64) + type AccountLockTelemetryInfo struct + CreateOrAlterUser int64 + LockUser int64 + UnlockUser int64 + type AdminPluginsExec struct + Action core.AdminPluginsAction + Plugins []string + func (e *AdminPluginsExec) Close() error + func (e *AdminPluginsExec) Next(ctx context.Context, _ *chunk.Chunk) error + func (e *AdminPluginsExec) Open(ctx context.Context) error + func (e *AdminPluginsExec) Schema() *expression.Schema + type AdminResetTelemetryIDExec struct + func (e *AdminResetTelemetryIDExec) Close() error + func (e *AdminResetTelemetryIDExec) Next(ctx context.Context, _ *chunk.Chunk) error + func (e *AdminResetTelemetryIDExec) Open(ctx context.Context) error + func (e *AdminResetTelemetryIDExec) Schema() *expression.Schema + type AdminShowTelemetryExec struct + func (e *AdminShowTelemetryExec) Close() error + func (e *AdminShowTelemetryExec) Next(ctx context.Context, req *chunk.Chunk) error + func (e *AdminShowTelemetryExec) Open(ctx context.Context) error + func (e *AdminShowTelemetryExec) Schema() *expression.Schema + type AfFinalResult struct + type AggSpillDiskAction struct + func (*AggSpillDiskAction) GetPriority() int64 + func (a *AggSpillDiskAction) Action(t *memory.Tracker) + type AggWorkerInfo struct + Concurrency int + WallTime int64 + type AggWorkerStat struct + ExecTime int64 + TaskNum int64 + WaitTime int64 + WorkerTime int64 + func (w *AggWorkerStat) Clone() *AggWorkerStat + type AnalyzeColumnsExec struct + type AnalyzeColumnsExecV1 struct + type AnalyzeColumnsExecV2 struct + type AnalyzeExec struct + OptionsMap map[int64]core.V2AnalyzeOptions + func (e *AnalyzeExec) Close() error + func (e *AnalyzeExec) Next(ctx context.Context, _ *chunk.Chunk) error + func (e *AnalyzeExec) Open(ctx context.Context) error + func (e *AnalyzeExec) Schema() *expression.Schema + type AnalyzeFastExec struct + type AnalyzeIndexExec struct + type AnalyzeTestFastExec struct + Collectors []*statistics.SampleCollector + ColsInfo []*model.ColumnInfo + Concurrency int + Ctx sessionctx.Context + HandleCols core.HandleCols + IdxsInfo []*model.IndexInfo + Opts map[ast.AnalyzeOptionType]uint64 + Snapshot uint64 + TableID statistics.AnalyzeTableID + TblInfo *model.TableInfo + func (e *AnalyzeTestFastExec) TestFastSample() error + type BRIEExec struct + func (e *BRIEExec) Close() error + func (e *BRIEExec) Next(ctx context.Context, req *chunk.Chunk) error + func (e *BRIEExec) Open(ctx context.Context) error + func (e *BRIEExec) Schema() *expression.Schema + type BatchPointGetExec struct + func (e *BatchPointGetExec) Close() error + func (e *BatchPointGetExec) Next(ctx context.Context, req *chunk.Chunk) error + func (e *BatchPointGetExec) Open(context.Context) error + func (e *BatchPointGetExec) Schema() *expression.Schema + type CTEExec struct + func (e *CTEExec) Close() (err error) + func (e *CTEExec) Next(ctx context.Context, req *chunk.Chunk) (err error) + func (e *CTEExec) Open(ctx context.Context) (err error) + func (e *CTEExec) Schema() *expression.Schema + type CTEStorages struct + IterInTbl cteutil.Storage + Producer *cteProducer + ResTbl cteutil.Storage + type CTETableReaderExec struct + func (e *CTETableReaderExec) Close() (err error) + func (e *CTETableReaderExec) Next(ctx context.Context, req *chunk.Chunk) (err error) + func (e *CTETableReaderExec) Open(ctx context.Context) error + func (e *CTETableReaderExec) Schema() *expression.Schema + type CancelDDLJobsExec struct + func (e *CancelDDLJobsExec) Close() error + func (e *CancelDDLJobsExec) Next(ctx context.Context, req *chunk.Chunk) error + func (e *CancelDDLJobsExec) Open(ctx context.Context) error + func (e *CancelDDLJobsExec) Schema() *expression.Schema + type ChangeExec struct + func (e *ChangeExec) Close() error + func (e *ChangeExec) Next(ctx context.Context, req *chunk.Chunk) error + func (e *ChangeExec) Open(ctx context.Context) error + func (e *ChangeExec) Schema() *expression.Schema + type CheckIndexRangeExec struct + func (e *CheckIndexRangeExec) Close() error + func (e *CheckIndexRangeExec) Next(ctx context.Context, req *chunk.Chunk) error + func (e *CheckIndexRangeExec) Open(ctx context.Context) error + func (e *CheckIndexRangeExec) Schema() *expression.Schema + type CheckTableExec struct + func (e *CheckTableExec) Close() error + func (e *CheckTableExec) Next(ctx context.Context, req *chunk.Chunk) error + func (e *CheckTableExec) Open(ctx context.Context) error + func (e *CheckTableExec) Schema() *expression.Schema + type ChecksumTableExec struct + func (e *ChecksumTableExec) Close() error + func (e *ChecksumTableExec) Next(ctx context.Context, req *chunk.Chunk) error + func (e *ChecksumTableExec) Open(ctx context.Context) error + func (e *ChecksumTableExec) Schema() *expression.Schema + type CleanupIndexExec struct + func (e *CleanupIndexExec) Close() error + func (e *CleanupIndexExec) Next(ctx context.Context, req *chunk.Chunk) error + func (e *CleanupIndexExec) Open(ctx context.Context) error + func (e *CleanupIndexExec) Schema() *expression.Schema + type Closeable interface + Close func() error + type CommitTask struct + type CompactTableTiFlashExec struct + func (e *CompactTableTiFlashExec) Close() error + func (e *CompactTableTiFlashExec) Next(ctx context.Context, chk *chunk.Chunk) error + func (e *CompactTableTiFlashExec) Open(ctx context.Context) error + func (e *CompactTableTiFlashExec) Schema() *expression.Schema + type Compiler struct + Ctx sessionctx.Context + func (c *Compiler) Compile(ctx context.Context, stmtNode ast.StmtNode) (_ *ExecStmt, err error) + type CoprocessorDAGHandler struct + func NewCoprocessorDAGHandler(sctx sessionctx.Context) *CoprocessorDAGHandler + func (h *CoprocessorDAGHandler) HandleRequest(ctx context.Context, req *coprocessor.Request) *coprocessor.Response + func (h *CoprocessorDAGHandler) HandleStreamRequest(ctx context.Context, req *coprocessor.Request, ...) error + type DDLExec struct + func (e *DDLExec) Close() error + func (e *DDLExec) Next(ctx context.Context, req *chunk.Chunk) (err error) + func (e *DDLExec) Open(ctx context.Context) error + func (e *DDLExec) Schema() *expression.Schema + type DDLJobRetriever struct + TZLoc *time.Location + type DDLJobsReaderExec struct + func (e *DDLJobsReaderExec) Close() error + func (e *DDLJobsReaderExec) Next(ctx context.Context, req *chunk.Chunk) error + func (e *DDLJobsReaderExec) Open(ctx context.Context) error + func (e *DDLJobsReaderExec) Schema() *expression.Schema + type DeallocateExec struct + Name string + func (e *DeallocateExec) Close() error + func (e *DeallocateExec) Next(ctx context.Context, req *chunk.Chunk) error + func (e *DeallocateExec) Open(ctx context.Context) error + func (e *DeallocateExec) Schema() *expression.Schema + type DeleteExec struct + IsMultiTable bool + func (e *DeleteExec) Close() error + func (e *DeleteExec) GetFKCascades() []*FKCascadeExec + func (e *DeleteExec) GetFKChecks() []*FKCheckExec + func (e *DeleteExec) HasFKCascades() bool + func (e *DeleteExec) Next(ctx context.Context, req *chunk.Chunk) error + func (e *DeleteExec) Open(ctx context.Context) error + func (e *DeleteExec) Schema() *expression.Schema + type ExecStmt struct + Ctx sessionctx.Context + GoCtx context.Context + InfoSchema infoschema.InfoSchema + LowerPriority bool + OutputNames []*types.FieldName + Plan plannercore.Plan + PsStmt *plannercore.PlanCacheStmt + StmtNode ast.StmtNode + Text string + Ti *TelemetryInfo + func (a *ExecStmt) CloseRecordSet(txnStartTS uint64, lastErr error) error + func (a *ExecStmt) Exec(ctx context.Context) (_ sqlexec.RecordSet, err error) + func (a *ExecStmt) FinishExecuteStmt(txnTS uint64, err error, hasMoreResults bool) + func (a *ExecStmt) GetStmtNode() ast.StmtNode + func (a *ExecStmt) GetTextToLog() string + func (a *ExecStmt) IsPrepared() bool + func (a *ExecStmt) IsReadOnly(vars *variable.SessionVars) bool + func (a *ExecStmt) LogSlowQuery(txnTS uint64, succ bool, hasMoreResults bool) + func (a *ExecStmt) OriginText() string + func (a *ExecStmt) PointGet(ctx context.Context) (*recordSet, error) + func (a *ExecStmt) RebuildPlan(ctx context.Context) (int64, error) + func (a *ExecStmt) SummaryStmt(succ bool) + type ExecuteExec struct + func (e *ExecuteExec) Build(b *executorBuilder) error + func (e *ExecuteExec) Close() error + func (e *ExecuteExec) Next(ctx context.Context, req *chunk.Chunk) error + func (e *ExecuteExec) Open(ctx context.Context) error + func (e *ExecuteExec) Schema() *expression.Schema + type Executor interface + Close func() error + Next func(ctx context.Context, req *chunk.Chunk) error + Open func(context.Context) error + Schema func() *expression.Schema + type ExplainExec struct + func (e *ExplainExec) Close() error + func (e *ExplainExec) Next(ctx context.Context, req *chunk.Chunk) error + func (e *ExplainExec) Open(ctx context.Context) error + func (e *ExplainExec) Schema() *expression.Schema + type FKCascadeExec struct + type FKCascadeRuntimeStats struct + Keys int + Total time.Duration + func (s *FKCascadeRuntimeStats) Clone() execdetails.RuntimeStats + func (s *FKCascadeRuntimeStats) Merge(other execdetails.RuntimeStats) + func (s *FKCascadeRuntimeStats) String() string + func (s *FKCascadeRuntimeStats) Tp() int + type FKCheckExec struct + type FKCheckRuntimeStats struct + Check time.Duration + Keys int + Lock time.Duration + Total time.Duration + func (s *FKCheckRuntimeStats) Clone() execdetails.RuntimeStats + func (s *FKCheckRuntimeStats) Merge(other execdetails.RuntimeStats) + func (s *FKCheckRuntimeStats) String() string + func (s *FKCheckRuntimeStats) Tp() int + type FieldMapping struct + Column *table.Column + UserVar *ast.VariableExpr + type GrantExec struct + AuthTokenOrTLSOptions []*ast.AuthTokenOrTLSOption + Level *ast.GrantLevel + ObjectType ast.ObjectTypeType + Privs []*ast.PrivElem + Users []*ast.UserSpec + WithGrant bool + func (e *GrantExec) Close() error + func (e *GrantExec) Next(ctx context.Context, req *chunk.Chunk) error + func (e *GrantExec) Open(ctx context.Context) error + func (e *GrantExec) Schema() *expression.Schema + type HashAggExec struct + FinalAggFuncs []aggfuncs.AggFunc + GroupByItems []expression.Expression + PartialAggFuncs []aggfuncs.AggFunc + func (e *HashAggExec) ActionSpill() *AggSpillDiskAction + func (e *HashAggExec) Close() error + func (e *HashAggExec) Next(ctx context.Context, req *chunk.Chunk) error + func (e *HashAggExec) Open(ctx context.Context) error + func (e *HashAggExec) Schema() *expression.Schema + type HashAggFinalWorker struct + type HashAggInput struct + type HashAggIntermData struct + type HashAggPartialWorker struct + type HashAggRuntimeStats struct + FinalConcurrency int + FinalStats []*AggWorkerStat + FinalWallTime int64 + PartialConcurrency int + PartialStats []*AggWorkerStat + PartialWallTime int64 + func (*HashAggRuntimeStats) Tp() int + func (e *HashAggRuntimeStats) Clone() execdetails.RuntimeStats + func (e *HashAggRuntimeStats) Merge(other execdetails.RuntimeStats) + func (e *HashAggRuntimeStats) String() string + type HashJoinExec struct + func (e *HashJoinExec) Close() error + func (e *HashJoinExec) Next(ctx context.Context, req *chunk.Chunk) (err error) + func (e *HashJoinExec) Open(ctx context.Context) error + func (e *HashJoinExec) Schema() *expression.Schema + type HistoryHotRegion struct + EndKey string + FlowBytes float64 + HotDegree int64 + HotRegionType string + IsLeader bool + IsLearner bool + KeyRate float64 + PeerID uint64 + QueryRate float64 + RegionID uint64 + StartKey string + StoreID uint64 + UpdateTime int64 + type HistoryHotRegions struct + HistoryHotRegion []*HistoryHotRegion + type HistoryHotRegionsRequest struct + EndTime int64 + HotRegionTypes []string + IsLeaders []bool + IsLearners []bool + PeerIDs []uint64 + RegionIDs []uint64 + StartTime int64 + StoreIDs []uint64 + type IndexAdvice struct + type IndexAdviseExec struct + IsLocal bool + func (e *IndexAdviseExec) Close() error + func (e *IndexAdviseExec) Next(ctx context.Context, req *chunk.Chunk) error + func (e *IndexAdviseExec) Open(ctx context.Context) error + func (e *IndexAdviseExec) Schema() *expression.Schema + type IndexAdviseInfo struct + Ctx sessionctx.Context + LinesInfo *ast.LinesClause + MaxIndexNum *ast.MaxIndexNumClause + MaxMinutes uint64 + Path string + Result *IndexAdvice + StmtNodes [][]ast.StmtNode + func (e *IndexAdviseInfo) GetIndexAdvice(ctx context.Context, data []byte) error + type IndexAdviseVarKeyType int + const IndexAdviseVarKey + func (k IndexAdviseVarKeyType) String() string + type IndexLookUpExecutor struct + PushedLimit *plannercore.PushedDownLimit + func (e *IndexLookUpExecutor) Close() error + func (e *IndexLookUpExecutor) Next(ctx context.Context, req *chunk.Chunk) error + func (e *IndexLookUpExecutor) Open(ctx context.Context) error + func (e *IndexLookUpExecutor) Schema() *expression.Schema + func (e *IndexLookUpExecutor) Table() table.Table + type IndexLookUpJoin struct + func (e *IndexLookUpJoin) Close() error + func (e *IndexLookUpJoin) Next(ctx context.Context, req *chunk.Chunk) error + func (e *IndexLookUpJoin) Open(ctx context.Context) error + func (e *IndexLookUpJoin) Schema() *expression.Schema + type IndexLookUpMergeJoin struct + func (e *IndexLookUpMergeJoin) Close() error + func (e *IndexLookUpMergeJoin) Next(ctx context.Context, req *chunk.Chunk) error + func (e *IndexLookUpMergeJoin) Open(ctx context.Context) error + func (e *IndexLookUpMergeJoin) Schema() *expression.Schema + type IndexLookUpRunTimeStats struct + Concurrency int + FetchHandle int64 + FetchHandleTotal int64 + NextWaitIndexScan time.Duration + NextWaitTableLookUpBuild time.Duration + NextWaitTableLookUpResp time.Duration + TableRowScan int64 + TableTaskNum int64 + TaskWait int64 + func (e *IndexLookUpRunTimeStats) Clone() execdetails.RuntimeStats + func (e *IndexLookUpRunTimeStats) Merge(other execdetails.RuntimeStats) + func (e *IndexLookUpRunTimeStats) String() string + func (e *IndexLookUpRunTimeStats) Tp() int + type IndexMergeReaderExecutor struct + func (e *IndexMergeReaderExecutor) Close() error + func (e *IndexMergeReaderExecutor) Next(ctx context.Context, req *chunk.Chunk) error + func (e *IndexMergeReaderExecutor) Open(ctx context.Context) (err error) + func (e *IndexMergeReaderExecutor) Schema() *expression.Schema + func (e *IndexMergeReaderExecutor) Table() table.Table + type IndexMergeRuntimeStat struct + Concurrency int + FetchIdxTime int64 + FetchRow int64 + IndexMergeProcess time.Duration + TableTaskNum int64 + WaitTime int64 + func (e *IndexMergeRuntimeStat) Clone() execdetails.RuntimeStats + func (e *IndexMergeRuntimeStat) Merge(other execdetails.RuntimeStats) + func (e *IndexMergeRuntimeStat) String() string + func (e *IndexMergeRuntimeStat) Tp() int + type IndexNestedLoopHashJoin struct + func (e *IndexNestedLoopHashJoin) Close() error + func (e *IndexNestedLoopHashJoin) Next(ctx context.Context, req *chunk.Chunk) error + func (e *IndexNestedLoopHashJoin) Open(ctx context.Context) error + func (e *IndexNestedLoopHashJoin) Schema() *expression.Schema + type IndexReaderExecutor struct + func (e *IndexReaderExecutor) Close() (err error) + func (e *IndexReaderExecutor) Next(ctx context.Context, req *chunk.Chunk) error + func (e *IndexReaderExecutor) Open(ctx context.Context) error + func (e *IndexReaderExecutor) Schema() *expression.Schema + func (e *IndexReaderExecutor) Table() table.Table + func (sr IndexReaderExecutor) SelectResult(ctx context.Context, sctx sessionctx.Context, kvReq *kv.Request, ...) (distsql.SelectResult, error) + type InsertExec struct + OnDuplicate []*expression.Assignment + Priority mysql.PriorityEnum + func (e *InsertExec) Close() error + func (e *InsertExec) GetFKCascades() []*FKCascadeExec + func (e *InsertExec) GetFKChecks() []*FKCheckExec + func (e *InsertExec) HasFKCascades() bool + func (e *InsertExec) Next(ctx context.Context, req *chunk.Chunk) error + func (e *InsertExec) Open(ctx context.Context) error + func (e InsertExec) Schema() *expression.Schema + type InsertRuntimeStat struct + CheckInsertTime time.Duration + FKCheckTime time.Duration + Prefetch time.Duration + func (e *InsertRuntimeStat) Clone() execdetails.RuntimeStats + func (e *InsertRuntimeStat) Merge(other execdetails.RuntimeStats) + func (e *InsertRuntimeStat) String() string + func (e *InsertRuntimeStat) Tp() int + type InsertValues struct + Columns []*ast.ColumnName + GenExprs []expression.Expression + Lists [][]expression.Expression + SelectExec Executor + SetList []*expression.Assignment + Table table.Table + func (e *InsertValues) Close() error + func (e *InsertValues) Next(ctx context.Context, req *chunk.Chunk) error + func (e *InsertValues) Open(ctx context.Context) error + func (e *InsertValues) Schema() *expression.Schema + type IterCb func(key uint64, e *entry) + type LimitExec struct + func (e *LimitExec) Close() error + func (e *LimitExec) Next(ctx context.Context, req *chunk.Chunk) error + func (e *LimitExec) Open(ctx context.Context) error + func (e *LimitExec) Schema() *expression.Schema + type LoadDataExec struct + IsLocal bool + OnDuplicate ast.OnDuplicateKeyHandlingType + func (e *LoadDataExec) Close() error + func (e *LoadDataExec) Next(ctx context.Context, req *chunk.Chunk) error + func (e *LoadDataExec) Open(ctx context.Context) error + func (e *LoadDataExec) Schema() *expression.Schema + type LoadDataInfo struct + ColumnAssignmentExprs []expression.Expression + ColumnAssignments []*ast.Assignment + ColumnsAndUserVars []*ast.ColumnNameOrUserVar + Ctx sessionctx.Context + Drained bool + FieldMappings []*FieldMapping + FieldsInfo *ast.FieldsClause + IgnoreLines uint64 + LinesInfo *ast.LinesClause + OnDuplicate ast.OnDuplicateKeyHandlingType + Path string + QuitCh chan struct{} + StopCh chan struct{} + Table table.Table + func (e *LoadDataInfo) CheckAndInsertOneBatch(ctx context.Context, rows [][]types.Datum, cnt uint64) error + func (e *LoadDataInfo) CloseTaskQueue() + func (e *LoadDataInfo) CommitOneTask(ctx context.Context, task CommitTask) error + func (e *LoadDataInfo) CommitWork(ctx context.Context) error + func (e *LoadDataInfo) EnqOneTask(ctx context.Context) error + func (e *LoadDataInfo) ForceQuit() + func (e *LoadDataInfo) GetCurBatchCnt() uint64 + func (e *LoadDataInfo) GetRows() [][]types.Datum + func (e *LoadDataInfo) InitQueues() + func (e *LoadDataInfo) InsertData(ctx context.Context, prevData, curData []byte) ([]byte, bool, error) + func (e *LoadDataInfo) MakeCommitTask() CommitTask + func (e *LoadDataInfo) SetMaxRowsInBatch(limit uint64) + func (e *LoadDataInfo) SetMessage() + func (e *LoadDataInfo) StartStopWatcher() + func (e LoadDataInfo) Close() error + func (e LoadDataInfo) Next(ctx context.Context, req *chunk.Chunk) error + func (e LoadDataInfo) Open(ctx context.Context) error + func (e LoadDataInfo) Schema() *expression.Schema + type LoadStatsExec struct + func (e *LoadStatsExec) Close() error + func (e *LoadStatsExec) Next(ctx context.Context, req *chunk.Chunk) error + func (e *LoadStatsExec) Open(ctx context.Context) error + func (e *LoadStatsExec) Schema() *expression.Schema + type LoadStatsInfo struct + Ctx sessionctx.Context + Path string + func (e *LoadStatsInfo) Update(data []byte) error + type LockStatsExec struct + Tables []*ast.TableName + func (e *LockStatsExec) Close() error + func (e *LockStatsExec) Next(ctx context.Context, req *chunk.Chunk) error + func (e *LockStatsExec) Open(ctx context.Context) error + func (e *LockStatsExec) Schema() *expression.Schema + type MPPGather struct + func (e *MPPGather) Close() error + func (e *MPPGather) Next(ctx context.Context, chk *chunk.Chunk) error + func (e *MPPGather) Open(ctx context.Context) (err error) + func (e *MPPGather) Schema() *expression.Schema + type MaxOneRowExec struct + func (e *MaxOneRowExec) Close() error + func (e *MaxOneRowExec) Next(ctx context.Context, req *chunk.Chunk) error + func (e *MaxOneRowExec) Open(ctx context.Context) error + func (e *MaxOneRowExec) Schema() *expression.Schema + type MemTableReaderExec struct + func (e *MemTableReaderExec) Close() error + func (e *MemTableReaderExec) Next(ctx context.Context, req *chunk.Chunk) error + func (e *MemTableReaderExec) Open(ctx context.Context) error + func (e *MemTableReaderExec) Schema() *expression.Schema + type MergeJoinExec struct + func (e *MergeJoinExec) Close() error + func (e *MergeJoinExec) Next(ctx context.Context, req *chunk.Chunk) (err error) + func (e *MergeJoinExec) Open(ctx context.Context) error + func (e *MergeJoinExec) Schema() *expression.Schema + type MetricRetriever struct + type MetricsSummaryByLabelRetriever struct + type MetricsSummaryRetriever struct + type MockExecutorBuilder struct + func NewMockExecutorBuilderForTest(ctx sessionctx.Context, is infoschema.InfoSchema, ti *TelemetryInfo) *MockExecutorBuilder + func (b *MockExecutorBuilder) Build(p plannercore.Plan) Executor + type MockPhysicalPlan interface + GetExecutor func() Executor + type NAAJType byte + const LeftHasNullRightHasNull + const LeftHasNullRightNotNull + const LeftNotNullRightHasNull + const LeftNotNullRightNotNull + const Unknown + type NestedLoopApplyExec struct + func (e *NestedLoopApplyExec) Close() error + func (e *NestedLoopApplyExec) Next(ctx context.Context, req *chunk.Chunk) (err error) + func (e *NestedLoopApplyExec) Open(ctx context.Context) error + func (e *NestedLoopApplyExec) Schema() *expression.Schema + type ParallelNestedLoopApplyExec struct + func (e *ParallelNestedLoopApplyExec) Close() error + func (e *ParallelNestedLoopApplyExec) Next(ctx context.Context, req *chunk.Chunk) (err error) + func (e *ParallelNestedLoopApplyExec) Open(ctx context.Context) error + func (e *ParallelNestedLoopApplyExec) Schema() *expression.Schema + type PartitionTelemetryInfo struct + TablePartitionMaxPartitionsNum uint64 + UseAddIntervalPartition bool + UseCompactTablePartition bool + UseCreateIntervalPartition bool + UseDropIntervalPartition bool + UseTablePartition bool + UseTablePartitionHash bool + UseTablePartitionList bool + UseTablePartitionListColumns bool + UseTablePartitionRange bool + UseTablePartitionRangeColumns bool + UseTablePartitionRangeColumnsGt1 bool + UseTablePartitionRangeColumnsGt2 bool + UseTablePartitionRangeColumnsGt3 bool + type PessimisticLockCacheGetter struct + func (getter *PessimisticLockCacheGetter) Get(_ context.Context, key kv.Key) ([]byte, error) + type PipelinedWindowExec struct + func (e *PipelinedWindowExec) Close() error + func (e *PipelinedWindowExec) Next(ctx context.Context, chk *chunk.Chunk) (err error) + func (e *PipelinedWindowExec) Open(ctx context.Context) (err error) + func (e *PipelinedWindowExec) Schema() *expression.Schema + type PlanReplayerCaptureInfo struct + PlanDigest string + SQLDigest string + type PlanReplayerDumpInfo struct + Analyze bool + ExecStmts []ast.StmtNode + File *os.File + FileName string + Path string + func (e *PlanReplayerDumpInfo) DumpSQLsFromFile(ctx context.Context, b []byte) error + type PlanReplayerExec struct + CaptureInfo *PlanReplayerCaptureInfo + DumpInfo *PlanReplayerDumpInfo + func (e *PlanReplayerExec) Close() error + func (e *PlanReplayerExec) Next(ctx context.Context, req *chunk.Chunk) error + func (e *PlanReplayerExec) Open(ctx context.Context) error + func (e *PlanReplayerExec) Schema() *expression.Schema + type PlanReplayerLoadExec struct + func (e *PlanReplayerLoadExec) Close() error + func (e *PlanReplayerLoadExec) Next(ctx context.Context, req *chunk.Chunk) error + func (e *PlanReplayerLoadExec) Open(ctx context.Context) error + func (e *PlanReplayerLoadExec) Schema() *expression.Schema + type PlanReplayerLoadInfo struct + Ctx sessionctx.Context + Path string + func (e *PlanReplayerLoadInfo) Update(data []byte) error + type PointGetExecutor struct + func (e *PointGetExecutor) Close() error + func (e *PointGetExecutor) Init(p *plannercore.PointGetPlan) + func (e *PointGetExecutor) Next(ctx context.Context, req *chunk.Chunk) error + func (e *PointGetExecutor) Open(context.Context) error + func (e *PointGetExecutor) Schema() *expression.Schema + type PrepareExec struct + Fields []*ast.ResultField + ID uint32 + IsGeneralStmt bool + ParamCount int + Stmt interface{} + func NewPrepareExec(ctx sessionctx.Context, sqlTxt string) *PrepareExec + func (e *PrepareExec) Close() error + func (e *PrepareExec) Next(ctx context.Context, req *chunk.Chunk) error + func (e *PrepareExec) Open(ctx context.Context) error + func (e *PrepareExec) Schema() *expression.Schema + type ProjectionExec struct + func (e *ProjectionExec) Close() error + func (e *ProjectionExec) Next(ctx context.Context, req *chunk.Chunk) error + func (e *ProjectionExec) Open(ctx context.Context) error + func (e *ProjectionExec) Schema() *expression.Schema + type RecoverIndexExec struct + func (e *RecoverIndexExec) Close() error + func (e *RecoverIndexExec) Next(ctx context.Context, req *chunk.Chunk) error + func (e *RecoverIndexExec) Open(ctx context.Context) error + func (e *RecoverIndexExec) Schema() *expression.Schema + type ReloadExprPushdownBlacklistExec struct + func (e *ReloadExprPushdownBlacklistExec) Close() error + func (e *ReloadExprPushdownBlacklistExec) Next(ctx context.Context, _ *chunk.Chunk) error + func (e *ReloadExprPushdownBlacklistExec) Open(ctx context.Context) error + func (e *ReloadExprPushdownBlacklistExec) Schema() *expression.Schema + type ReloadOptRuleBlacklistExec struct + func (e *ReloadOptRuleBlacklistExec) Close() error + func (e *ReloadOptRuleBlacklistExec) Next(ctx context.Context, _ *chunk.Chunk) error + func (e *ReloadOptRuleBlacklistExec) Open(ctx context.Context) error + func (e *ReloadOptRuleBlacklistExec) Schema() *expression.Schema + type ReplaceExec struct + Priority int + func (e *ReplaceExec) Close() error + func (e *ReplaceExec) EqualDatumsAsBinary(sc *stmtctx.StatementContext, a []types.Datum, b []types.Datum) (bool, error) + func (e *ReplaceExec) Next(ctx context.Context, req *chunk.Chunk) error + func (e *ReplaceExec) Open(ctx context.Context) error + func (e ReplaceExec) Schema() *expression.Schema + type RevokeExec struct + Level *ast.GrantLevel + ObjectType ast.ObjectTypeType + Privs []*ast.PrivElem + Users []*ast.UserSpec + func (e *RevokeExec) Close() error + func (e *RevokeExec) Next(ctx context.Context, req *chunk.Chunk) error + func (e *RevokeExec) Open(ctx context.Context) error + func (e *RevokeExec) Schema() *expression.Schema + type SQLBindExec struct + func (e *SQLBindExec) Close() error + func (e *SQLBindExec) Next(ctx context.Context, req *chunk.Chunk) error + func (e *SQLBindExec) Open(ctx context.Context) error + func (e *SQLBindExec) Schema() *expression.Schema + type SelectIntoExec struct + func (e *SelectIntoExec) Schema() *expression.Schema + func (s *SelectIntoExec) Close() error + func (s *SelectIntoExec) Next(ctx context.Context, req *chunk.Chunk) error + func (s *SelectIntoExec) Open(ctx context.Context) error + type SelectLockExec struct + Lock *ast.SelectLockInfo + func (e *SelectLockExec) Close() error + func (e *SelectLockExec) Next(ctx context.Context, req *chunk.Chunk) error + func (e *SelectLockExec) Open(ctx context.Context) error + func (e *SelectLockExec) Schema() *expression.Schema + type SelectionExec struct + func (e *SelectionExec) Close() error + func (e *SelectionExec) Next(ctx context.Context, req *chunk.Chunk) error + func (e *SelectionExec) Open(ctx context.Context) error + func (e *SelectionExec) Schema() *expression.Schema + type SetConfigExec struct + func (e *SetConfigExec) Close() error + func (e *SetConfigExec) Schema() *expression.Schema + func (s *SetConfigExec) Next(ctx context.Context, req *chunk.Chunk) error + func (s *SetConfigExec) Open(ctx context.Context) error + type SetExecutor struct + func (e *SetExecutor) Close() error + func (e *SetExecutor) Next(ctx context.Context, req *chunk.Chunk) error + func (e *SetExecutor) Open(ctx context.Context) error + func (e *SetExecutor) Schema() *expression.Schema + type ShowDDLExec struct + func (e *ShowDDLExec) Close() error + func (e *ShowDDLExec) Next(ctx context.Context, req *chunk.Chunk) error + func (e *ShowDDLExec) Open(ctx context.Context) error + func (e *ShowDDLExec) Schema() *expression.Schema + type ShowDDLJobQueriesExec struct + func (e *ShowDDLJobQueriesExec) Close() error + func (e *ShowDDLJobQueriesExec) Next(ctx context.Context, req *chunk.Chunk) error + func (e *ShowDDLJobQueriesExec) Open(ctx context.Context) error + func (e *ShowDDLJobQueriesExec) Schema() *expression.Schema + type ShowDDLJobQueriesWithRangeExec struct + func (e *ShowDDLJobQueriesWithRangeExec) Close() error + func (e *ShowDDLJobQueriesWithRangeExec) Next(ctx context.Context, req *chunk.Chunk) error + func (e *ShowDDLJobQueriesWithRangeExec) Open(ctx context.Context) error + func (e *ShowDDLJobQueriesWithRangeExec) Schema() *expression.Schema + type ShowDDLJobsExec struct + func (e *ShowDDLJobsExec) Close() error + func (e *ShowDDLJobsExec) Next(ctx context.Context, req *chunk.Chunk) error + func (e *ShowDDLJobsExec) Open(ctx context.Context) error + func (e *ShowDDLJobsExec) Schema() *expression.Schema + type ShowExec struct + Column *ast.ColumnName + CountWarningsOrErrors bool + DBName model.CIStr + Extended bool + Extractor plannercore.ShowPredicateExtractor + Flag int + Full bool + GlobalScope bool + IfNotExists bool + IndexName model.CIStr + Partition model.CIStr + Roles []*auth.RoleIdentity + Table *ast.TableName + Tp ast.ShowStmtType + User *auth.UserIdentity + func (e *ShowExec) Close() error + func (e *ShowExec) Next(ctx context.Context, req *chunk.Chunk) error + func (e *ShowExec) Open(ctx context.Context) error + func (e *ShowExec) Schema() *expression.Schema + type ShowNextRowIDExec struct + func (e *ShowNextRowIDExec) Close() error + func (e *ShowNextRowIDExec) Next(ctx context.Context, req *chunk.Chunk) error + func (e *ShowNextRowIDExec) Open(ctx context.Context) error + func (e *ShowNextRowIDExec) Schema() *expression.Schema + type ShowSlowExec struct + ShowSlow *ast.ShowSlow + func (e *ShowSlowExec) Close() error + func (e *ShowSlowExec) Next(ctx context.Context, req *chunk.Chunk) error + func (e *ShowSlowExec) Open(ctx context.Context) error + func (e *ShowSlowExec) Schema() *expression.Schema + type ShuffleExec struct + func (e *ShuffleExec) Close() error + func (e *ShuffleExec) Next(ctx context.Context, req *chunk.Chunk) error + func (e *ShuffleExec) Open(ctx context.Context) error + func (e *ShuffleExec) Schema() *expression.Schema + type SimpleExec struct + IsFromRemote bool + Statement ast.StmtNode + func (e *SimpleExec) Close() error + func (e *SimpleExec) Next(ctx context.Context, req *chunk.Chunk) (err error) + func (e *SimpleExec) Open(ctx context.Context) error + func (e *SimpleExec) Schema() *expression.Schema + type SortExec struct + ByItems []*util.ByItems + Idx int + func (e *SortExec) Close() error + func (e *SortExec) Next(ctx context.Context, req *chunk.Chunk) error + func (e *SortExec) Open(ctx context.Context) error + func (e *SortExec) Schema() *expression.Schema + type SplitIndexRegionExec struct + func (e *SplitIndexRegionExec) Close() error + func (e *SplitIndexRegionExec) Next(ctx context.Context, chk *chunk.Chunk) error + func (e *SplitIndexRegionExec) Open(ctx context.Context) (err error) + func (e *SplitIndexRegionExec) Schema() *expression.Schema + type SplitTableRegionExec struct + func (e *SplitTableRegionExec) Close() error + func (e *SplitTableRegionExec) Next(ctx context.Context, chk *chunk.Chunk) error + func (e *SplitTableRegionExec) Open(ctx context.Context) (err error) + func (e *SplitTableRegionExec) Schema() *expression.Schema + type StreamAggExec struct + func (e *StreamAggExec) Close() error + func (e *StreamAggExec) Next(ctx context.Context, req *chunk.Chunk) (err error) + func (e *StreamAggExec) Open(ctx context.Context) error + func (e *StreamAggExec) Schema() *expression.Schema + type TableDualExec struct + func (e *TableDualExec) Close() error + func (e *TableDualExec) Next(ctx context.Context, req *chunk.Chunk) error + func (e *TableDualExec) Open(ctx context.Context) error + func (e *TableDualExec) Schema() *expression.Schema + type TableReaderExecutor struct + func (e *TableReaderExecutor) Close() error + func (e *TableReaderExecutor) Next(ctx context.Context, req *chunk.Chunk) error + func (e *TableReaderExecutor) Open(ctx context.Context) error + func (e *TableReaderExecutor) Schema() *expression.Schema + func (e *TableReaderExecutor) Table() table.Table + func (sr TableReaderExecutor) SelectResult(ctx context.Context, sctx sessionctx.Context, kvReq *kv.Request, ...) (distsql.SelectResult, error) + type TableSampleExecutor struct + func (e *TableSampleExecutor) Close() error + func (e *TableSampleExecutor) Next(ctx context.Context, req *chunk.Chunk) error + func (e *TableSampleExecutor) Open(ctx context.Context) error + func (e *TableSampleExecutor) Schema() *expression.Schema + type TableScanExec struct + func (e *TableScanExec) Close() error + func (e *TableScanExec) Next(ctx context.Context, req *chunk.Chunk) error + func (e *TableScanExec) Open(ctx context.Context) error + func (e *TableScanExec) Schema() *expression.Schema + type TelemetryInfo struct + AccountLockTelemetry *AccountLockTelemetryInfo + PartitionTelemetry *PartitionTelemetryInfo + UesExchangePartition bool + UseFlashbackToCluster bool + UseIndexMerge bool + UseMultiSchemaChange bool + UseNonRecursive bool + UseRecursive bool + type TestShowClusterConfigFunc func() ([][]types.Datum, error) + type TiFlashSystemTableRetriever struct + type TopNExec struct + func (e *TopNExec) Next(ctx context.Context, req *chunk.Chunk) error + func (e *TopNExec) Open(ctx context.Context) error + func (e *TopNExec) Schema() *expression.Schema + type TraceExec struct + CollectedSpans []basictracer.RawSpan + func (e *TraceExec) Close() error + func (e *TraceExec) Next(ctx context.Context, req *chunk.Chunk) error + func (e *TraceExec) Open(ctx context.Context) error + func (e *TraceExec) Schema() *expression.Schema + type UnionExec struct + func (e *UnionExec) Close() error + func (e *UnionExec) Next(ctx context.Context, req *chunk.Chunk) error + func (e *UnionExec) Open(ctx context.Context) error + func (e *UnionExec) Schema() *expression.Schema + type UnionScanExec struct + func (e *UnionScanExec) Schema() *expression.Schema + func (us *UnionScanExec) Close() error + func (us *UnionScanExec) Next(ctx context.Context, req *chunk.Chunk) error + func (us *UnionScanExec) Open(ctx context.Context) error + type UnlockStatsExec struct + Tables []*ast.TableName + func (e *UnlockStatsExec) Close() error + func (e *UnlockStatsExec) Next(ctx context.Context, req *chunk.Chunk) error + func (e *UnlockStatsExec) Open(ctx context.Context) error + func (e *UnlockStatsExec) Schema() *expression.Schema + type UpdateExec struct + OrderedList []*expression.Assignment + func (e *UpdateExec) Close() error + func (e *UpdateExec) GetFKCascades() []*FKCascadeExec + func (e *UpdateExec) GetFKChecks() []*FKCheckExec + func (e *UpdateExec) HasFKCascades() bool + func (e *UpdateExec) Next(ctx context.Context, req *chunk.Chunk) error + func (e *UpdateExec) Open(ctx context.Context) error + func (e *UpdateExec) Schema() *expression.Schema + type UpdatedValuesCouple struct + NewValues []types.Datum + OldValuesList [][]types.Datum + type UpsertCb func(exist bool, valueInMap, newValue *entry) *entry + type WindowExec struct + func (e *WindowExec) Close() error + func (e *WindowExec) Next(ctx context.Context, chk *chunk.Chunk) error + func (e *WindowExec) Open(ctx context.Context) error + func (e *WindowExec) Schema() *expression.Schema + type WithForeignKeyTrigger interface + GetFKCascades func() []*FKCascadeExec + GetFKChecks func() []*FKCheckExec + HasFKCascades func() bool