oracle.odi.mapping.generation.spark

Class SparkHqlCmd

java.lang.Object

oracle.odi.mapping.generation.AbstractSyntaxTree

oracle.odi.mapping.generation.spark.SparkCommand

oracle.odi.mapping.generation.spark.SparkSQLCmd

oracle.odi.mapping.generation.spark.SparkHqlCmd

public class SparkHqlCmd
extends SparkSQLCmd

This is the AST representing a Spark Hql command.

Nested Class Summary

Nested classes/interfaces inherited from class oracle.odi.mapping.generation.AbstractSyntaxTree

AbstractSyntaxTree.LogCounter

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	HIVE_CONTEXT_NAME
static java.lang.String	HIVE_CONTEXT_TYPE

Fields inherited from class oracle.odi.mapping.generation.spark.SparkSQLCmd

PROP_KEY_NEED_FORMAT_OUTPUT, PROPKEY_ALLOW_FILTERING, PROPKEY_INDENT, PROPKEY_JDBC_DRIVER, PROPKEY_JDBC_URL, PROPKEY_JDBC_USER, PROPKEY_LOWER_BOUND, PROPKEY_NB_PARTITIONS, PROPKEY_OUTPUT_SCHEMA_DEF, PROPKEY_OUTPUT_SCHEMA_DEF_DF, PROPKEY_PARTITION_COLUMN, PROPKEY_PREDICATES, PROPKEY_SERVER_NAME, PROPKEY_SQL_STATEMENT, PROPKEY_SRC_SCHEMA, PROPKEY_UPPER_BOUND, PROPKEY_USE_PARTITION_COL, PROPKEY_USE_PREDICATES, PROPKEY_USE_QUERY_ALIAS, SQL_CONTEXT_NAME, SQL_CONTEXT_TYPE

Constructor Summary

Constructors

Constructor and Description
SparkHqlCmd(TemplateUtils templateUtils, MapPhysicalNode physicalNode, SqlQuery sqlToCall)

Method Summary

Modifier and Type	Method and Description
java.lang.String	getSparkContextName() Get the Hive context name.
java.lang.String	getSparkContextType() Get the Hive context type.

Methods inherited from class oracle.odi.mapping.generation.spark.SparkSQLCmd

getAPNodeAttributes, getJdbcDriver, getJdbcUrl, getLowerBound, getNumPartitions, getOutputSchemaConnectedFields, getOutputSchemaDefinition, getOutputSchemaDefinitionRow, getOutputSchemaFields, getOutputSchemaFieldsDF, getPartitionColumn, getPartitionPredicates, getServerName, getSQLStatement, getSrcSchemaName, getTypeEnum, getUpperBound, getUser, isFilteringAllowed, needFormatOutput, needPartitionColumn, needPartitionPredicates, useQueryAlias

Methods inherited from class oracle.odi.mapping.generation.spark.SparkCommand

convertExprs, convertExprsDF, getChildren, getCommandIndex, getExprText, getExprTextDF, getFlexField, getModulePaths, getOptionValue, getParentScript, getPhysicalNode, getScriptLevelCommonContext, getSourceAlias, getSourceAliases, getStrctType, getStreamEnableWindowing, getStreamSlideInterval, getStreamWindowLength, getTargetAlias, getTemplateSubstitutionMap, getText, getType, isStreamingMode, setSourceAliases, toString, useSQLExpressions

Methods inherited from class oracle.odi.mapping.generation.AbstractSyntaxTree

getCodeGenerationTemplate, getCodeGenerationTemplateName, getCustomTemplate, getKMName, getLeafLevelChildren, getMapPhysicalNode, getOrder, getParentAST, getParentOfType, getPropertyValue, getSourceLanguage, getSourceLocation, getSourceTechnology, getSourceText, getTargetLanguage, getTargetLocation, getTargetTechnology, getTargetText, hasCustomTemplate, hasSourceAndTargetText, isLeafLevelNode, isPushFromSource

Methods inherited from class java.lang.Object

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

Field Detail

HIVE_CONTEXT_TYPE

public static final java.lang.String HIVE_CONTEXT_TYPE

See Also:

Constant Field Values

HIVE_CONTEXT_NAME

public static final java.lang.String HIVE_CONTEXT_NAME

See Also:

Constant Field Values

Constructor Detail

SparkHqlCmd

public SparkHqlCmd(TemplateUtils templateUtils,
                   MapPhysicalNode physicalNode,
                   SqlQuery sqlToCall)

Method Detail

getSparkContextType

public java.lang.String getSparkContextType()

Get the Hive context type.

Overrides:

getSparkContextType in class SparkSQLCmd

getSparkContextName

public java.lang.String getSparkContextName()

Get the Hive context name.

Overrides:

getSparkContextName in class SparkSQLCmd