MCPcopy Create free account

hub / github.com/chrislusf/gleam / functions

Functions3,091 in github.com/chrislusf/gleam

↓ 1 callersMethodGetInputShardLocations
()
pb/gleam.pb.go:1260
↓ 1 callersMethodGetInstructionFunction
(i *pb.Instruction)
instruction/instruction.go:41
↓ 1 callersMethodGetInterface
GetInterface gets interface value.
sql/util/types/datum.go:182
↓ 1 callersMethodGetIsLeftOuterJoin
()
pb/gleam.pb.go:1451
↓ 1 callersMethodGetIsParallel
()
pb/gleam.pb.go:1750
↓ 1 callersMethodGetIsRightOuterJoin
()
pb/gleam.pb.go:1458
↓ 1 callersMethodGetKeyIndexes
()
pb/gleam.pb.go:1417
↓ 1 callersFunctionGetMapper
(mapperId MapperId)
gio/map_reduce.go:85
↓ 1 callersMethodGetMemoryInMB
()
pb/gleam.pb.go:1253
↓ 1 callersMethodGetMergeTo
()
pb/gleam.pb.go:1372
↓ 1 callersMethodGetMode
GetMode gets aggFunctionMode from aggregate function.
sql/expression/aggregation.go:47
↓ 1 callersMethodGetName
GetName implements AggregationFunction interface.
sql/expression/aggregation.go:202
↓ 1 callersMethodGetOffset
()
pb/gleam.pb.go:1716
↓ 1 callersMethodGetOrder
()
pb/gleam.pb.go:1774
↓ 1 callersMethodGetOutputShardLocations
()
pb/gleam.pb.go:1267
↓ 1 callersMethodGetParentByIndex
Retrieve the parent by index.
sql/plan/plan.go:86
↓ 1 callersMethodGetParents
Get all the parents.
sql/plan/plan.go:90
↓ 1 callersMethodGetRacks
()
distributed/master/structure.go:102
↓ 1 callersMethodGetReadRequest
()
pb/gleam.pb.go:1017
↓ 1 callersFunctionGetReducer
(reducerId ReducerId)
gio/map_reduce.go:104
↓ 1 callersMethodGetRequest
()
pb/gleam.pb.go:628
↓ 1 callersMethodGetRoundRobin
()
pb/gleam.pb.go:1323
↓ 1 callersMethodGetScope
GetScope gets the status variables scope.
sql/sessionctx/variable/statusvar.go:35
↓ 1 callersMethodGetStats
()
pb/gleam.pb.go:952
↓ 1 callersMethodGetStep
(stepId int32)
pb/status_proto_helper.go:59
↓ 1 callersMethodGetStepGroups
()
pb/gleam.pb.go:364
↓ 1 callersMethodGetStepIds
()
pb/gleam.pb.go:585
↓ 1 callersMethodGetStopTime
()
pb/gleam.pb.go:769
↓ 1 callersFunctionGetTimeValue
GetTimeValue gets the time value with type tp.
sql/expression/helper.go:53
↓ 1 callersMethodGetType
GetType implements Expression interface.
sql/expression/scalar_function.go:109
↓ 1 callersMethodGetTypeDesc
GetTypeDesc gets the description for column type.
sql/table/column.go:140
↓ 1 callersMethodGetUserTime
()
pb/gleam.pb.go:921
↓ 1 callersMethodGetValueIndexes
()
pb/gleam.pb.go:1424
↓ 1 callersFunctionGetZeroValue
GetZeroValue gets zero value for given column type.
sql/table/column.go:281
↓ 1 callersMethodGoTime
(loc *gotime.Location)
sql/util/types/mytime.go:90
↓ 1 callersFunctionHasBinaryFlag
HasBinaryFlag checks if BinaryFlag is set.
sql/mysql/type.go:115
↓ 1 callersFunctionHasMultipleKeyFlag
HasMultipleKeyFlag checks if MultipleKeyFlag is set.
sql/mysql/type.go:130
↓ 1 callersFunctionHasUniKeyFlag
HasUniKeyFlag checks if UniqueKeyFlag is set.
sql/mysql/type.go:125
↓ 1 callersFunctionHasZerofillFlag
HasZerofillFlag checks if ZerofillFlag is set.
sql/mysql/type.go:110
↓ 1 callersFunctionHosts
* This file is only for the builder API. */
plugins/cassandra/cassandra_source_builder.go:7
↓ 1 callersFunctionIndentFormatter
IndentFormatter returns a new Formatter which interprets %i and %u in the Format() formats string as indent and unindent commands. The commands can ne
sql/util/format/format.go:65
↓ 1 callersMethodInit
(code string)
script/shell.go:19
↓ 1 callersFunctionInsertPlan
InsertPlan means inserting plan between two plans.
sql/plan/logical_plans.go:297
↓ 1 callersFunctionIsClockUnit
IsClockUnit returns true when unit is interval unit with hour, minute or second.
sql/util/types/time.go:1604
↓ 1 callersMethodIsCorrelated
IsCorrelated checks if this expression has correlated key.
sql/expression/expression.go:68
↓ 1 callersFunctionIsDateFormat
IsDateFormat returns true when the specified time format could contain only date.
sql/util/types/time.go:1617
↓ 1 callersFunctionIsDir
(filepath string)
filesystem/vfs.go:67
↓ 1 callersMethodIsPoint
IsPoint returns if the index range is a point.
sql/plan/plans.go:54
↓ 1 callersFunctionIsUTF8Charset
IsUTF8Charset checks if charset is utf8 or utf8mb4
sql/mysql/charset.go:562
↓ 1 callersMethodJoinPartitionedSorted
JoinPartitionedSorted Join multiple datasets that are sharded by the same key, and locally sorted within the shard
flow/dataset_join.go:46
↓ 1 callersFunctionJson
(w http.ResponseWriter, r *http.Request, httpStatus int, obj interface{})
util/http_handler.go:16
↓ 1 callersMethodKeyspace
(keyspace string)
plugins/cassandra/cassandra_source_builder.go:19
↓ 1 callersMethodLen
Len implements heap.Interface Len interface.
sql/util/filesort/filesort.go:74
↓ 1 callersMethodLength
Length gets the length of the datum.
sql/util/types/datum.go:90
↓ 1 callersMethodLex
(lval *yySymType)
sql/parser/parser.go:8033
↓ 1 callersFunctionList
(filepath string)
filesystem/vfs.go:57
↓ 1 callersMethodList
(*FileLocation)
filesystem/vfs.go:30
↓ 1 callersFunctionListRegisteredFunctions
ListRegisteredFunctions lists out all registered mappers and reducers
gio/map_reduce.go:129
↓ 1 callersMethodLocalHashAndJoinWith
(name string, that *Dataset, sortOption *SortOption)
flow/dataset_join_hash.go:13
↓ 1 callersMethodLocalTop
(name string, n int, sortOption *SortOption)
flow/dataset_sort.go:72
↓ 1 callersMethodMicroSecond
MicroSecond returns current microsecond. e.g, hour("11:11:11.11") -> 110000
sql/util/types/time.go:813
↓ 1 callersFunctionMulInt64
MulInt64 multiplies int64 a and b and returns int64 if no overflow error.
sql/util/types/overflow.go:98
↓ 1 callersFunctionNew
(leader string, option *Option)
distributed/driver/scheduler/scheduler.go:46
↓ 1 callersFunctionNew
* This file is only for the builder API. */
plugins/kafka/kafka_source_builder.go:7
↓ 1 callersFunctionNew
(reader io.Reader)
plugins/file/tsv/tsv_file_reader.go:15
↓ 1 callersFunctionNew
(reader filesystem.VirtualFile, fileName string)
plugins/file/parquet/parquet_file_reader.go:52
↓ 1 callersFunctionNew
(filename string)
plugins/file/zipfile/zip_file_reader.go:17
↓ 1 callersFunctionNew
TODO predicate pushdown
plugins/file/orc/orc_file_reader.go:17
↓ 1 callersFunctionNew
(reader io.Reader)
plugins/file/txt/txt_file_reader.go:14
↓ 1 callersFunctionNew
(reader io.Reader)
plugins/file/csv/csv_file_reader.go:13
↓ 1 callersFunctionNewDataCenter
(name string)
distributed/master/structure.go:46
↓ 1 callersFunctionNewDatasetShardLocator
()
distributed/driver/scheduler/shard_location.go:18
↓ 1 callersFunctionNewDecFromInt
NewDecFromInt creates a MyDecimal from int.
sql/util/types/mydecimal.go:2082
↓ 1 callersFunctionNewDecimalDatum
NewDecimalDatum creates a new Datum form a MyDecimal value.
sql/util/types/datum.go:1479
↓ 1 callersFunctionNewErrf
NewErrf creates a SQL error, with an error code and a format specifier.
sql/mysql/error.go:59
↓ 1 callersFunctionNewFlowDriver
(option *Option)
distributed/driver/driver.go:42
↓ 1 callersFunctionNewGleamExecutorClient
(cc *grpc.ClientConn)
pb/gleam.pb.go:2136
↓ 1 callersFunctionNewInfoSchema
(schemaName string, tbList []*model.TableInfo)
sql/infoschema/infoschema.go:86
↓ 1 callersFunctionNewLocalDatasetShardsManager
(dir string, port int)
distributed/agent/local_dataset_shards_manager.go:19
↓ 1 callersFunctionNewLocalDatasetShardsManagerInMemory
()
distributed/agent/local_dataset_shards_manager_in_memory.go:66
↓ 1 callersFunctionNewLocalFileDataStore
(dir, name string)
distributed/store/local_file_data_store.go:26
↓ 1 callersFunctionNewMaxOrMinDec
NewMaxOrMinDec returns the max or min value decimal for given precision and fraction.
sql/util/types/mydecimal.go:2101
↓ 1 callersFunctionNewRack
(name string)
distributed/master/structure.go:53
↓ 1 callersFunctionNewReader
NewReader returns a new Reader that reads from r.
plugins/file/csv/generic_csv_reader.go:121
↓ 1 callersFunctionNewScanner
NewScanner returns a new scanner object.
sql/parser/lexer.go:134
↓ 1 callersFunctionNewSessionVars
NewSessionVars creates a session vars object.
sql/sessionctx/variable/session.go:126
↓ 1 callersFunctionNewStepGroup
()
distributed/plan/plan.go:38
↓ 1 callersFunctionNewTaskGroup
()
distributed/plan/plan.go:54
↓ 1 callersFunctionNewTopology
()
distributed/master/structure.go:40
↓ 1 callersMethodOnDisk
OnDisk ensure the intermediate dataset are persisted to disk. This allows executors to run not in parallel if executors are limited.
flow/dataset_hint.go:31
↓ 1 callersFunctionOptimize
Optimize does optimization and creates a Plan. The node must be prepared first.
sql/plan/optimizer.go:30
↓ 1 callersFunctionOrc
(fileOrPattern string, partitionCount int)
plugins/file/file_reader.go:35
↓ 1 callersFunctionParquet
(fileOrPattern string, partitionCount int)
plugins/file/file_reader.go:38
↓ 1 callersFunctionParseBit
ParseBit parses bit string. The string format can be b'val', B'val' or 0bval, val must be 0 or 1. Width is the display width for bit representation. -
sql/util/types/bit.go:69
↓ 1 callersFunctionParseDate
ParseDate is a helper function wrapping ParseTime with date type.
sql/util/types/time.go:1092
↓ 1 callersFunctionParseEnumName
ParseEnumName creates a Enum with item name.
sql/util/types/enum.go:40
↓ 1 callersFunctionParseHex
ParseHex parses hexadecimal literal string. The string format can be X'val', x'val' or 0xval. val must in (0...9, a...f, A...F).
sql/util/types/hex.go:81
↓ 1 callersFunctionParseHexStr
ParseHexStr parses hexadecimal literal as string. See https://dev.mysql.com/doc/refman/5.7/en/hexadecimal-literals.html
sql/util/types/hex.go:97
↓ 1 callersMethodParseOneStmt
ParseOneStmt parses a query and returns an ast.StmtNode. The query must have one statement, otherwise ErrSyntax is returned.
sql/parser/yy_parser.go:106
↓ 1 callersFunctionParseSetName
ParseSetName creates a Set with name.
sql/util/types/set.go:42
← previousnext →901–1,000 of 3,091, ranked by callers