Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Index your code
hub
/
github.com/chrislusf/gleam
/ functions
Functions
3,091 in github.com/chrislusf/gleam
⨍
Functions
3,091
◇
Types & classes
751
↓ 18 callers
Method
popContext
popContext is called when we leave a statement.
sql/resolver/resolver.go:121
↓ 18 callers
Method
pushContext
pushContext is called when we enter a statement.
sql/resolver/resolver.go:113
↓ 17 callers
Method
Error
Error implements error interface.
sql/terror/terror.go:211
↓ 17 callers
Function
Field
(indexes ...int)
flow/dataset_sort_option.go:14
↓ 17 callers
Method
GetID
Get the ID.
sql/plan/plan.go:98
↓ 16 callers
Method
AppendKey
(objects ...interface{})
util/row.go:20
↓ 16 callers
Method
Eval
Eval evaluates an expression through a row.
sql/expression/expression.go:53
↓ 16 callers
Method
GetShards
()
flow/dataset.go:19
↓ 16 callers
Method
data
(from *Pos)
sql/parser/lexer.go:650
↓ 15 callers
Method
Parse
Parse parses a query string to raw ast.StmtNode. If charset or collation is "", default charset and collation will be used.
sql/parser/yy_parser.go:78
↓ 15 callers
Method
PruneColumns
PruneColumns prunes the unused columns.
sql/plan/plan.go:159
↓ 15 callers
Method
Send
(*ExecutionResponse)
pb/gleam.pb.go:2408
↓ 15 callers
Function
ToInt64
(val interface{})
gio/type_convertion.go:5
↓ 15 callers
Method
URL
()
pb/resource_proto_helper.go:7
↓ 15 callers
Method
pos
()
sql/parser/lexer.go:646
↓ 14 callers
Method
Compare
Compare returns an integer comparing the time instant t to o. If t is after o, return 1, equal o, return 0, before o, return -1.
sql/util/types/time.go:270
↓ 14 callers
Method
GetCtx
GetCtx gets the context of function.
sql/expression/scalar_function.go:41
↓ 14 callers
Method
Minus
(b ComputeResource)
pb/resource_proto_helper.go:25
↓ 14 callers
Method
NewNextDataset
(shardSize int)
flow/context.go:45
↓ 14 callers
Function
NewPiper
()
util/piper.go:14
↓ 14 callers
Method
Round
Round rounds the decimal to "frac" digits. to - result buffer. d == to is allowed frac - to what position after fraction point to round. can be
sql/util/types/mydecimal.go:680
↓ 14 callers
Method
SetCorrelated
Set the value of attribute "correlated". A plan will be correlated if one of its expressions or its child plans is correlated, except Apply. As for Ap
sql/plan/plan.go:105
↓ 14 callers
Method
Sort
Sort sort on specific fields, default to the first field. Required Memory: about same size as each partition. example usage: Sort(Field(1,2)) means so
flow/dataset_sort.go:31
↓ 14 callers
Method
Text
Text returns the original text of the element.
sql/ast/ast.go:37
↓ 14 callers
Method
extractCorrelatedCols
()
sql/plan/plan.go:113
↓ 14 callers
Function
getRowLen
(e expression.Expression)
sql/plan/expression_rewriter.go:99
↓ 13 callers
Method
Clock
Clock returns the hour, minute, and second within the day specified by t.
sql/util/types/time.go:156
↓ 13 callers
Function
Init
Init determines whether the driver program will execute the mapper/reducer or not. If the command line invokes the mapper or reducer, execute it and e
gio/map_reduce.go:116
↓ 13 callers
Method
Init
(code string)
script/script.go:15
↓ 13 callers
Method
Printlnf
Printlnf prints to os.Stdout in the specified format, adding an "\n" at the end of each format
flow/dataset_output.go:62
↓ 13 callers
Method
ToBool
ToBool converts to a bool. We will use 1 for true, and 0 for false.
sql/util/types/datum.go:1107
↓ 13 callers
Method
incAsLongAs
(fn func(rune) bool)
sql/parser/lexer.go:654
↓ 13 callers
Function
parseDigits
(input string, count int)
sql/util/types/time.go:1978
↓ 12 callers
Method
Flush
()
util/message_write.go:61
↓ 12 callers
Function
FromGoTime
FromGoTime translates time.Time to mysql time internal representation.
sql/util/types/time.go:143
↓ 12 callers
Function
NewAggFunction
NewAggFunction creates a new AggregationFunction.
sql/expression/aggregation.go:98
↓ 12 callers
Function
Option
()
distributed/option.go:24
↓ 12 callers
Method
Plus
(b ComputeResource)
pb/resource_proto_helper.go:36
↓ 12 callers
Method
SetMysqlTime
SetMysqlTime sets types.Time value
sql/util/types/datum.go:289
↓ 12 callers
Method
SetValue
SetValue sets any kind of value.
sql/util/types/datum.go:329
↓ 12 callers
Method
eof
()
sql/parser/lexer.go:594
↓ 12 callers
Method
getContext
(groupKey []byte)
sql/expression/aggregation.go:226
↓ 12 callers
Function
initTokenFunc
(str string, fn func(s *Scanner) (int, Pos, string))
sql/parser/misc.go:74
↓ 11 callers
Function
CompareFloat64
CompareFloat64 returns an integer comparing the float64 x to y.
sql/util/types/compare.go:43
↓ 11 callers
Method
ConvertTo
ConvertTo converts a datum to the target field type.
sql/util/types/datum.go:644
↓ 11 callers
Method
Copy
Copy copies the current plan.
sql/plan/plan.go:191
↓ 11 callers
Method
Create
(name string)
plugins/file/parquet/parquet_file_reader.go:17
↓ 11 callers
Method
Equal
Equal checks whether two expressions are equal.
sql/expression/expression.go:65
↓ 11 callers
Method
Indexes
return a list of indexes
flow/dataset_sort_option.go:54
↓ 11 callers
Method
Open
(*FileLocation)
filesystem/vfs.go:29
↓ 11 callers
Method
PredicatePushDown
PredicatePushDown pushes down the predicates in the where/on/having clauses as deeply as possible. It will accept a predicate that is an expression sl
sql/plan/plan.go:156
↓ 11 callers
Function
ProcessRow
ProcessRow Reads and processes rows until EOF
util/row_read_write.go:63
↓ 11 callers
Method
SetText
SetText sets original text to the Node.
sql/ast/ast.go:39
↓ 11 callers
Method
Sub
Sub subtracts t1 from t, returns a duration value. Note that sub should not be done on different time types.
sql/util/types/time.go:449
↓ 11 callers
Method
ToInt
ToInt returns int part of the decimal, returns the result and errcode.
sql/util/types/mydecimal.go:885
↓ 11 callers
Function
add1ShardTo1Step
(d *Dataset)
flow/dataset_map.go:35
↓ 11 callers
Method
compareFloat64
(sc *variable.StatementContext, f float64)
sql/util/types/datum.go:461
↓ 11 callers
Function
convertNonInt2RoundUint64
covertNonIntegerToUint64 coverts a non-integer to an uint64
sql/util/types/datum_eval.go:551
↓ 11 callers
Function
convertToTime
(sc *variable.StatementContext, arg types.Datum, tp byte)
sql/expression/builtin_time.go:103
↓ 11 callers
Function
initTokenString
(str string, tok int)
sql/parser/misc.go:63
↓ 11 callers
Function
overflow
Overflow returns an overflowed error.
sql/util/types/etc.go:132
↓ 11 callers
Method
storePlanInfo
(prop *requiredProperty, info *physicalPlanInfo)
sql/plan/plan.go:227
↓ 10 callers
Function
CompareString
CompareString returns an integer comparing the string x to y.
sql/util/types/compare.go:54
↓ 10 callers
Method
FromString
FromString parses decimal from string.
sql/util/types/mydecimal.go:285
↓ 10 callers
Method
GetArgs
GetArgs gets arguments of function.
sql/expression/scalar_function.go:36
↓ 10 callers
Function
MaxValueDatum
MaxValueDatum returns a datum represents max value.
sql/util/types/datum.go:1508
↓ 10 callers
Function
RegisterMapper
RegisterMapper register a mapper function to process a command
gio/map_reduce.go:75
↓ 10 callers
Function
Txt
(fileOrPattern string, partitionCount int)
plugins/file/file_reader.go:29
↓ 10 callers
Function
WriteMessage
(writer io.Writer, m []byte)
util/message_write.go:16
↓ 10 callers
Method
endOffset
(v *yySymType)
sql/parser/yy_parser.go:132
↓ 10 callers
Method
getPlanInfo
(prop *requiredProperty)
sql/plan/plan.go:200
↓ 10 callers
Function
invalidConv
(d *Datum, tp byte)
sql/util/types/datum.go:1332
↓ 9 callers
Function
FromDate
FromDate makes a internal time representation from the given date.
sql/util/types/time.go:151
↓ 9 callers
Method
FromFloat64
FromFloat64 creates a decimal from float64 value.
sql/util/types/mydecimal.go:950
↓ 9 callers
Method
GoTime
(*gotime.Location)
sql/util/types/time.go:139
↓ 9 callers
Function
ReadRow
ReadRow read and decode one row of data
util/row_read_write.go:21
↓ 9 callers
Method
Recv
()
pb/gleam.pb.go:2290
↓ 9 callers
Method
Select
(indexes []int)
script/script.go:25
↓ 9 callers
Method
SetBytes
SetBytes sets bytes value to datum.
sql/util/types/datum.go:170
↓ 9 callers
Method
SetResultFields
SetResultFields sets result fields.
sql/ast/ast.go:155
↓ 9 callers
Function
addPlanToResponse
addPlanToResponse creates a *physicalPlanInfo that adds p as the parent of info.
sql/plan/physical_plan_builder.go:174
↓ 9 callers
Method
rewrite
rewrite function rewrites ast expr to expression.Expression. aggMapper maps ast.AggregateFuncExpr to the columns offset in p's output schema. asScalar
sql/plan/expression_rewriter.go:58
↓ 8 callers
Method
Clone
Clone implements Expression interface.
sql/expression/column.go:127
↓ 8 callers
Function
ColumnSubstitute
ColumnSubstitute substitutes the columns in filter to expressions in select fields. e.g. select * from (select b as a from t) k where a < 10 => select
sql/expression/util.go:40
↓ 8 callers
Function
Compare
(a interface{}, b interface{})
util/key.go:59
↓ 8 callers
Function
DecodeRow
DecodeRow decodes one row of data from a blob
util/row_read_write.go:53
↓ 8 callers
Function
Emit
Emit encode and write a row of data to os.Stdout
gio/emit.go:10
↓ 8 callers
Method
GetInstructions
()
pb/gleam.pb.go:1165
↓ 8 callers
Method
GetValue
GetValue gets the value of the datum of any kind.
sql/util/types/datum.go:295
↓ 8 callers
Method
LocalSort
(name string, sortOption *SortOption)
flow/dataset_sort.go:59
↓ 8 callers
Method
MergeSortedTo
(name string, partitionCount int)
flow/dataset_merge.go:7
↓ 8 callers
Method
NewReader
(vf filesystem.VirtualFile)
plugins/file/file_reader.go:45
↓ 8 callers
Function
NewStringDatum
NewStringDatum creates a new Datum from a string.
sql/util/types/datum.go:1455
↓ 8 callers
Method
NewTask
()
flow/step.go:24
↓ 8 callers
Function
ParseTime
ParseTime parses a formatted string with type tp and specific fsp. Type is TypeDatetime, TypeTimestamp and TypeDate. Fsp is in range [0, 6]. MySQL sup
sql/util/types/time.go:1063
↓ 8 callers
Method
SetValue
SetValue sets value to the expression.
sql/ast/ast.go:65
↓ 8 callers
Function
calcDaynr
calcDaynr calculates days since 0000-00-00.
sql/util/types/mytime.go:172
↓ 8 callers
Function
fromTaskToDatasetShard
(task *Task, shard *DatasetShard)
flow/context.go:223
↓ 8 callers
Method
readRune
readRune reads one rune from r, folding \r\n to \n and keeping track of how far into the line we have read. r.column will point to the start of this
plugins/file/csv/generic_csv_reader.go:182
↓ 8 callers
Method
resolveColumnInResultFields
(ctx *resolverContext, cn *ast.ColumnNameExpr, rfs []*ast.ResultField)
sql/resolver/resolver.go:633
← previous
next →
101–200 of 3,091, ranked by callers