MCPcopy Index your code

hub / github.com/chrislusf/gleam / functions

Functions3,091 in github.com/chrislusf/gleam

↓ 18 callersMethodpopContext
popContext is called when we leave a statement.
sql/resolver/resolver.go:121
↓ 18 callersMethodpushContext
pushContext is called when we enter a statement.
sql/resolver/resolver.go:113
↓ 17 callersMethodError
Error implements error interface.
sql/terror/terror.go:211
↓ 17 callersFunctionField
(indexes ...int)
flow/dataset_sort_option.go:14
↓ 17 callersMethodGetID
Get the ID.
sql/plan/plan.go:98
↓ 16 callersMethodAppendKey
(objects ...interface{})
util/row.go:20
↓ 16 callersMethodEval
Eval evaluates an expression through a row.
sql/expression/expression.go:53
↓ 16 callersMethodGetShards
()
flow/dataset.go:19
↓ 16 callersMethoddata
(from *Pos)
sql/parser/lexer.go:650
↓ 15 callersMethodParse
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 callersMethodPruneColumns
PruneColumns prunes the unused columns.
sql/plan/plan.go:159
↓ 15 callersMethodSend
(*ExecutionResponse)
pb/gleam.pb.go:2408
↓ 15 callersFunctionToInt64
(val interface{})
gio/type_convertion.go:5
↓ 15 callersMethodURL
()
pb/resource_proto_helper.go:7
↓ 15 callersMethodpos
()
sql/parser/lexer.go:646
↓ 14 callersMethodCompare
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 callersMethodGetCtx
GetCtx gets the context of function.
sql/expression/scalar_function.go:41
↓ 14 callersMethodMinus
(b ComputeResource)
pb/resource_proto_helper.go:25
↓ 14 callersMethodNewNextDataset
(shardSize int)
flow/context.go:45
↓ 14 callersFunctionNewPiper
()
util/piper.go:14
↓ 14 callersMethodRound
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 callersMethodSetCorrelated
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 callersMethodSort
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 callersMethodText
Text returns the original text of the element.
sql/ast/ast.go:37
↓ 14 callersMethodextractCorrelatedCols
()
sql/plan/plan.go:113
↓ 14 callersFunctiongetRowLen
(e expression.Expression)
sql/plan/expression_rewriter.go:99
↓ 13 callersMethodClock
Clock returns the hour, minute, and second within the day specified by t.
sql/util/types/time.go:156
↓ 13 callersFunctionInit
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 callersMethodInit
(code string)
script/script.go:15
↓ 13 callersMethodPrintlnf
Printlnf prints to os.Stdout in the specified format, adding an "\n" at the end of each format
flow/dataset_output.go:62
↓ 13 callersMethodToBool
ToBool converts to a bool. We will use 1 for true, and 0 for false.
sql/util/types/datum.go:1107
↓ 13 callersMethodincAsLongAs
(fn func(rune) bool)
sql/parser/lexer.go:654
↓ 13 callersFunctionparseDigits
(input string, count int)
sql/util/types/time.go:1978
↓ 12 callersMethodFlush
()
util/message_write.go:61
↓ 12 callersFunctionFromGoTime
FromGoTime translates time.Time to mysql time internal representation.
sql/util/types/time.go:143
↓ 12 callersFunctionNewAggFunction
NewAggFunction creates a new AggregationFunction.
sql/expression/aggregation.go:98
↓ 12 callersFunctionOption
()
distributed/option.go:24
↓ 12 callersMethodPlus
(b ComputeResource)
pb/resource_proto_helper.go:36
↓ 12 callersMethodSetMysqlTime
SetMysqlTime sets types.Time value
sql/util/types/datum.go:289
↓ 12 callersMethodSetValue
SetValue sets any kind of value.
sql/util/types/datum.go:329
↓ 12 callersMethodeof
()
sql/parser/lexer.go:594
↓ 12 callersMethodgetContext
(groupKey []byte)
sql/expression/aggregation.go:226
↓ 12 callersFunctioninitTokenFunc
(str string, fn func(s *Scanner) (int, Pos, string))
sql/parser/misc.go:74
↓ 11 callersFunctionCompareFloat64
CompareFloat64 returns an integer comparing the float64 x to y.
sql/util/types/compare.go:43
↓ 11 callersMethodConvertTo
ConvertTo converts a datum to the target field type.
sql/util/types/datum.go:644
↓ 11 callersMethodCopy
Copy copies the current plan.
sql/plan/plan.go:191
↓ 11 callersMethodCreate
(name string)
plugins/file/parquet/parquet_file_reader.go:17
↓ 11 callersMethodEqual
Equal checks whether two expressions are equal.
sql/expression/expression.go:65
↓ 11 callersMethodIndexes
return a list of indexes
flow/dataset_sort_option.go:54
↓ 11 callersMethodOpen
(*FileLocation)
filesystem/vfs.go:29
↓ 11 callersMethodPredicatePushDown
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 callersFunctionProcessRow
ProcessRow Reads and processes rows until EOF
util/row_read_write.go:63
↓ 11 callersMethodSetText
SetText sets original text to the Node.
sql/ast/ast.go:39
↓ 11 callersMethodSub
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 callersMethodToInt
ToInt returns int part of the decimal, returns the result and errcode.
sql/util/types/mydecimal.go:885
↓ 11 callersFunctionadd1ShardTo1Step
(d *Dataset)
flow/dataset_map.go:35
↓ 11 callersMethodcompareFloat64
(sc *variable.StatementContext, f float64)
sql/util/types/datum.go:461
↓ 11 callersFunctionconvertNonInt2RoundUint64
covertNonIntegerToUint64 coverts a non-integer to an uint64
sql/util/types/datum_eval.go:551
↓ 11 callersFunctionconvertToTime
(sc *variable.StatementContext, arg types.Datum, tp byte)
sql/expression/builtin_time.go:103
↓ 11 callersFunctioninitTokenString
(str string, tok int)
sql/parser/misc.go:63
↓ 11 callersFunctionoverflow
Overflow returns an overflowed error.
sql/util/types/etc.go:132
↓ 11 callersMethodstorePlanInfo
(prop *requiredProperty, info *physicalPlanInfo)
sql/plan/plan.go:227
↓ 10 callersFunctionCompareString
CompareString returns an integer comparing the string x to y.
sql/util/types/compare.go:54
↓ 10 callersMethodFromString
FromString parses decimal from string.
sql/util/types/mydecimal.go:285
↓ 10 callersMethodGetArgs
GetArgs gets arguments of function.
sql/expression/scalar_function.go:36
↓ 10 callersFunctionMaxValueDatum
MaxValueDatum returns a datum represents max value.
sql/util/types/datum.go:1508
↓ 10 callersFunctionRegisterMapper
RegisterMapper register a mapper function to process a command
gio/map_reduce.go:75
↓ 10 callersFunctionTxt
(fileOrPattern string, partitionCount int)
plugins/file/file_reader.go:29
↓ 10 callersFunctionWriteMessage
(writer io.Writer, m []byte)
util/message_write.go:16
↓ 10 callersMethodendOffset
(v *yySymType)
sql/parser/yy_parser.go:132
↓ 10 callersMethodgetPlanInfo
(prop *requiredProperty)
sql/plan/plan.go:200
↓ 10 callersFunctioninvalidConv
(d *Datum, tp byte)
sql/util/types/datum.go:1332
↓ 9 callersFunctionFromDate
FromDate makes a internal time representation from the given date.
sql/util/types/time.go:151
↓ 9 callersMethodFromFloat64
FromFloat64 creates a decimal from float64 value.
sql/util/types/mydecimal.go:950
↓ 9 callersMethodGoTime
(*gotime.Location)
sql/util/types/time.go:139
↓ 9 callersFunctionReadRow
ReadRow read and decode one row of data
util/row_read_write.go:21
↓ 9 callersMethodRecv
()
pb/gleam.pb.go:2290
↓ 9 callersMethodSelect
(indexes []int)
script/script.go:25
↓ 9 callersMethodSetBytes
SetBytes sets bytes value to datum.
sql/util/types/datum.go:170
↓ 9 callersMethodSetResultFields
SetResultFields sets result fields.
sql/ast/ast.go:155
↓ 9 callersFunctionaddPlanToResponse
addPlanToResponse creates a *physicalPlanInfo that adds p as the parent of info.
sql/plan/physical_plan_builder.go:174
↓ 9 callersMethodrewrite
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 callersMethodClone
Clone implements Expression interface.
sql/expression/column.go:127
↓ 8 callersFunctionColumnSubstitute
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 callersFunctionCompare
(a interface{}, b interface{})
util/key.go:59
↓ 8 callersFunctionDecodeRow
DecodeRow decodes one row of data from a blob
util/row_read_write.go:53
↓ 8 callersFunctionEmit
Emit encode and write a row of data to os.Stdout
gio/emit.go:10
↓ 8 callersMethodGetInstructions
()
pb/gleam.pb.go:1165
↓ 8 callersMethodGetValue
GetValue gets the value of the datum of any kind.
sql/util/types/datum.go:295
↓ 8 callersMethodLocalSort
(name string, sortOption *SortOption)
flow/dataset_sort.go:59
↓ 8 callersMethodMergeSortedTo
(name string, partitionCount int)
flow/dataset_merge.go:7
↓ 8 callersMethodNewReader
(vf filesystem.VirtualFile)
plugins/file/file_reader.go:45
↓ 8 callersFunctionNewStringDatum
NewStringDatum creates a new Datum from a string.
sql/util/types/datum.go:1455
↓ 8 callersMethodNewTask
()
flow/step.go:24
↓ 8 callersFunctionParseTime
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 callersMethodSetValue
SetValue sets value to the expression.
sql/ast/ast.go:65
↓ 8 callersFunctioncalcDaynr
calcDaynr calculates days since 0000-00-00.
sql/util/types/mytime.go:172
↓ 8 callersFunctionfromTaskToDatasetShard
(task *Task, shard *DatasetShard)
flow/context.go:223
↓ 8 callersMethodreadRune
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 callersMethodresolveColumnInResultFields
(ctx *resolverContext, cn *ast.ColumnNameExpr, rfs []*ast.ResultField)
sql/resolver/resolver.go:633
← previousnext →101–200 of 3,091, ranked by callers