dataflow

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
	UpsertStandardDataFlowVertex(taxonomy.AnnotationCtx, sqlparser.TableExpr) Vertex

	GetSplitAnnotationContextMap() taxonomy.AnnotationCtxSplitMap
	WithSplitAnnotationContextMap(taxonomy.AnnotationCtxSplitMap) Collection
	// contains filtered or unexported methods
}

type Edge interface {
	graph.WeightedEdge
	AddRelation(Relation)
	GetColumnDescriptors() ([]formulation.ColumnDescriptor, error)
	GetDest() Vertex
	GetProjection() (map[string]string, error)
	GetSelectExprs() (sqlparser.SelectExprs, error)
	HasSourceAttribute(attr string) bool
	GetSource() Vertex
	IsSQL() bool
}

type Relation interface {
	GetProjection() (string, string, error)
	GetSelectExpr() (sqlparser.SelectExpr, error)
	GetColumnDescriptor() (formulation.ColumnDescriptor, error)
	GetDestColumnName() string
	IsSQL() bool
}

type Unit interface {
	// contains filtered or unexported methods
}

type Vertex interface {
	graph.Node
	Unit
	GetAnnotation() taxonomy.AnnotationCtx
	GetEquivalencyGroup() int64
	SetEquivalencyGroup(id int64)
	GetTableExpr() sqlparser.TableExpr
}

type WeaklyConnectedComponent interface {
	Unit
	AddEdge(Edge)
	Analyze() error
	GetEdges() ([]Edge, error)
	GetOrderedNodes() ([]Vertex, error)
	PushBack(Vertex)
}