gudusoft.gsqlparser.dlineage

Class PipelinedFunctionAnalyzer

Object

gudusoft.gsqlparser.dlineage.PipelinedFunctionAnalyzer

public class PipelinedFunctionAnalyzer
extends Object

Handles Oracle pipelined table function cross-boundary data lineage stitching.

Two-phase approach:

1. Index phase: indexes object types, collection types, and pipelined function signatures
2. Stitch phase: at call sites, appends lineage from function body to caller columns

Constructor Summary

Constructors

Constructor and Description
PipelinedFunctionAnalyzer(ModelBindingManager modelManager, ModelFactory modelFactory, Option option)

Method Summary

Modifier and Type	Method and Description
void	analyzePipelinedFunction(TPlsqlCreateFunction func)
void	indexCollectionType(TPlsqlTableTypeDefStmt stmt)
void	indexObjectType(TPlsqlCreateType stmt)
void	stitchOnePending(PendingPipelinedCallSite cs) Stitch a single pending call site.
void	stitchPendingCallSites() Finalize hook: process all pending call sites.
boolean	tryStitchCallSite(TTable table, TFunctionCall funcCall) Called when TABLE(func(...)) is encountered in a FROM clause.
void	tryStitchTableExpr(TTable table) Handle TABLE(func(...)) which is parsed as tableExpr with funcCall=null.

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

PipelinedFunctionAnalyzer

public PipelinedFunctionAnalyzer(ModelBindingManager modelManager,
                                 ModelFactory modelFactory,
                                 Option option)

Method Detail

indexObjectType

public void indexObjectType(TPlsqlCreateType stmt)

indexCollectionType

public void indexCollectionType(TPlsqlTableTypeDefStmt stmt)

analyzePipelinedFunction

public void analyzePipelinedFunction(TPlsqlCreateFunction func)

tryStitchTableExpr

public void tryStitchTableExpr(TTable table)

Handle TABLE(func(...)) which is parsed as tableExpr with funcCall=null. The table name is the function name. Always defers to finalize because table columns are not yet populated during from-clause processing.

tryStitchCallSite

public boolean tryStitchCallSite(TTable table,
                                 TFunctionCall funcCall)

Called when TABLE(func(...)) is encountered in a FROM clause. Generates candidate keys and tries to stitch immediately. If the signature isn't available yet, adds to pending list.

stitchOnePending

public void stitchOnePending(PendingPipelinedCallSite cs)

Stitch a single pending call site. Called from DataFlowAnalyzer with the proper statement stack context.

stitchPendingCallSites

public void stitchPendingCallSites()

Finalize hook: process all pending call sites. Called before XML emit.