TPipeOperator (General SQL Parser Java Library Core 4.1.0.3 API)

Object
- gudusoft.gsqlparser.nodes.TParseTreeNode
- - gudusoft.gsqlparser.nodes.starrocks.TPipeOperator

All Implemented Interfaces:

Visitable, Iterator<TSourceToken>
```
public class TPipeOperator
extends TParseTreeNode
```
AST node representing a pipe operator operation in StarRocks pipe query syntax. The pipe operator (|>) chains SQL operations together in a linear flow: FROM table |> SELECT * |> WHERE cond |> ORDER BY col |> LIMIT n Each TPipeOperator represents one operation after a |> symbol.

Nested Class Summary

Nested Classes
Modifier and Type Class and Description

static class TPipeOperator.EPipeOperatorType
Enum for different types of pipe operations

Nested Classes
Modifier and Type	Class and Description
`static class`	`TPipeOperator.EPipeOperatorType` Enum for different types of pipe operations

Field Summary
- Fields inherited from class gudusoft.gsqlparser.nodes.TParseTreeNode
  dbvendor, doubleLinkedTokenListToString, nodeActionAppend, nodeActionInsert, nodeActionRemove, nodeActionUnknown, nodeActionUpdate, nodeActionUpdateText, nodeChangeEndToken, nodeChangeStartToken

Constructor Summary

Constructors
Constructor and Description

TPipeOperator()

Constructors
Constructor and Description
`TPipeOperator()`

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`TResultColumnList`	`getAggregateList()`
`TObjectNameList`	`getDropColumns()`
`TResultColumnList`	`getExtendList()`
`TGroupBy`	`getGroupByClause()`
`TExpression`	`getJoinCondition()`
`TJoinExpr`	`getJoinExpr()`
`TFromTable`	`getJoinTable()`
`EJoinType`	`getJoinType()`
`TLimitClause`	`getLimitClause()`
`TSourceToken`	`getOperatorKeyword()`
`TPipeOperator.EPipeOperatorType`	`getOperatorType()`
`TOrderBy`	`getOrderByClause()`
`TSourceToken`	`getPipeToken()`
`TSelectDistinct`	`getSelectDistinct()`
`TResultColumnList`	`getSelectList()`
`TParseTreeNode`	`getSetOperand()`
`TObjectName`	`getTableAlias()`
`TExpression`	`getWhereCondition()`
`void`	`initAggregate(TSourceToken pipeToken, TSourceToken aggKeyword, TResultColumnList aggregates, TGroupBy groupBy)` Initialize for AGGREGATE pipe operation
`void`	`initExcept(TSourceToken pipeToken, TSourceToken exceptKeyword, TParseTreeNode operand, boolean all)` Initialize for EXCEPT pipe operation
`void`	`initExtend(TSourceToken pipeToken, TSourceToken extendKeyword, TResultColumnList extendColumns)` Initialize for EXTEND pipe operation
`void`	`initIntersect(TSourceToken pipeToken, TSourceToken intersectKeyword, TParseTreeNode operand, boolean all)` Initialize for INTERSECT pipe operation
`void`	`initJoin(TSourceToken pipeToken, EJoinType joinType, TFromTable table, TExpression condition)` Initialize for JOIN pipe operation with table and condition
`void`	`initJoin(TSourceToken pipeToken, TJoinExpr join)` Initialize for JOIN pipe operation
`void`	`initLimit(TSourceToken pipeToken, TLimitClause limit)` Initialize for LIMIT pipe operation
`void`	`initOrderBy(TSourceToken pipeToken, TOrderBy orderBy)` Initialize for ORDER BY pipe operation
`void`	`initSelect(TSourceToken pipeToken, TSourceToken selectKeyword, TSelectDistinct distinct, TResultColumnList columns)` Initialize for SELECT pipe operation
`void`	`initUnion(TSourceToken pipeToken, TSourceToken unionKeyword, TParseTreeNode operand, boolean all)` Initialize for UNION pipe operation
`void`	`initWhere(TSourceToken pipeToken, TSourceToken whereKeyword, TExpression condition)` Initialize for WHERE pipe operation
`boolean`	`isSetAll()`
`void`	`setAggregateList(TResultColumnList aggregateList)`
`void`	`setDropColumns(TObjectNameList dropColumns)`
`void`	`setExtendList(TResultColumnList extendList)`
`void`	`setGroupByClause(TGroupBy groupByClause)`
`void`	`setJoinCondition(TExpression joinCondition)`
`void`	`setJoinExpr(TJoinExpr joinExpr)`
`void`	`setJoinTable(TFromTable joinTable)`
`void`	`setJoinType(EJoinType joinType)`
`void`	`setLimitClause(TLimitClause limitClause)`
`void`	`setOperatorKeyword(TSourceToken operatorKeyword)`
`void`	`setOperatorType(TPipeOperator.EPipeOperatorType operatorType)`
`void`	`setOrderByClause(TOrderBy orderByClause)`
`void`	`setPipeToken(TSourceToken pipeToken)`
`void`	`setSelectDistinct(TSelectDistinct selectDistinct)`
`void`	`setSelectList(TResultColumnList selectList)`
`void`	`setSetAll(boolean setAll)`
`void`	`setSetOperand(TParseTreeNode setOperand)`
`void`	`setTableAlias(TObjectName tableAlias)`
`void`	`setWhereCondition(TExpression whereCondition)`

