MCPcopy Create free account

hub / github.com/chrislusf/gleam / functions

Functions3,091 in github.com/chrislusf/gleam

⨍ Functions 3,091◇ Types & classes 751
↓ 1 callersFunctionisMergeableDataset
(ds *flow.Dataset, taskCount int)
distributed/plan/plan_logical.go:9
↓ 1 callersFunctionisNullRejected
isNullRejected check whether a condition is null-rejected A condition would be null-rejected in one of following cases: If it is a predicate containin
sql/plan/predicate_push_down.go:204
↓ 1 callersMethodisNullToExpression
(v *ast.IsNullExpr)
sql/plan/expression_rewriter.go:767
↓ 1 callersFunctionisOrderByEquals
(a []instruction.OrderBy, b []instruction.OrderBy)
flow/dataset_sort.go:82
↓ 1 callersFunctionisPrimary
(ops []*ast.ColumnOption)
sql/plan/validator.go:245
↓ 1 callersFunctionisSpace
(c byte)
sql/util/types/helper.go:82
↓ 1 callersFunctionisStepGroupFinished
(status *pb.FlowExecutionStatus, stepGroup *pb.FlowExecutionStatus_StepGroup)
distributed/master/ui/svg_writer.go:166
↓ 1 callersFunctionisTokenIdentifier
(s string, buf *bytes.Buffer)
sql/parser/misc.go:503
↓ 1 callersFunctionisTrueOpFactory
(op opcode.Op)
sql/expression/builtin_op.go:279
↓ 1 callersMethodisTrueToScalarFunc
(v *ast.IsTruthExpr)
sql/plan/expression_rewriter.go:786
↓ 1 callersFunctionjoin1
()
examples/join/join.go:28
↓ 1 callersMethodlikeToScalarFunc
(v *ast.PatternLikeExpr)
sql/plan/expression_rewriter.go:870
↓ 1 callersFunctionlinelabel
linelabel determines the connection and arrow geometry
distributed/master/ui/svg_writer_helper.go:65
↓ 1 callersMethodlocalExecute
(ctx context.Context, flowContext *flow.Flow, executionStatus *pb.FlowExecutionStatus_TaskGroup_Execution,
distributed/driver/scheduler/scheduler_execute.go:75
↓ 1 callersMethodlocalExecuteOutput
(ctx context.Context, flowContext *flow.Flow, task *flow.Task, wg *sync.WaitGroup)
distributed/driver/scheduler/scheduler_execute.go:121
↓ 1 callersMethodlocalExecuteSource
(ctx context.Context, flowContext *flow.Flow, executionStatus *pb.FlowExecutionStatus_TaskGroup_Execution,
distributed/driver/scheduler/scheduler_execute.go:87
↓ 1 callersMethodlogExecutionPlan
(fc *flow.Flow)
distributed/driver/driver_execution_status.go:26
↓ 1 callersFunctionmain1
(in string)
sql/parser/goyacc/main.go:228
↓ 1 callersMethodmakeBushyJoin
Make cartesian join as bushy tree.
sql/plan/join_reorder.go:167
↓ 1 callersMethodmatch
(fullPath string)
plugins/file/file_source.go:123
↓ 1 callersFunctionmatchDateWithToken
(t *mysqlTime, date string, token string, ctx map[string]int)
sql/util/types/time.go:1967
↓ 1 callersFunctionmatchField
(f *ast.SelectField, col *ast.ColumnNameExpr, ignoreAsName bool)
sql/plan/logical_plan_builder.go:487
↓ 1 callersFunctionmatchProp
(ctx context.Context, target, new *requiredProperty)
sql/plan/physical_plan_builder.go:790
↓ 1 callersFunctionmatchPropColumn
matchPropColumn checks if the idxCol match one of columns in required property and return the matched index. If no column is matched, return -1.
sql/plan/match_property.go:79
↓ 1 callersMethodmatchProperty
matchProperty implements PhysicalPlan matchProperty interface.
sql/plan/match_property.go:164
↓ 1 callersMethodmatchProperty
matchProperty implements PhysicalPlan matchProperty interface.
sql/plan/match_property.go:206
↓ 1 callersMethodmatchProperty
matchProperty implements PhysicalPlan matchProperty interface.
sql/plan/match_property.go:221
↓ 1 callersFunctionmaxDecimal
(precision, frac int, to *MyDecimal)
sql/util/types/mydecimal.go:1615
↓ 1 callersFunctionmemoryCost
(tg *plan.TaskGroup)
distributed/driver/scheduler/scheduler_score.go:31
↓ 1 callersFunctionmergeStats
merge existing stats with incoming stats
distributed/driver/scheduler/grpc_client_to_agent.go:149
↓ 1 callersMethodminusAllocated
(allocated pb.ComputeResource)
distributed/agent/agent_grpc_server.go:151
↓ 1 callersFunctionmysqlTimeFix
mysqlTimeFix fixes the mysqlTime use the values in the context.
sql/util/types/time.go:1821
↓ 1 callersMethodneed2ConsiderIndex
(prop *requiredProperty)
sql/plan/physical_plan_builder.go:98
↓ 1 callersFunctionneedCount
(af expression.AggregationFunction)
sql/plan/physical_plans.go:204
↓ 1 callersFunctionneedValue
(af expression.AggregationFunction)
sql/plan/physical_plans.go:208
↓ 1 callersMethodnewBuildFromIn
(expr *expression.ScalarFunction)
sql/plan/range.go:242
↓ 1 callersMethodnewBuildFromPatternLike
(expr *expression.ScalarFunction)
sql/plan/range.go:287
↓ 1 callersFunctionnewDataset
(context *Flow)
flow/dataset.go:9
↓ 1 callersFunctionnewExecutorBuilder
(ctx context.Context, is infoschema.InfoSchema)
sql/executor/builder.go:21
↓ 1 callersFunctionnewMasterServer
(logDirectory string)
distributed/master/master_grpc_server.go:26
↓ 1 callersFunctionnewMinQueueOfPairs
(orderBys []OrderBy)
instruction/local_top.go:94
↓ 1 callersFunctionnewMinQueueOfRowsWithOriginalData
(orderBys []OrderBy)
instruction/merge_sorted_to.go:62
↓ 1 callersFunctionnewTrackedChannel
(readerCount int)
distributed/agent/local_dataset_shards_manager_in_memory.go:20
↓ 1 callersFunctionnewVirtualFileGS
(readerCloser io.ReadCloser)
filesystem/vfs_gs.go:107
↓ 1 callersFunctionnewVirtualFileS3
(readerCloser io.ReadCloser)
filesystem/vfs_s3.go:82
↓ 1 callersMethodonStartup
()
distributed/master/master_grpc_server.go:129
↓ 1 callersMethodopenAllFiles
()
sql/util/filesort/filesort.go:362
↓ 1 callersFunctionouterJoinSimplify
outerJoinSimplify simplifies outer join.
sql/plan/predicate_push_down.go:145
↓ 1 callersFunctionparseDatetime
(str string, fsp int)
sql/util/types/time.go:512
↓ 1 callersFunctionparseDayInterval
(sc *variable.StatementContext, value types.Datum)
sql/expression/builtin_time.go:1463
↓ 1 callersMethodparseField
parseField parses the next field in the record. The read field is located in r.field. Delim is the first character not part of the field (r.Comma or
plugins/file/csv/generic_csv_reader.go:253
↓ 1 callersFunctionparseOrdinalNumbers
(input string)
sql/util/types/time.go:2249
↓ 1 callersMethodparseRecord
parseRecord reads and parses a single csv record from r.
plugins/file/csv/generic_csv_reader.go:215
↓ 1 callersFunctionparseTimeZone
(s string)
sql/sessionctx/varsutil/varsutil.go:108
↓ 1 callersMethodpartition_collect
(name string, shardCount int, indexes []int)
flow/dataset_partition.go:50
↓ 1 callersMethodpartition_scatter
(name string, shardCount int, indexes []int)
flow/dataset_partition.go:42
↓ 1 callersMethodpatternIn
(x *PatternInExpr)
sql/ast/flag.go:107
↓ 1 callersMethodpatternLike
(x *PatternLikeExpr)
sql/ast/flag.go:118
↓ 1 callersMethodpatternRegexp
(x *PatternRegexpExpr)
sql/ast/flag.go:126
↓ 1 callersFunctionpeek
peeks the first encoded value from b and returns its length.
sql/util/codec/codec.go:226
↓ 1 callersFunctionpeekBytes
(b []byte, reverse bool)
sql/util/codec/codec.go:259
↓ 1 callersFunctionpeekCompactBytes
(b []byte)
sql/util/codec/codec.go:283
↓ 1 callersFunctionpeekUvarint
(b []byte)
sql/util/codec/codec.go:306
↓ 1 callersFunctionpeekVarint
(b []byte)
sql/util/codec/codec.go:298
↓ 1 callersMethodpickBestDemandFor
(supply Supply)
distributed/driver/scheduler/market/cda_market.go:143
↓ 1 callersMethodpickBestSupplyFor
(r Requirement)
distributed/driver/scheduler/market/cda_market.go:120
↓ 1 callersMethodpickNewEQConds
pickNewEQConds tries to pick new equal conds and puts them to retMapper.
sql/expression/constant_propagation.go:166
↓ 1 callersMethodplusAllocated
(allocated pb.ComputeResource)
distributed/agent/agent_grpc_server.go:144
↓ 1 callersMethodpopJoin
popJoin is called when we leave a join node.
sql/resolver/resolver.go:132
↓ 1 callersMethodpositionToScalarFunc
(v *ast.PositionExpr)
sql/plan/expression_rewriter.go:778
↓ 1 callersMethodprintDistributedStatus
(writer io.Writer)
distributed/driver/driver_on_interrupt.go:9
↓ 1 callersMethodprocessMapper
(ctx context.Context, f Mapper)
gio/mapper.go:12
↓ 1 callersMethodprocessReducer
(ctx context.Context, f Reducer, keyPositions []int)
gio/reducer.go:12
↓ 1 callersMethodpropagateEQ
propagatesEQ propagates equal expression multiple times. An example runs as following: a = d & b * 2 = c & c = d + 2 & b = 1 & a = 4, we pick eq cond
sql/expression/constant_propagation.go:116
↓ 1 callersMethodpropagateInEQ
propagateInEQ propagates all in-equal conditions. e.g. For expression a = b and b = c and c = d and c < 1 , we can get extra a < 1 and b < 1 and d < 1
sql/expression/constant_propagation.go:75
↓ 1 callersMethodpushAggCrossUnion
(agg *Aggregation, unionSchema expression.Schema, unionChild LogicalPlan)
sql/plan/aggregation_push_down.go:272
↓ 1 callersFunctionpushDownNot
(expr expression.Expression, not bool, ctx context.Context)
sql/plan/refiner.go:261
↓ 1 callersMethodpushJoin
pushJoin is called when we enter a join node.
sql/resolver/resolver.go:126
↓ 1 callersFunctionrangePointEqualValueLess
(a, b rangePoint)
sql/plan/range.go:83
↓ 1 callersMethodregexpToScalarFunc
(v *ast.PatternRegexpExpr)
sql/plan/expression_rewriter.go:882
↓ 1 callersMethodremoteExecuteOnLocation
(ctx context.Context, flowContext *flow.Flow, taskGroupStatus *pb.FlowExecutionStatus_TaskGroup, executionS
distributed/driver/scheduler/scheduler_execute.go:16
↓ 1 callersMethodreorderJoin
reorderJoin implements a simple join reorder algorithm. It will extract all the equal conditions and compose them to a graph. Then walk through the gr
sql/plan/join_reorder.go:92
↓ 1 callersFunctionreplaceColsInPropBySchema
replaceColsInPropBySchema replaces the columns in original prop with the columns in schema.
sql/plan/physical_plan_builder.go:375
↓ 1 callersMethodreportStatus
(ctx context.Context, wg *sync.WaitGroup, master string, stopChan chan bool)
distributed/driver/driver.go:151
↓ 1 callersMethodreportStatus
()
distributed/executor/executor_grpc_client_to_agent.go:50
↓ 1 callersMethodreportStatus
()
gio/runner_grpc_client_to_executor.go:47
↓ 1 callersMethodreset
reset resets the sql string to be scanned.
sql/parser/lexer.go:56
↓ 1 callersMethodresolveColumnNameInContext
resolveColumnNameInContext looks up and sets ResultField for a column with the ctx.
sql/resolver/resolver.go:478
↓ 1 callersMethodresolveColumnNameInOnCondition
resolveColumnNameInOnCondition resolves the column name in current join.
sql/resolver/resolver.go:569
↓ 1 callersMethodresolveGbyExprs
(p LogicalPlan, gby *ast.GroupByClause, fields []*ast.SelectField)
sql/plan/logical_plan_builder.go:754
↓ 1 callersFunctionreverseByteSlice
(slice []byte)
sql/expression/builtin_string.go:1274
↓ 1 callersMethodrewriteVariable
(v *ast.VariableExpr)
sql/plan/expression_rewriter.go:646
↓ 1 callersMethodrow
(x *RowExpr)
sql/ast/flag.go:134
↓ 1 callersMethodrowToScalarFunc
(v *ast.RowExpr)
sql/plan/expression_rewriter.go:893
↓ 1 callersMethodrunDataset
(wg *sync.WaitGroup, d *Dataset)
flow/runner.go:62
↓ 1 callersMethodrunDatasetShard
(wg *sync.WaitGroup, shard *DatasetShard)
flow/runner.go:83
↓ 1 callersFunctionrunDisableParallel
()
examples/union/union.go:24
↓ 1 callersFunctionrunEnableParallel
()
examples/union/union.go:11
↓ 1 callersMethodrunMapperReducer
Serve starts processing stdin and writes output to stdout
gio/runner.go:17
↓ 1 callersMethodrunTask
(wg *sync.WaitGroup, task *Task)
flow/runner.go:130
← previousnext →1,401–1,500 of 3,091, ranked by callers