Skip to content

Commit acd9c0e

Browse files
yunjinlxpyunjinlxp
committed
update version to 5.17.1
1 parent 65d3b42 commit acd9c0e

File tree

47 files changed

+18965
-11817
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

47 files changed

+18965
-11817
lines changed

‎README.md‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -9,19 +9,19 @@
99
- 阿里云表格存储是阿里云自主研发的NoSQL数据存储服务，提供海量结构化数据的存储和实时访问。
1010

1111
## 版本
12-
- 当前版本：5.17.0
12+
- 当前版本：5.17.1
1313

1414
## 运行环境
1515
- JDK 6及其以上
1616

1717
## 安装
1818
#### Maven方式
19-
下载[最新版JAR包](https://search.maven.org/remotecontent?filepath=com/aliyun/openservices/tablestore/5.17.0/tablestore-5.17.0.jar)或者通过Maven：
19+
下载[最新版JAR包](https://search.maven.org/remotecontent?filepath=com/aliyun/openservices/tablestore/5.17.1/tablestore-5.17.1.jar)或者通过Maven：
2020
```xml
2121
<dependency>
2222
<groupId>com.aliyun.openservices</groupId>
2323
<artifactId>tablestore</artifactId>
24-
<version>5.17.0</version>
24+
<version>5.17.1</version>
2525
</dependency>
2626
```
2727

‎pom.xml‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@
33
<modelVersion>4.0.0</modelVersion>
44
<groupId>com.aliyun.openservices</groupId>
55
<artifactId>tablestore</artifactId>
6-
<version>5.17.0</version>
6+
<version>5.17.1</version>
77
<packaging>jar</packaging>
88
<name>AliCloud TableStore SDK for Java</name>
99
<url>http://www.aliyun.com</url>

‎src/main/java/com/alicloud/openservices/tablestore/AsyncTimeseriesClient.java‎

Lines changed: 17 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,9 @@
1010
import com.google.common.cache.Weigher;
1111

1212
import java.util.Map;
13-
import java.util.concurrent.*;
13+
import java.util.concurrent.ExecutorService;
14+
import java.util.concurrent.Future;
15+
import java.util.concurrent.TimeUnit;
1416

1517
public class AsyncTimeseriesClient implements AsyncTimeseriesClientInterface {
1618

@@ -232,6 +234,20 @@ public Future<UpdateTimeseriesAnalyticalStoreResponse> updateTimeseriesAnalytica
232234
return internalClient.updateTimeseriesAnalyticalStore(request, callback);
233235
}
234236

237+
@Override
238+
public Future<CreateTimeseriesLastpointIndexResponse> createTimeseriesLastpointIndex(CreateTimeseriesLastpointIndexRequest request,
239+
TableStoreCallback<CreateTimeseriesLastpointIndexRequest, CreateTimeseriesLastpointIndexResponse> callback)
240+
throws TableStoreException, ClientException {
241+
return internalClient.createTimeseriesLastpointIndex(request, callback);
242+
}
243+
244+
@Override
245+
public Future<DeleteTimeseriesLastpointIndexResponse> deleteTimeseriesLastpointIndex(DeleteTimeseriesLastpointIndexRequest request,
246+
TableStoreCallback<DeleteTimeseriesLastpointIndexRequest, DeleteTimeseriesLastpointIndexResponse> callback)
247+
throws TableStoreException, ClientException {
248+
return internalClient.deleteTimeseriesLastpointIndex(request, callback);
249+
}
250+
235251
public void shutdown() {
236252
this.internalClient.shutdown();
237253
}

‎src/main/java/com/alicloud/openservices/tablestore/AsyncTimeseriesClientInterface.java‎

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -64,6 +64,14 @@ Future<UpdateTimeseriesAnalyticalStoreResponse> updateTimeseriesAnalyticalStore(
6464
TableStoreCallback<UpdateTimeseriesAnalyticalStoreRequest, UpdateTimeseriesAnalyticalStoreResponse> callback)
6565
throws TableStoreException, ClientException;
6666

67+
Future<CreateTimeseriesLastpointIndexResponse> createTimeseriesLastpointIndex(CreateTimeseriesLastpointIndexRequest request,
68+
TableStoreCallback<CreateTimeseriesLastpointIndexRequest, CreateTimeseriesLastpointIndexResponse> callback)
69+
throws TableStoreException, ClientException;
70+
71+
Future<DeleteTimeseriesLastpointIndexResponse> deleteTimeseriesLastpointIndex(DeleteTimeseriesLastpointIndexRequest request,
72+
TableStoreCallback<DeleteTimeseriesLastpointIndexRequest, DeleteTimeseriesLastpointIndexResponse> callback)
73+
throws TableStoreException, ClientException;
74+
6775
public TimeseriesClientInterface asTimeseriesClientInterface();
6876

6977
/**

‎src/main/java/com/alicloud/openservices/tablestore/InternalClient.java‎

Lines changed: 60 additions & 28 deletions
Original file line numberDiff line numberDiff line change
@@ -1,45 +1,29 @@
11
package com.alicloud.openservices.tablestore;
22

3-
import java.util.Map;
4-
import java.util.Random;
5-
import java.util.UUID;
6-
import java.util.concurrent.*;
7-
3+
import com.alicloud.openservices.tablestore.core.*;
84
import com.alicloud.openservices.tablestore.core.auth.CredentialsProvider;
95
import com.alicloud.openservices.tablestore.core.auth.CredentialsProviderFactory;
10-
import com.alicloud.openservices.tablestore.core.utils.HttpUtil;
11-
import com.alicloud.openservices.tablestore.core.utils.Preconditions;
126
import com.alicloud.openservices.tablestore.core.auth.ServiceCredentials;
137
import com.alicloud.openservices.tablestore.core.http.AsyncServiceClient;
14-
import com.alicloud.openservices.tablestore.core.*;
8+
import com.alicloud.openservices.tablestore.core.utils.HttpUtil;
9+
import com.alicloud.openservices.tablestore.core.utils.Preconditions;
1510
import com.alicloud.openservices.tablestore.model.*;
1611
import com.alicloud.openservices.tablestore.model.delivery.*;
1712
import com.alicloud.openservices.tablestore.model.search.*;
1813
import com.alicloud.openservices.tablestore.model.sql.SQLQueryRequest;
1914
import com.alicloud.openservices.tablestore.model.sql.SQLQueryResponse;
2015
import com.alicloud.openservices.tablestore.model.timeseries.*;
21-
import com.alicloud.openservices.tablestore.model.tunnel.CreateTunnelRequest;
22-
import com.alicloud.openservices.tablestore.model.tunnel.CreateTunnelResponse;
23-
import com.alicloud.openservices.tablestore.model.tunnel.DeleteTunnelRequest;
24-
import com.alicloud.openservices.tablestore.model.tunnel.DeleteTunnelResponse;
25-
import com.alicloud.openservices.tablestore.model.tunnel.DescribeTunnelRequest;
26-
import com.alicloud.openservices.tablestore.model.tunnel.DescribeTunnelResponse;
27-
import com.alicloud.openservices.tablestore.model.tunnel.ListTunnelRequest;
28-
import com.alicloud.openservices.tablestore.model.tunnel.ListTunnelResponse;
29-
import com.alicloud.openservices.tablestore.model.tunnel.internal.CheckpointRequest;
30-
import com.alicloud.openservices.tablestore.model.tunnel.internal.CheckpointResponse;
31-
import com.alicloud.openservices.tablestore.model.tunnel.internal.ConnectTunnelRequest;
32-
import com.alicloud.openservices.tablestore.model.tunnel.internal.ConnectTunnelResponse;
33-
import com.alicloud.openservices.tablestore.model.tunnel.internal.GetCheckpointRequest;
34-
import com.alicloud.openservices.tablestore.model.tunnel.internal.GetCheckpointResponse;
35-
import com.alicloud.openservices.tablestore.model.tunnel.internal.HeartbeatRequest;
36-
import com.alicloud.openservices.tablestore.model.tunnel.internal.HeartbeatResponse;
37-
import com.alicloud.openservices.tablestore.model.tunnel.internal.ReadRecordsRequest;
38-
import com.alicloud.openservices.tablestore.model.tunnel.internal.ReadRecordsResponse;
39-
import com.alicloud.openservices.tablestore.model.tunnel.internal.ShutdownTunnelRequest;
40-
import com.alicloud.openservices.tablestore.model.tunnel.internal.ShutdownTunnelResponse;
16+
import com.alicloud.openservices.tablestore.model.tunnel.*;
17+
import com.alicloud.openservices.tablestore.model.tunnel.internal.*;
4118
import com.google.common.cache.Cache;
4219

20+
import java.util.Map;
21+
import java.util.Random;
22+
import java.util.UUID;
23+
import java.util.concurrent.ExecutorService;
24+
import java.util.concurrent.Future;
25+
import java.util.concurrent.ScheduledExecutorService;
26+
4327
public class InternalClient {
4428
private static int AVAILABLE_PROCESSORS = Runtime.getRuntime().availableProcessors();
4529
private String endpoint; // TableStore endpoint
@@ -1904,6 +1888,54 @@ public Future<UpdateTimeseriesAnalyticalStoreResponse> updateTimeseriesAnalytica
19041888
return f;
19051889
}
19061890

1891+
public Future<CreateTimeseriesLastpointIndexResponse> createTimeseriesLastpointIndex(
1892+
CreateTimeseriesLastpointIndexRequest request,
1893+
TableStoreCallback<CreateTimeseriesLastpointIndexRequest, CreateTimeseriesLastpointIndexResponse> callback) {
1894+
Preconditions.checkNotNull(request);
1895+
1896+
TraceLogger tracer = getTraceLogger();
1897+
RetryStrategy retry = this.retryStrategy.clone();
1898+
CreateTimeseriesLastpointIndexLauncher launcher = launcherFactory.createTimeseriesLastpointIndex(tracer, retry, request);
1899+
1900+
AsyncCompletion<CreateTimeseriesLastpointIndexRequest, CreateTimeseriesLastpointIndexResponse> completion =
1901+
new AsyncCompletion<CreateTimeseriesLastpointIndexRequest, CreateTimeseriesLastpointIndexResponse>(
1902+
launcher, request, tracer, callbackExecutor, retry, retryExecutor);
1903+
CallbackImpledFuture<CreateTimeseriesLastpointIndexRequest, CreateTimeseriesLastpointIndexResponse> f =
1904+
new CallbackImpledFuture<CreateTimeseriesLastpointIndexRequest, CreateTimeseriesLastpointIndexResponse>();
1905+
completion.watchBy(f);
1906+
if (callback != null) {
1907+
// user callback must be triggered after completion of the return
1908+
// future.
1909+
f.watchBy(callback);
1910+
}
1911+
launcher.fire(request, completion);
1912+
1913+
return f;
1914+
}
1915+
1916+
public Future<DeleteTimeseriesLastpointIndexResponse> deleteTimeseriesLastpointIndex(
1917+
DeleteTimeseriesLastpointIndexRequest request,
1918+
TableStoreCallback<DeleteTimeseriesLastpointIndexRequest, DeleteTimeseriesLastpointIndexResponse> callback) {
1919+
Preconditions.checkNotNull(request);
1920+
TraceLogger tracer = getTraceLogger();
1921+
RetryStrategy retry = this.retryStrategy.clone();
1922+
DeleteTimeseriesLastpointIndexLauncher launcher = launcherFactory.deleteTimeseriesLastpointIndex(tracer, retry, request);
1923+
AsyncCompletion<DeleteTimeseriesLastpointIndexRequest, DeleteTimeseriesLastpointIndexResponse> completion =
1924+
new AsyncCompletion<DeleteTimeseriesLastpointIndexRequest, DeleteTimeseriesLastpointIndexResponse>(
1925+
launcher, request, tracer, callbackExecutor, retry, retryExecutor);
1926+
CallbackImpledFuture<DeleteTimeseriesLastpointIndexRequest, DeleteTimeseriesLastpointIndexResponse> f =
1927+
new CallbackImpledFuture<DeleteTimeseriesLastpointIndexRequest, DeleteTimeseriesLastpointIndexResponse>();
1928+
completion.watchBy(f);
1929+
if (callback != null) {
1930+
// user callback must be triggered after completion of the return
1931+
// future.
1932+
f.watchBy(callback);
1933+
}
1934+
launcher.fire(request, completion);
1935+
1936+
return f;
1937+
}
1938+
19071939
public void setCredentials(ServiceCredentials credentials) {
19081940
CredentialsProvider newCrdsProvider = CredentialsProviderFactory.newDefaultCredentialProvider(credentials.getAccessKeyId(),
19091941
credentials.getAccessKeySecret(), credentials.getSecurityToken());

‎src/main/java/com/alicloud/openservices/tablestore/TimeseriesClient.java‎

Lines changed: 14 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -233,6 +233,20 @@ public UpdateTimeseriesAnalyticalStoreResponse updateTimeseriesAnalyticalStore(U
233233
return waitForFuture(resp);
234234
}
235235

236+
@Override
237+
public CreateTimeseriesLastpointIndexResponse createTimeseriesLastpointIndex(CreateTimeseriesLastpointIndexRequest request)
238+
throws TableStoreException, ClientException {
239+
Future<CreateTimeseriesLastpointIndexResponse> resp = internalClient.createTimeseriesLastpointIndex(request, null);
240+
return waitForFuture(resp);
241+
}
242+
243+
@Override
244+
public DeleteTimeseriesLastpointIndexResponse deleteTimeseriesLastpointIndex(DeleteTimeseriesLastpointIndexRequest request)
245+
throws TableStoreException, ClientException {
246+
Future<DeleteTimeseriesLastpointIndexResponse> resp = internalClient.deleteTimeseriesLastpointIndex(request, null);
247+
return waitForFuture(resp);
248+
}
249+
236250
private <Res> Res waitForFuture(Future<Res> f) {
237251
try {
238252
return f.get(this.internalClient.getClientConfig().getSyncClientWaitFutureTimeoutInMillis(), TimeUnit.MILLISECONDS);

‎src/main/java/com/alicloud/openservices/tablestore/TimeseriesClientInterface.java‎

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -46,4 +46,10 @@ DescribeTimeseriesAnalyticalStoreResponse describeTimeseriesAnalyticalStore(Desc
4646

4747
UpdateTimeseriesAnalyticalStoreResponse updateTimeseriesAnalyticalStore(UpdateTimeseriesAnalyticalStoreRequest request)
4848
throws TableStoreException, ClientException;
49+
50+
CreateTimeseriesLastpointIndexResponse createTimeseriesLastpointIndex(CreateTimeseriesLastpointIndexRequest request)
51+
throws TableStoreException, ClientException;
52+
53+
DeleteTimeseriesLastpointIndexResponse deleteTimeseriesLastpointIndex(DeleteTimeseriesLastpointIndexRequest request)
54+
throws TableStoreException, ClientException;
4955
}

‎src/main/java/com/alicloud/openservices/tablestore/core/Constants.java‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,7 @@
55
public class Constants {
66
// ALL HTTP HEADERS SHOULD BE DEFINED IN LOWERCASE
77
// request headers
8-
public static final String USER_AGENT = "ots-java-sdk 5.17.0";
8+
public static final String USER_AGENT = "ots-java-sdk 5.17.1";
99
public static final String OTS_HEADER_API_VERSION = "x-ots-apiversion";
1010
public static final String OTS_HEADER_ACCESS_KEY_ID = "x-ots-accesskeyid";
1111
public static final String OTS_HEADER_OTS_CONTENT_MD5 = "x-ots-contentmd5";

‎src/main/java/com/alicloud/openservices/tablestore/core/CreateTimeseriesLastpointIndexLauncher.java‎

Lines changed: 60 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,60 @@
1+
package com.alicloud.openservices.tablestore.core;
2+
3+
4+
import com.alicloud.openservices.tablestore.ClientConfiguration;
5+
import com.alicloud.openservices.tablestore.core.auth.CredentialsProvider;
6+
import com.alicloud.openservices.tablestore.core.http.AsyncServiceClient;
7+
import com.alicloud.openservices.tablestore.core.http.CreateTimeseriesLastpointIndexResponseConsumer;
8+
import com.alicloud.openservices.tablestore.core.http.OTSUri;
9+
import com.alicloud.openservices.tablestore.core.protocol.ResultParserFactory;
10+
import com.alicloud.openservices.tablestore.core.protocol.timeseries.Timeseries;
11+
import com.alicloud.openservices.tablestore.core.protocol.timeseries.TimeseriesProtocolBuilder;
12+
import com.alicloud.openservices.tablestore.core.utils.LogUtil;
13+
import com.alicloud.openservices.tablestore.model.RetryStrategy;
14+
import com.alicloud.openservices.tablestore.model.timeseries.CreateTimeseriesLastpointIndexRequest;
15+
import com.alicloud.openservices.tablestore.model.timeseries.CreateTimeseriesLastpointIndexResponse;
16+
import com.alicloud.openservices.tablestore.timeline.utils.Preconditions;
17+
import org.apache.http.concurrent.FutureCallback;
18+
19+
public class CreateTimeseriesLastpointIndexLauncher extends OperationLauncher<CreateTimeseriesLastpointIndexRequest, CreateTimeseriesLastpointIndexResponse> {
20+
21+
private OTSUri uri;
22+
private TraceLogger tracer;
23+
private RetryStrategy retry;
24+
25+
public CreateTimeseriesLastpointIndexLauncher(
26+
OTSUri uri,
27+
TraceLogger tracer,
28+
RetryStrategy retry,
29+
String instanceName,
30+
AsyncServiceClient client,
31+
CredentialsProvider crdsProvider,
32+
ClientConfiguration config,
33+
CreateTimeseriesLastpointIndexRequest originRequest) {
34+
super(instanceName, client, crdsProvider, config, originRequest);
35+
Preconditions.checkNotNull(uri);
36+
Preconditions.checkNotNull(tracer);
37+
Preconditions.checkNotNull(retry);
38+
this.uri = uri;
39+
this.tracer = tracer;
40+
this.retry = retry;
41+
}
42+
43+
@Override
44+
public void fire(CreateTimeseriesLastpointIndexRequest request, FutureCallback<CreateTimeseriesLastpointIndexResponse> cb) {
45+
LogUtil.logBeforeExecution(tracer, retry);
46+
47+
Timeseries.CreateTimeseriesLastpointIndexResponse defaultResponse =
48+
Timeseries.CreateTimeseriesLastpointIndexResponse.getDefaultInstance();
49+
asyncInvokePost(
50+
uri,
51+
null,
52+
TimeseriesProtocolBuilder.buildCreateTimeseriesLastpointIndexRequest(request),
53+
tracer,
54+
new CreateTimeseriesLastpointIndexResponseConsumer(
55+
ResultParserFactory.createFactory().createProtocolBufferResultParser(
56+
defaultResponse, tracer.getTraceId()),
57+
tracer, retry, lastResult),
58+
cb);
59+
}
60+
}

‎src/main/java/com/alicloud/openservices/tablestore/core/DeleteTimeseriesLastpointIndexLauncher.java‎

Lines changed: 60 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,60 @@
1+
package com.alicloud.openservices.tablestore.core;
2+
3+
4+
import com.alicloud.openservices.tablestore.ClientConfiguration;
5+
import com.alicloud.openservices.tablestore.core.auth.CredentialsProvider;
6+
import com.alicloud.openservices.tablestore.core.http.AsyncServiceClient;
7+
import com.alicloud.openservices.tablestore.core.http.DeleteTimeseriesLastpointIndexResponseConsumer;
8+
import com.alicloud.openservices.tablestore.core.http.OTSUri;
9+
import com.alicloud.openservices.tablestore.core.protocol.ResultParserFactory;
10+
import com.alicloud.openservices.tablestore.core.protocol.timeseries.Timeseries;
11+
import com.alicloud.openservices.tablestore.core.protocol.timeseries.TimeseriesProtocolBuilder;
12+
import com.alicloud.openservices.tablestore.core.utils.LogUtil;
13+
import com.alicloud.openservices.tablestore.model.RetryStrategy;
14+
import com.alicloud.openservices.tablestore.model.timeseries.DeleteTimeseriesLastpointIndexRequest;
15+
import com.alicloud.openservices.tablestore.model.timeseries.DeleteTimeseriesLastpointIndexResponse;
16+
import com.alicloud.openservices.tablestore.timeline.utils.Preconditions;
17+
import org.apache.http.concurrent.FutureCallback;
18+
19+
public class DeleteTimeseriesLastpointIndexLauncher extends OperationLauncher<DeleteTimeseriesLastpointIndexRequest, DeleteTimeseriesLastpointIndexResponse> {
20+
21+
private OTSUri uri;
22+
private TraceLogger tracer;
23+
private RetryStrategy retry;
24+
25+
public DeleteTimeseriesLastpointIndexLauncher(
26+
OTSUri uri,
27+
TraceLogger tracer,
28+
RetryStrategy retry,
29+
String instanceName,
30+
AsyncServiceClient client,
31+
CredentialsProvider crdsProvider,
32+
ClientConfiguration config,
33+
DeleteTimeseriesLastpointIndexRequest originRequest) {
34+
super(instanceName, client, crdsProvider, config, originRequest);
35+
Preconditions.checkNotNull(uri);
36+
Preconditions.checkNotNull(tracer);
37+
Preconditions.checkNotNull(retry);
38+
this.uri = uri;
39+
this.tracer = tracer;
40+
this.retry = retry;
41+
}
42+
43+
@Override
44+
public void fire(DeleteTimeseriesLastpointIndexRequest request, FutureCallback<DeleteTimeseriesLastpointIndexResponse> cb) {
45+
LogUtil.logBeforeExecution(tracer, retry);
46+
47+
Timeseries.DeleteTimeseriesLastpointIndexResponse defaultResponse =
48+
Timeseries.DeleteTimeseriesLastpointIndexResponse.getDefaultInstance();
49+
asyncInvokePost(
50+
uri,
51+
null,
52+
TimeseriesProtocolBuilder.buildDeleteTimeseriesLastpointIndexRequest(request),
53+
tracer,
54+
new DeleteTimeseriesLastpointIndexResponseConsumer(
55+
ResultParserFactory.createFactory().createProtocolBufferResultParser(
56+
defaultResponse, tracer.getTraceId()),
57+
tracer, retry, lastResult),
58+
cb);
59+
}
60+
}

0 commit comments

Comments
 (0)