MCPcopy Create free account

hub / github.com/chrislusf/gleam / functions

Functions3,091 in github.com/chrislusf/gleam

⨍ Functions 3,091◇ Types & classes 751
↓ 2 callersMethodCreateNamedDatasetShard
(name string)
distributed/agent/local_dataset_shards_manager.go:56
↓ 2 callersFunctionCsv
(fileOrPattern string, partitionCount int)
plugins/file/file_reader.go:26
↓ 2 callersMethodDay
()
sql/util/types/mytime.go:40
↓ 2 callersFunctionDecimalMul
* DecimalMul multiplies two decimals. from1, from2 - factors to - product RETURN VALUE E_DEC_OK/E_DEC_TRUNCATED/E_DEC_OVERFLO
sql/util/types/mydecimal.go:1663
↓ 2 callersFunctionDecodeInt
DecodeInt decodes value encoded by EncodeInt before. It returns the leftover un-decoded slice, decoded value if no error.
sql/util/codec/number.go:53
↓ 2 callersFunctionDecodeUint
DecodeUint decodes value encoded by EncodeUint before. It returns the leftover un-decoded slice, decoded value if no error.
sql/util/codec/number.go:95
↓ 2 callersFunctionDecodeVarint
DecodeVarint decodes value encoded by EncodeVarint before. It returns the leftover un-decoded slice, decoded value if no error.
sql/util/codec/number.go:128
↓ 2 callersMethodDestroy
()
distributed/store/local_file_data_store.go:13
↓ 2 callersFunctionEncodeBytes
EncodeBytes guarantees the encoded value is in ascending order for comparison, encoding with the following rule: [group1][marker1]...[groupN][markerN]
sql/util/codec/bytes.go:46
↓ 2 callersFunctionEncodeInt
EncodeInt appends the encoded value to slice b and returns the appended slice. EncodeInt guarantees that the encoded value is in ascending order for c
sql/util/codec/number.go:35
↓ 2 callersFunctionEncodeKeys
EncodeKeys encode keys to a blob, for comparing or sorting
util/row_read_write.go:41
↓ 2 callersFunctionEncodeVarint
EncodeVarint appends the encoded value to slice b and returns the appended slice. Note that the encoded result is not memcomparable.
sql/util/codec/number.go:120
↓ 2 callersFunctionErrorEqual
ErrorEqual returns a boolean indicating whether err1 is equal to err2.
sql/terror/terror.go:296
↓ 2 callersMethodErrors
()
sql/parser/parser.go:8035
↓ 2 callersFunctionEvalBool
EvalBool evaluates expression to a boolean value.
sql/expression/expression.go:78
↓ 2 callersMethodExec
Exec executes SQL and gets a Recordset.
sql/ast/ast.go:168
↓ 2 callersFunctionFoldConstant
FoldConstant does constant folding optimization on an expression.
sql/expression/constant_fold.go:22
↓ 2 callersMethodFrac
Frac gets the frac of the datum.
sql/util/types/datum.go:80
↓ 2 callersFunctionGenerateFileHash
(fullpath string)
distributed/resource/related_files.go:23
↓ 2 callersMethodGetArgs
GetArgs implements AggregationFunction interface.
sql/expression/aggregation.go:217
↓ 2 callersMethodGetCoGroupPartitionedSorted
()
pb/gleam.pb.go:1288
↓ 2 callersMethodGetCommand
()
script/script.go:16
↓ 2 callersMethodGetCpuLevel
()
pb/gleam.pb.go:133
↓ 2 callersFunctionGetDefaultDecimal
GetDefaultDecimal returns the default decimal length for column.
sql/mysql/util.go:45
↓ 2 callersFunctionGetDefaultFieldLength
GetDefaultFieldLength is used for Interger Types, Flen is the display length. Call this when no Flen assigned in ddl. or column value is calculated fr
sql/mysql/util.go:21
↓ 2 callersMethodGetDir
()
pb/gleam.pb.go:873
↓ 2 callersMethodGetFlowHashCode
()
pb/gleam.pb.go:1179
↓ 2 callersMethodGetGlobalSysVar
GetGlobalSysVar gets the global system variable value for name.
sql/sessionctx/variable/sysvar.go:607
↓ 2 callersMethodGetGpuLevel
()
pb/gleam.pb.go:147
↓ 2 callersMethodGetIsPipe
()
pb/gleam.pb.go:1615
↓ 2 callersMethodGetLocalDistinct
()
pb/gleam.pb.go:1379
↓ 2 callersMethodGetLocalGroupBySorted
()
pb/gleam.pb.go:1393
↓ 2 callersMethodGetLocalHashAndJoinWith
()
pb/gleam.pb.go:1344
↓ 2 callersMethodGetLocalSort
()
pb/gleam.pb.go:1358
↓ 2 callersMethodGetMemoryCostInMB
(partitionSize int64)
instruction/instruction.go:30
↓ 2 callersMethodGetMergeSortedTo
()
pb/gleam.pb.go:1365
↓ 2 callersMethodGetN
()
pb/gleam.pb.go:1563
↓ 2 callersMethodGetOnDisk
()
pb/gleam.pb.go:339
↓ 2 callersMethodGetOutput
()
pb/gleam.pb.go:900
↓ 2 callersMethodGetParentIds
()
pb/gleam.pb.go:480
↓ 2 callersMethodGetPipeAsArgs
()
pb/gleam.pb.go:1295
↓ 2 callersMethodGetResource
()
pb/gleam.pb.go:291
↓ 2 callersMethodGetScatterPartitions
()
pb/gleam.pb.go:1302
↓ 2 callersMethodGetScriptCommand
()
flow/step.go:69
↓ 2 callersFunctionGetSessionSystemVar
GetSessionSystemVar gets a system variable. If it is a session only variable, use the default value defined in code. Returns error if there is no such
sql/sessionctx/varsutil/varsutil.go:29
↓ 2 callersMethodGetShardLocation
(shardName string)
distributed/driver/scheduler/shard_location.go:26
↓ 2 callersMethodGetStatusFlag
GetStatusFlag gets the session server status variable, returns true if it is on.
sql/sessionctx/variable/session.go:169
↓ 2 callersMethodGetSystemTime
()
pb/gleam.pb.go:914
↓ 2 callersMethodGetTaskGroupStatus
(taskGroup *plan.TaskGroup)
distributed/driver/driver_execution_status.go:14
↓ 2 callersMethodGetTotalSize
GetTotalSize returns the total size in MB for the dataset. This is based on the given hint.
flow/context_hint.go:19
↓ 2 callersMethodGetType
Get the expression return type.
sql/expression/expression.go:56
↓ 2 callersMethodGetUnion
()
pb/gleam.pb.go:1400
↓ 2 callersFunctionGroupTasks
(fc *flow.Flow)
distributed/plan/plan.go:33
↓ 2 callersFunctionHasAutoIncrementFlag
HasAutoIncrementFlag checks if AutoIncrementFlag is set.
sql/mysql/type.go:100
↓ 2 callersFunctionHasNoDefaultValueFlag
HasNoDefaultValueFlag checks if NoDefaultValueFlag is set.
sql/mysql/type.go:95
↓ 2 callersFunctionHasOnUpdateNowFlag
HasOnUpdateNowFlag checks if OnUpdateNowFlag is set.
sql/mysql/type.go:140
↓ 2 callersFunctionHash
(bytes []byte)
util/hash.go:7
↓ 2 callersFunctionHashByKeys
(data []interface{})
util/key.go:9
↓ 2 callersMethodHour
()
sql/util/types/mytime.go:44
↓ 2 callersFunctionInferType
InferType infers result type for ast.ExprNode.
sql/plan/typeinferer.go:31
↓ 2 callersMethodInstructionNames
()
pb/instruction_helper.go:15
↓ 2 callersMethodJoinByKey
TODO use actual key fields instead of Field(1)
flow/dataset_join.go:14
↓ 2 callersMethodLastReadAt
()
distributed/store/local_file_data_store.go:15
↓ 2 callersMethodLastWriteAt
()
distributed/store/local_file_data_store.go:14
↓ 2 callersFunctionLineReaderToChannel
(wg *sync.WaitGroup, stat *pb.InstructionStat, name string, reader io.Reader, ch io.WriteCloser, closeOutput b
util/channel_util.go:142
↓ 2 callersMethodLocalDistinct
(name string, sortOption *SortOption)
flow/dataset_sort.go:51
↓ 2 callersFunctionLookup
Lookup returns the encoding with the specified label, and its canonical name. It returns nil and the empty string if label is not one of the standard
sql/util/charset/encoding_table.go:32
↓ 2 callersMethodMarkStop
(err error)
distributed/plan/plan.go:95
↓ 2 callersFunctionMergeFieldType
MergeFieldType merges two MySQL type to a new type. This is used in hybrid field type expression. For example "select case c when 1 then 2 when 2 then
sql/util/types/field_type.go:194
↓ 2 callersMethodMergeTo
(name string, partitionCount int)
flow/dataset_merge.go:35
↓ 2 callersMethodMeta
Meta returns TableInfo.
sql/table/table.go:57
↓ 2 callersMethodMicrosecond
()
sql/util/types/mytime.go:56
↓ 2 callersMethodMinute
()
sql/util/types/mytime.go:48
↓ 2 callersMethodMonth
()
sql/util/types/mytime.go:36
↓ 2 callersFunctionMulInteger
MulInteger multiplies uint64 a and int64 b, and returns uint64 if no overflow error.
sql/util/types/overflow.go:143
↓ 2 callersFunctionNew
New returns a Parser object.
sql/parser/yy_parser.go:70
↓ 2 callersFunctionNewBroadcast
()
instruction/broadcast.go:22
↓ 2 callersFunctionNewBufferedMessageWriter
(w io.Writer, size int)
util/message_write.go:33
↓ 2 callersFunctionNewBytesDatum
NewBytesDatum creates a new Datum from a byte slice.
sql/util/types/datum.go:1449
↓ 2 callersFunctionNewCastFunc
NewCastFunc creates a new cast function.
sql/expression/expression.go:323
↓ 2 callersFunctionNewCoGroupPartitionedSorted
(indexes []int)
instruction/cogroup_partitioned_sorted.go:25
↓ 2 callersFunctionNewCollectPartitions
()
instruction/partition_collect.go:22
↓ 2 callersFunctionNewFloat64Datum
NewFloat64Datum creates a new Datum from a float64 value.
sql/util/types/datum.go:1461
↓ 2 callersFunctionNewGleamAgentClient
(cc *grpc.ClientConn)
pb/gleam.pb.go:2239
↓ 2 callersFunctionNewJoinPartitionedSorted
(isLeftOuterJoin bool, isRightOuterJoin bool, indexes []int)
instruction/join_partitioned_sorted.go:29
↓ 2 callersFunctionNewLocalDistinct
(orderBys []OrderBy)
instruction/local_distinct.go:26
↓ 2 callersFunctionNewLocalGroupBySorted
(indexes []int)
instruction/local_group_by_sorted.go:26
↓ 2 callersFunctionNewLocalHashAndJoinWith
(indexes []int)
instruction/local_hash_and_join_with.go:27
↓ 2 callersFunctionNewLocalLimit
(n int, offset int)
instruction/local_limit.go:27
↓ 2 callersFunctionNewLocalSort
(orderBys []OrderBy, memoryInMB int)
instruction/local_sort.go:30
↓ 2 callersFunctionNewLocalTop
(n int, orderBys []OrderBy)
instruction/local_top.go:28
↓ 2 callersFunctionNewMarket
()
distributed/driver/scheduler/market/cda_market.go:46
↓ 2 callersFunctionNewMergeSortedTo
(orderBys []OrderBy)
instruction/merge_sorted_to.go:26
↓ 2 callersFunctionNewMergeTo
()
instruction/merge_to.go:22
↓ 2 callersFunctionNewPipeAsArgs
(code string)
instruction/pipe_as_args.go:29
↓ 2 callersFunctionNewRoundRobin
()
instruction/roud_robin.go:25
↓ 2 callersFunctionNewScatterPartitions
(indexes []int)
instruction/partition_scatter.go:25
↓ 2 callersFunctionNewShellScript
()
script/shell.go:15
↓ 2 callersFunctionNewUnion
(isParallel bool)
instruction/union.go:25
↓ 2 callersFunctionNewValuesFunc
NewValuesFunc creates a new values function.
sql/expression/expression.go:333
← previousnext →501–600 of 3,091, ranked by callers