MCPcopy Create free account

hub / github.com/chrislusf/gleam / functions

Functions3,091 in github.com/chrislusf/gleam

↓ 2 callersFunctionOpen
(filepath string)
filesystem/vfs.go:47
↓ 2 callersFunctionOrderBy
(index int, ascending bool)
flow/dataset_sort_option.go:25
↓ 2 callersMethodOutputRow
(f func(*util.Row) error)
flow/dataset_output.go:95
↓ 2 callersFunctionParseDatetime
ParseDatetime is a helper function wrapping ParseTime with datetime type and default fsp.
sql/util/types/time.go:1082
↓ 2 callersFunctionParseEnumValue
ParseEnumValue creates a Enum with special number.
sql/util/types/enum.go:56
↓ 2 callersFunctionParseServerToGrpcAddress
(server string)
util/grpc_util.go:39
↓ 2 callersFunctionParseSetValue
ParseSetValue creates a Set with special number.
sql/util/types/set.go:92
↓ 2 callersFunctionParseTimeFromInt64
ParseTimeFromInt64 parses mysql time value from int64.
sql/util/types/time.go:1633
↓ 2 callersMethodPipeAsArgs
PipeAsArgs takes each row of input, bind to variables in parameter code. The variables are specified via $1, $2, etc. The code is run as the command f
flow/dataset_pipe.go:26
↓ 2 callersMethodPush
Push implements heap.Interface Push interface.
sql/util/filesort/filesort.go:91
↓ 2 callersFunctionRange
(from, to int)
util/source_utils.go:24
↓ 2 callersMethodRead
Read reads one record from r. The record is a slice of strings with each string representing one field.
plugins/file/csv/generic_csv_reader.go:139
↓ 2 callersMethodReadAt
(data []byte, offset int64)
distributed/store/single_file_store.go:28
↓ 2 callersMethodReduce
(code string)
script/script.go:21
↓ 2 callersMethodReduceBy
(code string, indexes []int)
script/script.go:22
↓ 2 callersMethodReplaceParent
ReplaceParent means replacing a parent with another one.
sql/plan/plan.go:82
↓ 2 callersMethodResolveIndicesAndCorCols
ResolveIndicesAndCorCols resolves the index for columns and initializes the correlated columns.
sql/plan/plan.go:162
↓ 2 callersFunctionRound
Round rounds the argument f to dec decimal places. dec defaults to 0 if not specified. dec can be negative to cause dec digits left of the decimal poi
sql/util/types/helper.go:40
↓ 2 callersFunctionRoundFrac
RoundFrac rounds fractional seconds precision with new fsp and returns a new one. We will use the “round half up” rule, e.g, >= 0.5 -> 1, < 0.5 -> 0,
sql/util/types/time.go:357
↓ 2 callersMethodRoundFrac
RoundFrac rounds fractional seconds precision with new fsp and returns a new one. We will use the “round half up” rule, e.g, >= 0.5 -> 1, < 0.5 -> 0,
sql/util/types/time.go:751
↓ 2 callersMethodRunFlowContext
(context.Context, *Flow)
flow/runner.go:16
↓ 2 callersMethodSchema
()
sql/executor/executor.go:10
↓ 2 callersMethodSecond
()
sql/util/types/mytime.go:52
↓ 2 callersMethodSendFileResource
(ctx context.Context, opts ...grpc.CallOption)
pb/gleam.pb.go:2227
↓ 2 callersMethodSendFlowExecutionStatus
(ctx context.Context, opts ...grpc.CallOption)
pb/gleam.pb.go:1932
↓ 2 callersMethodSendHeartbeat
(ctx context.Context, opts ...grpc.CallOption)
pb/gleam.pb.go:1931
↓ 2 callersMethodSet
Set if key not exists, returns whether already exists.
sql/util/segmentmap/segmentmap.go:66
↓ 2 callersMethodSetCorrelated
SetCorrelated implements Plan interface.
sql/plan/logical_plans.go:85
↓ 2 callersMethodSetCorrelated
SetCorrelated implements Plan interface.
sql/plan/logical_plans.go:148
↓ 2 callersMethodSetDatum
SetDatum sets datum to the expression.
sql/ast/ast.go:69
↓ 2 callersMethodSetFetchFunction
(fn func([]Demand))
distributed/driver/scheduler/market/cda_market.go:57
↓ 2 callersMethodSetLength
SetLength sets the length of the datum
sql/util/types/datum.go:95
↓ 2 callersMethodSetMaster
(master string)
distributed/option.go:53
↓ 2 callersMethodSetMode
SetMode sets aggFunctionMode for aggregate function.
sql/expression/aggregation.go:44
↓ 2 callersMethodSetMysqlBit
SetMysqlBit sets Bit value
sql/util/types/datum.go:217
↓ 2 callersMethodSetMysqlSet
SetMysqlSet sets Set value
sql/util/types/datum.go:276
↓ 2 callersMethodSetProfiling
SetProfiling profiling will generate cpu and memory profile files when the executors are completed.
distributed/option.go:59
↓ 2 callersMethodSetScoreFunction
(scorer func(Requirement, float64, Object) float64)
distributed/driver/scheduler/market/cda_market.go:52
↓ 2 callersMethodSetStatusFlag
SetStatusFlag sets the session server status variable. If on is ture sets the flag in session status, otherwise removes the flag.
sql/sessionctx/variable/session.go:160
↓ 2 callersFunctionSha1Hash
Sha1Hash is an util function to calculate sha1 hash.
sql/util/auth.go:46
↓ 2 callersMethodSize
()
filesystem/vfs.go:24
↓ 2 callersMethodSortByKey
(name string)
flow/dataset_sort.go:37
↓ 2 callersFunctionStrToUint
StrToUint converts a string to an unsigned interger at the best-effortt.
sql/util/types/convert.go:149
↓ 2 callersFunctionSubUint64
SubUint64 subtracts uint64 a with b and returns uint64 if no overflow error.
sql/util/types/overflow.go:56
↓ 2 callersFunctionTakeTsv
message contains 3 kinds of data with the formats: the first 4 bytes is int32 flag if flag > 0 actual data row bytes with length = flag else if flag =
util/message_read.go:30
↓ 2 callersFunctionTimeDelayedRetry
(fn func() error, waitTimes ...time.Duration)
util/retry.go:12
↓ 2 callersMethodTimeTaken
()
flow/dataset.go:37
↓ 2 callersMethodToInfo
ToInfo casts Column to model.ColumnInfo
sql/table/column.go:48
↓ 2 callersFunctionToString
ToString explains a Plan, returns description string.
sql/plan/stringer.go:22
↓ 2 callersMethodTop
Top streams through total n items, picking reverse ordered k items with O(n*log(k)) complexity. Required Memory: about same size as n items in memory
flow/dataset_sort.go:43
↓ 2 callersFunctionTotalSize
TotalSize hints the total size in MB for all the partitions. This is usually used when sorting is needed.
flow/dataset_hint.go:15
↓ 2 callersMethodTrack
( execute func(*FlowExecutionStatus_TaskGroup_Execution) error)
pb/status_proto_helper.go:7
↓ 2 callersFunctionTsEmitKV
(ts int64, keys, values []interface{})
gio/emit.go:21
↓ 2 callersFunctionTypeStr
TypeStr converts tp to a string.
sql/util/types/etc.go:94
↓ 2 callersFunctionTypeToStr
TypeToStr converts a field to a string. It is used for converting Text to Blob, or converting Char to Binary. Args: tp: type enum cs: charset
sql/util/types/etc.go:104
↓ 2 callersMethodUnion
Union union multiple Datasets as one Dataset
flow/dataset_union.go:8
↓ 2 callersMethodWaitForNamedDatasetShard
(name string)
distributed/agent/local_dataset_shards_manager.go:76
↓ 2 callersMethodWrite
Write implements io.Writer. If a write would cause the log file to be larger than MaxMegaByte, the file is closed, renamed to include a timestamp of
distributed/store/single_file_store.go:62
↓ 2 callersMethodWriteMessage
(m []byte)
util/message_write.go:43
↓ 2 callersMethodYear
()
sql/util/types/mytime.go:32
↓ 2 callersMethodYearDay
()
sql/util/types/time.go:135
↓ 2 callersFunctionavailableIndices
(hints []*ast.IndexHint, tableInfo *model.TableInfo)
sql/plan/planbuilder.go:142
↓ 2 callersFunctionbenchmark
(name string, f func())
examples/tests/unix_pipe_test.go:38
↓ 2 callersMethodbuildDistinct
(child LogicalPlan, length int)
sql/plan/logical_plan_builder.go:323
↓ 2 callersMethodbuildFromIsFalse
(expr *expression.ScalarFunction, isNot int)
sql/plan/range.go:223
↓ 2 callersMethodbuildFromIsTrue
(expr *expression.ScalarFunction, isNot int)
sql/plan/range.go:202
↓ 2 callersMethodbuildInnerApply
buildInnerApply builds apply plan with outerPlan and innerPlan, which apply inner-join for every row from outerPlan and the whole innerPlan.
sql/plan/logical_plan_builder.go:959
↓ 2 callersFunctionbuiltinDateFormat
See http://dev.mysql.com/doc/refman/5.7/en/date-and-time-functions.html#function_date-format
sql/expression/builtin_time.go:280
↓ 2 callersFunctionbuiltinDayOfMonth
See http://dev.mysql.com/doc/refman/5.7/en/date-and-time-functions.html#function_dayofmonth
sql/expression/builtin_time.go:669
↓ 2 callersFunctionbuiltinMonth
See http://dev.mysql.com/doc/refman/5.7/en/date-and-time-functions.html#function_month
sql/expression/builtin_time.go:505
↓ 2 callersFunctionbuiltinNow
See https://dev.mysql.com/doc/refman/5.7/en/date-and-time-functions.html#function_now
sql/expression/builtin_time.go:584
↓ 2 callersFunctionbuiltinWeek
See http://dev.mysql.com/doc/refman/5.7/en/date-and-time-functions.html#function_week
sql/expression/builtin_time.go:787
↓ 2 callersFunctionbuiltinWeekDay
See http://dev.mysql.com/doc/refman/5.7/en/date-and-time-functions.html#function_weekday
sql/expression/builtin_time.go:837
↓ 2 callersFunctioncalcWeek
calcWeek calculates week and year for the time.
sql/util/types/mytime.go:236
↓ 2 callersMethodcalculateResult
(ctx *aggEvaluateContext)
sql/expression/aggregation.go:567
↓ 2 callersFunctioncheckAllDepencies
(dep []int, isUsed []bool)
distributed/master/ui/svg_writer_layout.go:37
↓ 2 callersMethodcheckAnyCountAndSum
(aggFuncs []expression.AggregationFunction)
sql/plan/aggregation_push_down.go:239
↓ 2 callersFunctioncheckDateType
(t TimeInternal)
sql/util/types/time.go:1152
↓ 2 callersMethodcheckScalarFunction
(scalar *expression.ScalarFunction)
sql/plan/refiner.go:154
↓ 2 callersMethodcleanup
(sched *scheduler.Scheduler, fc *flow.Flow)
distributed/driver/driver.go:106
↓ 2 callersMethodclearForAggPushDown
()
sql/plan/physical_plans.go:188
↓ 2 callersMethodcompareString
(sc *variable.StatementContext, s string)
sql/util/types/datum.go:502
↓ 2 callersFunctioncomposeConditionWithBinaryOp
composeConditionWithBinaryOp composes condition with binary operator into a balance deep tree, which benefits a lot for pb decoder/encoder.
sql/expression/expression.go:180
↓ 2 callersFunctionconcatOnAndWhereConds
concatOnAndWhereConds concatenate ON conditions with WHERE conditions.
sql/plan/predicate_push_down.go:223
↓ 2 callersMethodconvergeType
(hasUint, hasDecimal, hasFloat *bool)
sql/util/types/datum.go:1336
↓ 2 callersMethodconvert2PhysicalPlanRight
convert2PhysicalPlanRight converts the right join to *physicalPlanInfo.
sql/plan/physical_plan_builder.go:392
↓ 2 callersMethodconvert2PhysicalPlanSemi
convert2PhysicalPlanSemi converts the semi join to *physicalPlanInfo.
sql/plan/physical_plan_builder.go:267
↓ 2 callersMethodconvertToInt
(sc *variable.StatementContext, target *FieldType)
sql/util/types/datum.go:800
↓ 2 callersFunctionconvertUintToUint
(val uint64, upperBound uint64, tp byte)
sql/util/types/convert.go:108
↓ 2 callersFunctiondatetimeToUint64
datetimeToUint64 converts time value to integer in YYYYMMDDHHMMSS format.
sql/util/types/mytime.go:153
↓ 2 callersFunctiondecimalBinSize
decimalBinSize returns the size of array to hold a binary representation of a decimal.
sql/util/types/mydecimal.go:1264
↓ 2 callersFunctiondecodeBytes
(b []byte, reverse bool)
sql/util/codec/bytes.go:71
↓ 2 callersFunctiondecodeCmpUintToFloat
(u uint64)
sql/util/codec/float.go:32
↓ 2 callersFunctiondecodeCmpUintToInt
(u uint64)
sql/util/codec/number.go:29
↓ 2 callersFunctiondoAdd
(from1, from2, to *MyDecimal)
sql/util/types/mydecimal.go:1509
↓ 2 callersFunctiondoDivMod
(from1, from2, to, mod *MyDecimal, fracIncr int)
sql/util/types/mydecimal.go:1826
↓ 2 callersFunctiondoFlowExecutionStatus
(canvas *svg.SVG, status *pb.FlowExecutionStatus, width int)
distributed/master/ui/svg_writer.go:43
↓ 2 callersFunctiondoState
(canvas *svg.SVG, input point, state string)
distributed/master/ui/svg_writer.go:112
↓ 2 callersFunctionencode
(b []byte, vals []types.Datum, comparable bool)
sql/util/codec/codec.go:39
↓ 2 callersFunctionencodeFloatToCmpUint64
(f float64)
sql/util/codec/float.go:22
← previousnext →601–700 of 3,091, ranked by callers