org.apache.spark.sql.hive

Class HiveQl

Object

org.apache.spark.sql.hive.HiveQl

public class HiveQl
extends Object

Provides a mapping from HiveQL statements to catalyst logical plans and expression trees.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	HiveQl.Token$ Extractor for matching Hive's AST Tokens.
static class	HiveQl.TransformableNode A set of implicit transformations that allow Hive ASTNodes to be rewritten by transformations similar to catalyst.trees.TreeNode.

Constructor Summary

Constructors

Constructor and Description
HiveQl()

Method Summary

Methods

Modifier and Type	Method and Description
static scala.util.matching.Regex	allJoinTokens()
static scala.util.matching.Regex	AND()
static scala.util.matching.Regex	ARRAY()
static scala.util.matching.Regex	AVG()
static scala.util.matching.Regex	BETWEEN()
static scala.util.matching.Regex	CASE()
static scala.util.matching.Regex	COALESCE()
static scala.util.matching.Regex	COUNT()
static org.apache.spark.sql.catalyst.plans.logical.LogicalPlan	createPlan(String sql) Creates LogicalPlan for a given HiveQL string.
static org.apache.spark.sql.catalyst.plans.logical.Subquery	createPlanForView(org.apache.hadoop.hive.ql.metadata.Table view, scala.Option<String> alias)
static scala.util.matching.Regex	destinationToken()
static scala.util.matching.Regex	DIV()
static scala.collection.mutable.StringBuilder	dumpTree(org.apache.hadoop.hive.ql.lib.Node node, scala.collection.mutable.StringBuilder builder, int indent)
static scala.util.matching.Regex	errorRegEx()
static scala.util.matching.Regex	explode()
static scala.util.matching.Regex	FALSE()
static org.apache.hadoop.hive.ql.parse.ASTNode	getAst(String sql) Returns the AST for the given SQL string.
static org.apache.hadoop.hive.ql.lib.Node	getClause(String clauseName, scala.collection.Seq<org.apache.hadoop.hive.ql.lib.Node> nodeList)
static scala.Option<org.apache.hadoop.hive.ql.lib.Node>	getClauseOption(String clauseName, scala.collection.Seq<org.apache.hadoop.hive.ql.lib.Node> nodeList)
static scala.util.matching.Regex	IN()
static scala.util.matching.Regex	laterViewToken()
static scala.util.matching.Regex	LIKE()
static scala.util.matching.Regex	LOWER()
static scala.util.matching.Regex	MAX()
static scala.util.matching.Regex	MIN()
static org.apache.spark.sql.catalyst.expressions.Generator	nodesToGenerator(scala.collection.Seq<org.apache.hadoop.hive.ql.lib.Node> nodes)
static org.apache.spark.sql.catalyst.plans.logical.LogicalPlan	nodeToRelation(org.apache.hadoop.hive.ql.lib.Node node)
static org.apache.spark.sql.catalyst.expressions.SortOrder	nodeToSortOrder(org.apache.hadoop.hive.ql.lib.Node node)
static scala.util.matching.Regex	NOT()
static scala.collection.Seq<Object>	numericAstTypes()
static scala.util.matching.Regex	OR()
static scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Attribute>	parseDdl(String ddl)
static org.apache.spark.sql.catalyst.plans.logical.LogicalPlan	parseSql(String sql) Returns a LogicalPlan for a given HiveQL string.
static scala.util.matching.Regex	RAND()
static scala.util.matching.Regex	REGEXP()
static scala.util.matching.Regex	RLIKE()
static scala.util.matching.Regex	SQRT()
static scala.util.matching.Regex	SUBSTR()
static scala.util.matching.Regex	SUM()
static scala.util.matching.Regex	TRUE()
static scala.util.matching.Regex	UPPER()
static scala.util.matching.Regex	WHEN()

Methods inherited from class Object

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

Constructor Detail

HiveQl

