Functions — github.com/chrislusf/gleam

hub / github.com/chrislusf/gleam / functions

Functions3,091 in github.com/chrislusf/gleam

⨍ Functions 3,091◇ Types & classes 751

↓ 2 callersFunctionencodeIntToCmpUint

(v int64)

sql/util/codec/number.go:25

↓ 2 callersFunctionencodeShardInfo

(shardInfo *FileShardInfo)

plugins/file/file_shard_info.go:77

↓ 2 callersFunctionencodeSignedInt

(b []byte, v int64, comaprable bool)

sql/util/codec/codec.go:98

↓ 2 callersMethodequal

equal check if this function equals to another function.

sql/expression/builtin.go:97

↓ 2 callersFunctionextractHourMicrosecond

Format is `HH:MM:SS.FFFFFF`.

sql/util/types/time.go:1402

↓ 2 callersFunctionextractHourMinute

Format is `HH:MM`.

sql/util/types/time.go:1452

↓ 2 callersFunctionextractHourSecond

Format is `HH:MM:SS`.

sql/util/types/time.go:1427

↓ 2 callersMethodfetchNextRow

Fetch the next row given the source file index.

sql/util/filesort/filesort.go:321

↓ 2 callersMethodfieldsNotEmpty

fieldsNotEmpty supports omitempty tags

util/row_codec.go:145

↓ 2 callersFunctionfindAncestorStepId

find mergeable parent step or itself if parent is not mergeable

distributed/plan/plan_logical.go:28

↓ 2 callersMethodflush

()

util/message_write.go:66

↓ 2 callersMethodflushToFile

Flush the buffer to file if it is full.

sql/util/filesort/filesort.go:233

↓ 2 callersMethodformat

(flat bool, format string, args ...interface{})

sql/util/format/format.go:69

↓ 2 callersMethodformatFrac

(frac int)

sql/util/types/time.go:699

↓ 2 callersFunctionfprintRow

(writer io.Writer, base int, delimiter string, decodedObjects ...interface{})

util/printf.go:77

↓ 2 callersMethodgetArgs

getArgs returns the arguments expressions.

sql/expression/builtin.go:91

↓ 2 callersFunctiongetDateFromDaynr

getDateFromDaynr changes a daynr to year, month and day, daynr 0 is returned as date 00.00.00

sql/util/types/mytime.go:313

↓ 2 callersFunctiongetFieldTypeIndex

(tp byte)

sql/util/types/field_type.go:200

↓ 2 callersMethodgetFsp

(x *ast.FuncCallExpr)

sql/plan/typeinferer.go:243

↓ 2 callersMethodgetGbyColIndex

getGbyColIndex gets the column's index in the group-by columns.

sql/plan/predicate_push_down.go:291

↓ 2 callersMethodgetHashKey

getHashKey encodes a requiredProperty to a unique hash code.

sql/plan/plan.go:132

↓ 2 callersFunctiongetIndexesFromOrderBys

(orderBys []OrderBy)

instruction/local_sort.go:85

↓ 2 callersFunctiongetInnerFromParentheses

(expr ast.ExprNode)

sql/plan/logical_plan_builder.go:1164

↓ 2 callersFunctiongetRowArg

(e expression.Expression, idx int)

sql/plan/expression_rewriter.go:109

↓ 2 callersFunctiongetUintForLimitOffset

getUintForLimitOffset gets uint64 value for limit/offset. For ordinary statement, limit/offset should be uint64 constant value. For prepared statement

sql/plan/logical_plan_builder.go:432

↓ 2 callersFunctiongetValidFloatPrefix

getValidFloatPrefix gets prefix of string which can be successfully parsed as float.

sql/util/types/convert.go:242

↓ 2 callersFunctiongetValidIntPrefix

getValidIntPrefix gets prefix of the string which can be successfully parsed as int.

sql/util/types/convert.go:163

↓ 2 callersMethodhandleInSubquery

(v *ast.PatternInExpr)

sql/plan/expression_rewriter.go:472

↓ 2 callersFunctionhandleTruncateError

(sc *variable.StatementContext)

sql/util/types/datum.go:1565

↓ 2 callersMethodincN

(n int)

sql/parser/lexer.go:631

↓ 2 callersMethodisDatasetShardRegistered

(shard *flow.DatasetShard)

distributed/driver/scheduler/shard_location.go:45

↓ 2 callersFunctionisDigit

(ch rune)

sql/parser/misc.go:28

↓ 2 callersFunctionisDigit

