Documentation
¶
Index ¶
- Variables
- func FanIn(seq Seq) int
- func IsThis(e Expr) bool
- func IsTopLevelField(e Expr) bool
- func TopLevelField(e Expr) (string, bool)
- type Agg
- type ArrayExpr
- type Assignment
- type BinaryExpr
- type Call
- type Case
- type Combine
- type CommitMetaScan
- type Conditional
- type Cut
- type Def
- type DeleteScan
- type Deleter
- type Dot
- type Drop
- type Entry
- type Explode
- type Expr
- type Field
- type FileScan
- type Filter
- type Fork
- type Func
- type Fuse
- type HTTPScan
- type Head
- type Join
- type LakeMetaScan
- type Lister
- type Literal
- type Load
- type MapCall
- type MapExpr
- type Merge
- type Op
- type Over
- type OverExpr
- type Pass
- type PoolMetaScan
- type PoolScan
- type Put
- type RecordElem
- type RecordExpr
- type RegexpMatch
- type RegexpSearch
- type Rename
- type Scatter
- type Scope
- type Search
- type Seq
- type SeqScan
- type SetExpr
- type Shape
- type Slicer
- type Sort
- type Spread
- type Summarize
- type Switch
- type Tail
- type This
- type Top
- type UnaryExpr
- type Uniq
- type Var
- type VectorElem
- type VectorValue
- type Yield
Constants ¶
This section is empty.
Variables ¶
View Source
var CommitMetas = map[string]struct{}{
"indexes": {},
"log": {},
"objects": {},
"partitions": {},
"rawlog": {},
"vectors": {},
}
View Source
var LakeMetas = map[string]struct{}{
"branches": {},
"index_rules": {},
"pools": {},
}
View Source
var PassOp = &Pass{Kind: "Pass"}
View Source
var PoolMetas = map[string]struct{}{
"branches": {},
}
Functions ¶
func IsTopLevelField ¶ added in v1.0.0
func TopLevelField ¶ added in v1.0.0
Types ¶
type Agg ¶
type ArrayExpr ¶
type ArrayExpr struct {
Kind string `json:"kind" unpack:""`
Elems []VectorElem `json:"elems"`
}
type Assignment ¶
type Assignment struct {
Kind string `json:"kind" unpack:""`
LHS Expr `json:"lhs"`
RHS Expr `json:"rhs"`
}
func (*Assignment) ExprDAG ¶
func (*Assignment) ExprDAG()
type BinaryExpr ¶
type BinaryExpr struct {
Kind string `json:"kind" unpack:""`
Op string `json:"op"`
LHS Expr `json:"lhs"`
RHS Expr `json:"rhs"`
}
func NewBinaryExpr ¶ added in v1.3.0
func NewBinaryExpr(op string, lhs, rhs Expr) *BinaryExpr
func (*BinaryExpr) ExprDAG ¶
func (*BinaryExpr) ExprDAG()
type Call ¶
type CommitMetaScan ¶ added in v1.8.0
type CommitMetaScan struct {
Kind string `json:"kind" unpack:""`
Pool ksuid.KSUID `json:"pool"`
Commit ksuid.KSUID `json:"commit"`
Meta string `json:"meta"`
Tap bool `json:"tap"`
KeyPruner Expr `json:"key_pruner"`
}
func (*CommitMetaScan) OpNode ¶ added in v1.8.0
func (*CommitMetaScan) OpNode()
type Conditional ¶
type Conditional struct {
Kind string `json:"kind" unpack:""`
Cond Expr `json:"cond"`
Then Expr `json:"then"`
Else Expr `json:"else"`
}
func (*Conditional) ExprDAG ¶
func (*Conditional) ExprDAG()
type Cut ¶
type Cut struct {
Kind string `json:"kind" unpack:""`
Args []Assignment `json:"args"`
Quiet bool `json:"quiet"`
}
type DeleteScan ¶ added in v1.8.0
type DeleteScan struct {
Kind string `json:"kind" unpack:""`
ID ksuid.KSUID `json:"id"`
Commit ksuid.KSUID `json:"commit"`
}
func (*DeleteScan) OpNode ¶ added in v1.8.0
func (*DeleteScan) OpNode()
type Deleter ¶ added in v1.8.0
type Dot ¶
type Explode ¶
type FileScan ¶ added in v1.8.0
type Func ¶ added in v1.4.0
type HTTPScan ¶ added in v1.8.0
type Join ¶
type LakeMetaScan ¶ added in v1.8.0
func (*LakeMetaScan) OpNode ¶ added in v1.8.0
func (*LakeMetaScan) OpNode()
type Lister ¶ added in v1.8.0
type Load ¶ added in v1.8.0
type MapCall ¶ added in v1.11.0
type Merge ¶
type Op ¶
type Op interface {
OpNode()
}
func UnmarshalOp ¶ added in v1.8.0
UnmarshalOp transforms a JSON representation of an operator into an Op.
type Over ¶ added in v1.0.0
type OverExpr ¶ added in v1.1.0
type PoolMetaScan ¶ added in v1.8.0
type PoolMetaScan struct {
Kind string `json:"kind" unpack:""`
ID ksuid.KSUID `json:"id"`
Meta string `json:"meta"`
}
func (*PoolMetaScan) OpNode ¶ added in v1.8.0
func (*PoolMetaScan) OpNode()
type PoolScan ¶ added in v1.8.0
type Put ¶
type Put struct {
Kind string `json:"kind" unpack:""`
Args []Assignment `json:"args"`
}
type RecordElem ¶ added in v1.0.0
type RecordElem interface {
// contains filtered or unexported methods
}
type RecordExpr ¶
type RecordExpr struct {
Kind string `json:"kind" unpack:""`
Elems []RecordElem `json:"elems"`
}
func (*RecordExpr) ExprDAG ¶
func (*RecordExpr) ExprDAG()
type RegexpMatch ¶
type RegexpMatch struct {
Kind string `json:"kind" unpack:""`
Pattern string `json:"pattern"`
Expr Expr `json:"expr"`
}
func (*RegexpMatch) ExprDAG ¶
func (*RegexpMatch) ExprDAG()
type RegexpSearch ¶
type RegexpSearch struct {
Kind string `json:"kind" unpack:""`
Pattern string `json:"pattern"`
Expr Expr `json:"expr"`
}
func (*RegexpSearch) ExprDAG ¶
func (*RegexpSearch) ExprDAG()
type Rename ¶
type Rename struct {
Kind string `json:"kind" unpack:""`
Args []Assignment `json:"args"`
}
type Scope ¶ added in v1.8.0
type Search ¶
type SeqScan ¶ added in v1.8.0
type SetExpr ¶
type SetExpr struct {
Kind string `json:"kind" unpack:""`
Elems []VectorElem `json:"elems"`
}
type Sort ¶
type Summarize ¶
type Summarize struct {
Kind string `json:"kind" unpack:""`
Limit int `json:"limit"`
Keys []Assignment `json:"keys"`
Aggs []Assignment `json:"aggs"`
InputSortDir int `json:"input_sort_dir,omitempty"`
PartialsIn bool `json:"partials_in,omitempty"`
PartialsOut bool `json:"partials_out,omitempty"`
}
type Switch ¶
type Top ¶
type UnaryExpr ¶
type Var ¶ added in v1.0.0
type VectorElem ¶ added in v1.2.0
type VectorElem interface {
// contains filtered or unexported methods
}
type VectorValue ¶ added in v1.2.0
Click to show internal directories.
Click to hide internal directories.