public class SparkSQLCmd extends SparkCommand
AbstractSyntaxTree.LogCounter
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
PROP_KEY_NEED_FORMAT_OUTPUT |
static java.lang.String |
PROPKEY_ALLOW_FILTERING |
static java.lang.String |
PROPKEY_INDENT |
static java.lang.String |
PROPKEY_JDBC_DRIVER |
static java.lang.String |
PROPKEY_JDBC_URL |
static java.lang.String |
PROPKEY_JDBC_USER |
static java.lang.String |
PROPKEY_LOWER_BOUND |
static java.lang.String |
PROPKEY_NB_PARTITIONS |
static java.lang.String |
PROPKEY_OUTPUT_SCHEMA_DEF |
static java.lang.String |
PROPKEY_OUTPUT_SCHEMA_DEF_DF |
static java.lang.String |
PROPKEY_PARTITION_COLUMN |
static java.lang.String |
PROPKEY_PREDICATES |
static java.lang.String |
PROPKEY_SERVER_NAME |
static java.lang.String |
PROPKEY_SQL_STATEMENT |
static java.lang.String |
PROPKEY_SRC_SCHEMA |
static java.lang.String |
PROPKEY_UPPER_BOUND |
static java.lang.String |
PROPKEY_USE_PARTITION_COL |
static java.lang.String |
PROPKEY_USE_PREDICATES |
static java.lang.String |
PROPKEY_USE_QUERY_ALIAS |
static java.lang.String |
SQL_CONTEXT_NAME |
static java.lang.String |
SQL_CONTEXT_TYPE |
Modifier and Type | Method and Description |
---|---|
java.util.List |
getAPNodeAttributes()
Gets list of AP node attributes.
|
java.lang.String |
getJdbcDriver()
Get the name of JDBC driver.
|
java.lang.String |
getJdbcUrl()
Get the JDBC URL.
|
long |
getLowerBound()
Get lower bound of partitions.
|
int |
getNumPartitions()
Get the number of the partitions.
|
java.lang.String |
getOutputSchemaConnectedFields()
Gets list of connected fields for output schema.
|
java.lang.String |
getOutputSchemaDefinition()
Gets the definition for output schema
|
java.lang.String |
getOutputSchemaDefinitionRow()
Gets the definition of output schema for sql format
|
java.lang.String |
getOutputSchemaFields()
Gets list of fields for output schema.
|
java.lang.String |
getOutputSchemaFieldsDF()
Gets list of fields for output schema, specific to DataFrames.
|
java.lang.String |
getPartitionColumn()
Get the partition column.
|
java.lang.String |
getPartitionPredicates()
Get the partition predicates
|
java.lang.String |
getServerName()
Get the name of the server.
|
java.lang.String |
getSparkContextName()
Gets the context name for Spark.
|
java.lang.String |
getSparkContextType()
Gets the context type for Spark.
|
SqlQuery |
getSQLStatement()
Get the Sql Statement for this command.
|
java.lang.String |
getSrcSchemaName()
Get the name of source schema.
|
SparkCommandType |
getTypeEnum()
Get the type of spark command
|
long |
getUpperBound()
Get upper bound of partitions.
|
java.lang.String |
getUser()
Get the user name used in JDBC URL.
|
boolean |
isFilteringAllowed()
Return true if filtering is allowed.
|
boolean |
needFormatOutput()
Return true if output format is needed.
|
boolean |
needPartitionColumn()
Return true if partition column is needed.
|
boolean |
needPartitionPredicates()
Return true if partition predicates are needed.
|
boolean |
useQueryAlias()
Return true if source query alias is needed.
|
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
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 PROPKEY_OUTPUT_SCHEMA_DEF
public static final java.lang.String PROP_KEY_NEED_FORMAT_OUTPUT
public static final java.lang.String PROPKEY_SQL_STATEMENT
public static final java.lang.String PROPKEY_JDBC_URL
public static final java.lang.String PROPKEY_JDBC_DRIVER
public static final java.lang.String PROPKEY_JDBC_USER
public static final java.lang.String PROPKEY_SERVER_NAME
public static final java.lang.String PROPKEY_SRC_SCHEMA
public static final java.lang.String PROPKEY_PARTITION_COLUMN
public static final java.lang.String PROPKEY_LOWER_BOUND
public static final java.lang.String PROPKEY_UPPER_BOUND
public static final java.lang.String PROPKEY_NB_PARTITIONS
public static final java.lang.String PROPKEY_PREDICATES
public static final java.lang.String PROPKEY_USE_PREDICATES
public static final java.lang.String PROPKEY_USE_PARTITION_COL
public static final java.lang.String PROPKEY_ALLOW_FILTERING
public static final java.lang.String PROPKEY_USE_QUERY_ALIAS
public static final java.lang.String PROPKEY_INDENT
public static final java.lang.String SQL_CONTEXT_TYPE
public static final java.lang.String SQL_CONTEXT_NAME
public static final java.lang.String PROPKEY_OUTPUT_SCHEMA_DEF_DF
public SparkCommandType getTypeEnum()
getTypeEnum
in class SparkCommand
public java.lang.String getJdbcUrl()
public java.lang.String getJdbcDriver()
public java.lang.String getUser()
public java.lang.String getSrcSchemaName()
public java.lang.String getServerName()
public java.lang.String getPartitionColumn()
public long getLowerBound()
public long getUpperBound()
public int getNumPartitions()
public boolean needPartitionColumn()
public java.lang.String getPartitionPredicates()
public boolean needPartitionPredicates()
public boolean isFilteringAllowed()
public boolean useQueryAlias()
public SqlQuery getSQLStatement()
public boolean needFormatOutput()
public java.lang.String getOutputSchemaDefinition() throws GenerationException
GenerationException
public java.lang.String getOutputSchemaDefinitionRow() throws GenerationException
GenerationException
public java.lang.String getOutputSchemaFields() throws GenerationException
GenerationException
public java.lang.String getOutputSchemaFieldsDF() throws GenerationException
GenerationException
public java.lang.String getOutputSchemaConnectedFields() throws GenerationException
GenerationException
public java.util.List getAPNodeAttributes() throws GenerationException
GenerationException
public java.lang.String getSparkContextType()
getSparkContextType
in class SparkCommand
public java.lang.String getSparkContextName()
getSparkContextName
in class SparkCommand