This is an automated email from the ASF dual-hosted git repository.
qiaojialin pushed a change to branch add_function_figure
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from c722edded8 add function map
new 101dd3e34a rename class
add e16cf90c1e [IOTDB-3677] Fix NPE while calling
QueryExecution.getBatchResult (#6479)
add b7af23a4bd [IOTDB-3636] Fix delete non existing sg error msg (#6478)
add d05dcde13c [IOTDB-3391] && [IOTDB-3372] Judge ConfigNode status
through heartbeat && show cluster did not return a correct result when stop a
datanode or confignode (#6402)
add b6ca325434 Add default pool size for data block exchange pool (#6480)
new eece6b6af7 Merge remote-tracking branch 'origin/master' into
add_function_figure
The 2 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:
.../client/AsyncConfigNodeClientPool.java | 72 ++++++++++++++++++++++
.../confignode/client/AsyncDataNodeClientPool.java | 7 ++-
...andler.java => ConfigNodeHeartbeatHandler.java} | 34 +++++-----
...tHandler.java => DataNodeHeartbeatHandler.java} | 17 ++---
.../iotdb/confignode/manager/ConfigManager.java | 31 ++++++++++
.../apache/iotdb/confignode/manager/IManager.java | 3 +
.../iotdb/confignode/manager/NodeManager.java | 6 ++
.../iotdb/confignode/manager/load/LoadManager.java | 64 +++++++++++++++----
...eatCache.java => ConfigNodeHeartbeatCache.java} | 11 +---
...tbeatCache.java => DataNodeHeartbeatCache.java} | 6 +-
.../service/thrift/ConfigNodeRPCService.java | 4 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 24 +++-----
.../iotdb/confignode/cli/TemporaryClientDemo.java | 8 +--
.../iotdb/jdbc/AbstractIoTDBJDBCResultSet.java | 6 +-
.../org/apache/iotdb/jdbc/IoTDBConnection.java | 16 ++---
.../apache/iotdb/jdbc/IoTDBDatabaseMetadata.java | 7 ++-
.../org/apache/iotdb/jdbc/IoTDBJDBCResultSet.java | 6 +-
.../iotdb/jdbc/IoTDBNonAlignJDBCResultSet.java | 4 +-
.../apache/iotdb/jdbc/IoTDBPreparedStatement.java | 2 +-
.../java/org/apache/iotdb/jdbc/IoTDBStatement.java | 13 ++--
.../test/java/org/apache/iotdb/jdbc/BatchTest.java | 4 +-
.../org/apache/iotdb/jdbc/IoTDBConnectionTest.java | 4 +-
.../iotdb/jdbc/IoTDBDatabaseMetadataTest.java | 4 +-
.../apache/iotdb/jdbc/IoTDBJDBCResultSetTest.java | 4 +-
.../iotdb/jdbc/IoTDBPreparedStatementTest.java | 2 +-
.../org/apache/iotdb/jdbc/IoTDBStatementTest.java | 2 +-
.../async/AsyncConfigNodeIServiceClient.java | 4 +-
.../async/AsyncDataNodeInternalServiceClient.java | 4 +-
.../client/sync/SyncConfigNodeIServiceClient.java | 4 +-
.../sync/SyncDataNodeInternalServiceClient.java | 4 +-
.../iotdb/commons/client/ClientManagerTest.java | 4 +-
.../client/mock/MockInternalRPCService.java | 8 +--
.../resources/conf/iotdb-datanode.properties | 4 +-
.../apache/iotdb/db/client/ConfigNodeClient.java | 22 +++++--
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 4 +-
.../db/mpp/plan/execution/QueryExecution.java | 54 +++++++++-------
.../mpp/plan/execution/config/ShowClusterTask.java | 5 +-
.../config/executor/ClusterConfigTaskExecutor.java | 2 +-
.../executor/StandaloneConfigTaskExecutor.java | 15 ++++-
...{InternalService.java => ClientRPCService.java} | 22 +++----
.../java/org/apache/iotdb/db/service/DataNode.java | 6 +-
.../java/org/apache/iotdb/db/service/NewIoTDB.java | 6 +-
.../org/apache/iotdb/db/service/RPCService.java | 2 +-
.../db/service/thrift/ProcessorWithMetrics.java | 4 +-
...erviceImpl.java => DataNodeRPCServiceImpl.java} | 10 +--
...ServiceImpl.java => DataNodeTSServiceImpl.java} | 6 +-
.../db/service/thrift/impl/TSIEventHandler.java | 4 +-
.../schedule/DefaultDriverSchedulerTest.java | 5 +-
...ImplTest.java => ClientRPCServiceImplTest.java} | 14 ++---
.../org/apache/iotdb/rpc/IoTDBJDBCDataSet.java | 8 +--
.../java/org/apache/iotdb/rpc/IoTDBRpcDataSet.java | 6 +-
.../main/java/org/apache/iotdb/rpc/RpcUtils.java | 8 +--
.../org/apache/iotdb/rpc/SynchronizedHandler.java | 6 +-
.../apache/iotdb/session/SessionConnection.java | 10 +--
.../org/apache/iotdb/session/SessionDataSet.java | 6 +-
thrift-commons/src/main/thrift/common.thrift | 10 +--
.../src/main/thrift/confignode.thrift | 6 +-
.../src/main/thrift/{rpc.thrift => client.thrift} | 2 +-
.../main/thrift/{mpp.thrift => datanode.thrift} | 10 +--
59 files changed, 415 insertions(+), 231 deletions(-)
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/client/AsyncConfigNodeClientPool.java
copy
confignode/src/main/java/org/apache/iotdb/confignode/client/handlers/{HeartbeatHandler.java
=> ConfigNodeHeartbeatHandler.java} (52%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/client/handlers/{HeartbeatHandler.java
=> DataNodeHeartbeatHandler.java} (73%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/manager/load/heartbeat/{HeartbeatCache.java
=> ConfigNodeHeartbeatCache.java} (88%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/manager/load/heartbeat/{HeartbeatCache.java
=> DataNodeHeartbeatCache.java} (94%)
rename server/src/main/java/org/apache/iotdb/db/service/{InternalService.java
=> ClientRPCService.java} (82%)
rename
server/src/main/java/org/apache/iotdb/db/service/thrift/impl/{InternalServiceImpl.java
=> DataNodeRPCServiceImpl.java} (98%)
rename
server/src/main/java/org/apache/iotdb/db/service/thrift/impl/{DataNodeTSIServiceImpl.java
=> DataNodeTSServiceImpl.java} (99%)
rename
server/src/test/java/org/apache/iotdb/db/service/{InternalServiceImplTest.java
=> ClientRPCServiceImplTest.java} (96%)
rename thrift/src/main/thrift/{rpc.thrift => client.thrift} (99%)
rename thrift/src/main/thrift/{mpp.thrift => datanode.thrift} (96%)
