Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Collection ¶ added in v0.5.375
type Collection interface { AddOrUpdateEdge( source Vertex, dest Vertex, comparisonExpr *sqlparser.ComparisonExpr, sourceExpr sqlparser.Expr, destColumn *sqlparser.ColName) error AddVertex(v Vertex) GetAllUnits() ([]Unit, error) GetNextID() int64 InDegree(v Vertex) int OutDegree(v Vertex) int Sort() error Vertices() []Vertex }
Collection is the DAG representing.
func NewStandardDataFlowCollection ¶
func NewStandardDataFlowCollection() Collection
type Edge ¶ added in v0.5.375
type Edge interface { graph.WeightedEdge AddRelation(Relation) GetColumnDescriptors() ([]anysdk.ColumnDescriptor, error) GetDest() Vertex GetProjection() (map[string]string, error) GetSelectExprs() (sqlparser.SelectExprs, error) GetSource() Vertex IsSQL() bool }
type Relation ¶ added in v0.5.375
type Relation interface { GetProjection() (string, string, error) GetSelectExpr() (sqlparser.SelectExpr, error) GetColumnDescriptor() (anysdk.ColumnDescriptor, error) IsSQL() bool }
type Vertex ¶ added in v0.5.375
type Vertex interface { graph.Node Unit GetAnnotation() taxonomy.AnnotationCtx GetEquivalencyGroup() int64 SetEquivalencyGroup(id int64) GetTableExpr() sqlparser.TableExpr }
type WeaklyConnectedComponent ¶ added in v0.5.375
type WeaklyConnectedComponent interface { Unit AddEdge(Edge) Analyze() error GetEdges() ([]Edge, error) GetOrderedNodes() ([]Vertex, error) PushBack(Vertex) }
func NewStandardDataFlowWeaklyConnectedComponent ¶
func NewStandardDataFlowWeaklyConnectedComponent( collection *standardDataFlowCollection, root graph.Node, ) WeaklyConnectedComponent
Click to show internal directories.
Click to hide internal directories.