This is an automated email from the ASF dual-hosted git repository.
hxd pushed a change to branch refactor_overflow_2
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git.
from 9feb2cd comment an abandoned ut
new 6fa2457 refactor BufferWriteProcessor and some functions of
FileNodeProcessor into a new module TsFileProcessor:
new c7aa2a3 fix equals() method in InsertPlan
new 623b797 merge with head
new 9b8b68a [IOTDB-49]Remove 2 unneeded logs. (#99)
new 41e3fbe fix doc bug (#104)
new ef46df9 fix bug IOTDB-50
new 5f247c6 Merge pull request #107 from apache/fix_bug_IOTDB_50
new aae9a57 [IOTDB-23] Add monitor statistics of file size. Phase 1.1
(#88)
new a58b084 [IOTDB-56] faster memtable.getSortedTimeValuePairList (#105)
new 7dd3722 [IOTDB-8] Fix filenode restore deserialization (#96)
new 96f3710 rename postback to sync and reconstruct sync client
new 2f2e1d8 reconstruct thrift sync service
new ab830f9 reconstruct sync server
new 47dcea4 test sync function and modify the implementation of singleton
new c165a8f modify shell scripts about sync
new 0a46869 remove author mark
new 0bbf2f3 fix sonar issues
new 59d1ae8 Merge pull request #101 from apache/Sync-Reconstruct
new 24c3b4d merge with master, solve conflict with InsertPlan
The 1552 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:
Readme.md | 29 +-
iotdb/iotdb/bin/stop-postBackClient.sh => clean.sh | 28 +-
docs/Documentation/Frequently asked questions.md | 28 +-
docs/Documentation/QuickStart.md | 25 +-
.../UserGuideV0.7.0/4-Deployment and Management.md | 77 +++
...rt-postBackClient.bat => start-sync-client.bat} | 4 +-
...tart-postBackClient.sh => start-sync-client.sh} | 4 +-
...top-postBackClient.bat => stop-sync-client.bat} | 4 +-
...{stop-postBackClient.sh => stop-sync-client.sh} | 6 +-
iotdb/iotdb/conf/iotdb-engine.properties | 14 +-
...ent.properties => iotdb-sync-client.properties} | 11 +-
.../iotdb/db/auth/role/BasicRoleManager.java | 1 -
.../iotdb/db/auth/user/BasicUserManager.java | 1 -
.../org/apache/iotdb/db/concurrent/HashLock.java | 22 -
.../org/apache/iotdb/db/concurrent/ThreadName.java | 5 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 26 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 24 +-
.../iotdb/db/engine/filenode/FileNodeManager.java | 87 ++-
.../db/engine/filenode/FileNodeProcessor.java | 77 ++-
.../engine/filenode/FileNodeProcessorStatus.java | 32 +-
.../db/engine/filenode/FileNodeProcessorStore.java | 55 +-
.../db/engine/filenode/OverflowChangeType.java | 31 +-
.../iotdb/db/engine/filenode/SerializeUtil.java | 72 --
.../iotdb/db/engine/filenode/TsFileResource.java | 119 +++-
.../iotdb/db/engine/memtable/WritableMemChunk.java | 9 +-
.../db/engine/tsfiledata/TsFileProcessor.java | 30 -
...Exception.java => SyncConnectionException.java} | 14 +-
.../org/apache/iotdb/db/monitor/IStatistic.java | 5 +-
.../apache/iotdb/db/monitor/MonitorConstants.java | 67 +-
.../org/apache/iotdb/db/monitor/StatMonitor.java | 160 +++--
.../iotdb/db/monitor/collector/FileSize.java | 173 +++++
.../db/postback/receiver/ServerServiceImpl.java | 701 -------------------
.../iotdb/db/postback/sender/FileSenderImpl.java | 510 --------------
.../iotdb/db/qp/physical/crud/InsertPlan.java | 5 +-
.../java/org/apache/iotdb/db/service/IoTDB.java | 2 +-
.../org/apache/iotdb/db/service/ServiceType.java | 18 +-
.../org/apache/iotdb/db/sync/conf/Constans.java | 47 ++
.../conf/SyncSenderConfig.java} | 74 +-
.../conf/SyncSenderDescriptor.java} | 87 ++-
.../{postback => sync}/receiver/ServerManager.java | 35 +-
.../iotdb/db/sync/receiver/ServerServiceImpl.java | 742 +++++++++++++++++++++
.../db/{postback => sync}/sender/FileManager.java | 91 +--
.../db/{postback => sync}/sender/FileSender.java | 27 +-
.../iotdb/db/sync/sender/FileSenderImpl.java | 544 +++++++++++++++
.../FilePathUtils.java} | 24 +-
.../org/apache/iotdb/db/utils/PostbackUtils.java | 157 -----
.../java/org/apache/iotdb/db/utils/SyncUtils.java | 126 ++++
.../filenode/FileNodeProcessorStoreTest.java | 91 +++
.../db/engine/filenode/SerializeUtilTest.java | 134 ----
.../db/engine/filenode/TsFileResourceTest.java | 98 +++
.../filenodev2/FileNodeManagerBenchmark.java | 2 +-
.../db/engine/modification/DeletionQueryTest.java | 6 +
.../db/engine/tsfiledata/TsFileProcessorTest.java | 169 +++--
.../apache/iotdb/db/integration/IoTDBDaemonIT.java | 1 +
.../integration/QueryDataFromUnclosedTsFileIT.java | 3 +-
.../org/apache/iotdb/db/monitor/MonitorTest.java | 66 +-
.../iotdb/db/monitor/collector/FileSizeTest.java | 93 +++
.../{postback => sync}/sender/FileManagerTest.java | 80 +--
.../sender/MultipleClientSyncTest.java} | 10 +-
.../sender/SingleClientSyncTest.java} | 109 ++-
.../org/apache/iotdb/db/sync/test}/RandomNum.java | 2 +-
.../iotdb/db/sync/test/SyncTestClient1.java} | 15 +-
.../iotdb/db/sync/test/SyncTestClient2.java} | 13 +-
.../iotdb/db/sync/test/SyncTestClient3.java} | 13 +-
.../java/org/apache/iotdb/db/sync/test}/Utils.java | 6 +-
.../apache/iotdb/db/writelog/WriteLogNodeTest.java | 5 +-
.../{start-postBackTest.sh => start-sync-test.sh} | 0
.../{stop-postBackTest.sh => stop-sync-test.sh} | 0
.../src/main/thrift/sync.thrift | 26 +-
.../query/dataset/DataSetWithoutTimeGenerator.java | 2 +-
.../tsfile/write/record/datapoint/DataPoint.java | 9 +-
.../iotdb/tsfile/read/ReadOnlyTsFileTest.java | 49 +-
.../iotdb/tsfile/utils/TsFileGeneratorForTest.java | 19 +-
73 files changed, 3084 insertions(+), 2367 deletions(-)
copy iotdb/iotdb/bin/stop-postBackClient.sh => clean.sh (58%)
mode change 100755 => 100644
rename iotdb/iotdb/bin/{start-postBackClient.bat => start-sync-client.bat}
(94%)
rename iotdb/iotdb/bin/{start-postBackClient.sh => start-sync-client.sh} (90%)
rename iotdb/iotdb/bin/{stop-postBackClient.bat => stop-sync-client.bat} (82%)
rename iotdb/iotdb/bin/{stop-postBackClient.sh => stop-sync-client.sh} (84%)
rename iotdb/iotdb/conf/{iotdb-postbackClient.properties =>
iotdb-sync-client.properties} (91%)
delete mode 100644
iotdb/src/main/java/org/apache/iotdb/db/engine/filenode/SerializeUtil.java
copy iotdb/src/main/java/org/apache/iotdb/db/exception/{SysCheckException.java
=> SyncConnectionException.java} (75%)
create mode 100644
iotdb/src/main/java/org/apache/iotdb/db/monitor/collector/FileSize.java
delete mode 100644
iotdb/src/main/java/org/apache/iotdb/db/postback/receiver/ServerServiceImpl.java
delete mode 100644
iotdb/src/main/java/org/apache/iotdb/db/postback/sender/FileSenderImpl.java
create mode 100644
iotdb/src/main/java/org/apache/iotdb/db/sync/conf/Constans.java
rename
iotdb/src/main/java/org/apache/iotdb/db/{postback/conf/PostBackSenderConfig.java
=> sync/conf/SyncSenderConfig.java} (54%)
rename
iotdb/src/main/java/org/apache/iotdb/db/{postback/conf/PostBackSenderDescriptor.java
=> sync/conf/SyncSenderDescriptor.java} (52%)
rename iotdb/src/main/java/org/apache/iotdb/db/{postback =>
sync}/receiver/ServerManager.java (74%)
create mode 100644
iotdb/src/main/java/org/apache/iotdb/db/sync/receiver/ServerServiceImpl.java
rename iotdb/src/main/java/org/apache/iotdb/db/{postback =>
sync}/sender/FileManager.java (67%)
rename iotdb/src/main/java/org/apache/iotdb/db/{postback =>
sync}/sender/FileSender.java (59%)
create mode 100644
iotdb/src/main/java/org/apache/iotdb/db/sync/sender/FileSenderImpl.java
copy
iotdb/src/main/java/org/apache/iotdb/db/{engine/overflow/io/OverflowedTsFileIOWriter.java
=> utils/FilePathUtils.java} (66%)
delete mode 100644
iotdb/src/main/java/org/apache/iotdb/db/utils/PostbackUtils.java
create mode 100644 iotdb/src/main/java/org/apache/iotdb/db/utils/SyncUtils.java
create mode 100644
iotdb/src/test/java/org/apache/iotdb/db/engine/filenode/FileNodeProcessorStoreTest.java
delete mode 100644
iotdb/src/test/java/org/apache/iotdb/db/engine/filenode/SerializeUtilTest.java
create mode 100644
iotdb/src/test/java/org/apache/iotdb/db/engine/filenode/TsFileResourceTest.java
create mode 100644
iotdb/src/test/java/org/apache/iotdb/db/monitor/collector/FileSizeTest.java
rename iotdb/src/test/java/org/apache/iotdb/db/{postback =>
sync}/sender/FileManagerTest.java (81%)
rename
iotdb/src/test/java/org/apache/iotdb/db/{postback/sender/MultipleClientPostBackTest.java
=> sync/sender/MultipleClientSyncTest.java} (96%)
rename
iotdb/src/test/java/org/apache/iotdb/db/{postback/sender/IoTDBSingleClientPostBackTest.java
=> sync/sender/SingleClientSyncTest.java} (88%)
rename iotdb/src/{main/java/org/apache/iotdb/db/postback/utils =>
test/java/org/apache/iotdb/db/sync/test}/RandomNum.java (97%)
rename
iotdb/src/{main/java/org/apache/iotdb/db/postback/utils/CreateDataSender1.java
=> test/java/org/apache/iotdb/db/sync/test/SyncTestClient1.java} (95%)
rename
iotdb/src/{main/java/org/apache/iotdb/db/postback/utils/CreateDataSender2.java
=> test/java/org/apache/iotdb/db/sync/test/SyncTestClient2.java} (95%)
rename
iotdb/src/{main/java/org/apache/iotdb/db/postback/utils/CreateDataSender3.java
=> test/java/org/apache/iotdb/db/sync/test/SyncTestClient3.java} (95%)
rename iotdb/src/{main/java/org/apache/iotdb/db/postback/utils =>
test/java/org/apache/iotdb/db/sync/test}/Utils.java (94%)
rename iotdb/src/test/resources/{start-postBackTest.sh => start-sync-test.sh}
(100%)
rename iotdb/src/test/resources/{stop-postBackTest.sh => stop-sync-test.sh}
(100%)
rename iotdb/src/main/thrift/ServerService.thrift =>
service-rpc/src/main/thrift/sync.thrift (64%)
