This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a change to branch ty/forecast
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from a4cfe9bad23 perfect ForecastTableFunction
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)
new 1c0826be501 Merge remote-tracking branch 'origin/master' into
ty/forecast
new c859cf70b25 finish
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:
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 | 18 +-
.../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 | 2 +-
.../rpc/subscription/config/ConsumerConfig.java | 8 +
.../response/PipeSubscribeHeartbeatResp.java | 48 +-
.../apache/iotdb/session/SessionConnection.java | 148 ++++-
.../SubscriptionSessionConnection.java | 32 -
.../base/AbstractSubscriptionConsumer.java | 2 +-
.../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/SubscriptionSessionDataSet.java | 93 ++-
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 +-
.../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} | 6 +-
...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/function/ForecastTableFunction.java | 35 +-
.../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 +-
.../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 +
.../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} | 726 +++++----------------
.../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 +-
321 files changed, 6851 insertions(+), 2829 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%)
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} (98%)
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} (55%)
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%)
