Documentation
¶
Index ¶
- Constants
- func DecodeBatch(data []byte) (*batch.Batch, []byte, error)
- func DecodeBatchWithProcess(data []byte, proc *process.Process) (*batch.Batch, []byte, error)
- func DecodeExtend(data []byte) (extend.Extend, []byte, error)
- func DecodeInstruction(data []byte) (vm.Instruction, []byte, error)
- func DecodeInstructions(data []byte) (vm.Instructions, []byte, error)
- func DecodeRing(data []byte) (ring.Ring, []byte, error)
- func DecodeRingWithProcess(data []byte, proc *process.Process) (ring.Ring, []byte, error)
- func DecodeVector(data []byte) (*vector.Vector, []byte, error)
- func EncodeBatch(bat *batch.Batch, buf *bytes.Buffer) error
- func EncodeExtend(e extend.Extend, buf *bytes.Buffer) error
- func EncodeInstruction(in vm.Instruction, buf *bytes.Buffer) error
- func EncodeInstructions(ins vm.Instructions, buf *bytes.Buffer) error
- func EncodeRing(r ring.Ring, buf *bytes.Buffer) error
- func EncodeScope(s Scope, buf *bytes.Buffer) error
- func EncodeVector(v *vector.Vector, buf *bytes.Buffer) error
- func UntransferTransformArg(arg TransformArgument) *transform.Argument
- type DedupArgument
- type Field
- type JoinArgument
- type LimitArgument
- type MergeArgument
- type Node
- type OffsetArgument
- type OplusArgument
- type OrderArgument
- type OutputArgument
- type PlusArgument
- type ProjectionArgument
- type RestrictArgument
- type Scope
- type Source
- type TimesArgument
- type TopArgument
- type TransformArgument
- type Transformer
- type UntransformArgument
Constants ¶
View Source
const ( Attr = iota Unary Binary Multi Paren Func Star Value )
View Source
const ( DefaultRing = iota AvgRing CountRing StarCountRing ApproxCountDistinctRing // Max MaxInt8Ring MaxInt32Ring MaxDateRing MaxInt16Ring MaxInt64Ring MaxDatetimeRing MaxUInt8Ring MaxUInt16Ring MaxUInt32Ring MaxUInt64Ring MaxFloat32Ring MaxFloat64Ring MaxStrRing // Min MinInt8Ring MinInt32Ring MinDateRing MinInt16Ring MinInt64Ring MinDatetimeRing MinUInt8Ring MinUInt16Ring MinUInt32Ring MinUInt64Ring MinFloat32Ring MinFloat64Ring MinStrRing // Sum SumIntRing SumUIntRing SumFloatRing // Variance VarianceRing // BitAnd BitAndNumericRing //Bitor BitOrRing // BitXor BitXorRing // StdDevPop StdDevPopRing )
Variables ¶
This section is empty.
Functions ¶
func DecodeBatchWithProcess ¶
func DecodeInstruction ¶
func DecodeInstruction(data []byte) (vm.Instruction, []byte, error)
func DecodeInstructions ¶
func DecodeInstructions(data []byte) (vm.Instructions, []byte, error)
func DecodeRingWithProcess ¶
func EncodeInstruction ¶
func EncodeInstruction(in vm.Instruction, buf *bytes.Buffer) error
func EncodeInstructions ¶
func EncodeInstructions(ins vm.Instructions, buf *bytes.Buffer) error
func UntransferTransformArg ¶
func UntransferTransformArg(arg TransformArgument) *transform.Argument
Types ¶
type DedupArgument ¶
type DedupArgument struct {
}
type JoinArgument ¶
type LimitArgument ¶
type MergeArgument ¶
type MergeArgument struct {
}
type OffsetArgument ¶
type OplusArgument ¶
type OplusArgument struct {
Typ int
}
type OrderArgument ¶
type OrderArgument struct {
Fs []Field
}
type OutputArgument ¶
type OutputArgument struct {
Attrs []string
}
type PlusArgument ¶
type PlusArgument struct {
Typ int
}
type ProjectionArgument ¶
type RestrictArgument ¶
type RestrictArgument struct {
Attrs []string
}
type Scope ¶
type TimesArgument ¶
type TopArgument ¶
type TransformArgument ¶
type TransformArgument struct {
IsNull bool
Typ int
IsMerge bool
FreeVars []string
HasRestrict bool
Restrict RestrictArgument
HasProj bool
Projection ProjectionArgument
BoundVars []Transformer
}
func TransferTransformArg ¶
func TransferTransformArg(arg *transform.Argument) TransformArgument
type UntransformArgument ¶
Click to show internal directories.
Click to hide internal directories.