Versions in this module Expand all Collapse all v0 v0.4.1 Mar 11, 2016 Changes in this version + const UnspecifiedCapacity + func New() *bqlParser + type AliasAST struct + Alias string + Expr Expression + func (a AliasAST) Foldable() bool + func (a AliasAST) ReferencedRelations() map[string]bool + func (a AliasAST) RenameReferencedRelation(from, to string) Expression + func (a AliasAST) String() string + type AliasedStreamWindowAST struct + Alias string + type ArrayAST struct + func (a ArrayAST) Foldable() bool + func (a ArrayAST) ReferencedRelations() map[string]bool + func (a ArrayAST) RenameReferencedRelation(from, to string) Expression + func (a ArrayAST) String() string + type BinaryKeyword int + const No + const UnspecifiedKeyword + const Yes + func (k BinaryKeyword) String() string + type BinaryOpAST struct + Left Expression + Op Operator + Right Expression + func (b BinaryOpAST) Foldable() bool + func (b BinaryOpAST) ReferencedRelations() map[string]bool + func (b BinaryOpAST) RenameReferencedRelation(from, to string) Expression + func (b BinaryOpAST) String() string + type BoolLiteral struct + Value bool + func NewBoolLiteral(b bool) BoolLiteral + func (l BoolLiteral) Foldable() bool + func (l BoolLiteral) ReferencedRelations() map[string]bool + func (l BoolLiteral) RenameReferencedRelation(from, to string) Expression + func (l BoolLiteral) String() string + type ConditionCaseAST struct + Checks []WhenThenPairAST + Else Expression + func (c ConditionCaseAST) Foldable() bool + func (c ConditionCaseAST) ReferencedRelations() map[string]bool + func (c ConditionCaseAST) RenameReferencedRelation(from, to string) Expression + func (c ConditionCaseAST) String() string + type CreateSinkStmt struct + Name StreamIdentifier + Type SourceSinkType + func (s CreateSinkStmt) String() string + type CreateSourceStmt struct + Name StreamIdentifier + Paused BinaryKeyword + Type SourceSinkType + func (s CreateSourceStmt) String() string + type CreateStateStmt struct + Name StreamIdentifier + Type SourceSinkType + func (s CreateStateStmt) String() string + type CreateStreamAsSelectStmt struct + Name StreamIdentifier + Select SelectStmt + func (s CreateStreamAsSelectStmt) String() string + type CreateStreamAsSelectUnionStmt struct + Name StreamIdentifier + func (s CreateStreamAsSelectUnionStmt) String() string + type DropSinkStmt struct + Sink StreamIdentifier + func (s DropSinkStmt) String() string + type DropSourceStmt struct + Source StreamIdentifier + func (s DropSourceStmt) String() string + type DropStateStmt struct + State StreamIdentifier + func (s DropStateStmt) String() string + type DropStreamStmt struct + Stream StreamIdentifier + func (s DropStreamStmt) String() string + type Emitter int + const Dstream + const Istream + const Rstream + const UnspecifiedEmitter + func (e Emitter) String() string + type EmitterAST struct + EmitterOptions []interface{} + EmitterType Emitter + type EmitterLimit struct + Limit int64 + type EmitterSampling struct + Type EmitterSamplingType + Value float64 + type EmitterSamplingType int + const CountBasedSampling + const RandomizedSampling + const TimeBasedSampling + const UnspecifiedSamplingType + func (est EmitterSamplingType) String() string + type EvalStmt struct + Expr Expression + Input *MapAST + func (s EvalStmt) String() string + type Expression interface + Foldable func() bool + ReferencedRelations func() map[string]bool + RenameReferencedRelation func(string, string) Expression + String func() string + type ExpressionCaseAST struct + Expr Expression + func (c ExpressionCaseAST) Foldable() bool + func (c ExpressionCaseAST) ReferencedRelations() map[string]bool + func (c ExpressionCaseAST) RenameReferencedRelation(from, to string) Expression + func (c ExpressionCaseAST) String() string + type ExpressionsAST struct + Expressions []Expression + type FilterAST struct + Filter Expression + type FloatLiteral struct + Value float64 + func NewFloatLiteral(s string) FloatLiteral + func (l FloatLiteral) Foldable() bool + func (l FloatLiteral) ReferencedRelations() map[string]bool + func (l FloatLiteral) RenameReferencedRelation(from, to string) Expression + func (l FloatLiteral) String() string + type FuncAppAST struct + Function FuncName + Ordering []SortedExpressionAST + func (f FuncAppAST) Foldable() bool + func (f FuncAppAST) ReferencedRelations() map[string]bool + func (f FuncAppAST) RenameReferencedRelation(from, to string) Expression + func (f FuncAppAST) String() string + type FuncName string + type GroupingAST struct + GroupList []Expression + type HavingAST struct + Having Expression + type Identifier string + type InsertIntoFromStmt struct + Input StreamIdentifier + Sink StreamIdentifier + func (s InsertIntoFromStmt) String() string + type IntervalAST struct + Unit IntervalUnit + type IntervalUnit int + const Milliseconds + const Seconds + const Tuples + const UnspecifiedIntervalUnit + func (i IntervalUnit) String() string + type KeyValuePairAST struct + Key string + Value Expression + type LoadStateOrCreateStmt struct + CreateSpecs SourceSinkSpecsAST + LoadSpecs SourceSinkSpecsAST + Name StreamIdentifier + Tag string + Type SourceSinkType + func (s LoadStateOrCreateStmt) String() string + type LoadStateStmt struct + Name StreamIdentifier + Tag string + Type SourceSinkType + func (s LoadStateStmt) String() string + type MapAST struct + Entries []KeyValuePairAST + func (m MapAST) Foldable() bool + func (m MapAST) ReferencedRelations() map[string]bool + func (m MapAST) RenameReferencedRelation(from, to string) Expression + func (m MapAST) String() string + type MetaInformation int + const NowMeta + const TimestampMeta + const UnknownMeta + func (m MetaInformation) String() string + type Missing struct + func NewMissing() Missing + func (l Missing) Foldable() bool + func (l Missing) ReferencedRelations() map[string]bool + func (l Missing) RenameReferencedRelation(from, to string) Expression + func (l Missing) String() string + type NullLiteral struct + func NewNullLiteral() NullLiteral + func (l NullLiteral) Foldable() bool + func (l NullLiteral) ReferencedRelations() map[string]bool + func (l NullLiteral) RenameReferencedRelation(from, to string) Expression + func (l NullLiteral) String() string + type NumericLiteral struct + Value int64 + func NewNumericLiteral(s string) NumericLiteral + func (l NumericLiteral) Foldable() bool + func (l NumericLiteral) ReferencedRelations() map[string]bool + func (l NumericLiteral) RenameReferencedRelation(from, to string) Expression + func (l NumericLiteral) String() string + type Operator int + const And + const Concat + const Divide + const Equal + const Greater + const GreaterOrEqual + const Is + const IsNot + const Less + const LessOrEqual + const Minus + const Modulo + const Multiply + const Not + const NotEqual + const Or + const Plus + const UnaryMinus + const UnknownOperator + func (o Operator) String() string + type ParsedComponent struct + type PauseSourceStmt struct + Source StreamIdentifier + func (s PauseSourceStmt) String() string + type ProjectionsAST struct + Projections []Expression + type Raw struct + Expr string + func NewRaw(s string) Raw + type ResumeSourceStmt struct + Source StreamIdentifier + func (s ResumeSourceStmt) String() string + type RewindSourceStmt struct + Source StreamIdentifier + func (s RewindSourceStmt) String() string + type RowMeta struct + MetaType MetaInformation + Relation string + func NewRowMeta(s string, t MetaInformation) RowMeta + func (rm RowMeta) Foldable() bool + func (rm RowMeta) ReferencedRelations() map[string]bool + func (rm RowMeta) RenameReferencedRelation(from, to string) Expression + func (rm RowMeta) String() string + type RowValue struct + Column string + Relation string + func NewRowValue(s string) RowValue + func (rv RowValue) Foldable() bool + func (rv RowValue) ReferencedRelations() map[string]bool + func (rv RowValue) RenameReferencedRelation(from, to string) Expression + func (rv RowValue) String() string + type SaveStateStmt struct + Name StreamIdentifier + Tag string + func (s SaveStateStmt) String() string + type SelectStmt struct + func (s SelectStmt) String() string + type SelectUnionStmt struct + Selects []SelectStmt + func (s SelectUnionStmt) String() string + type SheddingOption int + const DropNewest + const DropOldest + const UnspecifiedSheddingOption + const Wait + func (t SheddingOption) String() string + type SortedExpressionAST struct + Ascending BinaryKeyword + Expr Expression + func (s SortedExpressionAST) Foldable() bool + func (s SortedExpressionAST) ReferencedRelations() map[string]bool + func (s SortedExpressionAST) RenameReferencedRelation(from, to string) Expression + func (s SortedExpressionAST) String() string + type SourceSinkParamAST struct + Key SourceSinkParamKey + Value data.Value + type SourceSinkParamKey string + type SourceSinkSpecsAST struct + Params []SourceSinkParamAST + type SourceSinkType string + type Stream struct + Name string + Params []Expression + Type StreamType + func NewStream(s string) Stream + type StreamIdentifier string + type StreamType int + const ActualStream + const UDSFStream + const UnknownStreamType + func (st StreamType) String() string + type StreamWindowAST struct + Capacity int64 + Shedding SheddingOption + type StringLiteral struct + Value string + func NewStringLiteral(s string) StringLiteral + func (l StringLiteral) Foldable() bool + func (l StringLiteral) ReferencedRelations() map[string]bool + func (l StringLiteral) RenameReferencedRelation(from, to string) Expression + func (l StringLiteral) String() string + type Type int + const Array + const Blob + const Bool + const Float + const Int + const Map + const String + const Timestamp + const UnknownType + func (t Type) String() string + type TypeCastAST struct + Expr Expression + Target Type + func (u TypeCastAST) Foldable() bool + func (u TypeCastAST) ReferencedRelations() map[string]bool + func (u TypeCastAST) RenameReferencedRelation(from, to string) Expression + func (u TypeCastAST) String() string + type UnaryOpAST struct + Expr Expression + Op Operator + func (u UnaryOpAST) Foldable() bool + func (u UnaryOpAST) ReferencedRelations() map[string]bool + func (u UnaryOpAST) RenameReferencedRelation(from, to string) Expression + func (u UnaryOpAST) String() string + type UpdateSinkStmt struct + Name StreamIdentifier + func (s UpdateSinkStmt) String() string + type UpdateSourceStmt struct + Name StreamIdentifier + func (s UpdateSourceStmt) String() string + type UpdateStateStmt struct + Name StreamIdentifier + func (s UpdateStateStmt) String() string + type WhenThenPairAST struct + Then Expression + When Expression + type Wildcard struct + Relation string + func NewWildcard(relation string) Wildcard + func (w Wildcard) Foldable() bool + func (w Wildcard) ReferencedRelations() map[string]bool + func (w Wildcard) RenameReferencedRelation(from, to string) Expression + func (w Wildcard) String() string + type WindowedFromAST struct + Relations []AliasedStreamWindowAST v0.4.0 Feb 19, 2016 v0.3.1 Oct 30, 2015 v0.3.0 Sep 4, 2015 v0.2.0 Aug 17, 2015 v0.1.0 Aug 3, 2015
Go to main page