multi

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 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, _ *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 FloorFloat64(vecs []*vector.Vector, proc *process.Process) (*vector.Vector, error)
• func FloorFloat64Int64(vecs []*vector.Vector, proc *process.Process) (*vector.Vector, error)
• func FloorInt64(vecs []*vector.Vector, proc *process.Process) (*vector.Vector, error)
• func FloorInt64Int64(vecs []*vector.Vector, proc *process.Process) (*vector.Vector, error)
• func FloorUInt64(vecs []*vector.Vector, proc *process.Process) (*vector.Vector, error)
• func FloorUInt64Int64(vecs []*vector.Vector, proc *process.Process) (*vector.Vector, error)
• func FromUnixTime(lv []*vector.Vector, proc *process.Process) (*vector.Vector, error)
• func FromUnixTimeFloat64(lv []*vector.Vector, proc *process.Process) (*vector.Vector, error)
• func FromUnixTimeUint64(lv []*vector.Vector, proc *process.Process) (*vector.Vector, error)
• func Lpad(vecs []*vector.Vector, proc *process.Process) (*vector.Vector, error)
• func MustDatetimeMe(s string) types.Datetime
• func Pi(_ []*vector.Vector, _ *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 Substring(inputVecs []*vector.Vector, proc *process.Process) (*vector.Vector, error)
• func TimeStampAdd(vectors []*vector.Vector, proc *process.Process) (*vector.Vector, error)
• func TimeStampSub(vectors []*vector.Vector, proc *process.Process) (*vector.Vector, error)
• func UTCTimestamp(_ []*vector.Vector, _ *process.Process) (*vector.Vector, error)
• func UnixTimestamp(lv []*vector.Vector, proc *process.Process) (*vector.Vector, error)
• func UnixTimestampVarchar(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)

Variables

var (
	MaxPad int64
)

Functions

func CeilFloat64

func CeilFloat64(vecs []*vector.Vector, proc *process.Process) (*vector.Vector, error)

func CeilInt64

func CeilInt64(vecs []*vector.Vector, proc *process.Process) (*vector.Vector, error)

func CeilUint64

func CeilUint64(vecs []*vector.Vector, proc *process.Process) (*vector.Vector, error)

func Concat

func Concat(vectors []*vector.Vector, proc *process.Process) (*vector.Vector, error)

func Concat_ws

func Concat_ws(vectors []*vector.Vector, proc *process.Process) (*vector.Vector, error)

todo(broccoli): revise this, maybe rewrite this? at least clean up the logic

func CurrentTimestamp

func CurrentTimestamp(vectors []*vector.Vector, _ *process.Process) (*vector.Vector, error)

a general round method is needed for timestamp fsp

func DateAdd

func DateAdd(vectors []*vector.Vector, proc *process.Process) (*vector.Vector, error)

func DateStringAdd

func DateStringAdd(vectors []*vector.Vector, proc *process.Process) (*vector.Vector, error)

func DateStringSub

func DateStringSub(vectors []*vector.Vector, proc *process.Process) (*vector.Vector, error)

func DateSub

func DateSub(vectors []*vector.Vector, proc *process.Process) (*vector.Vector, error)

func DatetimeAdd

func DatetimeAdd(vectors []*vector.Vector, proc *process.Process) (*vector.Vector, error)

func DatetimeSub

func DatetimeSub(vectors []*vector.Vector, proc *process.Process) (*vector.Vector, error)

func FloorFloat64

func FloorFloat64(vecs []*vector.Vector, proc *process.Process) (*vector.Vector, error)

floor function's evaluation for arguments: [float64]

func FloorFloat64Int64

func FloorFloat64Int64(vecs []*vector.Vector, proc *process.Process) (*vector.Vector, error)

floor function's evaluation for arguments: [float64, int64]

func FloorInt64

func FloorInt64(vecs []*vector.Vector, proc *process.Process) (*vector.Vector, error)

floor function's evaluation for arguments: [int64]

func FloorInt64Int64

func FloorInt64Int64(vecs []*vector.Vector, proc *process.Process) (*vector.Vector, error)

floor function's evaluation for arguments: [int64, int64]

func FloorUInt64

func FloorUInt64(vecs []*vector.Vector, proc *process.Process) (*vector.Vector, error)

floor function's evaluation for arguments: [uint64]

func FloorUInt64Int64

func FloorUInt64Int64(vecs []*vector.Vector, proc *process.Process) (*vector.Vector, error)

floor function's evaluation for arguments: [uint64, int64]

func FromUnixTime

func FromUnixTime(lv []*vector.Vector, proc *process.Process) (*vector.Vector, error)

func FromUnixTimeFloat64

func FromUnixTimeFloat64(lv []*vector.Vector, proc *process.Process) (*vector.Vector, error)

func FromUnixTimeUint64

func FromUnixTimeUint64(lv []*vector.Vector, proc *process.Process) (*vector.Vector, error)

func Lpad

func Lpad(vecs []*vector.Vector, proc *process.Process) (*vector.Vector, error)

First Parameter: source string Second Parameter: length Third Parameter: pad string

func MustDatetimeMe

func MustDatetimeMe(s string) types.Datetime

func Pi

func Pi(_ []*vector.Vector, _ *process.Process) (*vector.Vector, error)

func RoundFloat64

func RoundFloat64(vecs []*vector.Vector, proc *process.Process) (*vector.Vector, error)

func RoundInt64

func RoundInt64(vecs []*vector.Vector, proc *process.Process) (*vector.Vector, error)

func RoundUint64

func RoundUint64(vecs []*vector.Vector, proc *process.Process) (*vector.Vector, error)

func Rpad

func Rpad(origVecs []*vector.Vector, proc *process.Process) (*vector.Vector, error)

func Substring

func Substring(inputVecs []*vector.Vector, proc *process.Process) (*vector.Vector, error)

func TimeStampAdd

func TimeStampAdd(vectors []*vector.Vector, proc *process.Process) (*vector.Vector, error)

func TimeStampSub

func TimeStampSub(vectors []*vector.Vector, proc *process.Process) (*vector.Vector, error)

func UTCTimestamp

func UTCTimestamp(_ []*vector.Vector, _ *process.Process) (*vector.Vector, error)

func UnixTimestamp

func UnixTimestamp(lv []*vector.Vector, proc *process.Process) (*vector.Vector, error)

func UnixTimestampVarchar

func UnixTimestampVarchar(lv []*vector.Vector, proc *process.Process) (*vector.Vector, error)