in tablestore/src/main/java/com/alicloud/openservices/tablestore/core/LauncherFactory.java [46:196]
public LauncherFactory(
String endpoint,
String instanceName,
AsyncServiceClient client,
CredentialsProvider crdsProvider,
ClientConfiguration config)
{
this.instanceName = instanceName;
this.client = client;
this.crdsProvider = crdsProvider;
this.config = config;
contexts.put(OP_CREATE_TABLE,
new Context(new OTSUri(endpoint, OP_CREATE_TABLE)));
contexts.put(OP_DELETE_TABLE,
new Context(new OTSUri(endpoint, OP_DELETE_TABLE)));
contexts.put(OP_DESCRIBE_TABLE,
new Context(new OTSUri(endpoint, OP_DESCRIBE_TABLE)));
contexts.put(OP_LIST_TABLE,
new Context(new OTSUri(endpoint, OP_LIST_TABLE)));
contexts.put(OP_UPDATE_TABLE,
new Context(new OTSUri(endpoint, OP_UPDATE_TABLE)));
contexts.put(OP_CREATE_INDEX,
new Context(new OTSUri(endpoint, OP_CREATE_INDEX)));
contexts.put(OP_DELETE_INDEX,
new Context(new OTSUri(endpoint, OP_DELETE_INDEX)));
contexts.put(OP_ADD_DEFINED_COLUMN,
new Context(new OTSUri(endpoint, OP_ADD_DEFINED_COLUMN)));
contexts.put(OP_DELETE_DEFINED_COLUMN,
new Context(new OTSUri(endpoint, OP_DELETE_DEFINED_COLUMN)));
contexts.put(OP_PUT_ROW,
new Context(new OTSUri(endpoint, OP_PUT_ROW)));
contexts.put(OP_UPDATE_ROW,
new Context(new OTSUri(endpoint, OP_UPDATE_ROW)));
contexts.put(OP_DELETE_ROW,
new Context(new OTSUri(endpoint, OP_DELETE_ROW)));
contexts.put(OP_GET_ROW,
new Context(new OTSUri(endpoint, OP_GET_ROW)));
contexts.put(OP_BATCH_GET_ROW,
new Context(new OTSUri(endpoint, OP_BATCH_GET_ROW)));
contexts.put(OP_BATCH_WRITE_ROW,
new Context(new OTSUri(endpoint, OP_BATCH_WRITE_ROW)));
contexts.put(OP_BULK_IMPORT,
new Context(new OTSUri(endpoint, OP_BULK_IMPORT)));
contexts.put(OP_GET_RANGE,
new Context(new OTSUri(endpoint, OP_GET_RANGE)));
contexts.put(OP_BULK_EXPORT,
new Context(new OTSUri(endpoint, OP_BULK_EXPORT)));
contexts.put(OP_LIST_STREAM,
new Context(new OTSUri(endpoint, OP_LIST_STREAM)));
contexts.put(OP_DESCRIBE_STREAM,
new Context(new OTSUri(endpoint, OP_DESCRIBE_STREAM)));
contexts.put(OP_GET_SHARD_ITERATOR,
new Context(new OTSUri(endpoint, OP_GET_SHARD_ITERATOR)));
contexts.put(OP_GET_STREAM_RECORD,
new Context(new OTSUri(endpoint, OP_GET_STREAM_RECORD)));
contexts.put(OP_COMPUTE_SPLITS_BY_SIZE,
new Context(new OTSUri(endpoint, OP_COMPUTE_SPLITS_BY_SIZE)));
contexts.put(OP_CREATE_SEARCH_INDEX,
new Context(new OTSUri(endpoint, OP_CREATE_SEARCH_INDEX)));
contexts.put(OP_UPDATE_SEARCH_INDEX,
new Context(new OTSUri(endpoint, OP_UPDATE_SEARCH_INDEX)));
contexts.put(OP_LIST_SEARCH_INDEX,
new Context(new OTSUri(endpoint, OP_LIST_SEARCH_INDEX)));
contexts.put(OP_DELETE_SEARCH_INDEX,
new Context(new OTSUri(endpoint, OP_DELETE_SEARCH_INDEX)));
contexts.put(OP_DESCRIBE_SEARCH_INDEX,
new Context(new OTSUri(endpoint, OP_DESCRIBE_SEARCH_INDEX)));
contexts.put(OP_SEARCH,
new Context(new OTSUri(endpoint, OP_SEARCH)));
contexts.put(OP_PARALLEL_SCAN,
new Context(new OTSUri(endpoint, OP_PARALLEL_SCAN)));
contexts.put(OP_COMPUTE_SPLITS,
new Context(new OTSUri(endpoint, OP_COMPUTE_SPLITS)));
contexts.put(OP_START_LOCAL_TRANSACTION,
new Context(new OTSUri(endpoint, OP_START_LOCAL_TRANSACTION)));
contexts.put(OP_COMMIT_TRANSACTION,
new Context(new OTSUri(endpoint, OP_COMMIT_TRANSACTION)));
contexts.put(OP_ABORT_TRANSACTION,
new Context(new OTSUri(endpoint, OP_ABORT_TRANSACTION)));
contexts.put(OP_CREATE_TUNNEL,
new Context(new OTSUri(endpoint, OP_CREATE_TUNNEL)));
contexts.put(OP_LIST_TUNNEL,
new Context(new OTSUri(endpoint, OP_LIST_TUNNEL)));
contexts.put(OP_DESCRIBE_TUNNEL,
new Context(new OTSUri(endpoint, OP_DESCRIBE_TUNNEL)));
contexts.put(OP_DELETE_TUNNEL,
new Context(new OTSUri(endpoint, OP_DELETE_TUNNEL)));
contexts.put(OP_CONNECT_TUNNEL,
new Context(new OTSUri(endpoint, OP_CONNECT_TUNNEL)));
contexts.put(OP_HEARTBEAT,
new Context(new OTSUri(endpoint, OP_HEARTBEAT)));
contexts.put(OP_SHUTDOWN_TUNNEL,
new Context(new OTSUri(endpoint, OP_SHUTDOWN_TUNNEL)));
contexts.put(OP_GETCHECKPOINT,
new Context(new OTSUri(endpoint, OP_GETCHECKPOINT)));
contexts.put(OP_READRECORDS,
new Context(new OTSUri(endpoint, OP_READRECORDS)));
contexts.put(OP_CHECKPOINT,
new Context(new OTSUri(endpoint, OP_CHECKPOINT)));
contexts.put(OP_CREATE_DELIVERY_TASK,
new Context(new OTSUri(endpoint, OP_CREATE_DELIVERY_TASK)));
contexts.put(OP_DELETE_DELIVERY_TASK,
new Context(new OTSUri(endpoint, OP_DELETE_DELIVERY_TASK)));
contexts.put(OP_UPDATE_DELIVERY_TASK,
new Context(new OTSUri(endpoint, OP_UPDATE_DELIVERY_TASK)));
contexts.put(OP_DESCRIBE_DELIVERY_TASK,
new Context(new OTSUri(endpoint, OP_DESCRIBE_DELIVERY_TASK)));
contexts.put(OP_LIST_DELIVERY_TASK,
new Context(new OTSUri(endpoint, OP_LIST_DELIVERY_TASK)));
contexts.put(OP_CREATE_TIMESERIES_TABLE,
new Context(new OTSUri(endpoint, OP_CREATE_TIMESERIES_TABLE)));
contexts.put(OP_LIST_TIMESERIES_TABLE,
new Context(new OTSUri(endpoint, OP_LIST_TIMESERIES_TABLE)));
contexts.put(OP_DELETE_TIMESERIES_TABLE,
new Context(new OTSUri(endpoint, OP_DELETE_TIMESERIES_TABLE)));
contexts.put(OP_UPDATE_TIMESERIES_TABLE,
new Context(new OTSUri(endpoint, OP_UPDATE_TIMESERIES_TABLE)));
contexts.put(OP_DESCRIBE_TIMESERIES_TABLE,
new Context(new OTSUri(endpoint, OP_DESCRIBE_TIMESERIES_TABLE)));
contexts.put(OP_PUT_TIMESERIES_DATA,
new Context(new OTSUri(endpoint, OP_PUT_TIMESERIES_DATA)));
contexts.put(OP_GET_TIMESERIES_DATA,
new Context(new OTSUri(endpoint, OP_GET_TIMESERIES_DATA)));
contexts.put(OP_QUERY_TIMESERIES_META,
new Context(new OTSUri(endpoint, OP_QUERY_TIMESERIES_META)));
contexts.put(OP_UPDATE_TIMESERIES_META,
new Context(new OTSUri(endpoint, OP_UPDATE_TIMESERIES_META)));
contexts.put(OP_DELETE_TIMESERIES_META,
new Context(new OTSUri(endpoint, OP_DELETE_TIMESERIES_META)));
contexts.put(OP_SPLIT_TIMESERIES_SCAN_TASK,
new Context(new OTSUri(endpoint, OP_SPLIT_TIMESERIES_SCAN_TASK)));
contexts.put(OP_SCAN_TIMESERIES_DATA,
new Context(new OTSUri(endpoint, OP_SCAN_TIMESERIES_DATA)));
contexts.put(OP_CREATE_TIMESERIES_ANALYTICAL_STORE,
new Context(new OTSUri(endpoint, OP_CREATE_TIMESERIES_ANALYTICAL_STORE)));
contexts.put(OP_DELETE_TIMESERIES_ANALYTICAL_STORE,
new Context(new OTSUri(endpoint, OP_DELETE_TIMESERIES_ANALYTICAL_STORE)));
contexts.put(OP_DESCRIBE_TIMESERIES_ANALYTICAL_STORE,
new Context(new OTSUri(endpoint, OP_DESCRIBE_TIMESERIES_ANALYTICAL_STORE)));
contexts.put(OP_UPDATE_TIMESERIES_ANALYTICAL_STORE,
new Context(new OTSUri(endpoint, OP_UPDATE_TIMESERIES_ANALYTICAL_STORE)));
contexts.put(OP_CREATE_TIMESERIES_LASTPOINT_INDEX,
new Context(new OTSUri(endpoint, OP_CREATE_TIMESERIES_LASTPOINT_INDEX)));
contexts.put(OP_DELETE_TIMESERIES_LASTPOINT_INDEX,
new Context(new OTSUri(endpoint, OP_DELETE_TIMESERIES_LASTPOINT_INDEX)));
contexts.put(OP_SQL_Query,
new Context(new OTSUri(endpoint, OP_SQL_Query)));
}