org.apache.flink.sql.parser

Class SqlPartitionUtils

java.lang.Object

org.apache.flink.sql.parser.SqlPartitionUtils

public class SqlPartitionUtils
extends Object

Utils methods for partition DDLs.

Method Summary

Modifier and Type	Method and Description
static LinkedHashMap<String,String>	getPartitionKVs(org.apache.calcite.sql.SqlNodeList partitionSpec) Get static partition key value pair as strings.

Methods inherited from class java.lang.Object

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

Method Detail

getPartitionKVs

public static LinkedHashMap<String,String> getPartitionKVs(org.apache.calcite.sql.SqlNodeList partitionSpec)

Get static partition key value pair as strings.

For character literals we return the unquoted and unescaped values. For other types we use SqlNode.toString() to get the string format of the value literal.

Returns:

the mapping of column names to values of partition specifications, returns an empty map if there is no partition specifications.