Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/chrislusf/gleam
/ functions
Functions
3,091 in github.com/chrislusf/gleam
⨍
Functions
3,091
◇
Types & classes
751
↓ 2 callers
Function
Open
(filepath string)
filesystem/vfs.go:47
↓ 2 callers
Function
OrderBy
(index int, ascending bool)
flow/dataset_sort_option.go:25
↓ 2 callers
Method
OutputRow
(f func(*util.Row) error)
flow/dataset_output.go:95
↓ 2 callers
Function
ParseDatetime
ParseDatetime is a helper function wrapping ParseTime with datetime type and default fsp.
sql/util/types/time.go:1082
↓ 2 callers
Function
ParseEnumValue
ParseEnumValue creates a Enum with special number.
sql/util/types/enum.go:56
↓ 2 callers
Function
ParseServerToGrpcAddress
(server string)
util/grpc_util.go:39
↓ 2 callers
Function
ParseSetValue
ParseSetValue creates a Set with special number.
sql/util/types/set.go:92
↓ 2 callers
Function
ParseTimeFromInt64
ParseTimeFromInt64 parses mysql time value from int64.
sql/util/types/time.go:1633
↓ 2 callers
Method
PipeAsArgs
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 callers
Method
Push
Push implements heap.Interface Push interface.
sql/util/filesort/filesort.go:91
↓ 2 callers
Function
Range
(from, to int)
util/source_utils.go:24
↓ 2 callers
Method
Read
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 callers
Method
ReadAt
(data []byte, offset int64)
distributed/store/single_file_store.go:28
↓ 2 callers
Method
Reduce
(code string)
script/script.go:21
↓ 2 callers
Method
ReduceBy
(code string, indexes []int)
script/script.go:22
↓ 2 callers
Method
ReplaceParent
ReplaceParent means replacing a parent with another one.
sql/plan/plan.go:82
↓ 2 callers
Method
ResolveIndicesAndCorCols
ResolveIndicesAndCorCols resolves the index for columns and initializes the correlated columns.
sql/plan/plan.go:162
↓ 2 callers
Function
Round
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 callers
Function
RoundFrac
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 callers
Method
RoundFrac
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 callers
Method
RunFlowContext
(context.Context, *Flow)
flow/runner.go:16
↓ 2 callers
Method
Schema
()
sql/executor/executor.go:10
↓ 2 callers
Method
Second
()
sql/util/types/mytime.go:52
↓ 2 callers
Method
SendFileResource
(ctx context.Context, opts ...grpc.CallOption)
pb/gleam.pb.go:2227
↓ 2 callers
Method
SendFlowExecutionStatus
(ctx context.Context, opts ...grpc.CallOption)
pb/gleam.pb.go:1932
↓ 2 callers
Method
SendHeartbeat
(ctx context.Context, opts ...grpc.CallOption)
pb/gleam.pb.go:1931
↓ 2 callers
Method
Set
Set if key not exists, returns whether already exists.
sql/util/segmentmap/segmentmap.go:66
↓ 2 callers
Method
SetCorrelated
SetCorrelated implements Plan interface.
sql/plan/logical_plans.go:85
↓ 2 callers
Method
SetCorrelated
SetCorrelated implements Plan interface.
sql/plan/logical_plans.go:148
↓ 2 callers
Method
SetDatum
SetDatum sets datum to the expression.
sql/ast/ast.go:69
↓ 2 callers
Method
SetFetchFunction
(fn func([]Demand))
distributed/driver/scheduler/market/cda_market.go:57
↓ 2 callers
Method
SetLength
SetLength sets the length of the datum
sql/util/types/datum.go:95
↓ 2 callers
Method
SetMaster
(master string)
distributed/option.go:53
↓ 2 callers
Method
SetMode
SetMode sets aggFunctionMode for aggregate function.
sql/expression/aggregation.go:44
↓ 2 callers
Method
SetMysqlBit
SetMysqlBit sets Bit value
sql/util/types/datum.go:217
↓ 2 callers
Method
SetMysqlSet
SetMysqlSet sets Set value
sql/util/types/datum.go:276
↓ 2 callers
Method
SetProfiling
SetProfiling profiling will generate cpu and memory profile files when the executors are completed.
distributed/option.go:59
↓ 2 callers
Method
SetScoreFunction
(scorer func(Requirement, float64, Object) float64)
distributed/driver/scheduler/market/cda_market.go:52
↓ 2 callers
Method
SetStatusFlag
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 callers
Function
Sha1Hash
Sha1Hash is an util function to calculate sha1 hash.
sql/util/auth.go:46
↓ 2 callers
Method
Size
()
filesystem/vfs.go:24
↓ 2 callers
Method
SortByKey
(name string)
flow/dataset_sort.go:37
↓ 2 callers
Function
StrToUint
StrToUint converts a string to an unsigned interger at the best-effortt.
sql/util/types/convert.go:149
↓ 2 callers
Function
SubUint64
SubUint64 subtracts uint64 a with b and returns uint64 if no overflow error.
sql/util/types/overflow.go:56
↓ 2 callers
Function
TakeTsv
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 callers
Function
TimeDelayedRetry
(fn func() error, waitTimes ...time.Duration)
util/retry.go:12
↓ 2 callers
Method
TimeTaken
()
flow/dataset.go:37
↓ 2 callers
Method
ToInfo
ToInfo casts Column to model.ColumnInfo
sql/table/column.go:48
↓ 2 callers
Function
ToString
ToString explains a Plan, returns description string.
sql/plan/stringer.go:22
↓ 2 callers
Method
Top
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 callers
Function
TotalSize
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 callers
Method
Track
( execute func(*FlowExecutionStatus_TaskGroup_Execution) error)
pb/status_proto_helper.go:7
↓ 2 callers
Function
TsEmitKV
(ts int64, keys, values []interface{})
gio/emit.go:21
↓ 2 callers
Function
TypeStr
TypeStr converts tp to a string.
sql/util/types/etc.go:94
↓ 2 callers
Function
TypeToStr
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 callers
Method
Union
Union union multiple Datasets as one Dataset
flow/dataset_union.go:8
↓ 2 callers
Method
WaitForNamedDatasetShard
(name string)
distributed/agent/local_dataset_shards_manager.go:76
↓ 2 callers
Method
Write
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 callers
Method
WriteMessage
(m []byte)
util/message_write.go:43
↓ 2 callers
Method
Year
()
sql/util/types/mytime.go:32
↓ 2 callers
Method
YearDay
()
sql/util/types/time.go:135
↓ 2 callers
Function
availableIndices
(hints []*ast.IndexHint, tableInfo *model.TableInfo)
sql/plan/planbuilder.go:142
↓ 2 callers
Function
benchmark
(name string, f func())
examples/tests/unix_pipe_test.go:38
↓ 2 callers
Method
buildDistinct
(child LogicalPlan, length int)
sql/plan/logical_plan_builder.go:323
↓ 2 callers
Method
buildFromIsFalse
(expr *expression.ScalarFunction, isNot int)
sql/plan/range.go:223
↓ 2 callers
Method
buildFromIsTrue
(expr *expression.ScalarFunction, isNot int)
sql/plan/range.go:202
↓ 2 callers
Method
buildInnerApply
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 callers
Function
builtinDateFormat
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 callers
Function
builtinDayOfMonth
See http://dev.mysql.com/doc/refman/5.7/en/date-and-time-functions.html#function_dayofmonth
sql/expression/builtin_time.go:669
↓ 2 callers
Function
builtinMonth
See http://dev.mysql.com/doc/refman/5.7/en/date-and-time-functions.html#function_month
sql/expression/builtin_time.go:505
↓ 2 callers
Function
builtinNow
See https://dev.mysql.com/doc/refman/5.7/en/date-and-time-functions.html#function_now
sql/expression/builtin_time.go:584
↓ 2 callers
Function
builtinWeek
See http://dev.mysql.com/doc/refman/5.7/en/date-and-time-functions.html#function_week
sql/expression/builtin_time.go:787
↓ 2 callers
Function
builtinWeekDay
See http://dev.mysql.com/doc/refman/5.7/en/date-and-time-functions.html#function_weekday
sql/expression/builtin_time.go:837
↓ 2 callers
Function
calcWeek
calcWeek calculates week and year for the time.
sql/util/types/mytime.go:236
↓ 2 callers
Method
calculateResult
(ctx *aggEvaluateContext)
sql/expression/aggregation.go:567
↓ 2 callers
Function
checkAllDepencies
(dep []int, isUsed []bool)
distributed/master/ui/svg_writer_layout.go:37
↓ 2 callers
Method
checkAnyCountAndSum
(aggFuncs []expression.AggregationFunction)
sql/plan/aggregation_push_down.go:239
↓ 2 callers
Function
checkDateType
(t TimeInternal)
sql/util/types/time.go:1152
↓ 2 callers
Method
checkScalarFunction
(scalar *expression.ScalarFunction)
sql/plan/refiner.go:154
↓ 2 callers
Method
cleanup
(sched *scheduler.Scheduler, fc *flow.Flow)
distributed/driver/driver.go:106
↓ 2 callers
Method
clearForAggPushDown
()
sql/plan/physical_plans.go:188
↓ 2 callers
Method
compareString
(sc *variable.StatementContext, s string)
sql/util/types/datum.go:502
↓ 2 callers
Function
composeConditionWithBinaryOp
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 callers
Function
concatOnAndWhereConds
concatOnAndWhereConds concatenate ON conditions with WHERE conditions.
sql/plan/predicate_push_down.go:223
↓ 2 callers
Method
convergeType
(hasUint, hasDecimal, hasFloat *bool)
sql/util/types/datum.go:1336
↓ 2 callers
Method
convert2PhysicalPlanRight
convert2PhysicalPlanRight converts the right join to *physicalPlanInfo.
sql/plan/physical_plan_builder.go:392
↓ 2 callers
Method
convert2PhysicalPlanSemi
convert2PhysicalPlanSemi converts the semi join to *physicalPlanInfo.
sql/plan/physical_plan_builder.go:267
↓ 2 callers
Method
convertToInt
(sc *variable.StatementContext, target *FieldType)
sql/util/types/datum.go:800
↓ 2 callers
Function
convertUintToUint
(val uint64, upperBound uint64, tp byte)
sql/util/types/convert.go:108
↓ 2 callers
Function
datetimeToUint64
datetimeToUint64 converts time value to integer in YYYYMMDDHHMMSS format.
sql/util/types/mytime.go:153
↓ 2 callers
Function
decimalBinSize
decimalBinSize returns the size of array to hold a binary representation of a decimal.
sql/util/types/mydecimal.go:1264
↓ 2 callers
Function
decodeBytes
(b []byte, reverse bool)
sql/util/codec/bytes.go:71
↓ 2 callers
Function
decodeCmpUintToFloat
(u uint64)
sql/util/codec/float.go:32
↓ 2 callers
Function
decodeCmpUintToInt
(u uint64)
sql/util/codec/number.go:29
↓ 2 callers
Function
doAdd
(from1, from2, to *MyDecimal)
sql/util/types/mydecimal.go:1509
↓ 2 callers
Function
doDivMod
(from1, from2, to, mod *MyDecimal, fracIncr int)
sql/util/types/mydecimal.go:1826
↓ 2 callers
Function
doFlowExecutionStatus
(canvas *svg.SVG, status *pb.FlowExecutionStatus, width int)
distributed/master/ui/svg_writer.go:43
↓ 2 callers
Function
doState
(canvas *svg.SVG, input point, state string)
distributed/master/ui/svg_writer.go:112
↓ 2 callers
Function
encode
(b []byte, vals []types.Datum, comparable bool)
sql/util/codec/codec.go:39
↓ 2 callers
Function
encodeFloatToCmpUint64
(f float64)
sql/util/codec/float.go:22
← previous
next →
601–700 of 3,091, ranked by callers