Methods inherited from class gudusoft.gsqlparser.nodes.TParseTreeNode
accept, acceptChildren, addAllMyTokensToTokenList, addToTokenChain, appendNewNode, calculateTokenCount, doAppendNewNode, doParse, fastSetString, getAnchorNode, getColumnNo, getCommentAfterNode, getCommentBeforeNode, getCompactString, getDummyTag, getEndToken, getEvaluateDatatype, getEvalValue, getGsqlparser, getLineNo, getLocation, getMd5, getNodeStatus, getNodeType, getParentObjectName, getPlainText, getStartToken, getTokenCount, hasNext, init, init, init, init, init, init, init, init, init, init, insertAfterAToken, insertNewNodeBeforeMe, isChanged, isTokensInChain, next, refreshAllNodesTokenCount, remove, removeAllMyTokensFromTokenList, removeTokens, removeTokensBetweenNodes, removeTokensBetweenToken, replaceWithNewNode, resetIterator, setAnchorNode, setChanged, setDummyTag, setEndToken, setEndToken, setEndToken, setEndToken, setEndToken, setEndTokenDirectly, setEvaluateDatatype, setEvalValue, setGsqlparser, setIncludingComment, setLocation, setNewSubNode, setNodeStatus, setNodeType, setParent, setPlainText, setStartToken, setStartToken, setStartToken, setStartToken, setStartTokenDirectly, setString, setString2, subNodeInNode, toScript, toString, toString2

Methods inherited from class Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface Iterator
forEachRemaining

Constructor Detail
- TPipeOperator
```
public TPipeOperator()
```

Method Detail

getPipeToken
```
public TSourceToken getPipeToken()
```

setPipeToken

public void setPipeToken(TSourceToken pipeToken)

getOperatorType

public TPipeOperator.EPipeOperatorType getOperatorType()

setOperatorType

public void setOperatorType(TPipeOperator.EPipeOperatorType operatorType)

getOperatorKeyword

public TSourceToken getOperatorKeyword()

setOperatorKeyword

public void setOperatorKeyword(TSourceToken operatorKeyword)

getSelectList

public TResultColumnList getSelectList()

setSelectList

public void setSelectList(TResultColumnList selectList)

getSelectDistinct

public TSelectDistinct getSelectDistinct()

setSelectDistinct

public void setSelectDistinct(TSelectDistinct selectDistinct)

getWhereCondition

public TExpression getWhereCondition()

setWhereCondition

public void setWhereCondition(TExpression whereCondition)

getOrderByClause
```
public TOrderBy getOrderByClause()
```

setOrderByClause

public void setOrderByClause(TOrderBy orderByClause)

getLimitClause
```
public TLimitClause getLimitClause()
```

setLimitClause

public void setLimitClause(TLimitClause limitClause)

getAggregateList

public TResultColumnList getAggregateList()

setAggregateList

public void setAggregateList(TResultColumnList aggregateList)

getGroupByClause
```
public TGroupBy getGroupByClause()
```

setGroupByClause

public void setGroupByClause(TGroupBy groupByClause)

getExtendList

public TResultColumnList getExtendList()

setExtendList

public void setExtendList(TResultColumnList extendList)

