MCPcopy Create free account

hub / github.com/chrislusf/gleam / functions

Functions3,091 in github.com/chrislusf/gleam

⨍ Functions 3,091◇ Types & classes 751
↓ 3 callersMethodGetAgent
(name string)
distributed/master/structure.go:76
↓ 3 callersMethodGetColumnsIndices
GetColumnsIndices will return a slice which contains the position of each column in schema. If there is one column that doesn't match, nil will be ret
sql/expression/schema.go:132
↓ 3 callersMethodGetComputeResources
()
pb/gleam.pb.go:84
↓ 3 callersMethodGetDatum
GetDatum gets datum of the expression.
sql/ast/ast.go:71
↓ 3 callersFunctionGetDefaultCollation
GetDefaultCollation returns the default collation for charset.
sql/util/charset/charset.go:121
↓ 3 callersMethodGetExecutionStat
()
pb/gleam.pb.go:928
↓ 3 callersMethodGetLocalLimit
()
pb/gleam.pb.go:1386
↓ 3 callersMethodGetLocalTop
()
pb/gleam.pb.go:1330
↓ 3 callersMethodGetPartitionSize
GetPartitionSize returns the size in MB for each partition of the dataset. This is based on the hinted total size divided by the number of partitions.
flow/context_hint.go:34
↓ 3 callersMethodGetRack
(name string)
distributed/master/structure.go:68
↓ 3 callersMethodGetReaderCount
()
pb/gleam.pb.go:1120
↓ 3 callersMethodGetResources
(ctx context.Context, in *ComputeRequest, opts ...grpc.CallOption)
pb/gleam.pb.go:1930
↓ 3 callersMethodGetScript
()
pb/gleam.pb.go:1351
↓ 3 callersMethodGetSelect
()
pb/gleam.pb.go:1274
↓ 3 callersMethodGetStepId
()
pb/gleam.pb.go:1239
↓ 3 callersMethodGetTaskId
()
pb/gleam.pb.go:1246
↓ 3 callersMethodGetWriteRequest
()
pb/gleam.pb.go:1024
↓ 3 callersMethodHashCode
HashCode create the hashcode for expression
sql/expression/expression.go:62
↓ 3 callersMethodHint
Hint adds hints to the flow.
flow/context_hint.go:10
↓ 3 callersMethodIsDistinct
IsDistinct indicates if the aggregate function contains distinct attribute.
sql/expression/aggregation.go:68
↓ 3 callersMethodIsNegative
IsNegative returns whether a decimal is negative.
sql/util/types/mydecimal.go:168
↓ 3 callersFunctionIsTypeBlob
IsTypeBlob returns a boolean indicating whether the tp is a blob type.
sql/util/types/etc.go:32
↓ 3 callersFunctionIsTypeChar
IsTypeChar returns a boolean indicating whether the tp is the char type like a string type or a varchar type.
sql/util/types/etc.go:43
↓ 3 callersMethodLocalGroupBy
(name string, sortOption *SortOption)
flow/dataset_group.go:18
↓ 3 callersMethodLocalLimit
LocalLimit take the local first n rows and skip all other rows.
flow/dataset_map.go:59
↓ 3 callersFunctionMakeDatums
MakeDatums creates datum slice from interfaces.
sql/util/types/datum.go:1485
↓ 3 callersMethodMsgsize
Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
util/row_codec.go:428
↓ 3 callersFunctionNewGleamMasterClient
(cc *grpc.ClientConn)
pb/gleam.pb.go:1939
↓ 3 callersFunctionNewPriorityQueue
(lessFunc func(a, b interface{}) bool)
util/priority_queue.go:23
↓ 3 callersFunctionNewSelect
(keyIndexes, valueIndexes []int)
instruction/select.go:29
↓ 3 callersMethodNext
Next returns the next row, nil row means there is no more to return.
sql/ast/ast.go:141
↓ 3 callersMethodOutput
Output concurrently collects outputs from previous step to the driver.
flow/dataset_output.go:17
↓ 3 callersMethodPrecisionAndFrac
PrecisionAndFrac returns the internal precision and frac number.
sql/util/types/mydecimal.go:1153
↓ 3 callersFunctionRegisterReducer
(fn Reducer)
gio/map_reduce.go:94
↓ 3 callersMethodReplaceChild
ReplaceChild means replacing a child with another one.
sql/plan/plan.go:84
↓ 3 callersMethodRunFunction
(task *Task)
flow/step.go:36
↓ 3 callersFunctionScalarFuncs2Exprs
ScalarFuncs2Exprs converts []*ScalarFunction to []Expression.
sql/expression/scalar_function.go:84
↓ 3 callersMethodSeek
(offset int64, pos int)
plugins/file/parquet/parquet_file_reader.go:35
↓ 3 callersMethodSetBytesAsString
SetBytesAsString sets bytes value to datum as string type.
sql/util/types/datum.go:176
↓ 3 callersMethodSetFrac
SetFrac sets the frac of the datum.
sql/util/types/datum.go:85
↓ 3 callersMethodSetRow
SetRow sets row value.
sql/util/types/datum.go:198
↓ 3 callersMethodSetUniqueKeys
SetUniqueKeys will set the value of Schema.Keys.
sql/expression/schema.go:126
↓ 3 callersMethodTableByName
(schema, table model.CIStr)
sql/infoschema/infoschema.go:60
↓ 3 callersFunctionTakeMessage
TakeMessage Reads and processes MessagePack encoded messages. If count is less than 0, all lines are processed.
util/message_read.go:58
↓ 3 callersFunctionToFloat64
(val interface{})
util/type_convertion.go:40
↓ 3 callersMethodToOsExecCommand
()
script/script.go:29
↓ 3 callersFunctionTsEmit
TsEmit encode and write a row of data to os.Stdout with ts in milliseconds epoch time
gio/emit.go:16
↓ 3 callersMethodUnmarshalMsg
UnmarshalMsg implements msgp.Unmarshaler
util/row_codec.go:280
↓ 3 callersMethodaddTopN
(ctx context.Context, prop *requiredProperty)
sql/plan/physical_plans.go:80
↓ 3 callersMethodattachOnConds
(onConds []expression.Expression)
sql/plan/logical_plans.go:59
↓ 3 callersFunctionboolToInt64
(v bool)
sql/expression/helper.go:33
↓ 3 callersMethodbuildQuantifierPlan
buildQuantifierPlan adds extra condition for any / all subquery.
sql/plan/expression_rewriter.go:311
↓ 3 callersMethodbuildUnion
(union *ast.UnionStmt)
sql/plan/logical_plan_builder.go:340
↓ 3 callersFunctioncalcTimeDiff
calcTimeDiff calculates difference between two datetime values as seconds + microseconds. t1 and t2 should be TIME/DATE/DATETIME value. sign can be +1
sql/util/types/mytime.go:131
↓ 3 callersFunctioncheckFsp
(sc *variable.StatementContext, arg types.Datum)
sql/expression/builtin_time.go:1328
↓ 3 callersFunctionconnect
(canvas *svg.SVG, a, b point, label string)
distributed/master/ui/svg_writer_helper.go:39
↓ 3 callersMethodconstructBinaryOpFunction
constructBinaryOpFunctions converts (a0,a1,a2) op (b0,b1,b2) to (a0 op b0) and (a1 op b1) and (a2 op b2).
sql/plan/expression_rewriter.go:119
↓ 3 callersMethodconvert2PhysicalPlanLeft
convert2PhysicalPlanLeft converts the left join to *physicalPlanInfo.
sql/plan/physical_plan_builder.go:319
↓ 3 callersFunctionconvertIntToUint
(val int64, upperBound uint64, tp byte)
sql/util/types/convert.go:96
↓ 3 callersFunctioncopyBuffer
(dst io.Writer, src io.Reader, written *int64)
util/channel_util.go:206
↓ 3 callersFunctiondatumToConstant
(d types.Datum, tp byte)
sql/plan/expression_rewriter.go:642
↓ 3 callersMethoddoDelete
(name string)
distributed/agent/local_dataset_shards_manager.go:29
↓ 3 callersMethoddoDelete
(name string)
distributed/agent/local_dataset_shards_manager_in_memory.go:74
↓ 3 callersFunctiondoOptimize
(logic LogicalPlan, ctx context.Context, allocator *idAllocator)
sql/plan/optimizer.go:51
↓ 3 callersFunctiondoSub
(from1, from2, to *MyDecimal)
sql/util/types/mydecimal.go:1344
↓ 3 callersFunctionerrorOrWarning
errorOrWarning reports error or warning depend on the context.
sql/expression/builtin_time.go:1519
↓ 3 callersFunctionextractSecondMicrosecond
Format is `SS.FFFFFF`.
sql/util/types/time.go:1342
↓ 3 callersMethodfilename
()
distributed/store/single_file_store.go:122
↓ 3 callersFunctionfindColumnIndexByGroup
(groups []LogicalPlan, col *expression.Column)
sql/plan/join_reorder.go:38
↓ 3 callersFunctionfindIndexByName
(indices []*model.IndexInfo, name model.CIStr)
sql/plan/planbuilder.go:204
↓ 3 callersMethodgetMsg
()
sql/terror/terror.go:215
↓ 3 callersFunctiongetPrintDivLine
(maxColLen []int)
sql/util/printer/printer.go:76
↓ 3 callersFunctionmergeArithType
(a, b byte)
sql/plan/typeinferer.go:196
↓ 3 callersFunctionrangePointLess
(sc *variable.StatementContext, a, b rangePoint)
sql/plan/range.go:75
↓ 3 callersMethodresolveHavingAndOrderBy
(sel *ast.SelectStmt, p LogicalPlan)
sql/plan/logical_plan_builder.go:651
↓ 3 callersMethodscanFloat
(beg *Pos)
sql/parser/lexer.go:555
↓ 3 callersFunctionscanTimeArgs
(seps []string, args ...*int)
sql/util/types/time.go:613
↓ 3 callersMethodsendOneHeartbeat
(stream pb.GleamMaster_SendHeartbeatClient)
distributed/agent/agent_grpc_client_to_master.go:61
↓ 3 callersFunctionskipEmptySpace
(input string)
sql/util/types/time.go:1895
↓ 3 callersMethodskipEmptySpace
()
sql/parser/lexer.go:138
↓ 3 callersFunctionsplitLocationToParts
(location string)
filesystem/vfs_hdfs.go:94
↓ 3 callersMethodstartOffset
(v *yySymType)
sql/parser/yy_parser.go:128
↓ 3 callersFunctionsub
sub subtracts b and carry from a, returns the diff and new carry.
sql/util/types/mydecimal.go:76
↓ 3 callersMethodtableUniqueName
(schema, table model.CIStr)
sql/resolver/resolver.go:794
↓ 3 callersMethodtest
(flag weekBehaviour)
sql/util/types/mytime.go:222
↓ 3 callersFunctionwriteWord
(b []byte, word int32, size int)
sql/util/types/mydecimal.go:1292
↓ 3 callersFunctionyySymName
(c int)
sql/parser/parser.go:8043
↓ 2 callersMethodAddChild
AddChild means appending a child for plan.
sql/plan/plan.go:80
↓ 2 callersFunctionAddInteger
AddInteger adds uint64 a and int64 b and returns uint64 if no overflow error.
sql/util/types/overflow.go:44
↓ 2 callersMethodAvailable
()
util/message_write.go:40
↓ 2 callersFunctionBufWrites
BufWrites ensures all writers are bufio.Writer For any bufio.Writer created here, flush it before returning.
util/buf_writer.go:10
↓ 2 callersFunctionCastValue
CastValue casts a value based on column type.
sql/table/column.go:112
↓ 2 callersFunctionChannelToLineWriter
(wg *sync.WaitGroup, stat *pb.InstructionStat, name string, reader io.Reader, writer io.WriteCloser, errorOutp
util/channel_util.go:191
↓ 2 callersMethodClosed
()
flow/dataset.go:33
↓ 2 callersFunctionCoerceArithmetic
CoerceArithmetic converts datum to appropriate datum for arithmetic computing.
sql/util/types/datum_eval.go:25
↓ 2 callersMethodCompactStr
CompactStr only considers Tp/CharsetBin/Flen/Deimal. This is used for showing column type in infoschema.
sql/util/types/field_type.go:60
↓ 2 callersFunctionComputePlus
ComputePlus computes the result of a+b.
sql/util/types/datum_eval.go:75
↓ 2 callersMethodConvert
Convert converts t with type tp.
sql/util/types/time.go:240
↓ 2 callersFunctionConvertLineReaderToRowReader
(lineReader io.Reader, name string, errorOutput io.Writer)
util/channel_util.go:170
↓ 2 callersFunctionCreateDistinctChecker
CreateDistinctChecker creates a new distinct checker.
sql/util/distinct/distinct.go:23
← previousnext →401–500 of 3,091, ranked by callers