public class ConnectionResource extends Object
Modifier and Type | Class and Description |
---|---|
static class |
ConnectionResource.AuthenticationMode |
static class |
ConnectionResource.Protocol |
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?conf_list
jdbc:uquery://<endPoint>/projectId?conf_list is derepcated
jdbc:luxor://<endPoint>/projectId?conf_list is derepcated
where the conf_list is semicolon separated <key>=<val> pairs.
|
int |
getDirectFetchThreshold() |
String |
getEndpoint() |
String |
getIamEndpoint() |
String |
getObsEndpoint() |
static boolean |
isCharsetName(String charsetName) |
void |
loadPropertiesFromConf(Map map) |
public static final String ACCESS_KEY_PROP_KEY
public static final String SECRET_KEY_PROP_KEY
public static final String REGION_NAME_PROP_KEY
public static final String SERVICE_NAME_PROP_KEY
public static final String QUEUE_NAME_PROP_KEY
public static final String DATABASE_NAME_PROP_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 LOGCONFFILE_PROP_KEY
public static final String CHARSET_PROP_KEY
public static final String TOKEN_PROP_KEY
public static final String AUTHENTICATION_MODE_PROP_KEY
public static final String PROTOCOL_PROP_KEY
public static final String DLI_CONF_PREFIX
public static final String USE_PROXY_PROP_KEY
public static final String PROXY_HOST_PROP_KEY
public static final String PROXY_PORT_PROP_KEY
public static final String SQL_SYNC_MODE_KEY
public static final String CHECK_NO_RESULT_QUERY
public static final String USE_RETRY_KEY
public static final String RETRY_TIMES_KEY
public static final String RETRY_INTERVALS_KEY
public static final String IAM_ENDPOINT_KEY
public static final String OBS_ENDPOINT_KEY
public static final String DIRECT_FETCH_THRESHOLD_KEY
public static final String EXPORT_USE_BUFFER_THRESHOLD_KEY
public static final String EXPORT_INNER_THREAD_NUM_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 static final ConnectionResource.Protocol DEFAULT_PROTOCOL
public String getIamEndpoint()
public String getObsEndpoint()
public int getDirectFetchThreshold()
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
Copyright © 2023. All rights reserved.