MCPcopy Create free account

hub / github.com/chrislusf/gleam / functions

Functions3,091 in github.com/chrislusf/gleam

⨍ Functions 3,091◇ Types & classes 751
↓ 1 callersFunctionencodeShardInfo
(shardInfo *KafkaPartitionInfo)
plugins/kafka/kafka_partition_info.go:101
↓ 1 callersFunctionencodeShardInfo
(shardInfo *CassandraShardInfo)
plugins/cassandra/cassandra_shard_info.go:110
↓ 1 callersFunctionestimateJoinCount
(lc uint64, rc uint64)
sql/plan/match_property.go:179
↓ 1 callersMethodeval
eval does evaluation by the given row.
sql/expression/builtin.go:89
↓ 1 callersMethodexecuteCommand
( stream pb.GleamAgent_ExecuteServer, startRequest *pb.ExecutionRequest, dir string, statChan chan *pb.Exe
distributed/agent/agent_server_execute.go:17
↓ 1 callersMethodexecuteInstruction
(ctx context.Context, wg *sync.WaitGroup, ioErrChan, exeErrChan chan error, inChan, outChan *util.Piper, pre
distributed/executor/executor.go:172
↓ 1 callersFunctionexistsCartesianProduct
(p LogicalPlan)
sql/plan/optimizer.go:77
↓ 1 callersFunctionexprHasSetVar
exprHasSetVar checks if the expression has set-var function. If do, we should not prune it.
sql/plan/column_pruning.go:35
↓ 1 callersMethodexternalSort
Perform external file sort.
sql/util/filesort/filesort.go:446
↓ 1 callersMethodextractAggFuncs
(fields []*ast.SelectField)
sql/plan/logical_plan_builder.go:691
↓ 1 callersMethodextractCorColumnsBySchema
extractCorColumnsBySchema only extracts the correlated columns that match the outer plan's schema. e.g. If the correlated columns from inner plan are
sql/plan/decorrelate.go:24
↓ 1 callersFunctionextractDayHour
Format is `DD HH`.
sql/util/types/time.go:1532
↓ 1 callersFunctionextractDayMicrosecond
Format is `DD HH:MM:SS.FFFFFF`.
sql/util/types/time.go:1472
↓ 1 callersFunctionextractDayMinute
Format is `DD HH:MM`.
sql/util/types/time.go:1512
↓ 1 callersFunctionextractDaySecond
Format is `DD HH:MM:SS`.
sql/util/types/time.go:1492
↓ 1 callersFunctionextractMinuteMicrosecond
Format is `MM:SS.FFFFFF`.
sql/util/types/time.go:1362
↓ 1 callersFunctionextractMinuteSecond
Format is `MM:SS`.
sql/util/types/time.go:1382
↓ 1 callersFunctionextractSingleTimeValue
(unit string, format string)
sql/util/types/time.go:1310
↓ 1 callersFunctionextractYearMonth
Format is `YYYY-MM`.
sql/util/types/time.go:1552
↓ 1 callersFunctionfastReverseBytes
(b []byte)
sql/util/codec/bytes.go:163
↓ 1 callersMethodfetchPartitionIds
()
plugins/kafka/kafka_source.go:38
↓ 1 callersMethodfillShowFields
(s *ast.ShowStmt)
sql/resolver/resolver.go:841
↓ 1 callersMethodfindServers
(dc *DataCenter, requests []*pb.ComputeResource)
distributed/master/resource_assign.go:77
↓ 1 callersFunctionfloatStrToIntStr
floatStrToIntStr converts a valid float string into valid integer string which can be parsed by strconv.ParseInt, we can't parse float first then conv
sql/util/types/convert.go:174
↓ 1 callersMethodfuncCall
(x *FuncCallExpr)
sql/ast/flag.go:142
↓ 1 callersMethodfuncCallToExpression
(v *ast.FuncCallExpr)
sql/plan/expression_rewriter.go:951
↓ 1 callersMethodgenShardInfos
(f *flow.Flow, partitionIds []int32)
plugins/kafka/kafka_source.go:59
↓ 1 callersMethodgenShardInfos
(f *flow.Flow)
plugins/file/file_source.go:91
↓ 1 callersMethodgenShardInfos
(f *flow.Flow)
plugins/cassandra/cassandra_source.go:38
↓ 1 callersMethodgetAggFuncChildIdx
getAggFuncChildIdx gets which children it belongs to, 0 stands for left, 1 stands for right, -1 stands for both.
sql/plan/aggregation_push_down.go:52
↓ 1 callersMethodgetCtx
getCtx returns this function's context.
sql/expression/builtin.go:99
↓ 1 callersMethodgetDefaultValue
(col *table.Column)
sql/plan/planbuilder.go:269
↓ 1 callersMethodgetDefaultValues
(agg *Aggregation)
sql/plan/aggregation_push_down.go:227
↓ 1 callersFunctiongetEQFunctionOffset
getEQFunctionOffset judge if the expression is a eq function like A = 1 where a is an index. If so, it will return the offset of A in index columns. e
sql/plan/refiner.go:32
↓ 1 callersFunctiongetFormatToken
getFormatToken takes one format control token from the string. format "%d %H %m" will get token "%d" and the remain is " %H %m".
sql/util/types/time.go:1874
↓ 1 callersMethodgetFunction
getFunction gets a function signature by the types and the counts of given arguments.
sql/expression/builtin.go:120
↓ 1 callersFunctiongetInnerFromParentheses
(expr ast.ExprNode)
sql/resolver/resolver.go:693
↓ 1 callersFunctiongetLastStepId
(status *pb.FlowExecutionStatus, stepGroup *pb.FlowExecutionStatus_StepGroup)
distributed/master/ui/svg_writer.go:162
↓ 1 callersFunctiongetMaxColLen
(cols []string, datas [][]string)
sql/util/printer/printer.go:59
↓ 1 callersFunctiongetMaxFloat
(flen int, decimal int)
sql/util/types/helper.go:49
↓ 1 callersMethodgetMySQLErrorCode
()
sql/terror/terror.go:271
↓ 1 callersFunctiongetPrintCol
(cols []string, maxColLen []int)
sql/util/printer/printer.go:87
↓ 1 callersFunctiongetPrintRow
(data []string, maxColLen []int)
sql/util/printer/printer.go:100
↓ 1 callersFunctiongetPrintRows
(datas [][]string, maxColLen []int)
sql/util/printer/printer.go:113
↓ 1 callersFunctiongetResources
(master string, request *pb.ComputeRequest)
distributed/driver/scheduler/grpc_client_to_master.go:13
↓ 1 callersFunctiongetReverseOrderBy
(a []instruction.OrderBy)
flow/dataset_sort.go:94
↓ 1 callersFunctiongetStatsChan
(flowHashCode uint32, stepId int32, taskId int32)
distributed/agent/agent_grpc_stats.go:15
↓ 1 callersFunctiongetSystemTimestamp
(ctx context.Context)
sql/expression/helper.go:137
↓ 1 callersFunctiongetTimeValue
(ctx context.Context, v interface{}, tp byte, fsp int)
sql/expression/helper.go:57
↓ 1 callersFunctiongetTimeZone
(ctx context.Context)
sql/expression/builtin_time.go:1594
↓ 1 callersMethodgetUniqueFileName
()
sql/util/filesort/filesort.go:226
↓ 1 callersFunctiongetValidPrefix
getValidPrefix gets a prefix of string which can parsed to a number with base. the minimun base is 2 and the maximum is 36.
sql/expression/util.go:113
↓ 1 callersFunctiongleamSortDistributed
(fileName string, size int64, partition int, isDistributed, isInMemory bool)
examples/sort_benchmark/sort_benchmark.go:66
↓ 1 callersFunctiongrpcDial
(address string, opts ...grpc.DialOption)
util/grpc_util.go:13
↓ 1 callersMethodhandleCaseExpr
The return type of a CASE expression is the compatible aggregated type of all return values, but also depends on the context in which it is used. If u
sql/plan/typeinferer.go:371
↓ 1 callersMethodhandleColumnName
handleColumnName looks up and sets ResultField for the column name.
sql/resolver/resolver.go:455
↓ 1 callersMethodhandleCommandConnection
(conn net.Conn, command *pb.ControlMessage)
distributed/agent/agent_server.go:143
↓ 1 callersMethodhandleCompareSubquery
(v *ast.CompareSubqueryExpr)
sql/plan/expression_rewriter.go:205
↓ 1 callersMethodhandleEQAll
handleEQAll handles the case of = all. For example, if the query is t.id = all (select s.id from s), it will be rewrote to t.id = (select s.id from s
sql/plan/expression_rewriter.go:408
↓ 1 callersFunctionhandleEscape
handleEscape handles the case in scanString when previous char is '\'.
sql/parser/lexer.go:450
↓ 1 callersMethodhandleExistSubquery
(v *ast.ExistsSubqueryExpr)
sql/plan/expression_rewriter.go:437
↓ 1 callersMethodhandleFieldList
handleFieldList expands wild card field and sets fieldList in current context.
sql/resolver/resolver.go:685
↓ 1 callersMethodhandleFuncCallExpr
(x *ast.FuncCallExpr)
sql/plan/typeinferer.go:254
↓ 1 callersFunctionhandleIdent
(lval *yySymType)
sql/parser/misc.go:518
↓ 1 callersMethodhandleInMemoryReadConnection
(conn net.Conn, readerName, channelName string)
distributed/agent/agent_server_read_in_memory.go:12
↓ 1 callersMethodhandleJoin
handleJoin sets result fields for join.
sql/resolver/resolver.go:440
↓ 1 callersMethodhandleLikeExpr
like expression expects the target expression and pattern to be a string, if it's not, we add a cast function.
sql/plan/typeinferer.go:406
↓ 1 callersMethodhandleLocalInMemoryWriteConnection
(r io.Reader, writerName, channelName string, readerCount int)
distributed/agent/agent_server_write_in_memory.go:11
↓ 1 callersMethodhandleLocalWriteConnection
(reader io.Reader, writerName, channelName string, readerCount int)
distributed/agent/agent_server_write.go:10
↓ 1 callersMethodhandleNEAny
handleNEAny handles the case of != any. For exmaple, if the query is t.id != any (select s.id from s), it will be rewrote to t.id != s.id or count(dis
sql/plan/expression_rewriter.go:377
↓ 1 callersMethodhandleOtherComparableSubq
handleOtherComparableSubq handles the queries like < any, < max, etc. For example, if the query is t.id < any (select s.id from s), it will be rewrote
sql/plan/expression_rewriter.go:285
↓ 1 callersMethodhandlePosition
(pos *ast.PositionExpr)
sql/resolver/resolver.go:801
↓ 1 callersMethodhandleReadConnection
(conn net.Conn, readerName, channelName string)
distributed/agent/agent_server_read.go:13
↓ 1 callersMethodhandleRegexpExpr
regexp expression expects the target expression and pattern to be a string, if it's not, we add a cast function.
sql/plan/typeinferer.go:415
↓ 1 callersMethodhandleRequest
(conn net.Conn)
distributed/agent/agent_server.go:127
↓ 1 callersMethodhandleScalarSubquery
(v *ast.SubqueryExpr)
sql/plan/expression_rewriter.go:525
↓ 1 callersMethodhandleTableName
handleTableName looks up and sets the schema information and result fields for table name.
sql/resolver/resolver.go:334
↓ 1 callersMethodhandleTableSource
handleTableSources checks name duplication and puts the table source in current resolverContext. Note: "select * from t as a join (select 1) as a;" is
sql/resolver/resolver.go:394
↓ 1 callersMethodhandleUnionSelectList
(u *ast.UnionSelectList)
sql/resolver/resolver.go:824
↓ 1 callersMethodhandleValueExpr
(x *ast.ValueExpr)
sql/plan/typeinferer.go:235
↓ 1 callersMethodhandleValuesExpr
(x *ast.ValuesExpr)
sql/plan/typeinferer.go:239
↓ 1 callersFunctionhashByKey
(data interface{})
util/key.go:17
↓ 1 callersFunctionhashjoin
()
examples/join/join.go:54
↓ 1 callersMethodheartbeat
()
distributed/agent/agent_grpc_client_to_master.go:15
↓ 1 callersMethodinToExpression
(v *ast.PatternInExpr)
sql/plan/expression_rewriter.go:801
↓ 1 callersMethodinit
(l int)
sql/expression/constant_propagation.go:44
↓ 1 callersMethodinit
()
distributed/store/single_file_store.go:24
↓ 1 callersFunctioninjectImport
(src string)
sql/parser/goyacc/main.go:787
↓ 1 callersMethodinsertCol
(col *Column)
sql/expression/constant_propagation.go:245
↓ 1 callersFunctionintArrayEquals
(a []int, b []int)
flow/dataset_partition.go:58
↓ 1 callersMethodinternalSort
Perform full in-memory sort.
sql/util/filesort/filesort.go:429
↓ 1 callersMethodintersection
(a, b []rangePoint)
sql/plan/range.go:404
↓ 1 callersFunctionisCastType
(tp byte)
sql/util/types/convert.go:128
↓ 1 callersFunctionisConstraintKeyTp
(constraints []*ast.Constraint, colDef *ast.ColumnDef)
sql/plan/validator.go:134
↓ 1 callersMethodisDecomposable
isDecomposable checks if an aggregate function is decomposable. An aggregation function $F$ is decomposable if there exist aggregation functions F_1 a
sql/plan/aggregation_push_down.go:37
↓ 1 callersMethodisDeterministic
isDeterministic will be true by default. Non-deterministic function will override this function.
sql/expression/builtin.go:56
↓ 1 callersMethodisDeterministic
isDeterministic checks if a function is deterministic. A function is deterministic if it returns same results for same inputs. e.g. random is non-dete
sql/expression/builtin.go:95
↓ 1 callersFunctionisIdentChar
(ch rune)
sql/parser/misc.go:32
↓ 1 callersFunctionisIdentFirstChar
(ch rune)
sql/parser/misc.go:40
↓ 1 callersFunctionisInputOnDisk
(task *flow.Task)
distributed/driver/scheduler/scheduler_dataset_shard.go:42
← previousnext →1,301–1,400 of 3,091, ranked by callers