This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 2c9064ff67c [AINode] Adjust the maximum inference input length (#16640)
add dbf55834d67 Refactored some dependencies
No new revisions were added by this update.
Summary of changes:
LICENSE | 14 +-
LICENSE-binary | 4 -
dependencies.json | 13 +-
.../server/CustomizedJsonPayloadFormatter.java | 2 +-
integration-test/import-control.xml | 2 +-
integration-test/pom.xml | 12 -
.../iotdb/it/env/cluster/ClusterConstant.java | 2 +-
.../org/apache/iotdb/it/env/cluster/EnvUtils.java | 2 +-
.../iotdb/it/env/cluster/node/AINodeWrapper.java | 2 +-
.../it/env/cluster/node/AbstractNodeWrapper.java | 6 +-
.../itbase/runtime/ClusterTestConnection.java | 2 +-
.../confignode/it/IoTDBConfigNodeSnapshotIT.java | 2 +-
.../org/apache/iotdb/db/it/IoTDBRestartIT.java | 2 +-
.../iotdb/it/framework/IoTDBTestListener.java | 2 +-
.../manual/IoTDBPipeTypeConversionISessionIT.java | 11 +-
.../it/query/old/orderBy/IoTDBOrderByTableIT.java | 2 +-
.../view/old/orderby/IoTDBOrderByTableViewIT.java | 2 +-
.../iotdb/session/it/IoTDBSessionSimpleIT.java | 2 +-
.../org/apache/iotdb/util/AbstractSchemaIT.java | 2 +-
iotdb-client/cli/pom.xml | 8 -
.../java/org/apache/iotdb/cli/AbstractCli.java | 2 +-
.../org/apache/iotdb/cli/utils/IoTPrinter.java | 2 +-
.../apache/iotdb/tool/data/AbstractDataTool.java | 4 +-
.../org/apache/iotdb/tool/data/ExportData.java | 4 +-
.../apache/iotdb/tool/data/ExportDataTable.java | 6 +-
.../org/apache/iotdb/tool/data/ExportDataTree.java | 2 +-
.../org/apache/iotdb/tool/data/ImportData.java | 4 +-
.../apache/iotdb/tool/data/ImportDataTable.java | 8 +-
.../iotdb/tool/schema/AbstractSchemaTool.java | 2 +-
.../org/apache/iotdb/tool/schema/ExportSchema.java | 2 +-
.../iotdb/tool/schema/ExportSchemaTable.java | 6 +-
.../org/apache/iotdb/tool/schema/ImportSchema.java | 2 +-
.../iotdb/tool/schema/ImportSchemaTable.java | 4 +-
.../apache/iotdb/tool/schema/ImportSchemaTree.java | 6 +-
.../org/apache/iotdb/tool/tsfile/ExportTsFile.java | 2 +-
.../subscription/SubscriptionTableTsFile.java | 2 +-
.../subscription/SubscriptionTreeTsFile.java | 2 +-
iotdb-client/jdbc/pom.xml | 4 -
.../org/apache/iotdb/jdbc/IoTDBConnection.java | 2 +-
.../apache/iotdb/jdbc/IoTDBDatabaseMetadata.java | 24 +-
.../org/apache/iotdb/jdbc/IoTDBJDBCResultSet.java | 2 +-
.../java/org/apache/iotdb/jdbc/IoTDBStatement.java | 2 +-
iotdb-core/confignode/pom.xml | 16 -
.../confignode/conf/ConfigNodeRemoveCheck.java | 155 ----
.../consensus/request/write/cq/ActiveCQPlan.java | 2 +-
.../consensus/request/write/cq/AddCQPlan.java | 2 +-
.../consensus/request/write/cq/DropCQPlan.java | 2 +-
.../request/write/cq/UpdateCQLastExecTimePlan.java | 2 +-
.../load/cache/detector/PhiAccrualDetector.java | 14 +-
.../schema/CNPhysicalPlanGenerator.java | 2 +-
.../persistence/schema/TemplateTable.java | 2 +-
.../procedure/impl/cq/CreateCQProcedure.java | 2 +-
.../confignode/persistence/AuthorInfoTest.java | 2 +-
.../iotdb/confignode/persistence/CQInfoTest.java | 2 +-
.../ConfigRegionListeningQueueTest.java | 2 +-
.../iotdb/confignode/persistence/NodeInfoTest.java | 2 +-
.../confignode/persistence/PartitionInfoTest.java | 2 +-
.../iotdb/confignode/persistence/PipeInfoTest.java | 2 +-
.../confignode/persistence/QuotaInfoTest.java | 2 +-
.../iotdb/confignode/persistence/TTLInfoTest.java | 2 +-
.../confignode/persistence/TriggerInfoTest.java | 2 +-
.../iotdb/confignode/persistence/UDFInfoTest.java | 2 +-
.../persistence/schema/ClusterSchemaInfoTest.java | 2 +-
.../schema/TemplatePreSetTableTest.java | 2 +-
.../persistence/schema/TemplateTableTest.java | 2 +-
iotdb-core/consensus/pom.xml | 9 -
.../consensus/iot/IoTConsensusServerImpl.java | 2 +-
.../iot/client/AsyncIoTConsensusServiceClient.java | 2 +-
.../consensus/iot/client/DispatchLogHandler.java | 2 +-
.../iot/logdispatcher/IndexController.java | 2 +-
.../pipe/consensuspipe/ConsensusPipeManager.java | 4 +-
.../iotdb/consensus/ratis/SnapshotStorage.java | 2 +-
iotdb-core/datanode/pom.xml | 16 -
.../src/main/codegen/templates/ModeAccumulator.ftl | 2 +-
.../org/apache/iotdb/db/conf/IoTDBStartCheck.java | 2 +-
.../agent/runtime/SimpleProgressIndexAssigner.java | 2 +-
.../legacy/IoTDBLegacyPipeReceiverAgent.java | 2 +-
.../pipeconsensus/PipeConsensusReceiver.java | 2 +-
.../pipeconsensus/PipeConsensusReceiverAgent.java | 2 +-
.../transform/converter/ValueConverter.java | 2 +-
...leStatementDataTypeConvertExecutionVisitor.java | 2 +-
...eeStatementDataTypeConvertExecutionVisitor.java | 2 +-
...aNodeHardlinkOrCopiedFileDirStartupCleaner.java | 2 +-
.../sink/protocol/legacy/IoTDBLegacyPipeSink.java | 2 +-
.../async/handler/PipeTransferTsFileHandler.java | 2 +-
.../thrift/sync/IoTDBDataRegionSyncSink.java | 2 +-
.../websocket/WebSocketConnectorServer.java | 4 +-
.../util/builder/PipeTableModelTsFileBuilder.java | 2 +-
.../util/builder/PipeTreeModelTsFileBuilder.java | 2 +-
.../pipe/sink/util/builder/PipeTsFileBuilder.java | 2 +-
.../db/protocol/mqtt/BrokerAuthenticator.java | 2 +-
.../db/protocol/mqtt/JSONPayloadFormatter.java | 2 +-
.../db/protocol/mqtt/LinePayloadFormatter.java | 2 +-
.../db/protocol/mqtt/PayloadFormatManager.java | 6 +-
.../table/v1/handler/RequestValidationHandler.java | 2 +-
.../rest/v1/handler/RequestValidationHandler.java | 2 +-
.../rest/v1/impl/GrafanaApiServiceImpl.java | 2 +-
.../rest/v2/handler/RequestValidationHandler.java | 2 +-
.../rest/v2/impl/GrafanaApiServiceImpl.java | 2 +-
.../iotdb/db/protocol/session/SessionManager.java | 2 +-
.../execution/exchange/MPPDataExchangeManager.java | 2 +-
.../execution/exchange/SharedTsBlockQueue.java | 2 +-
.../execution/exchange/sink/LocalSinkChannel.java | 2 +-
.../execution/exchange/sink/ShuffleSinkHandle.java | 2 +-
.../execution/exchange/sink/SinkChannel.java | 2 +-
.../exchange/source/LocalSourceHandle.java | 2 +-
.../execution/exchange/source/SourceHandle.java | 2 +-
.../queryengine/execution/memory/MemoryPool.java | 2 +-
.../operator/process/TagAggregationOperator.java | 2 +-
.../process/join/merge/MergeSortComparator.java | 2 +-
.../plan/analyze/load/LoadTsFileAnalyzer.java | 2 +-
.../config/executor/ClusterConfigTaskExecutor.java | 2 +-
.../plan/execution/memory/MemorySourceHandle.java | 2 +-
.../expression/other/CaseWhenThenExpression.java | 2 +-
.../plan/expression/unary/RegularExpression.java | 2 +-
.../cartesian/BindSchemaForExpressionVisitor.java | 2 +-
.../cartesian/BindSchemaForPredicateVisitor.java | 2 +-
...catDeviceAndBindSchemaForExpressionVisitor.java | 2 +-
...ncatDeviceAndBindSchemaForPredicateVisitor.java | 2 +-
.../ConcatExpressionWithSuffixPathsVisitor.java | 2 +-
.../plan/optimization/AggregationPushDown.java | 4 +-
.../db/queryengine/plan/parser/ASTVisitor.java | 2 +-
.../plan/planner/LogicalPlanBuilder.java | 2 +-
.../plan/planner/OperatorTreeGenerator.java | 4 +-
.../plan/planner/TemplatedLogicalPlan.java | 2 +-
.../distribution/DistributionPlanContext.java | 2 +-
.../planner/distribution/DistributionPlanner.java | 2 +-
.../plan/AbstractFragmentParallelPlanner.java | 2 +-
.../plan/planner/plan/node/PlanGraphPrinter.java | 4 +-
.../planner/plan/node/process/GroupByTagNode.java | 2 +-
.../plan/node/source/LastQueryScanNode.java | 2 +-
.../planner/plan/parameter/IntoPathDescriptor.java | 2 +-
.../planner/distribute/SubPlanGenerator.java | 2 +-
.../relational/sql/ast/SearchedCaseExpression.java | 2 +-
.../relational/sql/ast/SimpleCaseExpression.java | 2 +-
.../plan/scheduler/AsyncSendPlanNodeHandler.java | 2 +-
.../scheduler/FragmentInstanceDispatcherImpl.java | 2 +-
.../statement/component/GroupByTagComponent.java | 2 +-
.../plan/statement/component/IntoItem.java | 2 +-
.../AbstractCaseWhenThenColumnTransformer.java | 2 +-
.../schemaengine/schemaregion/tag/TagLogFile.java | 2 +-
.../schemaengine/schemaregion/tag/TagManager.java | 2 +-
.../iotdb/db/schemaengine/template/Template.java | 2 +-
.../db/service/TemporaryQueryDataFileService.java | 2 +-
.../iotdb/db/storageengine/StorageEngine.java | 2 +-
.../db/storageengine/dataregion/DataRegion.java | 2 +-
.../exception/CompactionExceptionHandler.java | 2 +-
.../execute/recover/CompactionRecoverTask.java | 2 +-
.../estimator/AbstractCompactionEstimator.java | 2 +-
.../dataregion/flush/CompressionRatio.java | 2 +-
.../dataregion/snapshot/SnapshotLoader.java | 2 +-
.../file/AbstractTsFileRecoverPerformer.java | 2 +-
.../load/active/ActiveLoadDirScanner.java | 2 +-
.../load/active/ActiveLoadTsFileLoader.java | 2 +-
.../load/config/LoadTsFileConfigurator.java | 2 +-
...leStatementDataTypeConvertExecutionVisitor.java | 2 +-
...eeStatementDataTypeConvertExecutionVisitor.java | 2 +-
.../rescon/disk/DirectoryChecker.java | 2 +-
.../trigger/service/TriggerManagementService.java | 2 +-
.../org/apache/iotdb/db/utils/CommonUtils.java | 2 +-
.../apache/iotdb/db/utils/TypeInferenceUtils.java | 2 +-
.../db/auth/role/LocalFileRoleAccessorTest.java | 2 +-
.../db/auth/role/LocalFileRoleManagerTest.java | 2 +-
.../db/auth/user/LocalFileUserAccessorTest.java | 2 +-
.../db/auth/user/LocalFileUserManagerTest.java | 2 +-
.../schemaRegion/AbstractSchemaRegionTest.java | 2 +-
.../schemaRegion/SchemaRegionBasicTest.java | 2 +-
.../source/SchemaRegionListeningQueueTest.java | 2 +-
.../execution/exchange/SharedTsBlockQueueTest.java | 2 +-
.../security/encrypt/MessageDigestEncryptTest.java | 2 +-
.../storageengine/buffer/BloomFilterCacheTest.java | 2 +-
.../dataregion/TsFileManagerTest.java | 2 +-
.../TsFileResourceProgressIndexTest.java | 2 +-
.../compaction/AbstractCompactionTest.java | 4 +-
.../compaction/CompactionTaskManagerTest.java | 2 +-
.../compaction/CompactionValidationTest.java | 2 +-
.../TsFileValidationCorrectnessTests.java | 2 +-
.../inner/AbstractInnerSpaceCompactionTest.java | 2 +-
.../inner/FastCompactionPerformerAlignedTest.java | 2 +-
.../FastCompactionPerformerNoAlignedTest.java | 2 +-
.../inner/InnerCompactionEmptyTsFileTest.java | 2 +-
.../compaction/inner/InnerCompactionLogTest.java | 2 +-
.../inner/InnerCompactionMoreDataTest.java | 2 +-
.../ReadChunkCompactionPerformerAlignedTest.java | 2 +-
.../ReadChunkCompactionPerformerNoAlignedTest.java | 2 +-
.../inner/ReadChunkCompactionPerformerOldTest.java | 2 +-
.../recover/SizeTieredCompactionRecoverTest.java | 2 +-
.../compaction/utils/CompactionClearUtils.java | 2 +-
.../dataregion/flush/CompressionRatioTest.java | 2 +-
.../dataregion/memtable/TsFileProcessorTest.java | 2 +-
.../dataregion/tsfile/TsFileResourceTest.java | 2 +-
.../wal/compression/WALCompressionTest.java | 2 +-
.../iotdb/db/tools/TsFileSelfCheckToolTest.java | 2 +-
.../iotdb/db/tools/TsFileSketchToolTest.java | 2 +-
.../org/apache/iotdb/db/tools/WalCheckerTest.java | 2 +-
.../apache/iotdb/db/utils/EnvironmentUtils.java | 2 +-
.../apache/iotdb/db/utils/OpenFileNumUtilTest.java | 2 +-
.../db/utils/SchemaRegionSnapshotParserTest.java | 2 +-
.../db/utils/datastructure/AlignedTVListTest.java | 2 +-
.../db/utils/datastructure/BinaryTVListTest.java | 2 +-
.../db/utils/datastructure/BooleanTVListTest.java | 2 +-
.../db/utils/datastructure/DoubleTVListTest.java | 2 +-
.../db/utils/datastructure/FloatTVListTest.java | 2 +-
.../db/utils/datastructure/IntTVListTest.java | 2 +-
.../db/utils/datastructure/LongTVListTest.java | 2 +-
iotdb-core/node-commons/pom.xml | 12 -
.../commons/auth/role/LocalFileRoleAccessor.java | 4 +-
.../commons/auth/user/LocalFileUserAccessor.java | 4 +-
.../apache/iotdb/commons/client/ThriftClient.java | 2 +-
.../AsyncConfigNodeInternalServiceClient.java | 2 +-
.../async/AsyncDataNodeExternalServiceClient.java | 2 +-
.../async/AsyncDataNodeInternalServiceClient.java | 2 +-
.../AsyncDataNodeMPPDataExchangeServiceClient.java | 2 +-
.../async/AsyncPipeConsensusServiceClient.java | 2 +-
.../async/AsyncPipeDataTransferServiceClient.java | 2 +-
.../commons/executable/ExecutableManager.java | 17 +-
.../commons/external/collections4/BidiMap.java | 138 ++++
.../external/collections4/IterableSortedMap.java} | 40 +-
.../external/collections4/OrderedBidiMap.java | 51 ++
.../collections4/ResettableListIterator.java} | 43 +-
.../external/collections4/SortedBidiMap.java | 59 ++
.../collections4/bidimap/AbstractDualBidiMap.java | 798 +++++++++++++++++++++
.../collections4/bidimap/DualTreeBidiMap.java | 414 +++++++++++
.../collection/AbstractCollectionDecorator.java | 182 +++++
.../iterators/AbstractIteratorDecorator.java} | 57 +-
.../AbstractUntypedIteratorDecorator.java | 66 ++
.../iterators/ListIteratorWrapper.java | 274 +++++++
.../keyvalue/AbstractMapEntryDecorator.java | 92 +++
.../collections4/map/AbstractIterableMap.java} | 42 +-
.../collections4/map/AbstractMapDecorator.java | 153 ++++
.../map/AbstractSortedMapDecorator.java | 166 +++++
.../map/EntrySetToMapIteratorAdapter.java | 110 +++
.../iotdb/commons/file/SystemFileFactory.java | 2 +-
.../org/apache/iotdb/commons/path/PartialPath.java | 4 +-
.../iotdb/commons/path/fa/dfa/graph/NFAGraph.java | 2 +-
.../fa/dfa/transition/DFAWildcardTransition.java | 2 +-
.../service/PipePluginExecutableManager.java | 2 +-
.../datastructure/pattern/PrefixTreePattern.java | 2 +-
.../commons/pipe/receiver/IoTDBFileReceiver.java | 2 +-
.../commons/pipe/receiver/IoTDBReceiverAgent.java | 2 +-
.../viewExpression/leaf/ConstantViewOperand.java | 2 +-
.../unary/RegularViewExpression.java | 2 +-
.../commons/udf/service/UDFExecutableManager.java | 2 +-
.../org/apache/iotdb/commons/utils/FileUtils.java | 23 +-
library-udf/pom.xml | 4 +
pom.xml | 32 +-
246 files changed, 2867 insertions(+), 682 deletions(-)
delete mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeRemoveCheck.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/external/collections4/BidiMap.java
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/protocol/rest/filter/User.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/external/collections4/IterableSortedMap.java}
(59%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/external/collections4/OrderedBidiMap.java
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/protocol/rest/filter/User.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/external/collections4/ResettableListIterator.java}
(58%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/external/collections4/SortedBidiMap.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/external/collections4/bidimap/AbstractDualBidiMap.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/external/collections4/bidimap/DualTreeBidiMap.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/external/collections4/collection/AbstractCollectionDecorator.java
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/protocol/rest/filter/BasicSecurityContext.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/external/collections4/iterators/AbstractIteratorDecorator.java}
(50%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/external/collections4/iterators/AbstractUntypedIteratorDecorator.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/external/collections4/iterators/ListIteratorWrapper.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/external/collections4/keyvalue/AbstractMapEntryDecorator.java
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/protocol/rest/filter/User.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/external/collections4/map/AbstractIterableMap.java}
(58%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/external/collections4/map/AbstractMapDecorator.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/external/collections4/map/AbstractSortedMapDecorator.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/external/collections4/map/EntrySetToMapIteratorAdapter.java
