public class ConnectionResource extends Object
Constructor and Description |
---|
ConnectionResource() |
Modifier and Type | Method and Description |
---|---|
static boolean |
acceptURL(String url) |
static ConnectionResource |
constructConnectionResource(Properties info,
String url) |
static ConnectionResource |
extractParamsFromUrl(String url)
Parse JDBC connection URL
The format of the URL is:
jdbc:dli://<endPoint>/projectId?
|
String |
getEndpoint() |
String |
getLakeformationEndpoint() |
String |
getObsEndpoint() |
boolean |
getUserCacheReader() |
static boolean |
isCharsetName(String charsetName) |
void |
loadPropertiesFromConf(Map map) |
com.huawei.dli.sdk.common.DLIInfo |
toDliInfo() |
public static final String ACCESS_KEY_PROP_KEY
public static final String ACCESS_KEY_PROP_KEY_1
public static final String SECRET_KEY_PROP_KEY
public static final String SECRET_KEY_PROP_KEY_1
public static final String REGION_NAME_PROP_KEY
public static final String QUEUE_NAME_PROP_KEY
public static final String ENGINE_TYPE_PROP_KEY
public static final String DATABASE_NAME_PROP_KEY
public static final String SQL_CURRENT_DATABASE_KEY
public static final String MONITOR_PERIOD_PROP_KEY
public static final String JOB_TIMEOUT_PROP_KEY
public static final String PROJECT_ID_PROP_KEY
public static final String TOKEN_PROP_KEY
public static final String LOGCONFFILE_PROP_KEY
public static final String CHARSET_PROP_KEY
public static final String DLI_CONF_PREFIX
public static final String CATALOG
public static final String SPAKR_CONF_PREFIX
public static final String CHECK_NO_RESULT_QUERY
public static final String OBS_ENDPOINT_KEY
public static final String USE_CACHE_READER
public static final String OBS_ENDPOINT_KEY_1
public static final String OBS_RETRY_INTERVAL
public static final String LAKEFORMATION_ENDPOINT_KEY
public static final String GET_ONE_OBS_RESULT_THREAD_NUM_KEY
public static final String GET_OBS_RESULT_TOTAL_THREAD_NUM_KEY
public static final String SQL_SUBMIT_THREAD_NUM_KEY
public static final String RESULT_DATA_LINE_NUM_KEY
public static final String ONE_SQL_RESULT_CACHE_CAPACITY_KEY
public static final String PROXY_HOST
public static final String PROXY_PORT
public static final String PROXY_USER
public static final String PROXY_PASSWORD
public static final String CSV_READ_MAX_COLUMN_NUM
public static final String DLI_PARTITION_TABLE_FORCE_FILTER_KEY
public static final String DLI_SMALL_MERGE_KEY
public static final String DLI_BOOL_TYPE_TO_INT_KEY
public static final String DLI_DECIMAL_TYPE_TO_STRING_KEY
public static final String DLI_DATE_TYPE_TO_STRING_KEY
public static final long MONITOR_PERIOD_SECOND
public static final long JOB_TIMEOUT_SECOND
public static final String SERVICE_VERSION
public static final String CHARSET_DEFAULT_VALUE
public static final int RESULT_SET_BUFFER_SIZE
public String getObsEndpoint()
public boolean getUserCacheReader()
public String getLakeformationEndpoint()
public static boolean acceptURL(String url)
public static boolean isCharsetName(String charsetName)
public String getEndpoint()
public static ConnectionResource constructConnectionResource(Properties info, String url) throws DliException
DliException
public static ConnectionResource extractParamsFromUrl(String url) throws DliException
url
- the connection urlDliException
- If fail to call the API, e.g. server error or cannot deserialize the response bodypublic void loadPropertiesFromConf(Map map) throws DliException
DliException
public com.huawei.dli.sdk.common.DLIInfo toDliInfo()
Copyright © 2025. All rights reserved.