org.apache.drill.exec.planner.sql.handlers

Class SqlHandlerUtil

java.lang.Object

org.apache.drill.exec.planner.sql.handlers.SqlHandlerUtil

public class SqlHandlerUtil
extends Object

Constructor Summary

Constructors

Constructor and Description
SqlHandlerUtil()

Method Summary

Modifier and Type	Method and Description
static void	dropTableFromSchema(AbstractSchema drillSchema, String tableName) Drops table from schema.
static void	dropViewFromSchema(AbstractSchema drillSchema, String viewName) Drops view from schema.
static org.apache.calcite.schema.Table	getTableFromSchema(AbstractSchema drillSchema, String tblName)
static org.apache.calcite.rel.RelNode	qualifyPartitionCol(org.apache.calcite.rel.RelNode input, List<String> partitionColumns) Resolve the partition columns specified in "PARTITION BY" clause of CTAS statement.
static org.apache.calcite.rel.RelNode	resolveNewTableRel(boolean isNewTableView, List<String> tableFieldNames, org.apache.calcite.rel.type.RelDataType validatedRowtype, org.apache.calcite.rel.RelNode queryRelNode) Resolve final RelNode of the new table (or view) for given table field list and new table definition.
static void	unparseKeyValuePairs(org.apache.calcite.sql.SqlWriter writer, int leftPrec, int rightPrec, org.apache.calcite.sql.SqlNodeList list) Unparses given SqlNodeList into key / values pairs: (k1 = v1, k2 = v2).
static void	unparseSqlNodeList(org.apache.calcite.sql.SqlWriter writer, int leftPrec, int rightPrec, org.apache.calcite.sql.SqlNodeList fieldList)

Methods inherited from class java.lang.Object

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

Constructor Detail

SqlHandlerUtil

public SqlHandlerUtil()

Method Detail

resolveNewTableRel

public static org.apache.calcite.rel.RelNode resolveNewTableRel(boolean isNewTableView,
                                                                List<String> tableFieldNames,
                                                                org.apache.calcite.rel.type.RelDataType validatedRowtype,
                                                                org.apache.calcite.rel.RelNode queryRelNode)
                                                         throws org.apache.calcite.tools.ValidationException,
                                                                org.apache.calcite.tools.RelConversionException

Resolve final RelNode of the new table (or view) for given table field list and new table definition.

Parameters:

isNewTableView - Is the new table created a view? This doesn't affect the functionality, but it helps format better error messages.

tableFieldNames - List of fields specified in new table/view field list. These are the fields given just after new table name. Ex. CREATE TABLE newTblName(col1, medianOfCol2, avgOfCol3) AS SELECT col1, median(col2), avg(col3) FROM sourcetbl GROUP BY col1;

Throws:

org.apache.calcite.tools.ValidationException - If table's fields list and field list specified in table definition are not valid.

org.apache.calcite.tools.RelConversionException - If failed to convert the table definition into a RelNode.

qualifyPartitionCol

public static org.apache.calcite.rel.RelNode qualifyPartitionCol(org.apache.calcite.rel.RelNode input,
                                                                 List<String> partitionColumns)

Resolve the partition columns specified in "PARTITION BY" clause of CTAS statement. A partition column is resolved, either (1) the same column appear in the select list of CTAS or (2) CTAS has a * in select list. In the second case, a PROJECT with ITEM expression would be created and returned. Throw validation error if a partition column is not resolved correctly.

Parameters:

input - : the RelNode represents the select statement in CTAS.

partitionColumns - : the list of partition columns.

Returns:

: 1) the original RelNode input, if all partition columns are in select list of CTAS 2) a New Project, if a partition column is resolved to * column in select list 3) validation error, if partition column is not resolved.

getTableFromSchema

public static org.apache.calcite.schema.Table getTableFromSchema(AbstractSchema drillSchema,
                                                                 String tblName)

unparseSqlNodeList

public static void unparseSqlNodeList(org.apache.calcite.sql.SqlWriter writer,
                                      int leftPrec,
                                      int rightPrec,
                                      org.apache.calcite.sql.SqlNodeList fieldList)

dropTableFromSchema

public static void dropTableFromSchema(AbstractSchema drillSchema,
                                       String tableName)

Drops table from schema. If drop has failed makes concurrency check: checks if table still exists. If table exists, throws UserException since drop was unsuccessful, otherwise assumes that other user had dropped the view and exists without error.

Parameters:

drillSchema - drill schema

tableName - table name

dropViewFromSchema

public static void dropViewFromSchema(AbstractSchema drillSchema,
                                      String viewName)
                               throws IOException

Drops view from schema. If drop has failed makes concurrency check: checks if view still exists. If view exists, throws UserException since drop was unsuccessful, otherwise assumes that other user had dropped the view and exists without error.

Parameters:

drillSchema - drill schema

viewName - view name

Throws:

IOException

unparseKeyValuePairs

public static void unparseKeyValuePairs(org.apache.calcite.sql.SqlWriter writer,
                                        int leftPrec,
                                        int rightPrec,
                                        org.apache.calcite.sql.SqlNodeList list)

Unparses given SqlNodeList into key / values pairs: (k1 = v1, k2 = v2).

Parameters:

writer - sql writer

leftPrec - left precedence

rightPrec - right precedence

list - sql node list