org.apache.druid.sql.calcite.parser

Class DruidSqlReplace

java.lang.Object

org.apache.calcite.sql.SqlNode

org.apache.calcite.sql.SqlCall

org.apache.calcite.sql.SqlInsert

org.apache.druid.sql.calcite.parser.DruidSqlReplace

All Implemented Interfaces:

Cloneable

public class DruidSqlReplace
extends org.apache.calcite.sql.SqlInsert

Extends the 'replace' call to hold custom parameters specific to Druid i.e. PARTITIONED BY and the PARTITION SPECS This class extends the SqlInsert so that this SqlNode can be used in SqlToRelConverter for getting converted into RelNode, and further processing

Field Summary

Fields

Modifier and Type	Field and Description
static org.apache.calcite.sql.SqlOperator	OPERATOR
static String	SQL_REPLACE_TIME_CHUNKS

Fields inherited from class org.apache.calcite.sql.SqlNode

EMPTY_ARRAY, pos

Constructor Summary

Constructors

Constructor and Description

DruidSqlReplace(org.apache.calcite.sql.SqlInsert insertNode, Granularity partitionedBy, String partitionedByStringForUnparse, org.apache.calcite.sql.SqlNodeList clusteredBy, org.apache.calcite.sql.SqlNode replaceTimeQuery) While partitionedBy and partitionedByStringForUnparse can be null as arguments to the constructor, this is disallowed (semantically) and the constructor performs checks to ensure that.

Method Summary

Modifier and Type	Method and Description
org.apache.calcite.sql.SqlNodeList	getClusteredBy()
org.apache.calcite.sql.SqlOperator	getOperator()
Granularity	getPartitionedBy()
org.apache.calcite.sql.SqlNode	getReplaceTimeQuery()
void	unparse(org.apache.calcite.sql.SqlWriter writer, int leftPrec, int rightPrec)

Methods inherited from class org.apache.calcite.sql.SqlInsert

getKind, getModifierNode, getOperandList, getSource, getTargetColumnList, getTargetTable, isUpsert, setOperand, setSource, validate

Methods inherited from class org.apache.calcite.sql.SqlCall

accept, clone, equalsDeep, findValidOptions, getCallSignature, getFunctionQuantifier, getMonotonicity, isCountStar, isExpanded, operand, operandCount

Methods inherited from class org.apache.calcite.sql.SqlNode

clone, clone, cloneArray, equalDeep, equalDeep, equalsDeep, getParserPosition, isA, toSqlString, toSqlString, toString, validateExpr

Methods inherited from class java.lang.Object

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

Field Detail

SQL_REPLACE_TIME_CHUNKS

public static final String SQL_REPLACE_TIME_CHUNKS

See Also:

Constant Field Values

OPERATOR

public static final org.apache.calcite.sql.SqlOperator OPERATOR

Constructor Detail

DruidSqlReplace

public DruidSqlReplace(@Nonnull
                       org.apache.calcite.sql.SqlInsert insertNode,
                       @Nullable
                       Granularity partitionedBy,
                       @Nullable
                       String partitionedByStringForUnparse,
                       @Nullable
                       org.apache.calcite.sql.SqlNodeList clusteredBy,
                       @Nullable
                       org.apache.calcite.sql.SqlNode replaceTimeQuery)
                throws ParseException

While partitionedBy and partitionedByStringForUnparse can be null as arguments to the constructor, this is disallowed (semantically) and the constructor performs checks to ensure that. This helps in producing friendly errors when the PARTITIONED BY custom clause is not present, and keeps its error separate from JavaCC/Calcite's custom errors which can be cryptic when someone accidentally forgets to explicitly specify the PARTITIONED BY clause

Throws:

ParseException

Method Detail

getReplaceTimeQuery

public org.apache.calcite.sql.SqlNode getReplaceTimeQuery()

getPartitionedBy

public Granularity getPartitionedBy()

getClusteredBy

@Nullable
public org.apache.calcite.sql.SqlNodeList getClusteredBy()

getOperator

@Nonnull
public org.apache.calcite.sql.SqlOperator getOperator()

Overrides:

getOperator in class org.apache.calcite.sql.SqlInsert

unparse

public void unparse(org.apache.calcite.sql.SqlWriter writer,
                    int leftPrec,
                    int rightPrec)

Overrides:

unparse in class org.apache.calcite.sql.SqlInsert