public static final String |
ACCESS_KEY_PROP_KEY |
"accesskey" |
public static final String |
ACCESS_KEY_PROP_KEY_1 |
"user" |
public static final String |
CATALOG |
"catalog" |
public static final String |
CHARSET_DEFAULT_VALUE |
"UTF-8" |
public static final String |
CHARSET_PROP_KEY |
"charset" |
public static final String |
CHECK_NO_RESULT_QUERY |
"dli.sql.checkNoResultQuery" |
public static final String |
CSV_READ_MAX_COLUMN_NUM |
"dli.max.column.num" |
public static final String |
DATABASE_NAME_PROP_KEY |
"databasename" |
public static final String |
DLI_BOOL_TYPE_TO_INT_KEY |
"dli.boolean.type.return.int" |
public static final String |
DLI_CONF_PREFIX |
"dli." |
public static final String |
DLI_DATE_TYPE_TO_STRING_KEY |
"dli.date.type.return.string" |
public static final String |
DLI_DECIMAL_TYPE_TO_STRING_KEY |
"dli.decimal.type.return.string" |
public static final String |
DLI_PARTITION_TABLE_FORCE_FILTER_KEY |
"spark.sql.forcePartitionPredicatesOnPartitionedTable.enabled" |
public static final String |
DLI_SMALL_MERGE_KEY |
"spark.sql.mergeSmallFiles.enabled" |
public static final String |
ENGINE_TYPE_PROP_KEY |
"enginetype" |
public static final String |
GET_OBS_RESULT_TOTAL_THREAD_NUM_KEY |
"dli.obs.result.total.thread.num" |
public static final String |
GET_ONE_OBS_RESULT_THREAD_NUM_KEY |
"dli.obs.one.result.thread.num" |
public static final String |
JOB_TIMEOUT_PROP_KEY |
"jobtimeout" |
public static final long |
JOB_TIMEOUT_SECOND |
300L |
public static final String |
LAKEFORMATION_ENDPOINT_KEY |
"lakeformation.endpoint" |
public static final String |
LOGCONFFILE_PROP_KEY |
"logconffile" |
public static final String |
MONITOR_PERIOD_PROP_KEY |
"monitorperiod" |
public static final long |
MONITOR_PERIOD_SECOND |
1L |
public static final String |
OBS_ENDPOINT_KEY |
"obs.endpoint" |
public static final String |
OBS_ENDPOINT_KEY_1 |
"obs_endpoint" |
public static final String |
OBS_RETRY_INTERVAL |
"dli.obs.read.retry.interval.second" |
public static final String |
ONE_SQL_RESULT_CACHE_CAPACITY_KEY |
"dli.result.queue.cache.capacity" |
public static final String |
PROJECT_ID_PROP_KEY |
"projectid" |
public static final String |
PROXY_HOST |
"dli.proxy.host" |
public static final String |
PROXY_PASSWORD |
"dli.proxy.password" |
public static final String |
PROXY_PORT |
"dli.proxy.port" |
public static final String |
PROXY_USER |
"dli.proxy.user" |
public static final String |
QUEUE_NAME_PROP_KEY |
"queuename" |
public static final String |
REGION_NAME_PROP_KEY |
"regionname" |
public static final String |
RESULT_DATA_LINE_NUM_KEY |
"dli.result.line.num" |
public static final int |
RESULT_SET_BUFFER_SIZE |
1000 |
public static final String |
SECRET_KEY_PROP_KEY |
"secretkey" |
public static final String |
SECRET_KEY_PROP_KEY_1 |
"password" |
public static final String |
SERVICE_VERSION |
"v1.0" |
public static final String |
SPAKR_CONF_PREFIX |
"spark." |
public static final String |
SQL_CURRENT_DATABASE_KEY |
"dli.sql.current.database" |
public static final String |
SQL_SUBMIT_THREAD_NUM_KEY |
"dli.sql.submit.thread.num" |
public static final String |
TOKEN_PROP_KEY |
"token" |
public static final String |
USE_CACHE_READER |
"read_cache" |