oracle.odi.mapping.generation.spark

Class SparkHiveStoreCmd

java.lang.Object

oracle.odi.mapping.generation.AbstractSyntaxTree

oracle.odi.mapping.generation.spark.SparkCommand

oracle.odi.mapping.generation.spark.SparkSQLStoreCmd

oracle.odi.mapping.generation.spark.SparkHiveStoreCmd

public class SparkHiveStoreCmd
extends SparkSQLStoreCmd

This is the AST representing a Spark Hive store 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	SQL_CONTEXT_NAME
static java.lang.String	SQL_CONTEXT_TYPE

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

PROPKEY_DF_INFER_SCHEMA, PROPKEY_DF_SAMPLING_RATIO, PROPKEY_JDBC_DRIVER, PROPKEY_JDBC_URL, PROPKEY_JDBC_USER, PROPKEY_OVERWRITE_TGT_TABLE, PROPKEY_SERVER_NAME, PROPKEY_SQL_TGT_TABLE_NAME, PROPKEY_TGT_COLUMN_NAMES, PROPKEY_TGT_COLUMNS_DF, PROPKEY_TGT_CONTAINS_QUOTED_COLS_DF, PROPKEY_TGT_SCHEMA_DEFINITION, PROPKEY_TGT_SCHEMA_DEFINITION_DF, PROPKEY_TGT_SCHEMA_TYPES, PROPKEY_TGT_TECHNO

Constructor Summary

Constructors

Constructor and Description
SparkHiveStoreCmd(TemplateUtils templateUtils, oracle.odi.domain.mapping.physical.MapPhysicalNode physicalNode)

Method Summary

Modifier and Type	Method and Description
java.lang.String	generateTargetDefinitionHive() Get the generated target definition.
java.util.List	getNonPartitionColumns() Get partition columns.
java.util.List	getPartitionColumns() Get partition columns.

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

generateRDDTypes, generateTargetColumnNames, generateTargetColumnsDF, generateTargetDefinition, generateTargetDefinitionDF, generateTargetTypes, getInferSchema, getJdbcDriver, getJdbcUrl, getOverwriteTargetTable, getSamplingRatio, getServerName, getTargetTableName, getTechno, getTypeEnum, getUser, isMatchSchemaToTargetTypes, isQuotedColumns

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

convertExprs, convertExprsDF, getChildren, getCommandIndex, getExprText, getExprTextDF, getFlexField, getModulePaths, getOptionValue, getParentScript, getPhysicalNode, getScriptLevelCommonContext, getSourceAlias, getSourceAliases, getSparkContextName, getSparkContextType, 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

SQL_CONTEXT_TYPE

public static final java.lang.String SQL_CONTEXT_TYPE

See Also:

Constant Field Values

SQL_CONTEXT_NAME

public static final java.lang.String SQL_CONTEXT_NAME

See Also:

Constant Field Values

Constructor Detail

SparkHiveStoreCmd

public SparkHiveStoreCmd(TemplateUtils templateUtils,
                         oracle.odi.domain.mapping.physical.MapPhysicalNode physicalNode)

Method Detail

generateTargetDefinitionHive

public java.lang.String generateTargetDefinitionHive()
                                              throws GenerationException

Get the generated target definition.

Returns:

Throws:

GenerationException

getPartitionColumns

public java.util.List getPartitionColumns()
                                   throws GenerationException

Get partition columns.

Returns:

Throws:

GenerationException

getNonPartitionColumns

public java.util.List getNonPartitionColumns()
                                      throws GenerationException

Get partition columns.

Returns:

Throws:

GenerationException