MCPcopy Create free account

hub / github.com/chrislusf/gleam / functions

Functions3,091 in github.com/chrislusf/gleam

↓ 1 callersFunctionPartitionByKeys
(shardCount int, data []interface{})
util/key.go:51
↓ 1 callersFunctionPartitionSize
PartitionSize hints the partition size in MB. This is usually used when sorting is needed.
flow/dataset_hint.go:23
↓ 1 callersMethodPop
Push implements heap.Interface Pop interface.
sql/util/filesort/filesort.go:96
↓ 1 callersMethodPop
()
util/priority_queue.go:73
↓ 1 callersFunctionPrintDelimited
PrintDelimited Reads and formats MessagePack encoded messages with delimiter and lineSeparator.
util/printf.go:49
↓ 1 callersMethodPush
(x interface{})
util/priority_queue.go:64
↓ 1 callersFunctionQuery
(sql string)
sql/flow_query.go:41
↓ 1 callersMethodReadHeader
()
plugins/file/file_reader.go:23
↓ 1 callersMethodReadSplit
()
plugins/kafka/kafka_partition_info.go:34
↓ 1 callersMethodReadSplit
()
plugins/file/file_shard_info.go:36
↓ 1 callersMethodReadSplit
()
plugins/cassandra/cassandra_shard_info.go:42
↓ 1 callersFunctionReaderToChannel
(wg *sync.WaitGroup, name string, readCloser io.ReadCloser, writer io.WriteCloser, closeOutput bool, errorOutp
util/channel_util.go:103
↓ 1 callersMethodReduceBy
(name string, reducerId gio.ReducerId, keyFields *SortOption)
flow/dataset_reduce.go:19
↓ 1 callersMethodReduced
(rule, state int, lval *yySymType)
sql/parser/parser.go:8040
↓ 1 callersFunctionRegisterGleamAgentServer
(s *grpc.Server, srv GleamAgentServer)
pb/gleam.pb.go:2369
↓ 1 callersFunctionRegisterGleamExecutorServer
(s *grpc.Server, srv GleamExecutorServer)
pb/gleam.pb.go:2180
↓ 1 callersFunctionRegisterGleamMasterServer
(s *grpc.Server, srv GleamMasterServer)
pb/gleam.pb.go:2028
↓ 1 callersFunctionRegisterTable
(dataset *flow.Dataset, tableName string, columns []executor.TableColumn)
sql/flow_query.go:15
↓ 1 callersFunctionRemovePlan
RemovePlan means removing a plan.
sql/plan/logical_plans.go:312
↓ 1 callersMethodRequiredResources
()
distributed/plan/plan.go:76
↓ 1 callersMethodResolveIndices
ResolveIndices resolves indices by the given schema.
sql/expression/expression.go:74
↓ 1 callersFunctionResolveName
ResolveName resolves table name and column name. It generates ResultFields for ResultSetNode and resolves ColumnNameExpr to a ResultField.
sql/resolver/resolver.go:30
↓ 1 callersMethodReturnSupply
(s Supply)
distributed/driver/scheduler/market/cda_market.go:100
↓ 1 callersFunctionReverse
Reverse returns its argument string reversed rune-wise left to right.
sql/util/stringutil/string_util.go:27
↓ 1 callersMethodRightOuterJoinByKey
(name string, other *Dataset)
flow/dataset_join.go:30
↓ 1 callersMethodRunContext
Run starts the whole flow. This is a convenient method, same as *Flow.RunContext()
flow/dataset.go:29
↓ 1 callersMethodRunContext
(ctx context.Context, options ...FlowOption)
flow/context.go:29
↓ 1 callersMethodRunFlowAsync
(wg *sync.WaitGroup, fc *Flow)
flow/runner.go:47
↓ 1 callersMethodSaveFirstRowTo
SaveFirstRowTo saves the first row's values into the operands.
flow/dataset_output.go:67
↓ 1 callersMethodSchemaByName
(schema model.CIStr)
sql/infoschema/infoschema.go:58
↓ 1 callersMethodSelectKV
Select selects multiple fields into the next dataset. The index starts from 1.
flow/dataset_map.go:52
↓ 1 callersFunctionSendCleanupRequest
(server string, request *pb.CleanupRequest)
distributed/driver/scheduler/grpc_client_to_agent.go:192
↓ 1 callersMethodSerializeToCommand
()
instruction/instruction.go:29
↓ 1 callersMethodSetCorrelated
SetCorrelated implements Plan interface.
sql/plan/logical_plans.go:116
↓ 1 callersMethodSetCorrelated
SetCorrelated implements Plan interface.
sql/plan/logical_plans.go:182
↓ 1 callersMethodSetCorrelated
SetCorrelated implements Plan interface.
sql/plan/logical_plans.go:197
↓ 1 callersMethodSetCorrelated
SetCorrelated implements Plan interface.
sql/plan/logical_plans.go:265
↓ 1 callersMethodSetHasHeader
SetHasHeader sets whether the data contains header
plugins/file/file_source.go:38
↓ 1 callersMethodSetInputLocations
(locations []DataLocation)
pb/instruction_helper.go:22
↓ 1 callersMethodSetInterface
SetInterface sets interface to datum.
sql/util/types/datum.go:187
↓ 1 callersMethodSetMysqlEnum
SetMysqlEnum sets Enum value
sql/util/types/datum.go:252
↓ 1 callersMethodSetMysqlHex
SetMysqlHex sets Hex value
sql/util/types/datum.go:265
↓ 1 callersMethodSetOutputLocations
(locations []DataLocation)
pb/instruction_helper.go:33
↓ 1 callersMethodSetShardLocation
(name string, location pb.DataLocation)
distributed/driver/scheduler/shard_location.go:34
↓ 1 callersMethodShift
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 callersMethodSlices
Slices begins a flow with an [][]interface{}
flow/dataset_source.go:141
↓ 1 callersFunctionSplitDNFItems
SplitDNFItems splits DNF items. DNF means disjunctive normal form, e.g. "a or b or c".
sql/expression/expression.go:245
↓ 1 callersMethodStats
Stats returns the statistics status variables.
sql/sessionctx/variable/statusvar.go:37
↓ 1 callersMethodStrToDate
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 callersMethodString
String returns the decimal string representation rounded to resultFrac.
sql/util/types/mydecimal.go:173
↓ 1 callersFunctionSubInt64
SubInt64 subtracts int64 a with b and returns int64 if no overflow error.
sql/util/types/overflow.go:64
↓ 1 callersFunctionSubIntWithUint
SubIntWithUint subtracts int64 a with uint64 b and returns uint64 if no overflow error.
sql/util/types/overflow.go:82
↓ 1 callersFunctionSubUintWithInt
SubUintWithInt subtracts uint64 a with int64 b and returns uint64 if no overflow error.
sql/util/types/overflow.go:74
↓ 1 callersFunctionTimeFromDays
TimeFromDays Converts a day number to a date.
sql/util/types/time.go:1135
↓ 1 callersFunctionTimestampDiff
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 callersMethodToBin
* 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 callersFunctionToBytes
(val interface{})
util/type_convertion.go:60
↓ 1 callersMethodToPackedUint
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 callersFunctionToString
(val interface{})
util/type_convertion.go:50
↓ 1 callersMethodToString
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 callersMethodToUint
ToUint returns int part of the decimal, returns the result and errcode.
sql/util/types/mydecimal.go:926
↓ 1 callersFunctionTranslateToInstructionSet
(taskGroups *TaskGroup)
distributed/plan/instructions.go:8
↓ 1 callersMethodTreeMergeSortedTo
(name string, partitionCount int, factor int)
flow/dataset_merge.go:24
↓ 1 callersFunctionTruncateFloat
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 callersMethodUnmarshalMsgWithCfg
(bts []byte, cfg *msgp.RuntimeConfig)
util/row_codec.go:284
↓ 1 callersFunctionUnquoteChar
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 callersMethodUpdateAgentInformation
(ai *pb.Heartbeat)
distributed/master/resource_collect.go:9
↓ 1 callersFunctionUserHomeDir
()
util/dirpath.go:9
↓ 1 callersMethodWaitForAllTasksToComplete
()
distributed/plan/plan.go:101
↓ 1 callersMethodWhere
(whereClause string)
plugins/cassandra/cassandra_source_builder.go:34
↓ 1 callersFunctionWriteEOFMessage
(writer io.Writer)
util/message_write.go:9
↓ 1 callersFunctionabbrDayOfMonth
(day int)
sql/util/types/time.go:1782
↓ 1 callersMethodaddAggregation
(ctx context.Context, agg *PhysicalAggregation)
sql/plan/physical_plans.go:79
↓ 1 callersMethodaddLimit
(l *Limit)
sql/plan/physical_plans.go:226
↓ 1 callersMethodaddRelation
(a int, b int)
sql/expression/constant_propagation.go:51
↓ 1 callersMethodaggPushDown
aggPushDown tries to push down aggregate functions to join paths.
sql/plan/aggregation_push_down.go:300
↓ 1 callersMethodaggregateFunc
(x *ast.AggregateFuncExpr)
sql/plan/typeinferer.go:134
↓ 1 callersMethodaggregateFunc
(x *AggregateFuncExpr)
sql/ast/flag.go:150
↓ 1 callersFunctionalignFrac
alignFrac is used to generate alignment frac, like `100` -> `100000`
sql/util/types/fsp.go:89
↓ 1 callersMethodallFirstRow
(aggFuncs []expression.AggregationFunction)
sql/plan/aggregation_push_down.go:190
↓ 1 callersFunctionallMatch
(matchedList []bool)
sql/plan/match_property.go:68
↓ 1 callersMethodallocID
()
sql/plan/logical_plan_builder.go:32
↓ 1 callersMethodallocateDataCenter
(requests []*pb.ComputeResource)
distributed/master/resource_assign.go:11
↓ 1 callersMethodallocateServersOnRack
(dc *DataCenter, rack *Rack, requests []*pb.ComputeResource)
distributed/master/resource_assign.go:31
↓ 1 callersMethodappendIndexRange
(origin *IndexRange, rangePoints []rangePoint, ft *types.FieldType)
sql/plan/range.go:535
↓ 1 callersFunctionappendTableSources
(in []*ast.TableSource, resultSetNode ast.ResultSetNode)
sql/resolver/resolver.go:781
↓ 1 callersFunctionargsToSpecifiedType
argsToSpecifiedType converts the type of all arguments in args into string type or double type.
sql/expression/builtin_string.go:1437
↓ 1 callersFunctionarithmeticFuncFactory
(op opcode.Op)
sql/expression/builtin_math.go:694
↓ 1 callersFunctionassertSameNumberOfTasks
(steps []*flow.Step)
distributed/plan/plan_physical.go:31
↓ 1 callersMethodbetweenToExpression
(v *ast.BetweenExpr)
sql/plan/expression_rewriter.go:909
↓ 1 callersMethodbinaryOpToExpression
(v *ast.BinaryOperationExpr)
sql/plan/expression_rewriter.go:715
↓ 1 callersMethodbinaryOperation
(x *ast.BinaryOperationExpr)
sql/plan/typeinferer.go:163
↓ 1 callersFunctionbitOpFactory
(op opcode.Op)
sql/expression/builtin_op.go:215
↓ 1 callersMethodborrowChannel
()
distributed/agent/local_dataset_shards_manager_in_memory.go:52
↓ 1 callersMethodbuild
(node ast.Node)
sql/plan/planbuilder.go:74
↓ 1 callersMethodbuildAggregation
(p LogicalPlan, aggFuncList []*ast.AggregateFuncExpr, gbyItems []expression.Expression)
sql/plan/logical_plan_builder.go:46
↓ 1 callersMethodbuildAggregation
(v *plan.PhysicalAggregation)
sql/executor/builder.go:183
↓ 1 callersMethodbuildApply
(v *plan.PhysicalApply)
sql/executor/builder.go:231
↓ 1 callersMethodbuildDataSource
(tn *ast.TableName)
sql/plan/logical_plan_builder.go:913
↓ 1 callersMethodbuildExists
(p LogicalPlan)
sql/plan/logical_plan_builder.go:988
← previousnext →1,001–1,100 of 3,091, ranked by callers