package gudusoft.gsqlparser.dlineage.dataflow.model;

/**
 * Represents a single upstream source reference for a pipelined function output column.
 */
public class PipelinedSourceRef {
    private String parentName;
    private String columnName;
    private SourceKind sourceKind;
    private EffectType effectType;
    private String clauseType;

    public enum SourceKind {
        BASE_TABLE, CTE, SUBQUERY, CONST, UNRESOLVED
    }

    public PipelinedSourceRef(String parentName, String columnName, SourceKind sourceKind) {
        this.parentName = parentName;
        this.columnName = columnName;
        this.sourceKind = sourceKind;
        this.effectType = EffectType.select;
        this.clauseType = "PIPE_ROW";
    }

    public String getParentName() {
        return parentName;
    }

    public void setParentName(String parentName) {
        this.parentName = parentName;
    }

    public String getColumnName() {
        return columnName;
    }

    public void setColumnName(String columnName) {
        this.columnName = columnName;
    }

    public SourceKind getSourceKind() {
        return sourceKind;
    }

    public void setSourceKind(SourceKind sourceKind) {
        this.sourceKind = sourceKind;
    }

    public EffectType getEffectType() {
        return effectType;
    }

    public void setEffectType(EffectType effectType) {
        this.effectType = effectType;
    }

    public String getClauseType() {
        return clauseType;
    }

    public void setClauseType(String clauseType) {
        this.clauseType = clauseType;
    }

    @Override
    public String toString() {
        return parentName + "." + columnName + " (" + sourceKind + ")";
    }
}