gudusoft.gsqlparser.dlineage.dataflow.model

Class PipelinedFunctionSignature

Object

gudusoft.gsqlparser.dlineage.dataflow.model.PipelinedFunctionSignature

public class PipelinedFunctionSignature
extends Object

Captures the output row structure and per-column upstream lineage of a pipelined table function. This is the single source of truth for all stitching operations.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	PipelinedFunctionSignature.ResolutionStatus

Constructor Summary

Constructors

Constructor and Description
PipelinedFunctionSignature()

Method Summary

Modifier and Type	Method and Description
void	addSourceRef(String outputColumnNormalized, PipelinedSourceRef ref)
int	getArgCount()
String	getCollectionTypeKey()
String	getFunctionKey()
Map<String,List<PipelinedSourceRef>>	getLineageByOutputColumn()
String	getNakedKey()
List<String>	getOutputColumns()
String	getProcedureKey()
String	getRowTypeKey()
PipelinedFunctionSignature.ResolutionStatus	getStatus()
boolean	isPipelined()
boolean	isResolved()
void	setArgCount(int argCount)
void	setCollectionTypeKey(String collectionTypeKey)
void	setFunctionKey(String functionKey)
void	setNakedKey(String nakedKey)
void	setOutputColumns(List<String> outputColumns)
void	setPipelined(boolean pipelined)
void	setProcedureKey(String procedureKey)
void	setResolved(boolean resolved)
void	setRowTypeKey(String rowTypeKey)
void	setStatus(PipelinedFunctionSignature.ResolutionStatus status)
String	toString()

Methods inherited from class Object

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

Constructor Detail

PipelinedFunctionSignature

public PipelinedFunctionSignature()

Method Detail

getFunctionKey

public String getFunctionKey()

setFunctionKey

public void setFunctionKey(String functionKey)

getNakedKey

public String getNakedKey()

setNakedKey

public void setNakedKey(String nakedKey)

getProcedureKey

public String getProcedureKey()

setProcedureKey

public void setProcedureKey(String procedureKey)

getRowTypeKey

public String getRowTypeKey()

setRowTypeKey

public void setRowTypeKey(String rowTypeKey)

getCollectionTypeKey

public String getCollectionTypeKey()

setCollectionTypeKey

public void setCollectionTypeKey(String collectionTypeKey)

getArgCount

public int getArgCount()

setArgCount

public void setArgCount(int argCount)

isPipelined

public boolean isPipelined()

setPipelined

public void setPipelined(boolean pipelined)

isResolved

public boolean isResolved()

setResolved

public void setResolved(boolean resolved)

getStatus

public PipelinedFunctionSignature.ResolutionStatus getStatus()

setStatus

public void setStatus(PipelinedFunctionSignature.ResolutionStatus status)

getOutputColumns

public List<String> getOutputColumns()

setOutputColumns

public void setOutputColumns(List<String> outputColumns)

getLineageByOutputColumn

public Map<String,List<PipelinedSourceRef>> getLineageByOutputColumn()

addSourceRef

public void addSourceRef(String outputColumnNormalized,
                         PipelinedSourceRef ref)

toString

public String toString()

Overrides:

toString in class Object