This is an automated email from the ASF dual-hosted git repository.
spricoder pushed a change to branch feature/memory_heap_adapt
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 5250b022775 update size
add 8f29bcd8578 Load: Do not clear schema cache when last cache is
disabled (#15380)
add aaff44910bd Pipe: aggregate tablets with different measurements under
the same table before write into tsfile (#15372)
add 74827521421 Subscription: obtain database name for message payload
subscribed by table model consumer (#15374)
add 2cfd029f214 Pipe: use mem table to batch write table data into tsfile
(#15373)
add 3215a4f4782 Fix error code when Row appears in query
add 571dcbe19c9 [RTO/RPO] Coordinator/Session Failover Retry (#15269)
add b20ab8accf2 Subscription: implemented runtime permission check (#15376)
add 5fae88dd6a6 feat: disabled history for -e sql (#15389)
add ede9b7430b6 Fixed the issue where the code returned when executing
drop user root SQL is different from the CLI (#15387)
add 699487f7f12 Adapt TIMESTAMP type when import data (#15378)
add 285ee5b5b6b Load: Fixed the bug that an empty table database may not
check privilege for auto-creation (#15366)
add 9e02cbdd371 [RTO/RPO] Add requestor retry for network partition
error #15393
add bac9f664f5f Subscription: unify table and tree consumer builder
interface (#15392)
add b0cfead5f3b Pipe: Fixed the deadlock cause by terminate event
reporting & Added sink.batch.max-delay-ms to enable delicate control over batch
delay & Fixed the bug of premature halt in extractor snapshot mode cause by
real-time-first transfer & Stabilized the trigger of default batch sending &
Added "isNeedToReport" getter in PipeRawTabletInsertionEvent for user-defined
plugins & Reduce logs from PipeEventCommitter (#15377)
add 34795100682 Add ScalarArgumentChecker and auto-built pass through
index for TVF
add 8eb73e0cf1f Load: Enhanced the table auto-creation logic (#15265)
add b1344eefefc Subscription: add more methods for table session dataset
(#15398)
add eb15d9a8367 Subscription: simplify table and tree consumer builder
interface (#15399)
add db62fba21ba Subscription: implemented strict runtime permission check
for consumer group (#15400)
add dd429d9539f Pipe: Fix batch type can not be changed (Introduced in
#15377) & Enhance close() in PipeTsFileResource (#15401)
add a25ce1922fc Load IT: Ignore unstable
testLoadAutoCreateWithoutInsertPermission (#15405)
add aa1bd05234a Fix cpp client compilation (#15403)
add 1f67cf6e7cc update params in ImportSchemaTestIT (#15406)
add edf87ff4fc2 Load IT: Stabilized the
testLoadAutoCreateWithoutInsertPermission test (#15408)
add 923bb2c347c Add APPROX_COUNT_DISTINCT Function
add a17ec6771be Add authorization for metric prometheus report (#15363)
add bb087e7bc64 [Py-client] Query Timestamp type of values return readable
format
add db3a3845475 Add TableFunctionHandle for TVF
add 665e18f6f63 docker: support configuring JVM memory environment
variables in docker-compose file:IOTDB_JMX_OPTS for
datanode,CONFIGNODE_JMX_OPTS for confignode (#15413)
add c9453ab08c6 pref: Adjustments to sbin and tools Scripts (#15402)
add 3b7494e7ce0 IoTV2: Fix global client manager close by mistake when
running #15415
add a2f02048ec2 DAL: Fix thread leak when DN exit. #15395
add 7650b479347 [remove datanode] GCR load balancing implement for
removing datanode (#15282)
add 17da13e45d7 Procedure: Fix the concurrency error during
StateMachineProcedure snapshot (#15417)
add 15ad13c9207 Pipe: Implement hot loading of Pipe configuration
parameters (#15292)
add 12ddd33db6b recover the place of setting ON_HEAP_MEMORY and
OFF_HEAP_MEMORY to fix atmos (#15421)
add de1d224f4bd estimating inner compaction task memory during selection
(#15257)
add e27245e129e Fix memory leak in wal compressed buffer (#15418)
add 512188b689b Fixed the NPE caused by concurrent template unset /
activation #15420
add 76e1f0aab13 Fix conflict
No new revisions were added by this update.
Summary of changes:
distribution/src/assembly/ainode.xml | 6 +
distribution/src/assembly/all.xml | 50 +-
distribution/src/assembly/cli.xml | 17 +-
distribution/src/assembly/confignode.xml | 41 +-
distribution/src/assembly/datanode.xml | 45 +-
.../DockerCompose/docker-compose-host-3c3d.yml | 2 +
.../DockerCompose/docker-compose-standalone.yml | 4 +-
.../main/DockerCompose/replace-conf-from-env.sh | 11 +-
.../TableModelSubscriptionSessionExample.java | 19 +-
.../iotdb/udf/table/ExcludeColumnExample.java | 11 +-
.../org/apache/iotdb/udf/table/RepeatExample.java | 21 +-
.../org/apache/iotdb/udf/table/SplitExample.java | 27 +-
integration-test/src/assembly/mpp-test.xml | 32 +-
.../example/relational/MyErrorTableFunction.java | 15 +-
.../udf/example/relational/MyExcludeColumn.java | 11 +-
.../udf/example/relational/MyRepeatWithIndex.java | 17 +-
.../example/relational/MyRepeatWithoutIndex.java | 17 +-
.../{MyExcludeColumn.java => MySelectColumn.java} | 21 +-
.../db/query/udf/example/relational/MySplit.java | 27 +-
.../it/env/cluster/config/MppConfigNodeConfig.java | 12 +
.../it/env/cluster/config/MppDataNodeConfig.java | 12 +
.../iotdb/it/env/cluster/env/AbstractEnv.java | 13 +-
.../env/remote/config/RemoteConfigNodeConfig.java | 10 +
.../it/env/remote/config/RemoteDataNodeConfig.java | 10 +
.../iotdb/it/env/remote/env/RemoteServerEnv.java | 13 +-
.../java/org/apache/iotdb/itbase/env/BaseEnv.java | 11 +-
.../apache/iotdb/itbase/env/ConfigNodeConfig.java | 5 +
.../apache/iotdb/itbase/env/DataNodeConfig.java | 4 +
.../apache/iotdb/cli/it/StartClientScriptIT.java | 4 +-
.../org/apache/iotdb/db/it/IoTDBLoadTsFileIT.java | 54 ++
.../org/apache/iotdb/db/it/IoTDBRestartIT.java | 2 -
.../apache/iotdb/db/it/metric/IoTDBMetricIT.java | 92 ++-
.../org/apache/iotdb/db/it/utils/TestUtils.java | 29 +-
.../manual/basic/IoTDBPipeWithLoadIT.java | 107 +++
.../relational/it/db/it/IoTDBWindowTVFIT.java | 23 +-
.../db/it/udf/IoTDBUserDefinedTableFunctionIT.java | 16 +
.../it/query/recent/IoTDBTableAggregationIT.java | 77 +++
.../it/local/IoTDBSubscriptionPermissionIT.java | 339 ++++++++++
.../apache/iotdb/tools/it/ExportDataTestIT.java | 6 +-
.../apache/iotdb/tools/it/ExportSchemaTestIT.java | 10 +-
.../apache/iotdb/tools/it/ExportTsFileTestIT.java | 4 +-
.../apache/iotdb/tools/it/ImportDataTestIT.java | 2 +-
.../apache/iotdb/tools/it/ImportSchemaTestIT.java | 22 +-
.../api/relational/EmptyTableFunctionHandle.java | 22 +-
.../iotdb/udf/api/relational/TableFunction.java | 10 +-
.../relational/table/MapTableFunctionHandle.java | 186 ++++++
.../relational/table/TableFunctionAnalysis.java | 21 +-
.../table/TableFunctionHandle.java} | 15 +-
.../table/argument/ScalarArgumentChecker.java | 16 +-
.../processor/TableFunctionDataProcessor.java | 12 +-
.../ScalarParameterSpecification.java | 23 +-
iotdb-client/cli/src/assembly/cli.xml | 10 +
.../src/main/java/org/apache/iotdb/cli/Cli.java | 1 +
.../apache/iotdb/tool/data/AbstractDataTool.java | 12 +
.../org/apache/iotdb/tool/data/ImportDataTree.java | 57 +-
.../iotdb/tool/tsfile/ImportTsFileRemotely.java | 6 +-
.../subscription/SubscriptionTableTsFile.java | 2 +-
iotdb-client/client-cpp/src/main/Session.cpp | 2 +-
.../client-cpp/src/main/SessionConnection.h | 2 +-
iotdb-client/client-py/README.md | 4 +-
iotdb-client/client-py/iotdb/Session.py | 18 +-
iotdb-client/client-py/iotdb/SessionPool.py | 4 +-
iotdb-client/client-py/iotdb/utils/Field.py | 29 +-
.../client-py/iotdb/utils/SessionDataSet.py | 19 +-
.../client-py/iotdb/utils/iotdb_rpc_dataset.py | 38 +-
iotdb-client/client-py/iotdb/utils/rpc_utils.py | 41 ++
iotdb-client/client-py/requirements.txt | 1 +
iotdb-client/client-py/resources/pyproject.toml | 3 +-
.../session_aligned_timeseries_example.py | 4 +-
iotdb-client/client-py/session_example.py | 4 +-
iotdb-client/client-py/session_pool_example.py | 2 +-
iotdb-client/client-py/session_ssl_example.py | 4 +-
.../client-py/table_model_session_example.py | 4 +-
.../integration/tablet_performance_comparison.py | 4 +-
.../tests/integration/test_new_data_types.py | 12 +-
.../tests/integration/test_tablemodel_query.py | 22 +-
.../java/org/apache/iotdb/jdbc/IoTDBStatement.java | 134 ++--
.../rpc/subscription/annotation/TableModel.java | 12 +-
.../rpc/subscription/config/ConsumerConfig.java | 8 +
.../subscription/payload/poll/FileSealPayload.java | 27 +-
.../subscription/payload/poll/TabletsPayload.java | 41 +-
.../response/PipeSubscribeHeartbeatResp.java | 48 +-
.../apache/iotdb/session/SessionConnection.java | 148 ++++-
.../SubscriptionSessionConnection.java | 32 -
.../base/AbstractSubscriptionConsumer.java | 26 +-
.../base/AbstractSubscriptionConsumerBuilder.java | 20 -
.../base/AbstractSubscriptionProvider.java | 13 +-
.../base/AbstractSubscriptionProviders.java | 6 +-
.../SubscriptionTablePullConsumerBuilder.java | 3 +-
.../SubscriptionTablePushConsumerBuilder.java | 3 +-
.../tree/SubscriptionTreePullConsumerBuilder.java | 3 +-
.../tree/SubscriptionTreePushConsumerBuilder.java | 3 +-
.../payload/SubscriptionFileHandler.java | 7 -
.../subscription/payload/SubscriptionMessage.java | 29 +-
.../payload/SubscriptionMessageHandler.java | 7 +-
.../payload/SubscriptionSessionDataSet.java | 97 ++-
.../SubscriptionSessionDataSetsHandler.java | 56 +-
.../payload/SubscriptionTsFileHandler.java | 14 +-
iotdb-core/ainode/ainode.xml | 27 +
iotdb-core/confignode/src/assembly/confignode.xml | 28 +-
.../iotdb/confignode/manager/ConfigManager.java | 2 +-
.../iotdb/confignode/manager/ProcedureManager.java | 6 +-
.../region/GreedyCopySetRegionGroupAllocator.java | 358 +++++++++-
.../region/GreedyRegionGroupAllocator.java | 13 +
.../balancer/region/IRegionGroupAllocator.java | 21 +
.../PartiteGraphPlacementRegionGroupAllocator.java | 13 +
.../persistence/schema/ClusterSchemaInfo.java | 15 +-
.../procedure/env/RemoveDataNodeHandler.java | 186 ++++++
.../procedure/impl/StateMachineProcedure.java | 11 +-
.../impl/node/RemoveDataNodesProcedure.java | 6 +-
.../consumer/CreateConsumerProcedure.java | 4 +-
.../subscription/CreateSubscriptionProcedure.java | 21 +-
.../GreedyCopySetRemoveNodeReplicaSelectTest.java | 342 ++++++++++
iotdb-core/datanode/src/assembly/server.xml | 44 +-
.../apache/iotdb/db/conf/DataNodeMemoryConfig.java | 12 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 11 -
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 14 +-
.../schemaregion/SchemaExecutionVisitor.java | 15 +
.../task/builder/PipeDataNodeTaskBuilder.java | 51 +-
.../subtask/connector/PipeConnectorSubtask.java | 13 +-
.../PipeRealtimePriorityBlockingQueue.java | 26 +-
.../IoTDBDataNodeCacheLeaderClientManager.java | 12 +-
.../batch/PipeTabletEventTsFileBatch.java | 9 +-
.../batch/PipeTransferBatchReqBuilder.java | 41 +-
.../pipeconsensus/PipeConsensusSyncConnector.java | 3 -
.../PipeConsensusTransferBatchReqBuilder.java | 19 +-
.../async/IoTDBDataRegionAsyncConnector.java | 31 +-
...ilder.java => PipeTableModelTsFileBuilder.java} | 88 ++-
...rV2.java => PipeTableModelTsFileBuilderV2.java} | 133 +++-
.../deletion/persist/PageCacheDeletionBuffer.java | 12 +-
.../common/tablet/PipeRawTabletInsertionEvent.java | 5 +
.../event/common/terminate/PipeTerminateEvent.java | 6 +-
.../scan/TsFileInsertionEventScanParser.java | 5 +-
...ileInsertionEventTableParserTabletIterator.java | 16 +-
...oricalDataRegionTsFileAndDeletionExtractor.java | 30 +-
.../PipeRealtimeDataRegionHybridExtractor.java | 5 +-
.../realtime/assigner/PipeDataRegionAssigner.java | 5 +-
.../pipe/processor/twostage/combiner/Combiner.java | 5 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 10 +-
.../db/pipe/resource/memory/PipeMemoryManager.java | 54 +-
.../pipe/resource/tsfile/PipeTsFileResource.java | 14 +-
.../resource/tsfile/PipeTsFileResourceManager.java | 2 +-
.../rest/table/v1/handler/ExceptionHandler.java | 4 +
.../protocol/rest/v1/handler/ExceptionHandler.java | 4 +
.../protocol/rest/v2/handler/ExceptionHandler.java | 4 +
.../execution/executor/RegionReadExecutor.java | 17 +-
.../process/function/TableFunctionOperator.java | 18 +-
.../relational/aggregation/AccumulatorFactory.java | 5 +
.../ApproxCountDistinctAccumulator.java | 265 ++++++++
.../source/relational/aggregation/HyperLogLog.java | 246 +++++++
.../aggregation/HyperLogLogStateFactory.java | 88 +++
.../GroupedApproxCountDistinctAccumulator.java | 314 +++++++++
.../aggregation/grouped/array/BinaryBigArray.java | 4 -
.../grouped/array/HyperLogLogBigArray.java | 84 +++
.../aggregation/grouped/array/MapBigArray.java | 4 -
.../aggregation/grouped/array/ObjectBigArray.java | 12 +-
.../relational/ColumnTransformerBuilder.java | 2 +-
.../iotdb/db/queryengine/plan/Coordinator.java | 4 -
.../plan/analyze/load/LoadTsFileAnalyzer.java | 66 +-
.../analyze/load/LoadTsFileTableSchemaCache.java | 78 ++-
.../analyze/schema/AutoCreateSchemaExecutor.java | 14 +-
.../analyze/schema/ClusterSchemaFetchExecutor.java | 9 +-
.../plan/analyze/schema/ClusterSchemaFetcher.java | 1 -
.../config/executor/ClusterConfigTaskExecutor.java | 4 +-
.../plan/planner/TableOperatorGenerator.java | 5 +-
.../queryengine/plan/planner/TreeModelPlanner.java | 2 -
.../plan/planner/plan/node/PlanGraphPrinter.java | 30 +-
.../plan/node/metadata/write/MeasurementGroup.java | 25 +-
.../relational/analyzer/StatementAnalyzer.java | 9 +
.../TableFunctionInvocationAnalysis.java | 8 +
.../relational/metadata/TableMetadataImpl.java | 15 +
.../plan/relational/planner/RelationPlanner.java | 2 +-
.../plan/relational/planner/TableModelPlanner.java | 9 -
.../rule/ImplementTableFunctionSource.java | 4 +-
.../rule/PruneTableFunctionProcessorColumns.java | 2 +-
.../PruneTableFunctionProcessorSourceColumns.java | 2 +-
.../relational/planner/node/TableFunctionNode.java | 57 +-
.../planner/node/TableFunctionProcessorNode.java | 51 +-
.../optimizations/UnaliasSymbolReferences.java | 6 +-
.../plan/relational/sql/ast/Expression.java | 3 +
.../plan/relational/sql/ast/LoadTsFile.java | 10 +-
.../queryengine/plan/relational/sql/ast/Row.java | 33 +
.../relational/sql/ast/TableExpressionType.java | 3 +-
.../plan/relational/sql/parser/AstBuilder.java | 9 +
.../plan/scheduler/AsyncPlanNodeSender.java | 21 +-
.../plan/scheduler/ClusterScheduler.java | 5 -
....java => FailedFragmentInstanceWithStatus.java} | 22 +-
.../scheduler/FragmentInstanceDispatcherImpl.java | 248 ++++---
.../db/schemaengine/table/DataNodeTableCache.java | 18 +-
.../db/storageengine/dataregion/DataRegion.java | 6 +-
.../performer/ICrossCompactionPerformer.java | 6 +
...rformer.java => IInnerCompactionPerformer.java} | 11 +-
.../execute/performer/ISeqCompactionPerformer.java | 2 +-
.../performer/IUnseqCompactionPerformer.java | 2 +-
.../performer/impl/FastCompactionPerformer.java | 15 +
.../impl/ReadChunkCompactionPerformer.java | 8 +
.../impl/ReadPointCompactionPerformer.java | 8 +
.../execute/task/AbstractCompactionTask.java | 10 +
.../execute/task/InnerSpaceCompactionTask.java | 18 +-
.../estimator/AbstractCompactionEstimator.java | 124 +++-
.../estimator/AbstractCrossSpaceEstimator.java | 6 +-
.../estimator/AbstractInnerSpaceEstimator.java | 5 +-
.../estimator/CompactionEstimateUtils.java | 91 ++-
.../selector/estimator/CompactionTaskInfo.java | 6 -
...taInfo.java => CompactionTaskMetadataInfo.java} | 12 +-
.../FastCompactionInnerCompactionEstimator.java | 44 +-
.../FastCrossSpaceCompactionEstimator.java | 29 +-
.../compaction/selector/estimator/FileInfo.java | 39 +-
.../ReadChunkInnerCompactionEstimator.java | 25 +-
.../RepairUnsortedFileCompactionEstimator.java | 21 +-
.../impl/NewSizeTieredCompactionSelector.java | 76 ++-
.../impl/RewriteCrossSpaceCompactionSelector.java | 2 +-
.../dataregion/wal/buffer/WALBuffer.java | 9 +-
.../dataregion/wal/io/WALInputStream.java | 2 +
.../broker/SubscriptionPrefetchingTsFileQueue.java | 3 +
.../db/subscription/event/SubscriptionEvent.java | 4 +-
.../batch/SubscriptionPipeTabletEventBatch.java | 27 +-
.../batch/SubscriptionPipeTsFileEventBatch.java | 5 +-
.../response/SubscriptionEventTabletResponse.java | 20 +-
.../response/SubscriptionEventTsFileResponse.java | 9 +-
.../receiver/SubscriptionReceiverV1.java | 47 +-
.../apache/iotdb/db/utils/ErrorHandlingUtils.java | 4 +-
.../apache/iotdb/db/utils/ModificationUtils.java | 23 +-
.../iotdb/db/utils/constant/SqlConstant.java | 2 +
.../db/queryengine/plan/function/Exclude.java | 11 +-
.../iotdb/db/queryengine/plan/function/Repeat.java | 22 +-
.../iotdb/db/queryengine/plan/function/Split.java | 27 +-
.../relational/analyzer/TableFunctionTest.java | 92 +--
.../assertions/TableFunctionProcessorMatcher.java | 178 +----
.../org/apache/iotdb/db/script/EnvScriptIT.java | 12 +-
.../utils/CompactionTaskMemCostEstimatorTest.java | 87 ++-
.../wal/compression/WALCompressionTest.java | 45 +-
iotdb-core/metrics/interface/pom.xml | 5 +
.../apache/iotdb/metrics/config/MetricConfig.java | 38 ++
.../metrics/config/MetricConfigDescriptor.java | 19 +
.../reporter/prometheus/PrometheusReporter.java | 62 +-
.../conf/iotdb-system.properties.template | 11 +
.../apache/iotdb/commons/conf/CommonConfig.java | 445 +++++++++++++
.../iotdb/commons/conf/CommonDescriptor.java | 486 +-------------
...n.java => QuerySchemaFetchFailedException.java} | 10 +-
.../task/connection/BlockingPendingQueue.java | 13 +-
.../agent/task/execution/PipeSubtaskScheduler.java | 15 +-
.../agent/task/progress/PipeEventCommitter.java | 28 +-
.../iotdb/commons/pipe/config/PipeConfig.java | 5 +-
.../config/PipeDescriptor.java} | 732 +++++----------------
.../config/constant/PipeConnectorConstant.java | 3 +
.../pipe/connector/protocol/IoTDBConnector.java | 10 +
.../commons/pipe/receiver/IoTDBFileReceiver.java | 18 +-
.../meta/consumer/ConsumerGroupMeta.java | 49 ++
.../subscription/meta/consumer/ConsumerMeta.java | 12 +
.../commons/subscription/meta/topic/TopicMeta.java | 9 +-
.../TableBuiltinAggregationFunction.java | 2 +
.../relational/tvf/CapacityTableFunction.java | 27 +-
.../relational/tvf/CumulateTableFunction.java | 40 +-
.../builtin/relational/tvf/HOPTableFunction.java | 44 +-
.../relational/tvf/SessionTableFunction.java | 24 +-
.../relational/tvf/TumbleTableFunction.java | 32 +-
.../relational/tvf/VariationTableFunction.java | 25 +-
.../apache/iotdb/commons/utils/StatusUtils.java | 2 +-
.../thrift-commons/src/main/thrift/common.thrift | 3 +-
library-udf/src/assembly/tools/register-UDF.bat | 110 ++--
.../resources => scripts}/conf/ainode-env.sh | 0
.../resources => scripts}/conf/confignode-env.sh | 21 +-
.../resources => scripts}/conf/datanode-env.sh | 24 +-
.../sbin => scripts/conf}/iotdb-common.sh | 0
.../conf => scripts/conf/windows}/ainode-env.bat | 11 +-
.../conf/windows}/confignode-env.bat | 2 +-
.../conf => scripts/conf/windows}/datanode-env.bat | 2 +-
.../sbin => scripts/sbin/cluster}/start-all.sh | 2 +-
.../sbin => scripts/sbin/cluster}/stop-all.sh | 2 +-
.../resources => scripts}/sbin/start-ainode.sh | 17 +-
.../resources => scripts}/sbin/start-cli.sh | 0
.../resources => scripts}/sbin/start-confignode.sh | 2 +-
.../resources => scripts}/sbin/start-datanode.sh | 2 +-
.../resources => scripts}/sbin/start-standalone.sh | 0
.../resources => scripts}/sbin/stop-ainode.sh | 0
.../resources => scripts}/sbin/stop-confignode.sh | 2 +-
.../resources => scripts}/sbin/stop-datanode.sh | 2 +-
.../resources => scripts}/sbin/stop-standalone.sh | 0
.../sbin => scripts/sbin/windows}/start-ainode.bat | 12 +-
.../sbin/windows/start-cli-table.bat | 4 +-
.../sbin => scripts/sbin/windows}/start-cli.bat | 2 +-
.../sbin/windows}/start-confignode.bat | 8 +-
.../sbin/windows}/start-datanode.bat | 14 +-
.../sbin/windows}/start-standalone.bat | 12 +-
.../sbin => scripts/sbin/windows}/stop-ainode.bat | 8 +-
.../sbin/windows}/stop-confignode.bat | 13 +-
.../sbin/windows}/stop-datanode.bat | 13 +-
.../sbin/windows}/stop-standalone.bat | 10 +-
.../resources => scripts}/tools/export-data.sh | 0
.../resources => scripts}/tools/import-data.sh | 0
.../resources => scripts}/tools/load-tsfile.sh | 2 +-
.../tools => scripts/tools/ops}/backup.sh | 2 +-
.../tools => scripts/tools/ops}/collect-info.sh | 2 +-
.../tools/ops}/daemon-confignode.sh | 2 +-
.../sbin => scripts/tools/ops}/daemon-datanode.sh | 2 +-
.../sbin => scripts/tools/ops}/destroy-all.sh | 18 +-
.../tools/ops}/destroy-confignode.sh | 2 +-
.../sbin => scripts/tools/ops}/destroy-datanode.sh | 2 +-
.../sbin => scripts/tools/ops}/health_check.sh | 4 +-
.../sbin => scripts/tools/ops}/remove-ainode.sh | 23 +-
.../tools/schema}/export-schema.sh | 2 +-
.../tools/schema}/import-schema.sh | 2 +-
.../tools/schema/print-pb-tree-file.sh | 2 +-
.../tools/schema/print-schema-log.sh | 2 +-
.../check-overlap-sequence-files-and-repair.sh | 2 +-
.../tools/tsfile/overlap-statistic-tool.sh | 2 +-
.../tools/tsfile/print-iotdb-data-dir.sh | 2 +-
.../tools/tsfile/print-tsfile-resource-files.sh | 2 +-
.../tools/tsfile/print-tsfile.sh | 2 +-
.../tools/tsfile/settle-tsfile.sh | 0
.../tools/tsfile/split-tsfile-tool.sh | 2 +-
.../tools/tsfile/validate-tsfile.sh | 2 +-
.../tools/windows}/export-data.bat | 2 +-
.../tools/windows}/import-data.bat | 2 +-
.../tools/windows}/load-tsfile.bat | 2 +-
.../tools => scripts/tools/windows/ops}/backup.bat | 6 +-
.../tools/windows/ops}/collect-info.bat | 8 +-
.../tools/windows/ops}/destroy-all.bat | 8 +-
.../tools/windows/ops}/destroy-confignode.bat | 4 +-
.../tools/windows/ops}/destroy-datanode.bat | 4 +-
.../tools/windows/ops}/health_check.bat | 14 +-
.../tools/windows/ops}/remove-ainode.bat | 20 +-
.../tools/windows/schema}/export-schema.bat | 2 +-
.../tools/windows/schema}/import-schema.bat | 2 +-
.../tools/windows}/schema/print-pb-tree-file.bat | 2 +-
.../tools/windows}/schema/print-schema-log.bat | 2 +-
.../check-overlap-sequence-files-and-repair.bat | 2 +-
.../windows}/tsfile/overlap-statistic-tool.bat | 2 +-
.../tools/windows}/tsfile/print-iotdb-data-dir.bat | 2 +-
.../tsfile/print-tsfile-resource-files.bat | 2 +-
.../tools/windows}/tsfile/print-tsfile.bat | 2 +-
.../tools/windows}/tsfile/settle-tsfile.bat | 2 +-
.../tools/windows}/tsfile/split-tsfile-tool.bat | 2 +-
.../tools/windows}/tsfile/validate-tsfile.bat | 2 +-
335 files changed, 7133 insertions(+), 2909 deletions(-)
copy
integration-test/src/main/java/org/apache/iotdb/db/query/udf/example/relational/{MyExcludeColumn.java
=> MySelectColumn.java} (81%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/local/IoTDBSubscriptionPermissionIT.java
copy
iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/NonOpenTransport.java
=>
iotdb-api/udf-api/src/main/java/org/apache/iotdb/udf/api/relational/EmptyTableFunctionHandle.java
(69%)
create mode 100644
iotdb-api/udf-api/src/main/java/org/apache/iotdb/udf/api/relational/table/MapTableFunctionHandle.java
copy iotdb-api/udf-api/src/main/java/org/apache/iotdb/udf/api/{State.java =>
relational/table/TableFunctionHandle.java} (81%)
copy
integration-test/src/test/java/org/apache/iotdb/confignode/it/removedatanode/SQLModel.java
=>
iotdb-api/udf-api/src/main/java/org/apache/iotdb/udf/api/relational/table/argument/ScalarArgumentChecker.java
(69%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/SchemaRegion.java
=>
iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/subscription/annotation/TableModel.java
(76%)
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/load/balancer/region/GreedyCopySetRemoveNodeReplicaSelectTest.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/util/builder/{PipeTableModeTsFileBuilder.java
=> PipeTableModelTsFileBuilder.java} (72%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/util/builder/{PipeTreeModelTsFileBuilderV2.java
=> PipeTableModelTsFileBuilderV2.java} (55%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/ApproxCountDistinctAccumulator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/HyperLogLog.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/HyperLogLogStateFactory.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/grouped/GroupedApproxCountDistinctAccumulator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/grouped/array/HyperLogLogBigArray.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/scheduler/{FragInstanceDispatchResult.java
=> FailedFragmentInstanceWithStatus.java} (69%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/performer/{ICrossCompactionPerformer.java
=> IInnerCompactionPerformer.java} (74%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/selector/estimator/{MetadataInfo.java
=> CompactionTaskMetadataInfo.java} (81%)
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/exception/{RpcThrottlingException.java
=> QuerySchemaFetchFailedException.java} (72%)
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/{conf/CommonDescriptor.java
=> pipe/config/PipeDescriptor.java} (54%)
rename {iotdb-core/ainode/resources => scripts}/conf/ainode-env.sh (100%)
rename {iotdb-core/confignode/src/assembly/resources =>
scripts}/conf/confignode-env.sh (93%)
rename {iotdb-core/datanode/src/assembly/resources =>
scripts}/conf/datanode-env.sh (95%)
rename {iotdb-core/node-commons/src/assembly/resources/sbin =>
scripts/conf}/iotdb-common.sh (100%)
rename {iotdb-core/ainode/resources/conf =>
scripts/conf/windows}/ainode-env.bat (92%)
rename {iotdb-core/confignode/src/assembly/resources/conf =>
scripts/conf/windows}/confignode-env.bat (99%)
rename {iotdb-core/datanode/src/assembly/resources/conf =>
scripts/conf/windows}/datanode-env.bat (99%)
rename {iotdb-core/node-commons/src/assembly/resources/sbin =>
scripts/sbin/cluster}/start-all.sh (98%)
rename {iotdb-core/node-commons/src/assembly/resources/sbin =>
scripts/sbin/cluster}/stop-all.sh (97%)
rename {iotdb-core/ainode/resources => scripts}/sbin/start-ainode.sh (84%)
rename {iotdb-client/cli/src/assembly/resources => scripts}/sbin/start-cli.sh
(100%)
rename {iotdb-core/confignode/src/assembly/resources =>
scripts}/sbin/start-confignode.sh (99%)
rename {iotdb-core/datanode/src/assembly/resources =>
scripts}/sbin/start-datanode.sh (99%)
rename {iotdb-core/node-commons/src/assembly/resources =>
scripts}/sbin/start-standalone.sh (100%)
rename {iotdb-core/ainode/resources => scripts}/sbin/stop-ainode.sh (100%)
rename {iotdb-core/confignode/src/assembly/resources =>
scripts}/sbin/stop-confignode.sh (98%)
rename {iotdb-core/datanode/src/assembly/resources =>
scripts}/sbin/stop-datanode.sh (98%)
rename {iotdb-core/node-commons/src/assembly/resources =>
scripts}/sbin/stop-standalone.sh (100%)
rename {iotdb-core/ainode/resources/sbin =>
scripts/sbin/windows}/start-ainode.bat (85%)
copy iotdb-client/cli/src/assembly/resources/sbin/start-cli.bat =>
scripts/sbin/windows/start-cli-table.bat (98%)
rename {iotdb-client/cli/src/assembly/resources/sbin =>
scripts/sbin/windows}/start-cli.bat (99%)
rename {iotdb-core/confignode/src/assembly/resources/sbin =>
scripts/sbin/windows}/start-confignode.bat (96%)
rename {iotdb-core/datanode/src/assembly/resources/sbin =>
scripts/sbin/windows}/start-datanode.bat (96%)
rename {iotdb-core/node-commons/src/assembly/resources/sbin =>
scripts/sbin/windows}/start-standalone.bat (78%)
rename {iotdb-core/ainode/resources/sbin =>
scripts/sbin/windows}/stop-ainode.bat (90%)
rename {iotdb-core/confignode/src/assembly/resources/sbin =>
scripts/sbin/windows}/stop-confignode.bat (84%)
rename {iotdb-core/datanode/src/assembly/resources/sbin =>
scripts/sbin/windows}/stop-datanode.bat (85%)
rename {iotdb-core/node-commons/src/assembly/resources/sbin =>
scripts/sbin/windows}/stop-standalone.bat (80%)
rename {iotdb-client/cli/src/assembly/resources =>
scripts}/tools/export-data.sh (100%)
rename {iotdb-client/cli/src/assembly/resources =>
scripts}/tools/import-data.sh (100%)
rename {iotdb-client/cli/src/assembly/resources =>
scripts}/tools/load-tsfile.sh (97%)
rename {iotdb-client/cli/src/assembly/resources/tools =>
scripts/tools/ops}/backup.sh (98%)
rename {iotdb-client/cli/src/assembly/resources/tools =>
scripts/tools/ops}/collect-info.sh (98%)
rename {iotdb-core/confignode/src/assembly/resources/sbin =>
scripts/tools/ops}/daemon-confignode.sh (97%)
rename {iotdb-core/datanode/src/assembly/resources/sbin =>
scripts/tools/ops}/daemon-datanode.sh (97%)
rename {iotdb-core/node-commons/src/assembly/resources/sbin =>
scripts/tools/ops}/destroy-all.sh (82%)
rename {iotdb-core/node-commons/src/assembly/resources/sbin =>
scripts/tools/ops}/destroy-confignode.sh (95%)
rename {iotdb-core/node-commons/src/assembly/resources/sbin =>
scripts/tools/ops}/destroy-datanode.sh (97%)
rename {iotdb-core/node-commons/src/assembly/resources/sbin =>
scripts/tools/ops}/health_check.sh (99%)
rename {iotdb-core/ainode/resources/sbin =>
scripts/tools/ops}/remove-ainode.sh (84%)
rename {iotdb-client/cli/src/assembly/resources/tools =>
scripts/tools/schema}/export-schema.sh (96%)
rename {iotdb-client/cli/src/assembly/resources/tools =>
scripts/tools/schema}/import-schema.sh (96%)
rename {iotdb-core/datanode/src/assembly/resources =>
scripts}/tools/schema/print-pb-tree-file.sh (96%)
rename {iotdb-core/datanode/src/assembly/resources =>
scripts}/tools/schema/print-schema-log.sh (96%)
rename {iotdb-core/datanode/src/assembly/resources =>
scripts}/tools/tsfile/check-overlap-sequence-files-and-repair.sh (96%)
rename {iotdb-core/datanode/src/assembly/resources =>
scripts}/tools/tsfile/overlap-statistic-tool.sh (96%)
rename {iotdb-core/datanode/src/assembly/resources =>
scripts}/tools/tsfile/print-iotdb-data-dir.sh (96%)
rename {iotdb-core/datanode/src/assembly/resources =>
scripts}/tools/tsfile/print-tsfile-resource-files.sh (96%)
rename {iotdb-core/datanode/src/assembly/resources =>
scripts}/tools/tsfile/print-tsfile.sh (96%)
rename {iotdb-core/datanode/src/assembly/resources =>
scripts}/tools/tsfile/settle-tsfile.sh (100%)
rename {iotdb-core/datanode/src/assembly/resources =>
scripts}/tools/tsfile/split-tsfile-tool.sh (96%)
rename {iotdb-core/datanode/src/assembly/resources =>
scripts}/tools/tsfile/validate-tsfile.sh (96%)
rename {iotdb-client/cli/src/assembly/resources/tools =>
scripts/tools/windows}/export-data.bat (99%)
rename {iotdb-client/cli/src/assembly/resources/tools =>
scripts/tools/windows}/import-data.bat (99%)
rename {iotdb-client/cli/src/assembly/resources/tools =>
scripts/tools/windows}/load-tsfile.bat (99%)
rename {iotdb-client/cli/src/assembly/resources/tools =>
scripts/tools/windows/ops}/backup.bat (96%)
rename {iotdb-client/cli/src/assembly/resources/tools =>
scripts/tools/windows/ops}/collect-info.bat (97%)
rename {iotdb-core/node-commons/src/assembly/resources/sbin =>
scripts/tools/windows/ops}/destroy-all.bat (83%)
rename {iotdb-core/node-commons/src/assembly/resources/sbin =>
scripts/tools/windows/ops}/destroy-confignode.bat (96%)
rename {iotdb-core/node-commons/src/assembly/resources/sbin =>
scripts/tools/windows/ops}/destroy-datanode.bat (98%)
rename {iotdb-core/node-commons/src/assembly/resources/sbin =>
scripts/tools/windows/ops}/health_check.bat (98%)
rename {iotdb-core/ainode/resources/sbin =>
scripts/tools/windows/ops}/remove-ainode.bat (82%)
rename {iotdb-client/cli/src/assembly/resources/tools =>
scripts/tools/windows/schema}/export-schema.bat (99%)
rename {iotdb-client/cli/src/assembly/resources/tools =>
scripts/tools/windows/schema}/import-schema.bat (99%)
rename {iotdb-core/datanode/src/assembly/resources/tools =>
scripts/tools/windows}/schema/print-pb-tree-file.bat (98%)
rename {iotdb-core/datanode/src/assembly/resources/tools =>
scripts/tools/windows}/schema/print-schema-log.bat (98%)
rename {iotdb-core/datanode/src/assembly/resources/tools =>
scripts/tools/windows}/tsfile/check-overlap-sequence-files-and-repair.bat (98%)
rename {iotdb-core/datanode/src/assembly/resources/tools =>
scripts/tools/windows}/tsfile/overlap-statistic-tool.bat (98%)
rename {iotdb-core/datanode/src/assembly/resources/tools =>
scripts/tools/windows}/tsfile/print-iotdb-data-dir.bat (98%)
rename {iotdb-core/datanode/src/assembly/resources/tools =>
scripts/tools/windows}/tsfile/print-tsfile-resource-files.bat (98%)
rename {iotdb-core/datanode/src/assembly/resources/tools =>
scripts/tools/windows}/tsfile/print-tsfile.bat (98%)
rename {iotdb-core/datanode/src/assembly/resources/tools =>
scripts/tools/windows}/tsfile/settle-tsfile.bat (98%)
rename {iotdb-core/datanode/src/assembly/resources/tools =>
scripts/tools/windows}/tsfile/split-tsfile-tool.bat (98%)
rename {iotdb-core/datanode/src/assembly/resources/tools =>
scripts/tools/windows}/tsfile/validate-tsfile.bat (98%)