public HiveQl()

Method Detail

getAst

public static org.apache.hadoop.hive.ql.parse.ASTNode getAst(String sql)

Returns the AST for the given SQL string.

parseSql

public static org.apache.spark.sql.catalyst.plans.logical.LogicalPlan parseSql(String sql)

Returns a LogicalPlan for a given HiveQL string.

errorRegEx

public static scala.util.matching.Regex errorRegEx()

createPlan

public static org.apache.spark.sql.catalyst.plans.logical.LogicalPlan createPlan(String sql)

Creates LogicalPlan for a given HiveQL string.

createPlanForView

public static org.apache.spark.sql.catalyst.plans.logical.Subquery createPlanForView(org.apache.hadoop.hive.ql.metadata.Table view,
                                                                     scala.Option<String> alias)

parseDdl

public static scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Attribute> parseDdl(String ddl)

getClause

public static org.apache.hadoop.hive.ql.lib.Node getClause(String clauseName,
                                           scala.collection.Seq<org.apache.hadoop.hive.ql.lib.Node> nodeList)

getClauseOption

public static scala.Option<org.apache.hadoop.hive.ql.lib.Node> getClauseOption(String clauseName,
                                                               scala.collection.Seq<org.apache.hadoop.hive.ql.lib.Node> nodeList)

allJoinTokens

public static scala.util.matching.Regex allJoinTokens()

laterViewToken

public static scala.util.matching.Regex laterViewToken()

nodeToRelation

public static org.apache.spark.sql.catalyst.plans.logical.LogicalPlan nodeToRelation(org.apache.hadoop.hive.ql.lib.Node node)

nodeToSortOrder

public static org.apache.spark.sql.catalyst.expressions.SortOrder nodeToSortOrder(org.apache.hadoop.hive.ql.lib.Node node)

destinationToken

public static scala.util.matching.Regex destinationToken()

numericAstTypes

public static scala.collection.Seq<Object> numericAstTypes()

ARRAY

public static scala.util.matching.Regex ARRAY()

COALESCE

public static scala.util.matching.Regex COALESCE()

COUNT

public static scala.util.matching.Regex COUNT()

AVG

public static scala.util.matching.Regex AVG()

SUM

public static scala.util.matching.Regex SUM()

MAX

public static scala.util.matching.Regex MAX()

MIN

public static scala.util.matching.Regex MIN()

UPPER

public static scala.util.matching.Regex UPPER()

LOWER

public static scala.util.matching.Regex LOWER()

RAND

public static scala.util.matching.Regex RAND()

AND

public static scala.util.matching.Regex AND()

OR

public static scala.util.matching.Regex OR()

NOT

public static scala.util.matching.Regex NOT()

TRUE

public static scala.util.matching.Regex TRUE()

FALSE

public static scala.util.matching.Regex FALSE()

LIKE

public static scala.util.matching.Regex LIKE()

RLIKE

public static scala.util.matching.Regex RLIKE()

REGEXP

public static scala.util.matching.Regex REGEXP()

IN

public static scala.util.matching.Regex IN()

DIV

public static scala.util.matching.Regex DIV()

BETWEEN

public static scala.util.matching.Regex BETWEEN()

WHEN

public static scala.util.matching.Regex WHEN()

CASE

public static scala.util.matching.Regex CASE()

SUBSTR

public static scala.util.matching.Regex SUBSTR()

SQRT

public static scala.util.matching.Regex SQRT()

explode

public static scala.util.matching.Regex explode()

nodesToGenerator

public static org.apache.spark.sql.catalyst.expressions.Generator nodesToGenerator(scala.collection.Seq<org.apache.hadoop.hive.ql.lib.Node> nodes)

dumpTree

public static scala.collection.mutable.StringBuilder dumpTree(org.apache.hadoop.hive.ql.lib.Node node,
                                              scala.collection.mutable.StringBuilder builder,
                                              int indent)