You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by hx...@apache.org on 2020/04/17 00:43:11 UTC
[incubator-iotdb] branch disable_mqtt_server updated (08c5526 ->
a49f68f)
This is an automated email from the ASF dual-hosted git repository.
hxd pushed a change to branch disable_mqtt_server
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git.
from 08c5526 remove unused codes
add c4a8889 modify disclaimer (#1052)
add 642efa9 remove EnvironmentUtils.setup and clean in MTreeTest (#1054)
add 66be65a [IOTDB-594] Correct the use of Unseq file's TimeseriesMetadata (#1050)
add 8db2f32 Support left open and right close range in group by (#1056)
add 1c6cde5 add insert multiple batch in SessionPool
add 57fc486 fix init MManager bug (#1058)
add 8b96ae3 fix concurrent auto set storage group bug (#1061)
add 5a61718 Merge branch 'master' of https://github.com/apache/incubator-iotdb into disable_mqtt_server
add 9dd9dc3 Merge branch 'disable_mqtt_server' of https://github.com/apache/incubator-iotdb into disable_mqtt_server
new a49f68f remove unused codes
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../2-DML Data Manipulation Language.md | 35 +++++++--
.../5-Operation Manual/4-SQL Reference.md | 5 +-
.../2-DML Data Manipulation Language.md | 40 ++++++++---
.../5-Operation Manual/4-SQL Reference.md | 11 +--
.../org/apache/iotdb/db/qp/strategy/SqlBase.g4 | 1 +
.../db/concurrent/IoTDBThreadPoolFactory.java | 20 ------
.../org/apache/iotdb/db/metadata/MManager.java | 36 +++++++---
.../iotdb/db/qp/logical/crud/QueryOperator.java | 10 +++
.../iotdb/db/qp/physical/crud/GroupByPlan.java | 11 +++
.../iotdb/db/qp/strategy/LogicalGenerator.java | 4 +-
.../iotdb/db/qp/strategy/PhysicalGenerator.java | 20 ++++--
.../dataset/groupby/GroupByEngineDataSet.java | 10 +--
.../groupby/GroupByWithValueFilterDataSet.java | 7 +-
.../groupby/GroupByWithoutValueFilterDataSet.java | 7 +-
.../iotdb/db/query/reader/series/SeriesReader.java | 2 +
.../iotdb/db/integration/IoTDBGroupByFillIT.java | 82 +++++++++++++++++++++-
...ava => IoTDBMultiOverlappedChunkInUnseqIT.java} | 56 +++++----------
.../org/apache/iotdb/session/pool/SessionPool.java | 54 ++++++++++++++
site/src/main/.vuepress/theme/components/Page.vue | 2 +-
.../file/metadata/statistics/BinaryStatistics.java | 24 +++++--
.../metadata/statistics/BooleanStatistics.java | 24 +++++--
.../file/metadata/statistics/DoubleStatistics.java | 30 ++++++--
.../file/metadata/statistics/FloatStatistics.java | 31 ++++++--
.../metadata/statistics/IntegerStatistics.java | 31 ++++++--
.../file/metadata/statistics/LongStatistics.java | 31 ++++++--
.../file/metadata/statistics/Statistics.java | 1 +
.../metadata/statistics/BooleanStatisticsTest.java | 29 ++++++--
.../metadata/statistics/DoubleStatisticsTest.java | 32 +++++++--
.../metadata/statistics/FloatStatisticsTest.java | 38 +++++++---
.../metadata/statistics/IntegerStatisticsTest.java | 32 +++++++--
.../metadata/statistics/LongStatisticsTest.java | 36 +++++++---
.../metadata/statistics/StringStatisticsTest.java | 36 ++++++++--
32 files changed, 610 insertions(+), 178 deletions(-)
copy server/src/test/java/org/apache/iotdb/db/integration/{IoTDBOverlappedPageIT.java => IoTDBMultiOverlappedChunkInUnseqIT.java} (66%)
[incubator-iotdb] 01/01: remove unused codes
Posted by hx...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
hxd pushed a commit to branch disable_mqtt_server
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git
commit a49f68fcfaeb247087ba854c3189433c1b92d536
Author: xiangdong huang <sa...@gmail.com>
AuthorDate: Fri Apr 17 08:41:52 2020 +0800
remove unused codes
---
.../iotdb/db/concurrent/IoTDBThreadPoolFactory.java | 20 --------------------
1 file changed, 20 deletions(-)
diff --git a/server/src/main/java/org/apache/iotdb/db/concurrent/IoTDBThreadPoolFactory.java b/server/src/main/java/org/apache/iotdb/db/concurrent/IoTDBThreadPoolFactory.java
index 3de7802..41f35e6 100644
--- a/server/src/main/java/org/apache/iotdb/db/concurrent/IoTDBThreadPoolFactory.java
+++ b/server/src/main/java/org/apache/iotdb/db/concurrent/IoTDBThreadPoolFactory.java
@@ -23,7 +23,6 @@ import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.SynchronousQueue;
import java.util.concurrent.ThreadPoolExecutor;
-import org.apache.thrift.server.CustomizedTThreadPoolServer;
import org.apache.thrift.server.TThreadPoolServer;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -122,25 +121,6 @@ public class IoTDBThreadPoolFactory {
/**
* function for creating thrift rpc client thread pool.
*/
- public static ExecutorService createThriftRpcClientThreadPool(CustomizedTThreadPoolServer.Args args, String poolName) {
- SynchronousQueue<Runnable> executorQueue = new SynchronousQueue<>();
- return new ThreadPoolExecutor(args.minWorkerThreads, args.maxWorkerThreads, args.stopTimeoutVal,
- args.stopTimeoutUnit, executorQueue, new IoTThreadFactory(poolName));
- }
-
- /**
- * function for creating thrift rpc client thread pool.
- */
- public static ExecutorService createThriftRpcClientThreadPool(CustomizedTThreadPoolServer.Args args, String poolName,
- Thread.UncaughtExceptionHandler handler) {
- SynchronousQueue<Runnable> executorQueue = new SynchronousQueue<>();
- return new ThreadPoolExecutor(args.minWorkerThreads, args.maxWorkerThreads, args.stopTimeoutVal,
- args.stopTimeoutUnit, executorQueue, new IoTThreadFactory(poolName, handler));
- }
-
- /**
- * function for creating thrift rpc client thread pool.
- */
public static ExecutorService createThriftRpcClientThreadPool(TThreadPoolServer.Args args, String poolName) {
SynchronousQueue<Runnable> executorQueue = new SynchronousQueue<>();
return new ThreadPoolExecutor(args.minWorkerThreads, args.maxWorkerThreads, args.stopTimeoutVal,