Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
AST_PROP_TEMPLATE_UTILS |
"AST_PROP_TEMPLATE_UTILS" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
PIG_PROPKEY_REGISTER_PATHS |
"REGISTER_PATHS" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
SELECT_HINT_OPTION_KEY |
"SELECT_HINT" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
LANGUAGE_NONE |
"NONE" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
SQL_CONTEXT_NAME |
"hiveCtx" |
public static final java.lang.String |
SQL_CONTEXT_TYPE |
"HiveContext" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
HIVE_CONTEXT_NAME |
"hiveCtx" |
public static final java.lang.String |
HIVE_CONTEXT_TYPE |
"HiveContext" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
CONTEXT_AGGREGATE_FUNCTIONS |
"AGGREGATE_FUNCTIONS" |
public static final java.lang.String |
CONTEXT_DICT_2_TUPLE |
"DICT_2_TUPLE" |
public static final java.lang.String |
CONTEXT_HIVE_CONTEXT |
"HIVE_CONTEXT" |
public static final java.lang.String |
CONTEXT_JSON_SUPPORT |
"JSON_SUPPORT" |
public static final java.lang.String |
CONTEXT_NONE_RDD_SUPPORT |
"NONE_RDD_SUPPORT" |
public static final java.lang.String |
CONTEXT_SPARK_CONTEXT |
"SPARK_CONTEXT" |
public static final java.lang.String |
CONTEXT_SQL_CONTEXT |
"SQL_CONTEXT" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
PROPKEY_REGISTER_PATHS |
"REGISTER_PATHS" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
PROP_KEY_NEED_FORMAT_OUTPUT |
"NEED_FORMAT_OUTPUT" |
public static final java.lang.String |
PROPKEY_ALLOW_FILTERING |
"ALLOW_FILTERING" |
public static final java.lang.String |
PROPKEY_INDENT |
"INDENT" |
public static final java.lang.String |
PROPKEY_JDBC_DRIVER |
"JDBC_DRIVER" |
public static final java.lang.String |
PROPKEY_JDBC_URL |
"JDBC_URL" |
public static final java.lang.String |
PROPKEY_JDBC_USER |
"JDBC_USER" |
public static final java.lang.String |
PROPKEY_LOWER_BOUND |
"LOWER_BOUND" |
public static final java.lang.String |
PROPKEY_NB_PARTITIONS |
"NB_PARTITIONS" |
public static final java.lang.String |
PROPKEY_OUTPUT_SCHEMA_DEF |
"OUTPUT_SCHEMA_DEF" |
public static final java.lang.String |
PROPKEY_OUTPUT_SCHEMA_DEF_DF |
"OUTPUT_SCHEMA_DEF_DF" |
public static final java.lang.String |
PROPKEY_PARTITION_COLUMN |
"PARTITION_COLUMN" |
public static final java.lang.String |
PROPKEY_PREDICATES |
"PREDICATES" |
public static final java.lang.String |
PROPKEY_SERVER_NAME |
"SERVER_NAME" |
public static final java.lang.String |
PROPKEY_SQL_STATEMENT |
"SQL_STATEMENT" |
public static final java.lang.String |
PROPKEY_SRC_SCHEMA |
"SRC_SCHEMA" |
public static final java.lang.String |
PROPKEY_UPPER_BOUND |
"UPPER_BOUND" |
public static final java.lang.String |
PROPKEY_USE_PARTITION_COL |
"USE_PARTITION_COL" |
public static final java.lang.String |
PROPKEY_USE_PREDICATES |
"USE_PREDICATES" |
public static final java.lang.String |
PROPKEY_USE_QUERY_ALIAS |
"USE_QUERY_ALIAS" |
public static final java.lang.String |
SQL_CONTEXT_NAME |
"sqlCtx" |
public static final java.lang.String |
SQL_CONTEXT_TYPE |
"SQLContext" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
PROPKEY_DF_INFER_SCHEMA |
"DF_INFER_SCHEMA" |
public static final java.lang.String |
PROPKEY_DF_SAMPLING_RATIO |
"DF_SAMPLING_RATIO" |
public static final java.lang.String |
PROPKEY_JDBC_DRIVER |
"JDBC_DRIVER" |
public static final java.lang.String |
PROPKEY_JDBC_URL |
"JDBC_URL" |
public static final java.lang.String |
PROPKEY_JDBC_USER |
"JDBC_USER" |
public static final java.lang.String |
PROPKEY_OVERWRITE_TGT_TABLE |
"OVERWRITE_TARGET_TABLE" |
public static final java.lang.String |
PROPKEY_SERVER_NAME |
"SERVER_NAME" |
public static final java.lang.String |
PROPKEY_SQL_TGT_TABLE_NAME |
"SQL_TARGET_TABLE_NAME" |
public static final java.lang.String |
PROPKEY_TGT_COLUMN_NAMES |
"TGT_COLUMN_NAMES" |
public static final java.lang.String |
PROPKEY_TGT_COLUMNS_DF |
"TGT_COLUMNS_DF" |
public static final java.lang.String |
PROPKEY_TGT_CONTAINS_QUOTED_COLS_DF |
"TGT_CONTAINS_QUOTED_COLS_DF" |
public static final java.lang.String |
PROPKEY_TGT_SCHEMA_DEFINITION |
"TGT_SCHEMA_DEFINITION" |
public static final java.lang.String |
PROPKEY_TGT_SCHEMA_DEFINITION_DF |
"TGT_SCHEMA_DEFINITION_DF" |
public static final java.lang.String |
PROPKEY_TGT_SCHEMA_TYPES |
"TGT_SCHEMA_TYPES" |
public static final java.lang.String |
PROPKEY_TGT_TECHNO |
"TGT_TECHNO" |
public static final java.lang.String |
SQL_CONTEXT_NAME |
"sqlContext" |
public static final java.lang.String |
SQL_CONTEXT_TYPE |
"SQLContext" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
SQL_CONTEXT_NAME |
"sqlContext" |
public static final java.lang.String |
SQL_CONTEXT_TYPE |
"SQLContext" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
CUSTOM_IMPORTS |
"customPythonImports" |
public static final java.lang.String |
SPARK_DEFAULT_CONTEXT_NAME |
"sc" |
public static final java.lang.String |
SPARK_DEFAULT_CONTEXT_TYPE |
"SparkContext" |
public static final java.lang.String |
SPARK_PROPERTY_DEFAULT_VALUE_TAG |
"<fromEUDataServer>" |
public static final java.lang.String |
SPARK_PROPERTY_PREFIX |
"spark." |
public static final java.lang.String |
SPARK_PROPERTY_SERVER_INSTANCE_NAME |
"serverInstanceName" |
public static final java.lang.String |
SPARK_WORK_DIR |
"spark-work-dir" |
public static final java.lang.String |
STREAMING_CHECKPOINT_ID |
"spark.checkpoint.id" |
public static final java.lang.String |
STREAMING_MODE |
"STREAMING_MODE" |
public static final java.lang.String |
STREAMING_PROPERTY_BATCH_DURATION |
"spark.batchDuration" |
public static final java.lang.String |
STREAMING_PROPERTY_CHECKPOINTING |
"spark.checkpointing" |
public static final java.lang.String |
STREAMING_PROPERTY_STOP_GRACEFULLY |
"spark-stop-gracefully" |
public static final java.lang.String |
STREAMING_PROPERTY_TIMEOUT |
"spark.streaming.timeout" |
public static final java.lang.String |
USE_DATAFRAMES |
"spark.useDataFrames" |