(c byte)

sql/util/types/helper.go:86

↓ 2 callersFunctionisFloat

(a interface{})

util/key.go:108

↓ 2 callersFunctionisIdentExtend

(ch rune)

sql/parser/misc.go:36

↓ 2 callersFunctionisLetter

(ch rune)

sql/parser/misc.go:24

↓ 2 callersFunctionisRestartableTasks

(tasks []*flow.Task)

distributed/driver/scheduler/scheduler_dataset_shard.go:51

↓ 2 callersFunctionjoinInts

(a []int, sep string)

instruction/select.go:88

↓ 2 callersFunctionlessThan

(sc *variable.StatementContext, i []types.Datum, j []types.Datum, byDesc []bool)

sql/util/filesort/filesort.go:50

↓ 2 callersMethodmakeNewAgg

(aggFuncs []expression.AggregationFunction, gbyCols []*expression.Column)

sql/plan/aggregation_push_down.go:248

↓ 2 callersFunctionmatchByteCI

(a, b byte)

sql/expression/builtin_like.go:99

↓ 2 callersMethodmatchProperty

matchProperty implements PhysicalPlan matchProperty interface.

sql/plan/match_property.go:188

↓ 2 callersMethodmerge

(a, b []rangePoint, union bool)

sql/plan/range.go:412

↓ 2 callersFunctionmyMinInt8

(a, b int8)

sql/util/types/helper.go:111

↓ 2 callersFunctionneedsInputFromDriver

(task *flow.Task)

distributed/driver/scheduler/scheduler_dataset_shard.go:33

↓ 2 callersMethodnewJoin

(lChild, rChild LogicalPlan)

sql/plan/join_reorder.go:182

↓ 2 callersFunctionnewMysqlTime

(year, month, day, hour, minute, second, microsecond int)

sql/util/types/mytime.go:106

↓ 2 callersFunctionnewRowWithOriginalData

(row *util.Row)

instruction/merge_sorted_to.go:58

↓ 2 callersMethodopenNew

openNew opens a new log file for writing, moving any old log file out of the way. This methods assumes the file has already been closed.

distributed/store/single_file_store.go:100

↓ 2 callersFunctionparseDateFormat

(format string)

sql/util/types/time.go:481

↓ 2 callersFunctionparseDateTimeFromNum

See number_to_datetime function. https://github.com/mysql/mysql-server/blob/5.7/sql-common/my_time.c

sql/util/types/time.go:975

↓ 2 callersFunctionparseFrac

parseFrac parses the input string according to fsp, returns the microsecond, and also a bool value to indice overflow. eg: "999" fsp=2 will overflow.

sql/util/types/fsp.go:49

↓ 2 callersFunctionprintShardStatus

(shard *DatasetShard)

flow/runner_on_interrupt.go:30

↓ 2 callersMethodpurgeExpiredEntries

purge executor status older than 24 hours to save memory

distributed/agent/local_dataset_shards_manager.go:92

↓ 2 callersMethodreadOneLine

()

plugins/file/tsv/tsv_file_reader.go:37

↓ 2 callersFunctionreallocBytes

like realloc.

sql/util/codec/bytes.go:194

↓ 2 callersFunctionreduce

(f Reducer, x, y []interface{})

gio/reducer.go:109

↓ 2 callersFunctionremoveIgnores

(indices, ignores []*model.IndexInfo)

sql/plan/planbuilder.go:191

↓ 2 callersFunctionremoveTableName

(sqlText string)

sql/executor/executor_projection.go:75

↓ 2 callersMethodreport

(ctx context.Context, f func() error)

gio/reporter.go:8

↓ 2 callersMethodresolveFromSchema

(v *ast.ColumnNameExpr, schema expression.Schema)

sql/plan/logical_plan_builder.go:557

↓ 2 callersFunctionreverseBytes

(b []byte)

sql/util/codec/bytes.go:184

↓ 2 callersMethodroundFrac

(fsp int)

sql/util/types/time.go:313

↓ 2 callersFunctionroundTime

roundTime rounds the time value according to digits count specified by fsp.

sql/util/types/time.go:308

↓ 2 callersMethodrunStep

(wg *sync.WaitGroup, step *Step)

flow/runner.go:105

↓ 2 callersMethodscanBit

()

sql/parser/lexer.go:549

↓ 2 callersMethodscanHex

()

sql/parser/lexer.go:541

↓ 2 callersMethodscanString

()

sql/parser/lexer.go:422

