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
Function
PartitionByKeys
(shardCount int, data []interface{})
util/key.go:51
↓ 1 callers
Function
PartitionSize
PartitionSize hints the partition size in MB. This is usually used when sorting is needed.
flow/dataset_hint.go:23
↓ 1 callers
Method
Pop
Push implements heap.Interface Pop interface.
sql/util/filesort/filesort.go:96
↓ 1 callers
Method
Pop
()
util/priority_queue.go:73
↓ 1 callers
Function
PrintDelimited
PrintDelimited Reads and formats MessagePack encoded messages with delimiter and lineSeparator.
util/printf.go:49
↓ 1 callers
Method
Push
(x interface{})
util/priority_queue.go:64
↓ 1 callers
Function
Query
(sql string)
sql/flow_query.go:41
↓ 1 callers
Method
ReadHeader
()
plugins/file/file_reader.go:23
↓ 1 callers
Method
ReadSplit
()
plugins/kafka/kafka_partition_info.go:34
↓ 1 callers
Method
ReadSplit
()
plugins/file/file_shard_info.go:36
↓ 1 callers
Method
ReadSplit
()
plugins/cassandra/cassandra_shard_info.go:42
↓ 1 callers
Function
ReaderToChannel
(wg *sync.WaitGroup, name string, readCloser io.ReadCloser, writer io.WriteCloser, closeOutput bool, errorOutp
util/channel_util.go:103
↓ 1 callers
Method
ReduceBy
(name string, reducerId gio.ReducerId, keyFields *SortOption)
flow/dataset_reduce.go:19
↓ 1 callers
Method
Reduced
(rule, state int, lval *yySymType)
sql/parser/parser.go:8040
↓ 1 callers
Function
RegisterGleamAgentServer
(s *grpc.Server, srv GleamAgentServer)
pb/gleam.pb.go:2369
↓ 1 callers
Function
RegisterGleamExecutorServer
(s *grpc.Server, srv GleamExecutorServer)
pb/gleam.pb.go:2180
↓ 1 callers
Function
RegisterGleamMasterServer
(s *grpc.Server, srv GleamMasterServer)
pb/gleam.pb.go:2028
↓ 1 callers
Function
RegisterTable
(dataset *flow.Dataset, tableName string, columns []executor.TableColumn)
sql/flow_query.go:15
↓ 1 callers
Function
RemovePlan
RemovePlan means removing a plan.
sql/plan/logical_plans.go:312
↓ 1 callers
Method
RequiredResources
()
distributed/plan/plan.go:76
↓ 1 callers
Method
ResolveIndices
ResolveIndices resolves indices by the given schema.
sql/expression/expression.go:74
↓ 1 callers
Function
ResolveName
ResolveName resolves table name and column name. It generates ResultFields for ResultSetNode and resolves ColumnNameExpr to a ResultField.
sql/resolver/resolver.go:30
↓ 1 callers
Method
ReturnSupply
(s Supply)
distributed/driver/scheduler/market/cda_market.go:100
↓ 1 callers
Function
Reverse
Reverse returns its argument string reversed rune-wise left to right.
sql/util/stringutil/string_util.go:27
↓ 1 callers
Method
RightOuterJoinByKey
(name string, other *Dataset)
flow/dataset_join.go:30
↓ 1 callers
Method
RunContext
Run starts the whole flow. This is a convenient method, same as *Flow.RunContext()
flow/dataset.go:29
↓ 1 callers
Method
RunContext
(ctx context.Context, options ...FlowOption)
flow/context.go:29
↓ 1 callers
Method
RunFlowAsync
(wg *sync.WaitGroup, fc *Flow)
flow/runner.go:47
↓ 1 callers
Method
SaveFirstRowTo
SaveFirstRowTo saves the first row's values into the operands.
flow/dataset_output.go:67
↓ 1 callers
Method
SchemaByName
(schema model.CIStr)
sql/infoschema/infoschema.go:58
↓ 1 callers
Method
SelectKV
Select selects multiple fields into the next dataset. The index starts from 1.
flow/dataset_map.go:52
↓ 1 callers
Function
SendCleanupRequest
(server string, request *pb.CleanupRequest)
distributed/driver/scheduler/grpc_client_to_agent.go:192
↓ 1 callers
Method
SerializeToCommand
()
instruction/instruction.go:29
↓ 1 callers
Method
SetCorrelated
SetCorrelated implements Plan interface.
sql/plan/logical_plans.go:116
↓ 1 callers
Method
SetCorrelated
SetCorrelated implements Plan interface.
sql/plan/logical_plans.go:182
↓ 1 callers
Method
SetCorrelated
SetCorrelated implements Plan interface.
sql/plan/logical_plans.go:197
↓ 1 callers
Method
SetCorrelated
SetCorrelated implements Plan interface.
sql/plan/logical_plans.go:265
↓ 1 callers
Method
SetHasHeader
SetHasHeader sets whether the data contains header
plugins/file/file_source.go:38
↓ 1 callers
Method
SetInputLocations
(locations []DataLocation)
pb/instruction_helper.go:22
↓ 1 callers
Method
SetInterface
SetInterface sets interface to datum.
sql/util/types/datum.go:187
↓ 1 callers
Method
SetMysqlEnum
SetMysqlEnum sets Enum value
sql/util/types/datum.go:252
↓ 1 callers
Method
SetMysqlHex
SetMysqlHex sets Hex value
sql/util/types/datum.go:265
↓ 1 callers
Method
SetOutputLocations
(locations []DataLocation)
pb/instruction_helper.go:33
↓ 1 callers
Method
SetShardLocation
(name string, location pb.DataLocation)
distributed/driver/scheduler/shard_location.go:34
↓ 1 callers
Method
Shift
Shift shifts decimal digits in given number (with rounding if it need), shift > 0 means shift to left shift, shift < 0 means right shift. In fact it i
sql/util/types/mydecimal.go:416
↓ 1 callers
Method
Slices
Slices begins a flow with an [][]interface{}
flow/dataset_source.go:141
↓ 1 callers
Function
SplitDNFItems
SplitDNFItems splits DNF items. DNF means disjunctive normal form, e.g. "a or b or c".
sql/expression/expression.go:245
↓ 1 callers
Method
Stats
Stats returns the statistics status variables.
sql/sessionctx/variable/statusvar.go:37
↓ 1 callers
Method
StrToDate
StrToDate converts date string according to format. See https://dev.mysql.com/doc/refman/5.7/en/date-and-time-functions.html#function_date-format
sql/util/types/time.go:1799
↓ 1 callers
Method
String
String returns the decimal string representation rounded to resultFrac.
sql/util/types/mydecimal.go:173
↓ 1 callers
Function
SubInt64
SubInt64 subtracts int64 a with b and returns int64 if no overflow error.
sql/util/types/overflow.go:64
↓ 1 callers
Function
SubIntWithUint
SubIntWithUint subtracts int64 a with uint64 b and returns uint64 if no overflow error.
sql/util/types/overflow.go:82
↓ 1 callers
Function
SubUintWithInt
SubUintWithInt subtracts uint64 a with int64 b and returns uint64 if no overflow error.
sql/util/types/overflow.go:74
↓ 1 callers
Function
TimeFromDays
TimeFromDays Converts a day number to a date.
sql/util/types/time.go:1135
↓ 1 callers
Function
TimestampDiff
TimestampDiff returns t2 - t1 where t1 and t2 are date or datetime expressions. The unit for the result (an integer) is given by the unit argument. Th
sql/util/types/time.go:477
↓ 1 callers
Method
ToBin
* ToBin converts decimal to its binary fixed-length representation two representations of the same length can be compared with memcmp with the correct
sql/util/types/mydecimal.go:1042
↓ 1 callers
Function
ToBytes
(val interface{})
util/type_convertion.go:60
↓ 1 callers
Method
ToPackedUint
ToPackedUint encodes Time to a packed uint64 value. 1 bit 0 17 bits year*13+month (year 0-9999, month 0-12) 5 bits day (0-31) 5 bits h
sql/util/types/time.go:379
↓ 1 callers
Function
ToString
(val interface{})
util/type_convertion.go:50
↓ 1 callers
Method
ToString
ToString converts decimal to its printable string representation without rounding. RETURN VALUE str - result string errCode - eDecOK/eDecTru
sql/util/types/mydecimal.go:207
↓ 1 callers
Method
ToUint
ToUint returns int part of the decimal, returns the result and errcode.
sql/util/types/mydecimal.go:926
↓ 1 callers
Function
TranslateToInstructionSet
(taskGroups *TaskGroup)
distributed/plan/instructions.go:8
↓ 1 callers
Method
TreeMergeSortedTo
(name string, partitionCount int, factor int)
flow/dataset_merge.go:24
↓ 1 callers
Function
TruncateFloat
TruncateFloat tries to truncate f. If the result exceeds the max/min float that flen/decimal allowed, returns the max/min float allowed.
sql/util/types/helper.go:58
↓ 1 callers
Method
UnmarshalMsgWithCfg
(bts []byte, cfg *msgp.RuntimeConfig)
util/row_codec.go:284
↓ 1 callers
Function
UnquoteChar
UnquoteChar decodes the first character or byte in the escaped string or character literal represented by the string s. It returns four values: 1) va
sql/util/stringutil/string_util.go:50
↓ 1 callers
Method
UpdateAgentInformation
(ai *pb.Heartbeat)
distributed/master/resource_collect.go:9
↓ 1 callers
Function
UserHomeDir
()
util/dirpath.go:9
↓ 1 callers
Method
WaitForAllTasksToComplete
()
distributed/plan/plan.go:101
↓ 1 callers
Method
Where
(whereClause string)
plugins/cassandra/cassandra_source_builder.go:34
↓ 1 callers
Function
WriteEOFMessage
(writer io.Writer)
util/message_write.go:9
↓ 1 callers
Function
abbrDayOfMonth
(day int)
sql/util/types/time.go:1782
↓ 1 callers
Method
addAggregation
(ctx context.Context, agg *PhysicalAggregation)
sql/plan/physical_plans.go:79
↓ 1 callers
Method
addLimit
(l *Limit)
sql/plan/physical_plans.go:226
↓ 1 callers
Method
addRelation
(a int, b int)
sql/expression/constant_propagation.go:51
↓ 1 callers
Method
aggPushDown
aggPushDown tries to push down aggregate functions to join paths.
sql/plan/aggregation_push_down.go:300
↓ 1 callers
Method
aggregateFunc
(x *ast.AggregateFuncExpr)
sql/plan/typeinferer.go:134
↓ 1 callers
Method
aggregateFunc
(x *AggregateFuncExpr)
sql/ast/flag.go:150
↓ 1 callers
Function
alignFrac
alignFrac is used to generate alignment frac, like `100` -> `100000`
sql/util/types/fsp.go:89
↓ 1 callers
Method
allFirstRow
(aggFuncs []expression.AggregationFunction)
sql/plan/aggregation_push_down.go:190
↓ 1 callers
Function
allMatch
(matchedList []bool)
sql/plan/match_property.go:68
↓ 1 callers
Method
allocID
()
sql/plan/logical_plan_builder.go:32
↓ 1 callers
Method
allocateDataCenter
(requests []*pb.ComputeResource)
distributed/master/resource_assign.go:11
↓ 1 callers
Method
allocateServersOnRack
(dc *DataCenter, rack *Rack, requests []*pb.ComputeResource)
distributed/master/resource_assign.go:31
↓ 1 callers
Method
appendIndexRange
(origin *IndexRange, rangePoints []rangePoint, ft *types.FieldType)
sql/plan/range.go:535
↓ 1 callers
Function
appendTableSources
(in []*ast.TableSource, resultSetNode ast.ResultSetNode)
sql/resolver/resolver.go:781
↓ 1 callers
Function
argsToSpecifiedType
argsToSpecifiedType converts the type of all arguments in args into string type or double type.
sql/expression/builtin_string.go:1437
↓ 1 callers
Function
arithmeticFuncFactory
(op opcode.Op)
sql/expression/builtin_math.go:694
↓ 1 callers
Function
assertSameNumberOfTasks
(steps []*flow.Step)
distributed/plan/plan_physical.go:31
↓ 1 callers
Method
betweenToExpression
(v *ast.BetweenExpr)
sql/plan/expression_rewriter.go:909
↓ 1 callers
Method
binaryOpToExpression
(v *ast.BinaryOperationExpr)
sql/plan/expression_rewriter.go:715
↓ 1 callers
Method
binaryOperation
(x *ast.BinaryOperationExpr)
sql/plan/typeinferer.go:163
↓ 1 callers
Function
bitOpFactory
(op opcode.Op)
sql/expression/builtin_op.go:215
↓ 1 callers
Method
borrowChannel
()
distributed/agent/local_dataset_shards_manager_in_memory.go:52
↓ 1 callers
Method
build
(node ast.Node)
sql/plan/planbuilder.go:74
↓ 1 callers
Method
buildAggregation
(p LogicalPlan, aggFuncList []*ast.AggregateFuncExpr, gbyItems []expression.Expression)
sql/plan/logical_plan_builder.go:46
↓ 1 callers
Method
buildAggregation
(v *plan.PhysicalAggregation)
sql/executor/builder.go:183
↓ 1 callers
Method
buildApply
(v *plan.PhysicalApply)
sql/executor/builder.go:231
↓ 1 callers
Method
buildDataSource
(tn *ast.TableName)
sql/plan/logical_plan_builder.go:913
↓ 1 callers
Method
buildExists
(p LogicalPlan)
sql/plan/logical_plan_builder.go:988
← previous
next →
1,001–1,100 of 3,091, ranked by callers