getDropColumns

public TObjectNameList getDropColumns()

setDropColumns

public void setDropColumns(TObjectNameList dropColumns)

getTableAlias
```
public TObjectName getTableAlias()
```

setTableAlias

public void setTableAlias(TObjectName tableAlias)

getJoinExpr
```
public TJoinExpr getJoinExpr()
```

setJoinExpr

public void setJoinExpr(TJoinExpr joinExpr)

getJoinTable
```
public TFromTable getJoinTable()
```

setJoinTable

public void setJoinTable(TFromTable joinTable)

getJoinCondition
```
public TExpression getJoinCondition()
```

setJoinCondition

public void setJoinCondition(TExpression joinCondition)

getJoinType
```
public EJoinType getJoinType()
```

setJoinType

public void setJoinType(EJoinType joinType)

getSetOperand
```
public TParseTreeNode getSetOperand()
```

setSetOperand

public void setSetOperand(TParseTreeNode setOperand)

isSetAll
```
public boolean isSetAll()
```

setSetAll

public void setSetAll(boolean setAll)

initSelect

public void initSelect(TSourceToken pipeToken,
                       TSourceToken selectKeyword,
                       TSelectDistinct distinct,
                       TResultColumnList columns)

Initialize for SELECT pipe operation

initWhere

public void initWhere(TSourceToken pipeToken,
                      TSourceToken whereKeyword,
                      TExpression condition)

Initialize for WHERE pipe operation

initOrderBy

public void initOrderBy(TSourceToken pipeToken,
                        TOrderBy orderBy)

Initialize for ORDER BY pipe operation

initLimit

public void initLimit(TSourceToken pipeToken,
                      TLimitClause limit)

Initialize for LIMIT pipe operation

initAggregate

public void initAggregate(TSourceToken pipeToken,
                          TSourceToken aggKeyword,
                          TResultColumnList aggregates,
                          TGroupBy groupBy)

Initialize for AGGREGATE pipe operation

initExtend

public void initExtend(TSourceToken pipeToken,
                       TSourceToken extendKeyword,
                       TResultColumnList extendColumns)

Initialize for EXTEND pipe operation

initJoin

public void initJoin(TSourceToken pipeToken,
                     TJoinExpr join)

Initialize for JOIN pipe operation

initJoin

public void initJoin(TSourceToken pipeToken,
                     EJoinType joinType,
                     TFromTable table,
                     TExpression condition)

Initialize for JOIN pipe operation with table and condition

initUnion

public void initUnion(TSourceToken pipeToken,
                      TSourceToken unionKeyword,
                      TParseTreeNode operand,
                      boolean all)

Initialize for UNION pipe operation

initIntersect

public void initIntersect(TSourceToken pipeToken,
                          TSourceToken intersectKeyword,
                          TParseTreeNode operand,
                          boolean all)

Initialize for INTERSECT pipe operation

initExcept

public void initExcept(TSourceToken pipeToken,
                       TSourceToken exceptKeyword,
                       TParseTreeNode operand,
                       boolean all)

Initialize for EXCEPT pipe operation

Class TPipeOperator

Nested Class Summary

Field Summary

Fields inherited from class gudusoft.gsqlparser.nodes.TParseTreeNode

Constructor Summary

Method Summary

Methods inherited from class gudusoft.gsqlparser.nodes.TParseTreeNode

Methods inherited from class Object

Methods inherited from interface Iterator

Constructor Detail

TPipeOperator

Method Detail

getPipeToken

setPipeToken

getOperatorType

setOperatorType

getOperatorKeyword

setOperatorKeyword

getSelectList

setSelectList

getSelectDistinct

setSelectDistinct

getWhereCondition

setWhereCondition

getOrderByClause

setOrderByClause

getLimitClause

setLimitClause

getAggregateList

setAggregateList

getGroupByClause

setGroupByClause

getExtendList

setExtendList

getDropColumns

setDropColumns

getTableAlias

setTableAlias

getJoinExpr

setJoinExpr

getJoinTable

setJoinTable

getJoinCondition

setJoinCondition

getJoinType

setJoinType

getSetOperand

setSetOperand

isSetAll

setSetAll

initSelect

initWhere

initOrderBy

initLimit

initAggregate

initExtend

initJoin

initJoin

initUnion

initIntersect

initExcept