Merge pull request #38 from aliyun/v5.13.14

update version to 5.13.14

Author: whybert

README.md

@@ -9,7 +9,7 @@
  - 阿里云表格存储是阿里云自主研发的NoSQL数据存储服务，提供海量结构化数据的存储和实时访问。
 
 ## 版本
- - 当前版本：5.13.13
+ - 当前版本：5.13.14
 
 ## 运行环境
  - JDK 6及其以上
@@ -21,7 +21,7 @@
 <dependency>
   <groupId>com.aliyun.openservices</groupId>
   <artifactId>tablestore</artifactId>
-  <version>5.13.13</version>
+  <version>5.13.14</version>
 </dependency>
 ```
 

pom.xml

@@ -3,7 +3,7 @@
   <modelVersion>4.0.0</modelVersion>  
   <groupId>com.aliyun.openservices</groupId>  
   <artifactId>tablestore</artifactId>  
-  <version>5.13.13</version>  
+  <version>5.13.14</version>  
   <packaging>jar</packaging>  
   <name>AliCloud TableStore SDK for Java</name>  
   <url>http://www.aliyun.com</url>  

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

@@ -208,6 +208,11 @@ public void shutdown() {
         this.internalClient.shutdown();
     }
 
+    @Override
+    public TimeseriesClientInterface asTimeseriesClientInterface() {
+        return new TimeseriesClient(this.internalClient);
+    }
+
     public SyncClient asSyncClient() {
         return new SyncClient(this.internalClient);
     }

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

@@ -47,4 +47,12 @@ Future<SplitTimeseriesScanTaskResponse> splitTimeseriesScanTask(SplitTimeseriesS
     Future<ScanTimeseriesDataResponse> scanTimeseriesData(ScanTimeseriesDataRequest request,
                                                           TableStoreCallback<ScanTimeseriesDataRequest, ScanTimeseriesDataResponse> callback)
             throws TableStoreException, ClientException;
+
+    public TimeseriesClientInterface asTimeseriesClientInterface();
+
+    /**
+     * 释放资源。
+     * <p>请确保在所有请求执行完毕之后释放资源。释放资源之后将不能再发送请求，正在执行的请求可能无法返回结果。</p>
+     */
+    public void shutdown();
 }

src/main/java/com/alicloud/openservices/tablestore/DefaultTableStoreTimeseriesWriter.java

@@ -0,0 +1,36 @@
+package com.alicloud.openservices.tablestore;
+
+import com.alicloud.openservices.tablestore.model.timeseries.TimeseriesTableRow;
+import com.alicloud.openservices.tablestore.timeserieswriter.TimeseriesWriterResult;
+import com.alicloud.openservices.tablestore.timeserieswriter.callback.TimeseriesRowResult;
+import com.alicloud.openservices.tablestore.timeserieswriter.config.TimeseriesWriterConfig;
+import com.alicloud.openservices.tablestore.timeserieswriter.handle.TimeseriesWriterHandleStatistics;
+
+
+import java.util.List;
+import java.util.concurrent.Future;
+
+public interface TableStoreTimeseriesWriter {
+
+    void addTimeseriesRowChange(TimeseriesTableRow timeseriesTableRow) throws ClientException;
+
+    Future<TimeseriesWriterResult> addTimeseriesRowChangeWithFuture(TimeseriesTableRow timeseriesTableRow) throws ClientException;
+
+    boolean tryAddTimeseriesRowChange(TimeseriesTableRow timeseriesTableRow) throws ClientException;
+
+    void addTimeseriesRowChange(List<TimeseriesTableRow> timeseriesTableRows, List<TimeseriesTableRow> ditryRows) throws ClientException;
+
+    Future<TimeseriesWriterResult> addTimeseriesRowChangeWithFuture(List<TimeseriesTableRow> timeseriesTableRows) throws ClientException;
+
+    void setResultCallback(TableStoreCallback<TimeseriesTableRow, TimeseriesRowResult> callback);
+
+    TableStoreCallback<TimeseriesTableRow, TimeseriesRowResult> getResultCallback();
+
+    TimeseriesWriterConfig getTimeseriesWriterConfig();
+
+    TimeseriesWriterHandleStatistics getTimeseriesWriterStatistics();
+
+    void flush() throws ClientException;
+
+    void close();
+}

src/main/java/com/alicloud/openservices/tablestore/TableStoreTimeseriesWriter.java

@@ -5,7 +5,7 @@
 public class Constants {
     // ALL HTTP HEADERS SHOULD BE DEFINED IN LOWERCASE
     // request headers
-    public static final String USER_AGENT = "ots-java-sdk 5.13.12";
+    public static final String USER_AGENT = "ots-java-sdk 5.13.14";
     public static final String OTS_HEADER_API_VERSION = "x-ots-apiversion";
     public static final String OTS_HEADER_ACCESS_KEY_ID = "x-ots-accesskeyid";
     public static final String OTS_HEADER_OTS_CONTENT_MD5 = "x-ots-contentmd5";