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 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 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 FloorUInt64(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 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 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 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 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 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 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 SerialWithSomeCols ¶ added in v0.6.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
- floor.go
- from_unixtime.go
- hash.go
- lpad.go
- math_multi.go
- pi.go
- regular_instr.go
- regular_like.go
- regular_replace.go
- regular_substr.go
- round.go
- rpad.go
- serial.go
- substr.go
- timestampdiff.go
- unix_timestamp.go
- utc_timestamp.go
- uuid.go