gudusoft.gsqlparser.nodes

Class TCreateRoutineLoadSqlNode

Object

gudusoft.gsqlparser.nodes.TParseTreeNode

gudusoft.gsqlparser.nodes.TCreateRoutineLoadSqlNode

All Implemented Interfaces:

Visitable, Iterator<TSourceToken>

public class TCreateRoutineLoadSqlNode
extends TParseTreeNode

AST node for StarRocks CREATE ROUTINE LOAD statement. Syntax: CREATE ROUTINE LOAD [database.]job_name ON table_name [load_properties] [job_properties] FROM data_source [data_source_properties] load_properties: [COLUMNS TERMINATED BY ''] [ROWS TERMINATED BY ''] [COLUMNS ([, , , ...])] [WHERE ] [PARTITION ([, , ...])] job_properties: PROPERTIES ("key" = "value"[, ...]) data_source: FROM KAFKA ("key" = "value"[, ...])

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
TCreateRoutineLoadSqlNode()

Method Summary

Modifier and Type	Method and Description
TObjectNameList	getColumnList()
TSourceToken	getColumnSeparator()
TPTNodeList<TFlinkTableProperty>	getDataSourceProperties()
TSourceToken	getDataSourceType()
TObjectName	getJobName()
TPTNodeList<TFlinkTableProperty>	getJobProperties()
TObjectNameList	getPartitionList()
TSourceToken	getRowSeparator()
TObjectName	getTableName()
TObjectNameList	getTemporaryPartitionList()
TExpression	getWhereClause()
void	init(Object arg1, Object arg2)
void	setColumnList(TObjectNameList columnList)
void	setColumnSeparator(TSourceToken columnSeparator)
void	setDataSourceProperties(TParseTreeNode dataSourceProperties)
void	setDataSourceType(TSourceToken dataSourceType)
void	setJobName(TObjectName jobName)
void	setJobProperties(TParseTreeNode jobProperties)
void	setPartitionList(TObjectNameList partitionList)
void	setRowSeparator(TSourceToken rowSeparator)
void	setTableName(TObjectName tableName)
void	setTemporaryPartitionList(TObjectNameList temporaryPartitionList)
void	setWhereClause(TExpression whereClause)

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, 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

TCreateRoutineLoadSqlNode

public TCreateRoutineLoadSqlNode()

Method Detail

getJobName

public TObjectName getJobName()

setJobName

public void setJobName(TObjectName jobName)

getTableName

public TObjectName getTableName()

setTableName

public void setTableName(TObjectName tableName)

getColumnSeparator

public TSourceToken getColumnSeparator()

setColumnSeparator

public void setColumnSeparator(TSourceToken columnSeparator)

getRowSeparator

public TSourceToken getRowSeparator()

setRowSeparator

public void setRowSeparator(TSourceToken rowSeparator)

getColumnList

public TObjectNameList getColumnList()

setColumnList

public void setColumnList(TObjectNameList columnList)

getWhereClause

public TExpression getWhereClause()

setWhereClause

public void setWhereClause(TExpression whereClause)

getPartitionList

public TObjectNameList getPartitionList()

setPartitionList

public void setPartitionList(TObjectNameList partitionList)

getTemporaryPartitionList

public TObjectNameList getTemporaryPartitionList()

setTemporaryPartitionList

public void setTemporaryPartitionList(TObjectNameList temporaryPartitionList)

getJobProperties

public TPTNodeList<TFlinkTableProperty> getJobProperties()

setJobProperties

public void setJobProperties(TParseTreeNode jobProperties)

getDataSourceType

public TSourceToken getDataSourceType()

setDataSourceType

public void setDataSourceType(TSourceToken dataSourceType)

getDataSourceProperties

public TPTNodeList<TFlinkTableProperty> getDataSourceProperties()

setDataSourceProperties

public void setDataSourceProperties(TParseTreeNode dataSourceProperties)

init

public void init(Object arg1,
                 Object arg2)

Overrides:

init in class TParseTreeNode