org.apache.flink.table.planner.delegation.hive.copy

Class HiveParserContext

java.lang.Object

org.apache.flink.table.planner.delegation.hive.copy.HiveParserContext

public class HiveParserContext
extends Object

Counterpart of hive's org.apache.hadoop.hive.ql.Context.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	HiveParserContext.DestClausePrefix DestClausePrefix.
static class	HiveParserContext.Operation These ops require special handling in various places (note that Insert into Acid table is in OTHER category).

Field Summary

Fields

Modifier and Type	Field and Description
protected int	pathid

Constructor Summary

Constructors

Constructor and Description
HiveParserContext(org.apache.hadoop.conf.Configuration conf) Create a HiveParserContext with a given executionId.

Method Summary

Modifier and Type	Method and Description
void	addViewTokenRewriteStream(String viewFullyQualifiedName, org.antlr.runtime.TokenRewriteStream tokenRewriteStream)
org.apache.hadoop.conf.Configuration	getConf()
HiveParserContext.DestClausePrefix	getDestNamePrefix(HiveParserASTNode curNode) The suffix is always relative to a given HiveParserASTNode.
org.antlr.runtime.TokenRewriteStream	getTokenRewriteStream()
boolean	isExplainSkipExecution()
void	setTokenRewriteStream(org.antlr.runtime.TokenRewriteStream tokenRewriteStream) Set the token rewrite stream being used to parse the current top-level SQL statement.

Methods inherited from class java.lang.Object

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

Field Detail

pathid

protected int pathid

Constructor Detail

HiveParserContext

public HiveParserContext(org.apache.hadoop.conf.Configuration conf)

Create a HiveParserContext with a given executionId. ExecutionId, together with user name and conf, will determine the temporary directory locations.

Method Detail

getDestNamePrefix

public HiveParserContext.DestClausePrefix getDestNamePrefix(HiveParserASTNode curNode)

The suffix is always relative to a given HiveParserASTNode.

isExplainSkipExecution

public boolean isExplainSkipExecution()

setTokenRewriteStream

public void setTokenRewriteStream(org.antlr.runtime.TokenRewriteStream tokenRewriteStream)

Set the token rewrite stream being used to parse the current top-level SQL statement. Note that this should not be used for other parsing activities; for example, when we encounter a reference to a view, we switch to a new stream for parsing the stored view definition from the catalog, but we don't clobber the top-level stream in the context.

Parameters:

tokenRewriteStream - the stream being used

getTokenRewriteStream

public org.antlr.runtime.TokenRewriteStream getTokenRewriteStream()

Returns:

the token rewrite stream being used to parse the current top-level SQL statement, or null if it isn't available (e.g. for parser tests)

addViewTokenRewriteStream

public void addViewTokenRewriteStream(String viewFullyQualifiedName,
                                      org.antlr.runtime.TokenRewriteStream tokenRewriteStream)

getConf

public org.apache.hadoop.conf.Configuration getConf()