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
↓ 1 callers
Method
GetInputShardLocations
()
pb/gleam.pb.go:1260
↓ 1 callers
Method
GetInstructionFunction
(i *pb.Instruction)
instruction/instruction.go:41
↓ 1 callers
Method
GetInterface
GetInterface gets interface value.
sql/util/types/datum.go:182
↓ 1 callers
Method
GetIsLeftOuterJoin
()
pb/gleam.pb.go:1451
↓ 1 callers
Method
GetIsParallel
()
pb/gleam.pb.go:1750
↓ 1 callers
Method
GetIsRightOuterJoin
()
pb/gleam.pb.go:1458
↓ 1 callers
Method
GetKeyIndexes
()
pb/gleam.pb.go:1417
↓ 1 callers
Function
GetMapper
(mapperId MapperId)
gio/map_reduce.go:85
↓ 1 callers
Method
GetMemoryInMB
()
pb/gleam.pb.go:1253
↓ 1 callers
Method
GetMergeTo
()
pb/gleam.pb.go:1372
↓ 1 callers
Method
GetMode
GetMode gets aggFunctionMode from aggregate function.
sql/expression/aggregation.go:47
↓ 1 callers
Method
GetName
GetName implements AggregationFunction interface.
sql/expression/aggregation.go:202
↓ 1 callers
Method
GetOffset
()
pb/gleam.pb.go:1716
↓ 1 callers
Method
GetOrder
()
pb/gleam.pb.go:1774
↓ 1 callers
Method
GetOutputShardLocations
()
pb/gleam.pb.go:1267
↓ 1 callers
Method
GetParentByIndex
Retrieve the parent by index.
sql/plan/plan.go:86
↓ 1 callers
Method
GetParents
Get all the parents.
sql/plan/plan.go:90
↓ 1 callers
Method
GetRacks
()
distributed/master/structure.go:102
↓ 1 callers
Method
GetReadRequest
()
pb/gleam.pb.go:1017
↓ 1 callers
Function
GetReducer
(reducerId ReducerId)
gio/map_reduce.go:104
↓ 1 callers
Method
GetRequest
()
pb/gleam.pb.go:628
↓ 1 callers
Method
GetRoundRobin
()
pb/gleam.pb.go:1323
↓ 1 callers
Method
GetScope
GetScope gets the status variables scope.
sql/sessionctx/variable/statusvar.go:35
↓ 1 callers
Method
GetStats
()
pb/gleam.pb.go:952
↓ 1 callers
Method
GetStep
(stepId int32)
pb/status_proto_helper.go:59
↓ 1 callers
Method
GetStepGroups
()
pb/gleam.pb.go:364
↓ 1 callers
Method
GetStepIds
()
pb/gleam.pb.go:585
↓ 1 callers
Method
GetStopTime
()
pb/gleam.pb.go:769
↓ 1 callers
Function
GetTimeValue
GetTimeValue gets the time value with type tp.
sql/expression/helper.go:53
↓ 1 callers
Method
GetType
GetType implements Expression interface.
sql/expression/scalar_function.go:109
↓ 1 callers
Method
GetTypeDesc
GetTypeDesc gets the description for column type.
sql/table/column.go:140
↓ 1 callers
Method
GetUserTime
()
pb/gleam.pb.go:921
↓ 1 callers
Method
GetValueIndexes
()
pb/gleam.pb.go:1424
↓ 1 callers
Function
GetZeroValue
GetZeroValue gets zero value for given column type.
sql/table/column.go:281
↓ 1 callers
Method
GoTime
(loc *gotime.Location)
sql/util/types/mytime.go:90
↓ 1 callers
Function
HasBinaryFlag
HasBinaryFlag checks if BinaryFlag is set.
sql/mysql/type.go:115
↓ 1 callers
Function
HasMultipleKeyFlag
HasMultipleKeyFlag checks if MultipleKeyFlag is set.
sql/mysql/type.go:130
↓ 1 callers
Function
HasUniKeyFlag
HasUniKeyFlag checks if UniqueKeyFlag is set.
sql/mysql/type.go:125
↓ 1 callers
Function
HasZerofillFlag
HasZerofillFlag checks if ZerofillFlag is set.
sql/mysql/type.go:110
↓ 1 callers
Function
Hosts
* This file is only for the builder API. */
plugins/cassandra/cassandra_source_builder.go:7
↓ 1 callers
Function
IndentFormatter
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 callers
Method
Init
(code string)
script/shell.go:19
↓ 1 callers
Function
InsertPlan
InsertPlan means inserting plan between two plans.
sql/plan/logical_plans.go:297
↓ 1 callers
Function
IsClockUnit
IsClockUnit returns true when unit is interval unit with hour, minute or second.
sql/util/types/time.go:1604
↓ 1 callers
Method
IsCorrelated
IsCorrelated checks if this expression has correlated key.
sql/expression/expression.go:68
↓ 1 callers
Function
IsDateFormat
IsDateFormat returns true when the specified time format could contain only date.
sql/util/types/time.go:1617
↓ 1 callers
Function
IsDir
(filepath string)
filesystem/vfs.go:67
↓ 1 callers
Method
IsPoint
IsPoint returns if the index range is a point.
sql/plan/plans.go:54
↓ 1 callers
Function
IsUTF8Charset
IsUTF8Charset checks if charset is utf8 or utf8mb4
sql/mysql/charset.go:562
↓ 1 callers
Method
JoinPartitionedSorted
JoinPartitionedSorted Join multiple datasets that are sharded by the same key, and locally sorted within the shard
flow/dataset_join.go:46
↓ 1 callers
Function
Json
(w http.ResponseWriter, r *http.Request, httpStatus int, obj interface{})
util/http_handler.go:16
↓ 1 callers
Method
Keyspace
(keyspace string)
plugins/cassandra/cassandra_source_builder.go:19
↓ 1 callers
Method
Len
Len implements heap.Interface Len interface.
sql/util/filesort/filesort.go:74
↓ 1 callers
Method
Length
Length gets the length of the datum.
sql/util/types/datum.go:90
↓ 1 callers
Method
Lex
(lval *yySymType)
sql/parser/parser.go:8033
↓ 1 callers
Function
List
(filepath string)
filesystem/vfs.go:57
↓ 1 callers
Method
List
(*FileLocation)
filesystem/vfs.go:30
↓ 1 callers
Function
ListRegisteredFunctions
ListRegisteredFunctions lists out all registered mappers and reducers
gio/map_reduce.go:129
↓ 1 callers
Method
LocalHashAndJoinWith
(name string, that *Dataset, sortOption *SortOption)
flow/dataset_join_hash.go:13
↓ 1 callers
Method
LocalTop
(name string, n int, sortOption *SortOption)
flow/dataset_sort.go:72
↓ 1 callers
Method
MicroSecond
MicroSecond returns current microsecond. e.g, hour("11:11:11.11") -> 110000
sql/util/types/time.go:813
↓ 1 callers
Function
MulInt64
MulInt64 multiplies int64 a and b and returns int64 if no overflow error.
sql/util/types/overflow.go:98
↓ 1 callers
Function
New
(leader string, option *Option)
distributed/driver/scheduler/scheduler.go:46
↓ 1 callers
Function
New
* This file is only for the builder API. */
plugins/kafka/kafka_source_builder.go:7
↓ 1 callers
Function
New
(reader io.Reader)
plugins/file/tsv/tsv_file_reader.go:15
↓ 1 callers
Function
New
(reader filesystem.VirtualFile, fileName string)
plugins/file/parquet/parquet_file_reader.go:52
↓ 1 callers
Function
New
(filename string)
plugins/file/zipfile/zip_file_reader.go:17
↓ 1 callers
Function
New
TODO predicate pushdown
plugins/file/orc/orc_file_reader.go:17
↓ 1 callers
Function
New
(reader io.Reader)
plugins/file/txt/txt_file_reader.go:14
↓ 1 callers
Function
New
(reader io.Reader)
plugins/file/csv/csv_file_reader.go:13
↓ 1 callers
Function
NewDataCenter
(name string)
distributed/master/structure.go:46
↓ 1 callers
Function
NewDatasetShardLocator
()
distributed/driver/scheduler/shard_location.go:18
↓ 1 callers
Function
NewDecFromInt
NewDecFromInt creates a MyDecimal from int.
sql/util/types/mydecimal.go:2082
↓ 1 callers
Function
NewDecimalDatum
NewDecimalDatum creates a new Datum form a MyDecimal value.
sql/util/types/datum.go:1479
↓ 1 callers
Function
NewErrf
NewErrf creates a SQL error, with an error code and a format specifier.
sql/mysql/error.go:59
↓ 1 callers
Function
NewFlowDriver
(option *Option)
distributed/driver/driver.go:42
↓ 1 callers
Function
NewGleamExecutorClient
(cc *grpc.ClientConn)
pb/gleam.pb.go:2136
↓ 1 callers
Function
NewInfoSchema
(schemaName string, tbList []*model.TableInfo)
sql/infoschema/infoschema.go:86
↓ 1 callers
Function
NewLocalDatasetShardsManager
(dir string, port int)
distributed/agent/local_dataset_shards_manager.go:19
↓ 1 callers
Function
NewLocalDatasetShardsManagerInMemory
()
distributed/agent/local_dataset_shards_manager_in_memory.go:66
↓ 1 callers
Function
NewLocalFileDataStore
(dir, name string)
distributed/store/local_file_data_store.go:26
↓ 1 callers
Function
NewMaxOrMinDec
NewMaxOrMinDec returns the max or min value decimal for given precision and fraction.
sql/util/types/mydecimal.go:2101
↓ 1 callers
Function
NewRack
(name string)
distributed/master/structure.go:53
↓ 1 callers
Function
NewReader
NewReader returns a new Reader that reads from r.
plugins/file/csv/generic_csv_reader.go:121
↓ 1 callers
Function
NewScanner
NewScanner returns a new scanner object.
sql/parser/lexer.go:134
↓ 1 callers
Function
NewSessionVars
NewSessionVars creates a session vars object.
sql/sessionctx/variable/session.go:126
↓ 1 callers
Function
NewStepGroup
()
distributed/plan/plan.go:38
↓ 1 callers
Function
NewTaskGroup
()
distributed/plan/plan.go:54
↓ 1 callers
Function
NewTopology
()
distributed/master/structure.go:40
↓ 1 callers
Method
OnDisk
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 callers
Function
Optimize
Optimize does optimization and creates a Plan. The node must be prepared first.
sql/plan/optimizer.go:30
↓ 1 callers
Function
Orc
(fileOrPattern string, partitionCount int)
plugins/file/file_reader.go:35
↓ 1 callers
Function
Parquet
(fileOrPattern string, partitionCount int)
plugins/file/file_reader.go:38
↓ 1 callers
Function
ParseBit
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 callers
Function
ParseDate
ParseDate is a helper function wrapping ParseTime with date type.
sql/util/types/time.go:1092
↓ 1 callers
Function
ParseEnumName
ParseEnumName creates a Enum with item name.
sql/util/types/enum.go:40
↓ 1 callers
Function
ParseHex
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 callers
Function
ParseHexStr
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 callers
Method
ParseOneStmt
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 callers
Function
ParseSetName
ParseSetName creates a Set with name.
sql/util/types/set.go:42
← previous
next →
901–1,000 of 3,091, ranked by callers