This is an automated email from the ASF dual-hosted git repository.
sunzesong pushed a change to branch tsfile_v4
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from e62efc5173 Add print
add a3a0b23916 [IOTDB-3439] Move Setting up RPC Service to the last step
of starting DataNode 2 (#6232)
add abb242a54b fix the issue that AutoCreateTimeSeries throws NPE (#6249)
add ae5f78646c [IOTDB-3424] avoid run duplicated IotDB server/node (#6200)
add e3fe470a0f [IOTDB-3460] Python API: Add support for DBAPI (#6246)
add 3247f48cd8 [IOTDB-3447] add some schema template function in python
client (#6223)
add c05ac0ff0b [IOTDB-3099] Flush in new cluster (#6167)
add 51acf53822 Support LocalSinkHandle and LocalSourceHandle if two FI in
the same DataNode (#6193)
add 149ededde9 fix test (#6251)
add a5aed992fa Abandon set ttl, schema replication factor, data
replication factor, time partition interval to specific storage group (#6252)
add f6943d9dfe Support flush in new standalone IoTDB (#6254)
add 1e31ab278d [IOTDB-3445][IOTDB-3446] Fixed empty dirs are not deleted
after data … (#6242)
add 5f9d274930 Fix group by level node serialize bug (#6258)
add 0eba12bfcf Rename deleteDirectoryAndParent to
deleteDirectoryAndEmptyParent (#6262)
add 2242a4033e [IOTDB-3331] Fix create three level timeseries. (#6247)
add 9e749b8ee1 [IOTDB-3472] Fix OOM in New Standalone mode (#6263)
add c742abeff6 [IOTDB-3390] Serialize ConfigNode expansion (#6256)
add a9060a1d3e [IOTDB-3440] Add description of compatibility between
0.13.x and 0.12.x / master and 0.13.x (#6234)
add 3e0a1281fb [IOTDB-5879]Override hashCode of AuthorReq (#6257)
add 3c78969fea Revert "[IOTDB-3390] Serialize ConfigNode expansion
(#6256)" (#6266)
add 9da5ad5281 [IOTDB-3463] IT framework supports read and compare from
multi data nodes (#6271)
add a93728770f IOTDB-3481 Optimize Log Print (#6273)
add c4b22f26ac [IOTDB-3477] Send two phase message to ConfigNode when
starting DataNode (#6269)
add babb62a355 [IOTDB-3416] Abstract interface of ConfigTask Execution for
standalone IoTDB (#6260)
add d7cf590774 [IOTDB-3384] fix run length tsblock serde (#6270)
add 16314af65a Add data Deletion IT and Insert IT for aligned time series
(#6259)
add 1871e60f39 [IOTDB-3476] remove error log when update cache
add 47ad89c8da Fix the issue that query is not removed from
QueryExecutionMap (#6278)
add b3355c58b3 [IOTDB-3485] Insert with wrong type didn't return error
massage (#6277)
add d976dcf530 [IOTDB-3434] Implement the Built-in Functions of String
(#6250)
add 73b4253ab9 fix the bug that the judgement of hasResultSet is skipped
(#6284)
add 3d4061ad69 [IOTDB-3473][metrics] Prometheus reporter will lose data in
some conditions (#6265)
add 914cc9a354 [IOTDB-3401] Fix some operators in filter condition query
are currently not returning BOOLEAN (#6169)
add f29b0f7609 [IOTDB-3486] Support deleteStorageGroup for new standalone
IoTDB (#6280)
add 732fa7716e [IOTDB-3489] Add test name to log folder in cluster test
(#6279)
add e2bb2ddc57 [IOTDB-3490] Eliminate LocalConfigNode Usage in New Cluster
(#6281)
add 2c8ff673cc [IOTDB-3494] Fix TypeError in python session (#6292)
add 1d599bf873 Merge remote-tracking branch 'origin/master' into
TsFile_v4_new
No new revisions were added by this update.
Summary of changes:
.github/workflows/cluster-it.yml | 14 +-
.../org/apache/iotdb/db/qp/sql/IdentifierParser.g4 | 2 +
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 2 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 4 +
client-py/README.md | 114 +-
client-py/SessionExample.py | 44 +-
client-py/iotdb/Session.py | 226 +++-
client-py/iotdb/dbapi/Connection.py | 91 ++
client-py/iotdb/dbapi/Cursor.py | 282 +++++
.../{tsfile/utils/Pair.py => dbapi/Exceptions.py} | 47 +-
.../{tsfile/utils/Pair.py => dbapi/__init__.py} | 12 +-
client-py/iotdb/{ => dbapi/tests}/__init__.py | 0
client-py/iotdb/dbapi/tests/test_connection.py | 57 +
client-py/iotdb/dbapi/tests/test_cursor.py | 123 ++
client-py/iotdb/template/Template.py | 5 +-
client-py/iotdb/template/TemplateNode.py | 3 +-
.../Pair.py => template/TemplateQueryType.py} | 25 +-
client-py/iotdb/tsfile/utils/Pair.py | 4 +-
client-py/tests/test_template.py | 130 ++-
.../confignode/client/SyncDataNodeClientPool.java | 46 +-
.../consensus/request/auth/AuthorReq.java | 6 +
.../iotdb/confignode/manager/ConfigManager.java | 31 +-
.../apache/iotdb/confignode/manager/Manager.java | 8 +-
.../confignode/manager/PermissionManager.java | 36 +-
.../iotdb/confignode/manager/ProcedureManager.java | 3 +-
.../persistence/partition/PartitionInfo.java | 82 +-
.../partition/StorageGroupPartitionTable.java | 17 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 38 +
.../confignode/persistence/PartitionInfoTest.java | 4 -
docs/Download/README.md | 20 +-
.../UserGuide/API/Programming-Python-Native-API.md | 113 +-
docs/UserGuide/Maintenance-Tools/Metric-Tool.md | 6 +-
docs/UserGuide/Reference/Syntax-Conventions.md | 22 +-
docs/UserGuide/UDF-Library/String-Processing.md | 656 +++++++++--
docs/zh/Download/README.md | 21 +-
.../UserGuide/API/Programming-Python-Native-API.md | 112 +-
docs/zh/UserGuide/Maintenance-Tools/Metric-Tool.md | 6 +-
docs/zh/UserGuide/Reference/Syntax-Conventions.md | 27 +-
docs/zh/UserGuide/UDF-Library/String-Processing.md | 652 +++++++++--
integration-test/README.md | 27 +-
.../org/apache/iotdb/it/env/ClusterEnvBase.java | 125 +-
.../org/apache/iotdb/it/env/ClusterEnvConfig.java | 11 +
.../java/org/apache/iotdb/it/env/ConfigNode.java | 16 +-
.../java/org/apache/iotdb/it/env/DataNode.java | 14 +-
.../java/org/apache/iotdb/it/env/EnvFactory.java | 2 +
.../org/apache/iotdb/it/env/IoTDBTestRunner.java | 44 +
.../org/apache/iotdb/it/env/RemoteServerEnv.java | 4 +
.../org/apache/iotdb/itbase/env/BaseConfig.java | 16 +
.../java/org/apache/iotdb/itbase/env/BaseEnv.java | 2 +
.../itbase/runtime/ClusterResultSetMetaData.java | 239 ++++
.../itbase/runtime/ClusterTestConnection.java | 333 ++++++
.../iotdb/itbase/runtime/ClusterTestResultSet.java | 1178 +++++++++++++++++++
.../iotdb/itbase/runtime/ClusterTestStatement.java | 297 +++++
.../InconsistentDataException.java} | 22 +-
.../iotdb/itbase/runtime/NodeConnection.java | 85 ++
.../itbase/runtime/ParallelRequestDelegate.java | 60 +
.../iotdb/itbase/runtime/RequestDelegate.java | 86 ++
.../iotdb/itbase/runtime/RequestThreadPool.java | 49 +
.../SerialRequestDelegate.java} | 42 +-
.../org/apache/iotdb/db/it/IoTDBExampleIT.java | 3 +
.../iotdb/db/it/IoTDBUDTFBuiltinFunctionIT.java | 1233 ++++++++++++++++++++
.../iotdb/db/it/aligned/AlignedWriteUtil.java | 8 +-
.../db/it/aligned/IoTDBAlignedSeriesQuery2IT.java | 3 +
.../db/it/aligned/IoTDBAlignedSeriesQuery3IT.java | 3 +
.../db/it/aligned/IoTDBAlignedSeriesQueryIT.java | 19 +-
.../db/it/aligned/IoTDBInsertAlignedValues2IT.java | 120 ++
.../db/it/aligned/IoTDBInsertAlignedValues3IT.java | 121 ++
.../db/it/aligned/IoTDBInsertAlignedValues4IT.java | 78 ++
.../db/it/aligned/IoTDBInsertAlignedValuesIT.java | 284 +++++
...2IT.java => IoTDBLastQueryWithDeletion2IT.java} | 25 +-
...heIT.java => IoTDBLastQueryWithDeletionIT.java} | 275 +++--
.../aligned/IoTDBLastQueryWithoutLastCache2IT.java | 3 +
.../aligned/IoTDBLastQueryWithoutLastCacheIT.java | 19 +-
...BLastQueryWithoutLastCacheWithDeletion2IT.java} | 23 +-
...DBLastQueryWithoutLastCacheWithDeletionIT.java} | 30 +-
...RawQueryWithoutValueFilterWithDeletion2IT.java} | 28 +-
...DBRawQueryWithoutValueFilterWithDeletionIT.java | 407 +++----
.../org/apache/iotdb/db/it/env/StandaloneEnv.java | 8 +-
.../iotdb/db/it/env/StandaloneEnvConfig.java | 16 +
.../iotdb/db/integration/IoTDBNestedQueryIT.java | 14 +-
.../aligned/IoTDBInsertAlignedValuesIT.java | 391 -------
.../aligned/IoTDBLastQueryWithDeletion2IT.java | 80 --
.../aligned/IoTDBLastQueryWithDeletionIT.java | 379 ------
...DBLastQueryWithoutLastCacheWithDeletion2IT.java | 85 --
...TDBLastQueryWithoutLastCacheWithDeletionIT.java | 383 ------
...BRawQueryWithoutValueFilterWithDeletion2IT.java | 83 --
.../reporter/MicrometerPrometheusReporter.java | 1 +
.../micrometer/MicrometerMetricManagerTest.java | 12 +
metrics/pom.xml | 41 +
.../iotdb/commons/partition/DataPartition.java | 3 +-
.../iotdb/commons/partition/SchemaPartition.java | 3 +-
.../BuiltinTimeSeriesGeneratingFunction.java | 21 +
.../commons/udf/builtin/String/UDTFConcat.java | 76 ++
.../commons/udf/builtin/String/UDTFEndsWith.java | 53 +
.../commons/udf/builtin/String/UDTFLower.java | 50 +
.../commons/udf/builtin/String/UDTFStartsWith.java | 52 +
.../commons/udf/builtin/String/UDTFStrCompare.java | 57 +
.../commons/udf/builtin/String/UDTFStrLength.java | 50 +
.../commons/udf/builtin/String/UDTFStrLocate.java | 62 +
.../commons/udf/builtin/String/UDTFSubstr.java | 72 ++
.../iotdb/commons/udf/builtin/String/UDTFTrim.java | 50 +
.../commons/udf/builtin/String/UDTFUpper.java | 50 +
.../org/apache/iotdb/commons/utils/AuthUtils.java | 22 +
.../org/apache/iotdb/commons/utils/FileUtils.java | 12 +
.../org/apache/iotdb/commons/utils/PathUtils.java | 4 +
.../iotdb/commons/client/ClientManagerTest.java | 29 +-
.../src/assembly/resources/sbin/start-datanode.sh | 63 +
.../assembly/resources/sbin/start-new-server.sh | 63 +
server/src/assembly/resources/sbin/start-server.sh | 63 +
.../apache/iotdb/db/auth/AuthorizerManager.java | 18 +-
.../iotdb/db/auth/ClusterAuthorityFetcher.java | 51 +-
.../apache/iotdb/db/auth/IAuthorityFetcher.java | 9 +-
.../iotdb/db/auth/StandaloneAuthorityFetcher.java | 20 +-
.../apache/iotdb/db/client/ConfigNodeClient.java | 34 +
.../org/apache/iotdb/db/engine/StorageEngine.java | 3 +-
.../apache/iotdb/db/engine/StorageEngineV2.java | 41 +
.../iotdb/db/engine/storagegroup/DataRegion.java | 41 +-
.../dataregion/StorageGroupManager.java | 4 +-
.../iotdb/db/localconfignode/LocalConfigNode.java | 102 +-
.../db/metadata/schemaregion/SchemaEngine.java | 139 ++-
.../metadata/schemaregion/SchemaRegionUtils.java | 5 +
.../iotdb/db/mpp/common/schematree/SchemaTree.java | 3 +-
.../execution/datatransfer/DataBlockManager.java | 108 +-
.../execution/datatransfer/LocalSinkHandle.java | 8 +-
.../execution/datatransfer/LocalSourceHandle.java | 46 +-
.../execution/datatransfer/SharedTsBlockQueue.java | 2 +-
.../db/mpp/execution/datatransfer/SinkHandle.java | 36 +-
.../mpp/execution/datatransfer/SourceHandle.java | 134 +--
.../fragment/FragmentInstanceExecution.java | 35 +-
.../fragment/FragmentInstanceStateMachine.java | 7 +-
.../execution/schedule/AbstractDriverThread.java | 13 +-
.../db/mpp/execution/schedule/DriverScheduler.java | 4 +-
.../mpp/execution/schedule/DriverTaskThread.java | 71 +-
.../org/apache/iotdb/db/mpp/plan/Coordinator.java | 12 +-
.../mpp/plan/analyze/ClusterPartitionFetcher.java | 8 +-
.../db/mpp/plan/analyze/ClusterSchemaFetcher.java | 70 +-
.../db/mpp/plan/analyze/ExpressionAnalyzer.java | 4 +
.../plan/analyze/StandalonePartitionFetcher.java | 3 +-
.../db/mpp/plan/constant/DataNodeEndPoints.java | 4 +
.../db/mpp/plan/execution/QueryExecution.java | 56 +-
.../mpp/plan/execution/config/AuthorizerTask.java | 67 +-
.../mpp/plan/execution/config/ConfigExecution.java | 27 +-
.../plan/execution/config/ConfigTaskVisitor.java | 6 +
.../execution/config/CountStorageGroupTask.java | 51 +-
.../plan/execution/config/CreateFunctionTask.java | 74 +-
.../execution/config/DeleteStorageGroupTask.java | 69 +-
.../plan/execution/config/DropFunctionTask.java | 65 +-
.../db/mpp/plan/execution/config/FlushTask.java | 66 ++
.../db/mpp/plan/execution/config/IConfigTask.java | 7 +-
.../plan/execution/config/SetStorageGroupTask.java | 68 +-
.../db/mpp/plan/execution/config/SetTTLTask.java | 58 +-
.../mpp/plan/execution/config/ShowClusterTask.java | 65 +-
.../plan/execution/config/ShowFunctionsTask.java | 7 +-
.../execution/config/ShowStorageGroupTask.java | 64 +-
.../db/mpp/plan/execution/config/ShowTTLTask.java | 85 +-
.../config/executor/ClusterConfigTaskExecutor.java | 328 ++++++
.../config/executor/IConfigTaskExecutor.java | 61 +
.../executor/StandsloneConfigTaskExecutor.java | 259 ++++
.../db/mpp/plan/expression/unary/InExpression.java | 6 +-
.../mpp/plan/expression/unary/LikeExpression.java | 8 +-
.../plan/expression/unary/RegularExpression.java | 8 +-
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 33 +
.../db/mpp/plan/planner/LocalExecutionPlanner.java | 42 +-
.../plan/parameter/GroupByLevelDescriptor.java | 8 +
.../db/mpp/plan/scheduler/ClusterScheduler.java | 12 +-
.../scheduler/FragmentInstanceDispatcherImpl.java | 14 +-
.../db/mpp/plan/scheduler/StandaloneScheduler.java | 3 +
.../db/mpp/plan/statement/StatementVisitor.java | 5 +
.../db/mpp/plan/statement/sys/FlushStatement.java | 92 ++
.../dag/transformer/unary/InTransformer.java | 14 +-
.../dag/transformer/unary/RegularTransformer.java | 4 +-
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 2 +-
.../iotdb/db/qp/physical/sys/AuthorPlan.java | 26 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 90 +-
.../java/org/apache/iotdb/db/service/IoTDB.java | 10 +-
.../java/org/apache/iotdb/db/service/NewIoTDB.java | 10 +-
.../recorder/CompactionMetricsRecorder.java | 4 +-
.../thrift/impl/DataNodeTSIServiceImpl.java | 45 +-
.../service/thrift/impl/InternalServiceImpl.java | 21 +-
.../db/mpp/execution/ConfigExecutionTest.java | 7 +-
.../datatransfer/LocalSourceHandleTest.java | 2 +-
.../node/process/GroupByLevelNodeSerdeTest.java | 12 +-
thrift-commons/src/main/thrift/common.thrift | 6 +
.../src/main/thrift/confignode.thrift | 13 +
thrift/src/main/thrift/mpp.thrift | 2 +
.../block/column/BinaryArrayColumnEncoder.java | 5 +-
.../block/column/ByteArrayColumnEncoder.java | 5 +-
.../read/common/block/column/ColumnEncoder.java | 9 +-
.../common/block/column/ColumnEncoderFactory.java | 3 +-
.../read/common/block/column/ColumnEncoding.java | 6 +-
.../block/column/Int32ArrayColumnEncoder.java | 8 +-
.../block/column/Int64ArrayColumnEncoder.java | 21 +-
.../block/column/RunLengthColumnEncoder.java | 54 +
.../block/column/RunLengthEncodedColumn.java | 2 +-
.../read/common/block/column/TsBlockSerde.java | 19 +-
.../common/block/BinaryArrayColumnEncoderTest.java | 8 +-
.../common/block/ByteArrayColumnEncoderTest.java | 9 +-
.../common/block/Int32ArrayColumnEncoderTest.java | 15 +-
.../common/block/Int64ArrayColumnEncoderTest.java | 17 +-
...erTest.java => RunLengthColumnEncoderTest.java} | 75 +-
200 files changed, 10511 insertions(+), 3535 deletions(-)
create mode 100644 client-py/iotdb/dbapi/Connection.py
create mode 100644 client-py/iotdb/dbapi/Cursor.py
copy client-py/iotdb/{tsfile/utils/Pair.py => dbapi/Exceptions.py} (61%)
copy client-py/iotdb/{tsfile/utils/Pair.py => dbapi/__init__.py} (77%)
copy client-py/iotdb/{ => dbapi/tests}/__init__.py (100%)
create mode 100644 client-py/iotdb/dbapi/tests/test_connection.py
create mode 100644 client-py/iotdb/dbapi/tests/test_cursor.py
copy client-py/iotdb/{tsfile/utils/Pair.py => template/TemplateQueryType.py}
(62%)
create mode 100644
integration-test/src/main/java/org/apache/iotdb/it/env/IoTDBTestRunner.java
create mode 100644
integration-test/src/main/java/org/apache/iotdb/itbase/runtime/ClusterResultSetMetaData.java
create mode 100644
integration-test/src/main/java/org/apache/iotdb/itbase/runtime/ClusterTestConnection.java
create mode 100644
integration-test/src/main/java/org/apache/iotdb/itbase/runtime/ClusterTestResultSet.java
create mode 100644
integration-test/src/main/java/org/apache/iotdb/itbase/runtime/ClusterTestStatement.java
copy integration-test/src/main/java/org/apache/iotdb/itbase/{env/BaseEnv.java
=> runtime/InconsistentDataException.java} (66%)
create mode 100644
integration-test/src/main/java/org/apache/iotdb/itbase/runtime/NodeConnection.java
create mode 100644
integration-test/src/main/java/org/apache/iotdb/itbase/runtime/ParallelRequestDelegate.java
create mode 100644
integration-test/src/main/java/org/apache/iotdb/itbase/runtime/RequestDelegate.java
create mode 100644
integration-test/src/main/java/org/apache/iotdb/itbase/runtime/RequestThreadPool.java
copy integration-test/src/main/java/org/apache/iotdb/itbase/{env/BaseEnv.java
=> runtime/SerialRequestDelegate.java} (51%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBUDTFBuiltinFunctionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBInsertAlignedValues2IT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBInsertAlignedValues3IT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBInsertAlignedValues4IT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBInsertAlignedValuesIT.java
copy
integration-test/src/test/java/org/apache/iotdb/db/it/aligned/{IoTDBLastQueryWithoutLastCache2IT.java
=> IoTDBLastQueryWithDeletion2IT.java} (75%)
copy
integration-test/src/test/java/org/apache/iotdb/db/it/aligned/{IoTDBLastQueryWithoutLastCacheIT.java
=> IoTDBLastQueryWithDeletionIT.java} (51%)
copy
integration-test/src/test/java/org/apache/iotdb/db/it/aligned/{IoTDBLastQueryWithoutLastCache2IT.java
=> IoTDBLastQueryWithoutLastCacheWithDeletion2IT.java} (76%)
copy
integration-test/src/test/java/org/apache/iotdb/db/it/aligned/{IoTDBLastQueryWithoutLastCache2IT.java
=> IoTDBLastQueryWithoutLastCacheWithDeletionIT.java} (70%)
copy
integration-test/src/test/java/org/apache/iotdb/db/it/aligned/{IoTDBLastQueryWithoutLastCache2IT.java
=> IoTDBRawQueryWithoutValueFilterWithDeletion2IT.java} (71%)
rename {integration/src/test/java/org/apache/iotdb/db/integration =>
integration-test/src/test/java/org/apache/iotdb/db/it}/aligned/IoTDBRawQueryWithoutValueFilterWithDeletionIT.java
(52%)
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBInsertAlignedValuesIT.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBLastQueryWithDeletion2IT.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBLastQueryWithDeletionIT.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBLastQueryWithoutLastCacheWithDeletion2IT.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBLastQueryWithoutLastCacheWithDeletionIT.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBRawQueryWithoutValueFilterWithDeletion2IT.java
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/String/UDTFConcat.java
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/String/UDTFEndsWith.java
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/String/UDTFLower.java
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/String/UDTFStartsWith.java
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/String/UDTFStrCompare.java
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/String/UDTFStrLength.java
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/String/UDTFStrLocate.java
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/String/UDTFSubstr.java
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/String/UDTFTrim.java
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/String/UDTFUpper.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/FlushTask.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/executor/ClusterConfigTaskExecutor.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/executor/IConfigTaskExecutor.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/executor/StandsloneConfigTaskExecutor.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/sys/FlushStatement.java
create mode 100644
tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/block/column/RunLengthColumnEncoder.java
copy
tsfile/src/test/java/org/apache/iotdb/tsfile/common/block/{BinaryArrayColumnEncoderTest.java
=> RunLengthColumnEncoderTest.java} (53%)
