You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by xu...@apache.org on 2021/01/04 05:38:04 UTC
[iotdb] branch xkf_tpc_test updated: update
This is an automated email from the ASF dual-hosted git repository.
xuekaifeng pushed a commit to branch xkf_tpc_test
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/xkf_tpc_test by this push:
new f632ad0 update
f632ad0 is described below
commit f632ad007719c22b0d42430f1592ce6faf0abc37
Author: 151250176 <15...@smail.nju.edu.cn>
AuthorDate: Mon Jan 4 13:37:34 2021 +0800
update
---
.../org/apache/iotdb/db/service/TSServiceImpl.java | 28 ++++++++++++++++++++--
1 file changed, 26 insertions(+), 2 deletions(-)
diff --git a/server/src/main/java/org/apache/iotdb/db/service/TSServiceImpl.java b/server/src/main/java/org/apache/iotdb/db/service/TSServiceImpl.java
index 0d95ee2..a9f76d3 100644
--- a/server/src/main/java/org/apache/iotdb/db/service/TSServiceImpl.java
+++ b/server/src/main/java/org/apache/iotdb/db/service/TSServiceImpl.java
@@ -139,6 +139,7 @@ import org.apache.iotdb.tsfile.file.metadata.enums.TSDataType;
import org.apache.iotdb.tsfile.file.metadata.enums.TSEncoding;
import org.apache.iotdb.tsfile.read.common.Path;
import org.apache.iotdb.tsfile.read.query.dataset.QueryDataSet;
+import org.apache.iotdb.tsfile.utils.ReadWriteIOUtils;
import org.apache.thrift.TException;
import org.apache.thrift.server.ServerContext;
import org.slf4j.Logger;
@@ -1499,8 +1500,31 @@ public class TSServiceImpl implements TSIService.Iface, ServerContext {
public TSStatus insertTablets(TSInsertTabletsReq req) {
// transfer to another
if(!req.isFinal){
- req.isFinal = true;
- AsyncInsertPool.getInstance().submit(req);
+ TSInsertTabletsReq transferReq = new TSInsertTabletsReq();
+ transferReq.deviceIds = req.deviceIds;
+ transferReq.isFinal = true;
+ transferReq.measurementsList = req.measurementsList;
+ transferReq.typesList = req.typesList;
+ transferReq.sizeList = new ArrayList<>(req.sizeList);
+ List<ByteBuffer> valueBuffer = new ArrayList<>(req.valuesList.size());
+ for(ByteBuffer byteBuffer : req.valuesList){
+ valueBuffer.add(ReadWriteIOUtils.clone(byteBuffer));
+ byteBuffer.flip();
+ }
+ List<ByteBuffer> timeBuffer = new ArrayList<>(req.timestampsList.size());
+ for(ByteBuffer byteBuffer : req.timestampsList){
+ timeBuffer.add(ReadWriteIOUtils.clone(byteBuffer));
+ byteBuffer.flip();
+ }
+ transferReq.valuesList = valueBuffer;
+ transferReq.timestampsList = timeBuffer;
+
+ AsyncInsertPool.getInstance().submit(transferReq);
+ }
+ else{
+ for(ByteBuffer byteBuffer : req.timestampsList){
+ System.out.println(byteBuffer);
+ }
}
//
long t1 = System.currentTimeMillis();