public class SparkHiveStoreCmd extends SparkSQLStoreCmd
AbstractSyntaxTree.LogCounter
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
SQL_CONTEXT_NAME |
static java.lang.String |
SQL_CONTEXT_TYPE |
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 and Description |
---|
SparkHiveStoreCmd(TemplateUtils templateUtils,
oracle.odi.domain.mapping.physical.MapPhysicalNode physicalNode) |
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.
|
generateRDDTypes, generateTargetColumnNames, generateTargetColumnsDF, generateTargetDefinition, generateTargetDefinitionDF, generateTargetTypes, getInferSchema, getJdbcDriver, getJdbcUrl, getOverwriteTargetTable, getSamplingRatio, getServerName, getTargetTableName, getTechno, getTypeEnum, getUser, isMatchSchemaToTargetTypes, isQuotedColumns
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
getCodeGenerationTemplate, getCodeGenerationTemplateName, getCustomTemplate, getKMName, getLeafLevelChildren, getMapPhysicalNode, getOrder, getParentAST, getParentOfType, getPropertyValue, getSourceLanguage, getSourceLocation, getSourceTechnology, getSourceText, getTargetLanguage, getTargetLocation, getTargetTechnology, getTargetText, hasCustomTemplate, hasSourceAndTargetText, isLeafLevelNode, isPushFromSource
public static final java.lang.String SQL_CONTEXT_TYPE
public static final java.lang.String SQL_CONTEXT_NAME
public SparkHiveStoreCmd(TemplateUtils templateUtils, oracle.odi.domain.mapping.physical.MapPhysicalNode physicalNode)
public java.lang.String generateTargetDefinitionHive() throws GenerationException
GenerationException
public java.util.List getPartitionColumns() throws GenerationException
GenerationException
public java.util.List getNonPartitionColumns() throws GenerationException
GenerationException