↓ 2 callersFunctionsendDeleteRequest

(server string, request *pb.DeleteDatasetShardRequest)

distributed/driver/scheduler/grpc_client_to_agent.go:182

↓ 2 callersMethodsetConds2ConstFalse

()

sql/expression/constant_propagation.go:158

↓ 2 callersMethodsetShardLocation

(shard *flow.DatasetShard, loc pb.DataLocation)

distributed/driver/scheduler/scheduler_dataset_shard.go:65

↓ 2 callersMethodsetUseBuf

(str string)

sql/parser/lexer.go:393

↓ 2 callersFunctionsetValueTo

(src, dst interface{})

flow/dataset_output.go:109

↓ 2 callersFunctionsortCost

(cnt uint64)

sql/plan/physical_plan_builder.go:213

↓ 2 callersFunctionsplitNormalFormItems

splitNormalFormItems split CNF(conjunctive normal form) like "a and b and c", or DNF(disjunctive normal form) like "a or b or c"

sql/expression/expression.go:223

↓ 2 callersMethodstmtText

()

sql/parser/yy_parser.go:66

↓ 2 callersMethodstreamUpdateSum

(row []types.Datum, ectx context.Context)

sql/expression/aggregation.go:280

↓ 2 callersFunctiontestPureGoGleam

(name string, isLocal bool)

examples/pi_estimation/pi_estimation.go:51

↓ 2 callersMethodtoSignedInteger

(sc *variable.StatementContext, tp byte)

sql/util/types/datum.go:1196

↓ 2 callersFunctiontrimFn

For LTRIM & RTRIM See https://dev.mysql.com/doc/refman/5.7/en/string-functions.html#function_ltrim See https://dev.mysql.com/doc/refman/5.7/en/string-

sql/expression/builtin_string.go:1054

↓ 2 callersFunctiontrimLeft

(str, remstr string)

sql/expression/builtin_string.go:1068

↓ 2 callersFunctiontrimRight

(str, remstr string)

sql/expression/builtin_string.go:1078

↓ 2 callersFunctiontruncateStr

(str string, flen int)

sql/util/types/convert.go:30

↓ 2 callersMethodtryToPushDownAgg

tryToPushDownAgg tries to push down an aggregate function into a join path. If all aggFuncs are first row, we won't process it temporarily. If not, We

sql/plan/aggregation_push_down.go:202

↓ 2 callersFunctionuniformHexStrLit

(s string)

sql/util/types/hex.go:59

↓ 2 callersMethodupdateSum

(row []types.Datum, groupKey []byte, ectx context.Context)

sql/expression/aggregation.go:253

↓ 2 callersMethodvalidPropagateCond

validPropagateCond checks if the cond is an expression like [column op constant] and op is in the funNameMap.

sql/expression/constant_propagation.go:139

↓ 2 callersMethodwaitForInputDatasetShardLocations

(task *flow.Task)

distributed/driver/scheduler/shard_location.go:55

↓ 2 callersFunctionweekMode

(mode int)

sql/util/types/mytime.go:226

↓ 2 callersFunctionwithClient

(server string, fn func(client pb.GleamAgentClient) error)

distributed/executor/executor_grpc_client_to_agent.go:77

↓ 2 callersFunctionwithClient

(server string, fn func(client pb.GleamExecutorClient) error)

gio/runner_grpc_client_to_executor.go:70

↓ 1 callersMethodAddAgent

(a *AgentInformation)

distributed/master/structure.go:120

↓ 1 callersMethodAddAllToAllStep

(input *Dataset, output *Dataset)

flow/context.go:114

↓ 1 callersMethodAddAllToOneStep

the task should run on the destination dataset shard

flow/context.go:78

↓ 1 callersMethodAddDataCenter

(dc *DataCenter)

distributed/master/structure.go:84

↓ 1 callersFunctionAddInt64

AddInt64 adds int64 a and b if no overflow, otherwise returns error.

sql/util/types/overflow.go:34

↓ 1 callersMethodAddOneToAllStep

the task should run on the source dataset shard input is nil for initial source dataset

flow/context.go:97

↓ 1 callersMethodAddOneToEveryNStep

(input *Dataset, n int, output *Dataset)

flow/context.go:131

↓ 1 callersMethodAddRack

(rack *Rack)

distributed/master/structure.go:113

↓ 1 callersMethodAddStep

(Step *flow.Step)

distributed/plan/plan.go:44

← previous next →701–800 of 3,091, ranked by callers