Documentation ¶
Overview ¶
Copyright 2021 - 2022 Matrix Origin
Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.
Copyright 2021 - 2022 Matrix Origin ¶
Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.
Index ¶
- Constants
- Variables
- func AddFaultPoint(vecs []*vector.Vector, proc *process.Process) (*vector.Vector, error)
- func CeilDecimal128(vecs []*vector.Vector, proc *process.Process) (*vector.Vector, error)
- func CeilFloat64(vecs []*vector.Vector, proc *process.Process) (*vector.Vector, error)
- func CeilInt64(vecs []*vector.Vector, proc *process.Process) (*vector.Vector, error)
- func CeilStr(vecs []*vector.Vector, proc *process.Process) (*vector.Vector, error)
- func CeilUint64(vecs []*vector.Vector, proc *process.Process) (*vector.Vector, error)
- func Concat(vectors []*vector.Vector, proc *process.Process) (*vector.Vector, error)
- func Concat_ws(vectors []*vector.Vector, proc *process.Process) (*vector.Vector, error)
- func CurrentTimestamp(vectors []*vector.Vector, proc *process.Process) (*vector.Vector, error)
- func DateAdd(vectors []*vector.Vector, proc *process.Process) (*vector.Vector, error)
- func DateStringAdd(vectors []*vector.Vector, proc *process.Process) (*vector.Vector, error)
- func DateStringSub(vectors []*vector.Vector, proc *process.Process) (*vector.Vector, error)
- func DateSub(vectors []*vector.Vector, proc *process.Process) (*vector.Vector, error)
- func DatetimeAdd(vectors []*vector.Vector, proc *process.Process) (*vector.Vector, error)
- func DatetimeSub(vectors []*vector.Vector, proc *process.Process) (*vector.Vector, error)
- func DisableFaultInjection(vecs []*vector.Vector, proc *process.Process) (*vector.Vector, error)
- func EnableFaultInjection(vecs []*vector.Vector, proc *process.Process) (*vector.Vector, error)
- func FieldNumber[T number](vs []*vector.Vector, proc *process.Process) (*vector.Vector, error)
- func FieldString(vs []*vector.Vector, proc *process.Process) (*vector.Vector, error)
- func FloorDecimal128(vecs []*vector.Vector, proc *process.Process) (*vector.Vector, error)
- func FloorFloat64(vecs []*vector.Vector, proc *process.Process) (*vector.Vector, error)
- func FloorInt64(vecs []*vector.Vector, proc *process.Process) (*vector.Vector, error)
- func FloorStr(vecs []*vector.Vector, proc *process.Process) (*vector.Vector, error)
- func FloorUInt64(vecs []*vector.Vector, proc *process.Process) (*vector.Vector, error)
- func Format(vecs []*vector.Vector, proc *process.Process) (*vector.Vector, error)
- func FromUnixTimeFloat64(lv []*vector.Vector, proc *process.Process) (*vector.Vector, error)
- func FromUnixTimeFloat64Format(vs []*vector.Vector, proc *process.Process) (*vector.Vector, error)
- func FromUnixTimeInt64(lv []*vector.Vector, proc *process.Process) (*vector.Vector, error)
- func FromUnixTimeInt64Format(vs []*vector.Vector, proc *process.Process) (*vector.Vector, error)
- func FromUnixTimeUint64(lv []*vector.Vector, proc *process.Process) (*vector.Vector, error)
- func FromUnixTimeUint64Format(vs []*vector.Vector, proc *process.Process) (*vector.Vector, error)
- func Hash(vecs []*vector.Vector, proc *process.Process) (*vector.Vector, error)
- func JsonExtract(parameters []*vector.Vector, result vector.FunctionResultWrapper, ...) error
- func Lpad(vecs []*vector.Vector, proc *process.Process) (*vector.Vector, error)
- func MustTimestamp(loc *time.Location, s string) types.Timestamp
- func Pi(_ []*vector.Vector, _ *process.Process) (*vector.Vector, error)
- func RegularInstr(vectors []*vector.Vector, proc *process.Process) (*vector.Vector, error)
- func RegularLike(vectors []*vector.Vector, proc *process.Process) (*vector.Vector, error)
- func RegularReplace(vectors []*vector.Vector, proc *process.Process) (*vector.Vector, error)
- func RegularSubstr(vectors []*vector.Vector, proc *process.Process) (*vector.Vector, error)
- func RemoveFaultPoint(vecs []*vector.Vector, proc *process.Process) (*vector.Vector, error)
- func Replace(vectors []*vector.Vector, proc *process.Process) (*vector.Vector, error)
- func RoundFloat64(vecs []*vector.Vector, proc *process.Process) (*vector.Vector, error)
- func RoundInt64(vecs []*vector.Vector, proc *process.Process) (*vector.Vector, error)
- func RoundUint64(vecs []*vector.Vector, proc *process.Process) (*vector.Vector, error)
- func Rpad(origVecs []*vector.Vector, proc *process.Process) (*vector.Vector, error)
- func Serial(vectors []*vector.Vector, proc *process.Process) (*vector.Vector, error)
- func SerialWithSomeCols(vectors []*vector.Vector, proc *process.Process) (*vector.Vector, error)
- func SplitPart(vectors []*vector.Vector, proc *process.Process) (vec *vector.Vector, err error)
- func SubStrIndex(vecs []*vector.Vector, proc *process.Process) (*vector.Vector, error)
- func Substring(inputVecs []*vector.Vector, proc *process.Process) (*vector.Vector, error)
- func TimeAdd(vectors []*vector.Vector, proc *process.Process) (*vector.Vector, error)
- func TimeStampAdd(vectors []*vector.Vector, proc *process.Process) (*vector.Vector, error)
- func TimeStampDiff(vectors []*vector.Vector, proc *process.Process) (*vector.Vector, error)
- func TimeStampSub(vectors []*vector.Vector, proc *process.Process) (*vector.Vector, error)
- func TriggerFaultPoint(vecs []*vector.Vector, proc *process.Process) (*vector.Vector, error)
- func Trim(parameters []*vector.Vector, result vector.FunctionResultWrapper, ...) error
- func UTCTimestamp(_ []*vector.Vector, _ *process.Process) (*vector.Vector, error)
- func UUID(inputVecs []*vector.Vector, proc *process.Process) (*vector.Vector, error)
- func UnixTimestamp(lv []*vector.Vector, proc *process.Process) (*vector.Vector, error)
- func UnixTimestampVarcharToDecimal128(lv []*vector.Vector, proc *process.Process) (*vector.Vector, error)
- func UnixTimestampVarcharToFloat64(lv []*vector.Vector, proc *process.Process) (*vector.Vector, error)
- func UnixTimestampVarcharToInt64(lv []*vector.Vector, proc *process.Process) (*vector.Vector, error)
Constants ¶
const ( MaxSpacePerRowOfLpad = int64(16 * 1024 * 1024) ParameterSourceString = int(0) ParameterLengths = int(1) ParameterPadString = int(2) )
const UINT16_MAX = ^uint16(0)
const UUID_LENGTH uint32 = 36
Variables ¶
var (
Decimal128Zero = types.Decimal128_FromInt32(0)
)
var (
MaxPad int64
)
Functions ¶
func AddFaultPoint ¶ added in v0.6.0
func CeilDecimal128 ¶ added in v0.6.0
func CeilFloat64 ¶
func CeilUint64 ¶
func CurrentTimestamp ¶
a general round method is needed for timestamp fsp
func DateStringAdd ¶
func DateStringSub ¶
func DatetimeAdd ¶
func DatetimeSub ¶
func DisableFaultInjection ¶ added in v0.6.0
func EnableFaultInjection ¶ added in v0.6.0
func FieldNumber ¶ added in v0.7.0
func FieldString ¶ added in v0.7.0
func FloorDecimal128 ¶ added in v0.6.0
func FloorFloat64 ¶
floor function's evaluation for arguments: [float64]
func FloorInt64 ¶
floor function's evaluation for arguments: [int64]
func FloorUInt64 ¶
floor function's evaluation for arguments: [uint64]
func FromUnixTimeFloat64 ¶
func FromUnixTimeFloat64Format ¶ added in v0.6.0
func FromUnixTimeInt64 ¶ added in v0.6.0
func FromUnixTimeInt64Format ¶ added in v0.6.0
func FromUnixTimeUint64 ¶
func FromUnixTimeUint64Format ¶ added in v0.6.0
func JsonExtract ¶ added in v0.7.0
func MustTimestamp ¶ added in v0.6.0
func RegularInstr ¶ added in v0.6.0
func RegularLike ¶ added in v0.6.0
func RegularReplace ¶ added in v0.6.0
func RegularSubstr ¶ added in v0.6.0
func RemoveFaultPoint ¶ added in v0.6.0
func RoundFloat64 ¶
func RoundInt64 ¶
func RoundUint64 ¶
func Serial ¶ added in v0.6.0
Serial have a similar function named SerialWithCompacted in the index_util Serial func is used by users, the function make true when input vec have ten rows, the output vec is ten rows, when the vectors have null value, the output vec will set the row null for example: input vec is [[1, 1, 1], [2, 2, null], [3, 3, 3]] result vec is [serial(1, 2, 3), serial(1, 2, 3), null]
func SerialWithSomeCols ¶ added in v0.6.0
func SubStrIndex ¶ added in v0.7.0
func TimeStampAdd ¶
func TimeStampDiff ¶ added in v0.6.0
func TimeStampSub ¶
func TriggerFaultPoint ¶ added in v0.6.0
func UTCTimestamp ¶
func UnixTimestamp ¶
func UnixTimestampVarcharToDecimal128 ¶ added in v0.6.0
func UnixTimestampVarcharToFloat64 ¶ added in v0.6.0
Types ¶
This section is empty.
Source Files ¶
- ceil.go
- concat.go
- concat_ws.go
- current_timestamp.go
- date_add.go
- date_sub.go
- faultinj.go
- field.go
- floor.go
- format.go
- from_unixtime.go
- hash.go
- json_extract.go
- lpad.go
- math_multi.go
- pi.go
- regular_instr.go
- regular_like.go
- regular_replace.go
- regular_substr.go
- replace.go
- round.go
- rpad.go
- serial.go
- split_part.go
- substr.go
- substr_index.go
- timestampdiff.go
- trim.go
- unix_timestamp.go
- utc_timestamp.go
- uuid.go