Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DependencyPlanner ¶
type DependencyPlanner interface {
Plan() error
GetBldr() primitivebuilder.Builder
GetSelectCtx() drm.PreparedStatementCtx
WithPrepStmtOffset(offset int) DependencyPlanner
WithElideRead(isElideRead bool) DependencyPlanner
}
func NewStandardDependencyPlanner ¶
func NewStandardDependencyPlanner( annotatedAST annotatedast.AnnotatedAst, handlerCtx handler.HandlerContext, dataflowCollection dataflow.Collection, colRefs parserutil.ColTableMap, rewrittenWhere *sqlparser.Where, sqlStatement *sqlparser.Select, tblz taxonomy.TblMap, primitiveComposer primitivecomposer.PrimitiveComposer, tcc internaldto.TxnControlCounters, tccSetAheadOfTime bool, ) (DependencyPlanner, error)
type StreamDependecyCollection ¶ added in v0.5.692
type StreamDependecyCollection interface {
// Add adds a stream to the collection
// departingID is the ID of the stream that is departing
// arrivingID is the ID of the stream that is arriving
// stream is the stream that is being added
Add(departingID int64, arrivingID int64, stream streaming.MapStream)
GetArriving(int64) streaming.MapStreamCollection
GetDeparting(int64) streaming.MapStreamCollection
}
func NewStreamDependecyCollection ¶ added in v0.5.692
func NewStreamDependecyCollection() StreamDependecyCollection
Source Files
Click to show internal directories.
Click to hide internal directories.