parser

type AliasAST struct {
	Expr  Expression
	Alias string
}

type AliasedStreamWindowAST struct {
	StreamWindowAST
	Alias string
}

type ArrayAST struct {
	ExpressionsAST
}

type BinaryKeyword int

type BinaryOpAST struct {
	Op    Operator
	Left  Expression
	Right Expression
}

type BoolLiteral struct {
	Value bool
}

type ConditionCaseAST struct {
	Checks []WhenThenPairAST
	Else   Expression
}

type CreateSinkStmt struct {
	Name StreamIdentifier
	Type SourceSinkType
	SourceSinkSpecsAST
}

type CreateSourceStmt struct {
	Paused BinaryKeyword
	Name   StreamIdentifier
	Type   SourceSinkType
	SourceSinkSpecsAST
}

type CreateStateStmt struct {
	Name StreamIdentifier
	Type SourceSinkType
	SourceSinkSpecsAST
}

type CreateStreamAsSelectStmt struct {
	Name   StreamIdentifier
	Select SelectStmt
}

type CreateStreamAsSelectUnionStmt struct {
	Name StreamIdentifier
	SelectUnionStmt
}

type DropSinkStmt struct {
	Sink StreamIdentifier
}

type DropSourceStmt struct {
	Source StreamIdentifier
}

type DropStateStmt struct {
	State StreamIdentifier
}

type DropStreamStmt struct {
	Stream StreamIdentifier
}

type Emitter int

type EmitterAST struct {
	EmitterType    Emitter
	EmitterOptions []interface{}
}

type EmitterLimit struct {
	Limit int64
}

type EmitterSampling struct {
	Value float64
	Type  EmitterSamplingType
}

type EmitterSamplingType int

type EvalStmt struct {
	Expr  Expression
	Input *MapAST
}

type Expression interface {
	ReferencedRelations() map[string]bool
	RenameReferencedRelation(string, string) Expression
	Foldable() bool
	String() string
}

type ExpressionCaseAST struct {
	Expr Expression
	ConditionCaseAST
}

type ExpressionsAST struct {
	Expressions []Expression
}

type FilterAST struct {
	Filter Expression
}

type FloatLiteral struct {
	Value float64
}

type FuncAppAST struct {
	Function FuncName
	ExpressionsAST
	Ordering []SortedExpressionAST
}

type FuncName string

type GroupingAST struct {
	GroupList []Expression
}

type HavingAST struct {
	Having Expression
}

type Identifier string

type InsertIntoFromStmt struct {
	Sink  StreamIdentifier
	Input StreamIdentifier
}

type IntervalAST struct {
	FloatLiteral
	Unit IntervalUnit
}

type IntervalUnit int

type KeyValuePairAST struct {
	Key   string
	Value Expression
}

type LoadStateOrCreateStmt struct {
	Name        StreamIdentifier
	Type        SourceSinkType
	Tag         string
	LoadSpecs   SourceSinkSpecsAST
	CreateSpecs SourceSinkSpecsAST
}

type LoadStateStmt struct {
	Name StreamIdentifier
	Type SourceSinkType
	Tag  string
	SourceSinkSpecsAST
}

type MapAST struct {
	Entries []KeyValuePairAST
}

type MetaInformation int

type Missing struct {
}

type NullLiteral struct {
}

type NumericLiteral struct {
	Value int64
}

type Operator int

type ParsedComponent struct {
	// contains filtered or unexported fields
}

type PauseSourceStmt struct {
	Source StreamIdentifier
}

type ProjectionsAST struct {
	Projections []Expression
}

type Raw struct {
	Expr string
}

type ResumeSourceStmt struct {
	Source StreamIdentifier
}

type RewindSourceStmt struct {
	Source StreamIdentifier
}

type RowMeta struct {
	Relation string
	MetaType MetaInformation
}

type RowValue struct {
	Relation string
	Column   string
}

type SaveStateStmt struct {
	Name StreamIdentifier
	Tag  string
}

type SelectStmt struct {
	EmitterAST
	ProjectionsAST
	WindowedFromAST
	FilterAST
	GroupingAST
	HavingAST
}

type SelectUnionStmt struct {
	Selects []SelectStmt
}

type SheddingOption int

type SortedExpressionAST struct {
	Expr      Expression
	Ascending BinaryKeyword
}

type SourceSinkParamAST struct {
	Key   SourceSinkParamKey
	Value data.Value
}

type SourceSinkParamKey string

type SourceSinkSpecsAST struct {
	Params []SourceSinkParamAST
}

type SourceSinkType string

type Stream struct {
	Type   StreamType
	Name   string
	Params []Expression
}

type StreamIdentifier string

type StreamType int

type StreamWindowAST struct {
	Stream
	IntervalAST
	Capacity int64
	Shedding SheddingOption
}

type StringLiteral struct {
	Value string
}

type Type int

type TypeCastAST struct {
	Expr   Expression
	Target Type
}

type UnaryOpAST struct {
	Op   Operator
	Expr Expression
}

type UpdateSinkStmt struct {
	Name StreamIdentifier
	SourceSinkSpecsAST
}

type UpdateSourceStmt struct {
	Name StreamIdentifier
	SourceSinkSpecsAST
}

type UpdateStateStmt struct {
	Name StreamIdentifier
	SourceSinkSpecsAST
}

type WhenThenPairAST struct {
	When Expression
	Then Expression
}

type Wildcard struct {
	Relation string
}

type WindowedFromAST struct {
	Relations []AliasedStreamWindowAST
}