oracle.odi.mapping.generation.spark

Class SparkStoreCmd

java.lang.Object

oracle.odi.mapping.generation.AbstractSyntaxTree

oracle.odi.mapping.generation.spark.SparkCommand

oracle.odi.mapping.generation.spark.SparkStoreCmd

public class SparkStoreCmd
extends SparkCommand

This is the AST representing a Spark store command.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	SparkStoreCmd.StoreField

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

Method Summary

Modifier and Type	Method and Description
java.util.List	generateTargetColumnNames() Generate the names for target columns.
java.lang.String	generateTargetColumnsDF() Generate the target columns list.
java.lang.String	generateTargetDefinition() Generate the target definition.
java.lang.String	generateTargetDefinitionDF() Generate the target definition for dataframes.
java.util.List	generateTargetTypes() Generate list of target types.
java.lang.String	getBootstrapServers() Get the bootstrap servers.
java.lang.String	getDirectory() Get the directory name.
java.lang.String	getFieldSep() Get the field separator.
java.util.List	getFullTgtAttrs() Get full target attributes.
java.lang.String	getOutputAvroSchemaDef()
java.lang.String	getRowSep() Get the row separator.
int	getSampleRatio()
java.lang.String	getStorageFormat()
java.lang.String	getStoreFuncArgs() Get the arguments of store functions.
java.lang.String	getStoreFunction() Get the name for the store function.
java.lang.String	getStoreOptions() Get the store options.
java.lang.String	getTargetSchema() Get the target schema.
java.lang.String	getTechnologyType() Get the technology type.
java.util.List	getTgtAttrExprs() Get the expressions for target attributes.
java.util.List	getTgtAttrNames() Get the names of target attributes.
java.util.List	getTgtDataTypes() Get the list of target data types.
SparkCommandType	getTypeEnum() Get the type of spark command
boolean	isFlattenInput() Return true if flatten input is used.
boolean	isHasScaledField() Return true if scaled field is used.
boolean	isInferSourceSchema()
boolean	isQuotedColumns() Return true target table columns need to be quoted.
boolean	isStoreKeys() Return true of keys are needed to store.
boolean	isStoreToFile() Return true if this command is used to store to a file.
void	setInferSourceSchema(boolean inferSourceSchema)
void	setOutputAvroSchemaDef(java.lang.String outputAvroSchemaDef)
void	setSampleRatio(int sampleRatio)
void	setStorageFormat(java.lang.String storageFormat)

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, 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

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

Method Detail

getTypeEnum

public SparkCommandType getTypeEnum()

Get the type of spark command

Specified by:

getTypeEnum in class SparkCommand

Returns:

The SparkCommandType enum value.

getBootstrapServers

public java.lang.String getBootstrapServers()

Get the bootstrap servers.

Returns:

The bootstrap servers.

getTargetSchema

public java.lang.String getTargetSchema()

Get the target schema.

Returns:

The target schema.

getDirectory

public java.lang.String getDirectory()

Get the directory name.

Returns:

The directory name.

getStoreFunction

public java.lang.String getStoreFunction()

Get the name for the store function.

Returns:

The name for the store function.

getStoreFuncArgs

public java.lang.String getStoreFuncArgs()

Get the arguments of store functions.

Returns:

The arguments of store functions.

getTgtAttrExprs

public java.util.List getTgtAttrExprs()

Get the expressions for target attributes.

Returns:

The expressions for target attributes.

getTgtAttrNames

public java.util.List getTgtAttrNames()

Get the names of target attributes.

Returns:

The names of target attributes.

getFullTgtAttrs

public java.util.List getFullTgtAttrs()

Get full target attributes.

Returns:

The full target attributes.

isFlattenInput

public boolean isFlattenInput()

Return true if flatten input is used.

Returns:

Boolean

isHasScaledField

public boolean isHasScaledField()

Return true if scaled field is used.

Returns:

Boolean

isInferSourceSchema

public boolean isInferSourceSchema()

setInferSourceSchema

public void setInferSourceSchema(boolean inferSourceSchema)

getSampleRatio

public int getSampleRatio()

setSampleRatio

public void setSampleRatio(int sampleRatio)

generateTargetDefinition

public java.lang.String generateTargetDefinition()
                                          throws GenerationException

Generate the target definition.

Returns:

The target definition.

Throws:

GenerationException

generateTargetTypes

public java.util.List generateTargetTypes()
                                   throws GenerationException

Generate list of target types.

Returns:

The list of target types.

Throws:

GenerationException

getFieldSep

public java.lang.String getFieldSep()

Get the field separator.

Returns:

The field separator.

getRowSep

public java.lang.String getRowSep()

Get the row separator.

Returns:

The row separator.

getTgtDataTypes

public java.util.List getTgtDataTypes()

Get the list of target data types.

Returns:

The list of target data types.

isStoreKeys

public boolean isStoreKeys()

Return true of keys are needed to store.

Returns:

Boolean

isStoreToFile

public boolean isStoreToFile()

Return true if this command is used to store to a file.

Returns:

Boolean

getTechnologyType

public java.lang.String getTechnologyType()

Get the technology type.

Returns:

The technology type.

getStoreOptions

public java.lang.String getStoreOptions()

Get the store options.

Returns:

The store options.

getStorageFormat

public java.lang.String getStorageFormat()

setStorageFormat

public void setStorageFormat(java.lang.String storageFormat)

isQuotedColumns

public boolean isQuotedColumns()

Return true target table columns need to be quoted.

getOutputAvroSchemaDef

public java.lang.String getOutputAvroSchemaDef()

setOutputAvroSchemaDef

public void setOutputAvroSchemaDef(java.lang.String outputAvroSchemaDef)

generateTargetDefinitionDF

public java.lang.String generateTargetDefinitionDF()
                                            throws GenerationException

Generate the target definition for dataframes.

Returns:

The target definition for dataframes.

Throws:

GenerationException

generateTargetColumnNames

public java.util.List generateTargetColumnNames()
                                         throws GenerationException

Generate the names for target columns.

Returns:

The names for target columns.

Throws:

GenerationException

generateTargetColumnsDF

public java.lang.String generateTargetColumnsDF()
                                         throws GenerationException

Generate the target columns list.

Returns:

Throws:

GenerationException