Documentation
¶
Index ¶
- func NewDescribeMethodInstructionExecutor(handlerCtx handler.HandlerContext, rsc formulation.Resource, methodName string, ...) internaldto.ExecutorOutput
- func NewDescribeTableInstructionExecutor(handlerCtx handler.HandlerContext, tbl tablemetadata.ExtendedTableMetadata, ...) internaldto.ExecutorOutput
- func NewDescribeViewInstructionExecutor(handlerCtx handler.HandlerContext, tbl tablemetadata.ExtendedTableMetadata, ...) internaldto.ExecutorOutput
- func NewInsertableValsPrimitive(handlerCtx handler.HandlerContext, vals map[int]map[int]interface{}) (primitive.IPrimitive, error)
- func NewLocalSelectExecutor(handlerCtx handler.HandlerContext, node *sqlparser.Select, ...) (primitive.IPrimitive, error)
- func NewShowInstructionExecutor(node *sqlparser.Show, prov provider.IProvider, ...) internaldto.ExecutorOutput
- func NewUpdateableValsPrimitive(handlerCtx handler.HandlerContext, vals map[*sqlparser.ColName]interface{}) (primitive.IPrimitive, error)
- type Builder
- func NewDDL(bldrInput builder_input.BuilderInput) (Builder, error)
- func NewDataflowGraphBuilder(graph primitivegraph.PrimitiveGraphHolder, ...) Builder
- func NewDelete(graph primitivegraph.PrimitiveGraphHolder, handlerCtx handler.HandlerContext, ...) Builder
- func NewDependencySubDAGBuilder(graph primitivegraph.PrimitiveGraphHolder, dependencyBuilders []Builder, ...) Builder
- func NewDependentMultipleAcquireAndSelect(graph primitivegraph.PrimitiveGraphHolder, acquireBuilders []Builder, ...) Builder
- func NewDiamondBuilder(parent Builder, children []Builder, ...) Builder
- func NewExec(graph primitivegraph.PrimitiveGraphHolder, handlerCtx handler.HandlerContext, ...) Builder
- func NewExplainBuilder(graph primitivegraph.PrimitiveGraphHolder, ...) Builder
- func NewInsertOrUpdate(bldrInput builder_input.BuilderInput) Builder
- func NewNativeSelect(graph primitivegraph.PrimitiveGraphHolder, handlerCtx handler.HandlerContext, ...) Builder
- func NewNopBuilder(graph primitivegraph.PrimitiveGraphHolder, ...) Builder
- func NewRawNativeExec(graph primitivegraph.PrimitiveGraphHolder, handlerCtx handler.HandlerContext, ...) Builder
- func NewRawNativeSelect(graph primitivegraph.PrimitiveGraphHolder, handlerCtx handler.HandlerContext, ...) Builder
- func NewRefreshMaterializedView(bldrInput builder_input.BuilderInput) (Builder, error)
- func NewSQLDataSourceSingleSelectAcquire(graph primitivegraph.PrimitiveGraphHolder, handlerCtx handler.HandlerContext, ...) Builder
- func NewSingleAcquireAndSelect(bldrInput builder_input.BuilderInput, insertCtx drm.PreparedStatementCtx, ...) Builder
- func NewSingleSelect(graph primitivegraph.PrimitiveGraphHolder, handlerCtx handler.HandlerContext, ...) Builder
- func NewSingleSelectAcquire(graphHolder primitivegraph.PrimitiveGraphHolder, ...) Builder
- func NewSubTreeBuilder(children []Builder) Builder
- func NewUnion(graph primitivegraph.PrimitiveGraphHolder, handlerCtx handler.HandlerContext, ...) Builder
- type DataflowGraphBuilder
- type Delete
- type DependencySubDAGBuilder
- type DependentMultipleAcquireAndSelect
- type DiamondBuilder
- type Exec
- type ExplainBuilder
- type GraphQLSingleSelectAcquire
- type NativeSelect
- type NopBuilder
- type RawNativeExec
- type RawNativeSelect
- type SingleAcquireAndSelect
- type SingleSelect
- type SubTreeBuilder
- type Union
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewDescribeMethodInstructionExecutor ¶ added in v0.10.474
func NewDescribeMethodInstructionExecutor( handlerCtx handler.HandlerContext, rsc formulation.Resource, methodName string, extended bool, ) internaldto.ExecutorOutput
func NewDescribeTableInstructionExecutor ¶
func NewDescribeTableInstructionExecutor( handlerCtx handler.HandlerContext, tbl tablemetadata.ExtendedTableMetadata, extended bool, full bool, ) internaldto.ExecutorOutput
func NewDescribeViewInstructionExecutor ¶
func NewDescribeViewInstructionExecutor( handlerCtx handler.HandlerContext, tbl tablemetadata.ExtendedTableMetadata, nonControlColumns []typing.ColumnMetadata, extended bool, full bool, ) internaldto.ExecutorOutput
func NewInsertableValsPrimitive ¶
func NewInsertableValsPrimitive( handlerCtx handler.HandlerContext, vals map[int]map[int]interface{}, ) (primitive.IPrimitive, error)
func NewLocalSelectExecutor ¶
func NewShowInstructionExecutor ¶
func NewShowInstructionExecutor( node *sqlparser.Show, prov provider.IProvider, tbl tablemetadata.ExtendedTableMetadata, handlerCtx handler.HandlerContext, commentDirectives sqlparser.CommentDirectives, tableFilter func(formulation.ITable, ) (formulation.ITable, error), ) internaldto.ExecutorOutput
func NewUpdateableValsPrimitive ¶
func NewUpdateableValsPrimitive( handlerCtx handler.HandlerContext, vals map[*sqlparser.ColName]interface{}, ) (primitive.IPrimitive, error)
Types ¶
type Builder ¶
type Builder interface {
Build() error
GetRoot() primitivegraph.PrimitiveNode
GetTail() primitivegraph.PrimitiveNode
}
func NewDDL ¶
func NewDDL( bldrInput builder_input.BuilderInput, ) (Builder, error)
func NewDataflowGraphBuilder ¶
func NewDataflowGraphBuilder( graph primitivegraph.PrimitiveGraphHolder, dataflowGraph dataflow.WeaklyConnectedComponent, txnControlCounters *internaldto.TxnControlCounters, handlerCtx handler.HandlerContext, sqlEngine sqlengine.SQLEngine, ) Builder
func NewDelete ¶
func NewDelete( graph primitivegraph.PrimitiveGraphHolder, handlerCtx handler.HandlerContext, insertCtx drm.PreparedStatementCtx, selectCtx drm.PreparedStatementCtx, node sqlparser.SQLNode, tbl tablemetadata.ExtendedTableMetadata, commentDirectives sqlparser.CommentDirectives, isAwait bool, bldrInput builder_input.BuilderInput, ) Builder
func NewDependencySubDAGBuilder ¶
func NewDependencySubDAGBuilder( graph primitivegraph.PrimitiveGraphHolder, dependencyBuilders []Builder, dependentBuilder Builder, ) Builder
func NewDependentMultipleAcquireAndSelect ¶
func NewDependentMultipleAcquireAndSelect( graph primitivegraph.PrimitiveGraphHolder, acquireBuilders []Builder, selectBuilder Builder, dataflowToEdges map[int][]int, sqlSystem sql_system.SQLSystem, ) Builder
func NewDiamondBuilder ¶
func NewDiamondBuilder( parent Builder, children []Builder, graphHolder primitivegraph.PrimitiveGraphHolder, sqlSystem sql_system.SQLSystem, shouldCollectGarbage bool, ) Builder
func NewExec ¶
func NewExec( graph primitivegraph.PrimitiveGraphHolder, handlerCtx handler.HandlerContext, node sqlparser.SQLNode, tbl tablemetadata.ExtendedTableMetadata, isAwait bool, isShowResults bool, tcc internaldto.TxnControlCounters, ) Builder
func NewExplainBuilder ¶ added in v0.9.266
func NewExplainBuilder( graph primitivegraph.PrimitiveGraphHolder, txnControlCounters internaldto.TxnControlCounters, handlerCtx handler.HandlerContext, sqlEngine sqlengine.SQLEngine, messages []string, instructionErr error, ) Builder
func NewInsertOrUpdate ¶ added in v0.5.375
func NewInsertOrUpdate( bldrInput builder_input.BuilderInput, ) Builder
func NewNativeSelect ¶
func NewNativeSelect( graph primitivegraph.PrimitiveGraphHolder, handlerCtx handler.HandlerContext, selectQuery nativedb.Select, ) Builder
func NewNopBuilder ¶
func NewNopBuilder( graph primitivegraph.PrimitiveGraphHolder, txnControlCounters internaldto.TxnControlCounters, handlerCtx handler.HandlerContext, sqlEngine sqlengine.SQLEngine, messages []string, ) Builder
func NewRawNativeExec ¶
func NewRawNativeExec( graph primitivegraph.PrimitiveGraphHolder, handlerCtx handler.HandlerContext, txnCtrlCtr internaldto.TxnControlCounters, nativeQuery string, bldrInput builder_input.BuilderInput, ) Builder
func NewRawNativeSelect ¶
func NewRawNativeSelect( graph primitivegraph.PrimitiveGraphHolder, handlerCtx handler.HandlerContext, txnCtrlCtr internaldto.TxnControlCounters, nativeQuery string, ) Builder
func NewRefreshMaterializedView ¶ added in v0.5.451
func NewRefreshMaterializedView( bldrInput builder_input.BuilderInput, ) (Builder, error)
func NewSQLDataSourceSingleSelectAcquire ¶
func NewSQLDataSourceSingleSelectAcquire( graph primitivegraph.PrimitiveGraphHolder, handlerCtx handler.HandlerContext, insertionContainer tableinsertioncontainer.TableInsertionContainer, query string, queryArgs []interface{}, insertCtx drm.PreparedStatementCtx, rowSort func(map[string]map[string]interface{}) []string, stream streaming.MapStream, ) Builder
func NewSingleAcquireAndSelect ¶
func NewSingleAcquireAndSelect( bldrInput builder_input.BuilderInput, insertCtx drm.PreparedStatementCtx, selectCtx drm.PreparedStatementCtx, rowSort func(map[string]map[string]interface{}) []string, ) Builder
func NewSingleSelect ¶
func NewSingleSelect( graph primitivegraph.PrimitiveGraphHolder, handlerCtx handler.HandlerContext, selectCtx drm.PreparedStatementCtx, insertionContainers []tableinsertioncontainer.TableInsertionContainer, rowSort func(map[string]map[string]interface{}) []string, stream streaming.MapStream, ) Builder
func NewSingleSelectAcquire ¶
func NewSingleSelectAcquire( graphHolder primitivegraph.PrimitiveGraphHolder, handlerCtx handler.HandlerContext, insertionContainer tableinsertioncontainer.TableInsertionContainer, insertCtx drm.PreparedStatementCtx, rowSort func(map[string]map[string]interface{}) []string, stream streaming.MapStream, bldrInput builder_input.BuilderInput, ) Builder
func NewSubTreeBuilder ¶
func NewUnion ¶
func NewUnion( graph primitivegraph.PrimitiveGraphHolder, handlerCtx handler.HandlerContext, unionCtx drm.PreparedStatementCtx, ) Builder
type DataflowGraphBuilder ¶
type DataflowGraphBuilder struct {
// contains filtered or unexported fields
}
func (*DataflowGraphBuilder) Build ¶
func (nb *DataflowGraphBuilder) Build() error
func (*DataflowGraphBuilder) GetRoot ¶
func (nb *DataflowGraphBuilder) GetRoot() primitivegraph.PrimitiveNode
func (*DataflowGraphBuilder) GetTail ¶
func (nb *DataflowGraphBuilder) GetTail() primitivegraph.PrimitiveNode
type Delete ¶
type Delete struct {
// contains filtered or unexported fields
}
func (*Delete) GetRoot ¶
func (ss *Delete) GetRoot() primitivegraph.PrimitiveNode
func (*Delete) GetTail ¶
func (ss *Delete) GetTail() primitivegraph.PrimitiveNode
type DependencySubDAGBuilder ¶
type DependencySubDAGBuilder struct {
// contains filtered or unexported fields
}
func (*DependencySubDAGBuilder) Build ¶
func (ss *DependencySubDAGBuilder) Build() error
func (*DependencySubDAGBuilder) GetRoot ¶
func (ss *DependencySubDAGBuilder) GetRoot() primitivegraph.PrimitiveNode
func (*DependencySubDAGBuilder) GetTail ¶
func (ss *DependencySubDAGBuilder) GetTail() primitivegraph.PrimitiveNode
type DependentMultipleAcquireAndSelect ¶
type DependentMultipleAcquireAndSelect struct {
// contains filtered or unexported fields
}
func (*DependentMultipleAcquireAndSelect) Build ¶
func (ss *DependentMultipleAcquireAndSelect) Build() error
func (*DependentMultipleAcquireAndSelect) GetRoot ¶
func (ss *DependentMultipleAcquireAndSelect) GetRoot() primitivegraph.PrimitiveNode
Cache queries may not have acquire builders.
func (*DependentMultipleAcquireAndSelect) GetTail ¶
func (ss *DependentMultipleAcquireAndSelect) GetTail() primitivegraph.PrimitiveNode
type DiamondBuilder ¶
type DiamondBuilder struct {
SubTreeBuilder
// contains filtered or unexported fields
}
func (*DiamondBuilder) Build ¶
func (db *DiamondBuilder) Build() error
func (*DiamondBuilder) GetRoot ¶
func (db *DiamondBuilder) GetRoot() primitivegraph.PrimitiveNode
func (*DiamondBuilder) GetTail ¶
func (db *DiamondBuilder) GetTail() primitivegraph.PrimitiveNode
type Exec ¶
type Exec struct {
// contains filtered or unexported fields
}
func (*Exec) GetRoot ¶
func (ss *Exec) GetRoot() primitivegraph.PrimitiveNode
func (*Exec) GetTail ¶
func (ss *Exec) GetTail() primitivegraph.PrimitiveNode
type ExplainBuilder ¶ added in v0.9.266
type ExplainBuilder struct {
// contains filtered or unexported fields
}
func (*ExplainBuilder) Build ¶ added in v0.9.266
func (nb *ExplainBuilder) Build() error
func (*ExplainBuilder) GetRoot ¶ added in v0.9.266
func (nb *ExplainBuilder) GetRoot() primitivegraph.PrimitiveNode
func (*ExplainBuilder) GetTail ¶ added in v0.9.266
func (nb *ExplainBuilder) GetTail() primitivegraph.PrimitiveNode
type GraphQLSingleSelectAcquire ¶
type GraphQLSingleSelectAcquire struct {
// contains filtered or unexported fields
}
GraphQLSingleSelectAcquire implements the Builder interface and represents the action of acquiring data from an endpoint and then persisting that data into a table. This data would then subsequently be queried by later execution phases.
func (*GraphQLSingleSelectAcquire) Build ¶
func (ss *GraphQLSingleSelectAcquire) Build() error
func (*GraphQLSingleSelectAcquire) GetRoot ¶
func (ss *GraphQLSingleSelectAcquire) GetRoot() primitivegraph.PrimitiveNode
func (*GraphQLSingleSelectAcquire) GetTail ¶
func (ss *GraphQLSingleSelectAcquire) GetTail() primitivegraph.PrimitiveNode
type NativeSelect ¶
type NativeSelect struct {
// contains filtered or unexported fields
}
func (*NativeSelect) Build ¶
func (ss *NativeSelect) Build() error
func (*NativeSelect) GetRoot ¶
func (ss *NativeSelect) GetRoot() primitivegraph.PrimitiveNode
func (*NativeSelect) GetTail ¶
func (ss *NativeSelect) GetTail() primitivegraph.PrimitiveNode
type NopBuilder ¶
type NopBuilder struct {
// contains filtered or unexported fields
}
func (*NopBuilder) Build ¶
func (nb *NopBuilder) Build() error
func (*NopBuilder) GetRoot ¶
func (nb *NopBuilder) GetRoot() primitivegraph.PrimitiveNode
func (*NopBuilder) GetTail ¶
func (nb *NopBuilder) GetTail() primitivegraph.PrimitiveNode
type RawNativeExec ¶
type RawNativeExec struct {
// contains filtered or unexported fields
}
func (*RawNativeExec) Build ¶
func (ss *RawNativeExec) Build() error
func (*RawNativeExec) GetRoot ¶
func (ss *RawNativeExec) GetRoot() primitivegraph.PrimitiveNode
func (*RawNativeExec) GetTail ¶
func (ss *RawNativeExec) GetTail() primitivegraph.PrimitiveNode
type RawNativeSelect ¶
type RawNativeSelect struct {
// contains filtered or unexported fields
}
func (*RawNativeSelect) Build ¶
func (ss *RawNativeSelect) Build() error
func (*RawNativeSelect) GetRoot ¶
func (ss *RawNativeSelect) GetRoot() primitivegraph.PrimitiveNode
func (*RawNativeSelect) GetTail ¶
func (ss *RawNativeSelect) GetTail() primitivegraph.PrimitiveNode
type SingleAcquireAndSelect ¶
type SingleAcquireAndSelect struct {
// contains filtered or unexported fields
}
func (*SingleAcquireAndSelect) Build ¶
func (ss *SingleAcquireAndSelect) Build() error
func (*SingleAcquireAndSelect) GetRoot ¶
func (ss *SingleAcquireAndSelect) GetRoot() primitivegraph.PrimitiveNode
func (*SingleAcquireAndSelect) GetTail ¶
func (ss *SingleAcquireAndSelect) GetTail() primitivegraph.PrimitiveNode
type SingleSelect ¶
type SingleSelect struct {
// contains filtered or unexported fields
}
func (*SingleSelect) Build ¶
func (ss *SingleSelect) Build() error
func (*SingleSelect) GetRoot ¶
func (ss *SingleSelect) GetRoot() primitivegraph.PrimitiveNode
func (*SingleSelect) GetTail ¶
func (ss *SingleSelect) GetTail() primitivegraph.PrimitiveNode
type SubTreeBuilder ¶
type SubTreeBuilder struct {
// contains filtered or unexported fields
}
func (*SubTreeBuilder) Build ¶
func (st *SubTreeBuilder) Build() error
func (*SubTreeBuilder) GetRoot ¶
func (st *SubTreeBuilder) GetRoot() primitivegraph.PrimitiveNode
func (*SubTreeBuilder) GetTail ¶
func (st *SubTreeBuilder) GetTail() primitivegraph.PrimitiveNode
type Union ¶
type Union struct {
// contains filtered or unexported fields
}
func (*Union) GetRoot ¶
func (un *Union) GetRoot() primitivegraph.PrimitiveNode
func (*Union) GetTail ¶
func (un *Union) GetTail() primitivegraph.PrimitiveNode
Source Files
¶
- builder.go
- dataflow_graph.go
- ddl.go
- delete.go
- dependent_multiple_acquire_and_select.go
- dependent_recursive.go
- diamond_builder.go
- exec.go
- explain.go
- generic_http_reversal.go
- generic_http_stream_input.go
- graphql_single_select_acquire.go
- insert_into_physical_table.go
- insert_or_update.go
- maps_aggregator_dto.go
- mono_valent_builder.go
- native_select.go
- nop.go
- raw_native_exec.go
- raw_native_select.go
- refresh_materialized_view.go
- shortcuts.go
- single_acquire_and_select.go
- single_select.go
- single_select_acquire.go
- sql_data_source_single_select_acquire.go
- sub_tree_builder.go
- union.go
Click to show internal directories.
Click to hide internal directories.