This is an automated email from the ASF dual-hosted git repository.
shuwenwei pushed a change to branch sync-generic-changes
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from ec5b274fdbd [Query] Add long-list memory estimation helper
add 25bf38eba0c [Query] Fix result-column OOM diagnostics (#18661)
add 2b6d628e022 [Pipe] Fix deletion buffer close flush race (#18662)
add 5b9e8868c47 [ConfigNode] Skip non-existent and duplicate region IDs
during reconstruction (#18664)
add 5d67dae28c8 Fix init of DeviceEntryBatchSizeInBytes config when there
is no properties file (#18660)
add c611a389e7d Fix table model JDBC example TTL retrieval (#18669)
add 87a6d198a90 Allow removing regions from read-only DataNodes (#18670)
add 7310b2bc0eb Fix oversized Load TsFile piece dispatch (#18627)
add 6709dfa9494 Fix concurrent subscription consumer handshakes (#18654)
add 0862ecb1d1c Fix Surefire fork port isolation (#18676)
add 957204481d9 Fragment large TsBlocks in MPP DataExchange responses
(#18645)
add d2fcb5383ab Fix delayed query cleanup during file metadata scans
(#18679)
add 61f2014ded8 Fix client manager metrics and JMX lifecycle races (#18681)
add 94329e01692 [Pipe] Move OPC UA sink to pipe library (#18464)
add 5aae6697fba [Pipe] Avoid no-op consensus writes for covered progress
(#18574)
add 76005c94103 Avoid holding ProcedureManager lock while waiting for
table tasks (#18673)
add 9be80ead1dc Fix PathPatternNode wildcard cache lifecycle (#18672)
add 3b47945b3ce Show pre-deleted table schemas and improve write errors
(#18626)
add 34349e3ad8b Fix snapshot omission of closing TsFiles (#18682)
add 142d3b14fce Pipe: Cache table-model pattern matches by table (#18648)
add 8d94de90db3 Fix stale OPC UA builtin plugin references (#18687)
add a670bce7ec6 Refactor TSDataType switches to use TypeService (#18606)
add 4405647b0f2 Fix schema partition lookup during ConfigNode removal
(#18686)
add 4cd6f70ed76 Merge branch 'iotdb_master' into sync-generic-changes
No new revisions were added by this update.
Summary of changes:
LICENSE-binary | 18 +
architecture-test/pom.xml | 284 +
.../db/utils/TSDataTypeSwitchArchitectureTest.java | 26 +-
.../iotdb/db/utils/TSDataTypeSwitchRule.java | 182 +
.../iotdb/db/utils/TSDataTypeSwitchRuleTest.java | 186 +
distribution/pom.xml | 9 +
...{external-service-impl.xml => library-pipe.xml} | 12 +-
.../org/apache/iotdb/TableModelJDBCExample.java | 8 +-
example/pom.xml | 1 -
.../org/apache/iotdb/DataMigrationExample.java | 64 +-
.../main/java/org/apache/iotdb/TabletExample.java | 56 +-
example/udf/pom.xml | 6 +
.../java/org/apache/iotdb/udf/UDAFExample.java | 106 +-
.../v1/handler/StatementConstructionHandler.java | 113 +-
.../rest/protocol/utils/InsertRowDataUtils.java | 109 +-
.../iotdb/rest/protocol/utils/TypeServices.java | 162 +
.../v1/handler/StatementConstructionHandler.java | 113 +-
.../v2/handler/StatementConstructionHandler.java | 113 +-
.../protocol/v2/handler/FastLastHandlerTest.java | 5 +-
integration-test/pom.xml | 7 +
.../apache/iotdb/db/query/udf/example/TwoSum.java | 44 +-
.../apache/iotdb/db/query/udf/example/UDAFAvg.java | 112 +-
.../apache/iotdb/db/query/udf/example/UDAFSum.java | 112 +-
.../it/env/cluster/config/MppConfigNodeConfig.java | 6 +
.../it/env/cluster/config/MppDataNodeConfig.java | 15 +
.../env/remote/config/RemoteConfigNodeConfig.java | 5 +
.../it/env/remote/config/RemoteDataNodeConfig.java | 11 +
.../apache/iotdb/itbase/env/ConfigNodeConfig.java | 2 +
.../apache/iotdb/itbase/env/DataNodeConfig.java | 4 +
.../IoTDBRemoveConfigNodeSchemaPartitionIT.java | 262 +
.../iotdb/pipe/it/single/AbstractPipeSingleIT.java | 70 +-
.../iotdb/pipe/it/single/IoTDBPipeOPCUAIT.java | 17 +-
...AbstractIoTDBMPPDataExchangeLargeTsBlockIT.java | 98 +
.../IoTDBMPPDataExchangeLargeTsBlock128KIT.java} | 18 +-
.../java/org/apache/iotdb/udf/api/access/Row.java | 7 +-
.../org/apache/iotdb/udf/api/utils/RowImpl.java | 30 +-
.../en/org/apache/iotdb/cli/i18n/CliMessages.java | 4 +
.../zh/org/apache/iotdb/cli/i18n/CliMessages.java | 4 +
.../java/org/apache/iotdb/cli/AbstractCli.java | 79 +-
.../apache/iotdb/tool/data/AbstractDataTool.java | 67 +-
.../org/apache/iotdb/isession/SessionDataSet.java | 39 +-
.../org/apache/iotdb/isession/TypeServices.java | 68 +
.../org/apache/iotdb/jdbc/i18n/JdbcMessages.java | 2 +
.../org/apache/iotdb/jdbc/i18n/JdbcMessages.java | 1 +
.../iotdb/jdbc/GroupedLSBWatermarkEncoder.java | 56 +-
.../iotdb/jdbc/IoTDBAbstractDatabaseMetadata.java | 62 +-
.../org/apache/iotdb/rpc/IoTDBJDBCDataSet.java | 177 +-
.../java/org/apache/iotdb/rpc/IoTDBRpcDataSet.java | 96 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 1 +
.../java/org/apache/iotdb/rpc/TypeServices.java | 162 +
.../iotdb/rpc/stmt/PreparedParameterSerde.java | 41 +-
.../org/apache/iotdb/rpc/IoTDBJDBCDataSetTest.java | 176 +
.../iotdb/rpc/stmt/PreparedParameterSerdeTest.java | 12 +
.../java/org/apache/iotdb/session/Session.java | 167 +-
.../iotdb/session/util/SessionTypeServices.java | 435 ++
.../apache/iotdb/session/util/SessionUtils.java | 299 +-
.../java/org/apache/iotdb/session/SessionTest.java | 43 +
.../iotdb/session/util/SessionUtilsTest.java | 21 +
.../rpc/subscription/config/ConsumerConfig.java | 4 +
.../rpc/subscription/config/ConsumerConstant.java | 1 +
...va => SubscriptionConsumerFencedException.java} | 18 +-
.../base/AbstractSubscriptionConsumer.java | 200 +-
.../base/AbstractSubscriptionProvider.java | 21 +
.../base/AbstractSubscriptionProviders.java | 55 +-
.../base/AbstractSubscriptionPullConsumer.java | 14 +-
.../base/AbstractSubscriptionPushConsumer.java | 4 +-
.../payload/SubscriptionRecordHandler.java | 76 +-
.../session/subscription/payload/TypeServices.java | 115 +
.../base/SubscriptionConsumerLifecycleTest.java | 352 +-
.../base/SubscriptionProviderStatusTest.java | 72 +
.../subscription/payload/TypeServicesTest.java | 69 +
.../org/apache/iotdb/calc/i18n/CalcMessages.java | 53 +
.../org/apache/iotdb/calc/i18n/CalcMessages.java | 53 +
.../aggregation/CentralMomentAccumulator.java | 35 +-
.../aggregation/CorrelationAccumulator.java | 20 +-
.../aggregation/CovarianceAccumulator.java | 20 +-
.../aggregation/RegressionAccumulator.java | 20 +-
.../execution/aggregation/VarianceAccumulator.java | 115 +-
.../execution/operator/process/TopKOperator.java | 95 +-
.../process/join/merge/MergeSortComparator.java | 46 +-
.../merge/comparator/JoinKeyComparatorFactory.java | 36 +-
.../process/window/function/value/LagFunction.java | 36 -
.../window/function/value/LeadFunction.java | 36 -
.../window/function/value/ValueWindowFunction.java | 9 +
.../process/window/partition/frame/RangeFrame.java | 294 +-
.../operator/process/window/utils/ColumnList.java | 9 +
.../process/window/utils/RowComparator.java | 174 +-
.../relational/MergeSortFullOuterJoinOperator.java | 6 +-
.../AbstractApproxMostFrequentAccumulator.java | 2 +-
.../AbstractApproxPercentileAccumulator.java | 64 +-
.../relational/aggregation/AccumulatorFactory.java | 64 +-
.../ApproxCountDistinctAccumulator.java | 54 +-
.../relational/aggregation/AvgAccumulator.java | 207 +-
.../relational/aggregation/ExtremeAccumulator.java | 165 +-
.../relational/aggregation/FirstAccumulator.java | 248 +-
.../relational/aggregation/FirstByAccumulator.java | 226 +-
.../relational/aggregation/LastAccumulator.java | 282 +-
.../relational/aggregation/LastByAccumulator.java | 222 +-
.../relational/aggregation/MaxAccumulator.java | 193 +-
.../relational/aggregation/MinAccumulator.java | 193 +-
.../aggregation/PercentileAccumulator.java | 132 +-
.../relational/aggregation/SumAccumulator.java | 204 +-
.../aggregation/TableCentralMomentAccumulator.java | 51 +-
.../aggregation/TableCorrelationAccumulator.java | 33 +-
.../aggregation/TableCovarianceAccumulator.java | 33 +-
.../aggregation/TableMaxMinByBaseAccumulator.java | 352 +-
.../aggregation/TableModeAccumulator.java | 667 +--
.../aggregation/TableRegressionAccumulator.java | 33 +-
.../aggregation/TableVarianceAccumulator.java | 226 +-
.../source/relational/aggregation/Utils.java | 62 +-
...AbstractGroupedApproxPercentileAccumulator.java | 58 +-
.../GroupedApproxCountDistinctAccumulator.java | 74 +-
.../aggregation/grouped/GroupedAvgAccumulator.java | 133 +-
.../grouped/GroupedCentralMomentAccumulator.java | 38 +-
.../grouped/GroupedCorrelationAccumulator.java | 29 +-
.../grouped/GroupedCovarianceAccumulator.java | 29 +-
.../grouped/GroupedExtremeAccumulator.java | 337 +-
.../grouped/GroupedFirstAccumulator.java | 458 +-
.../grouped/GroupedFirstByAccumulator.java | 463 +-
.../grouped/GroupedLastAccumulator.java | 457 +-
.../grouped/GroupedLastByAccumulator.java | 463 +-
.../aggregation/grouped/GroupedMaxAccumulator.java | 368 +-
.../grouped/GroupedMaxMinByBaseAccumulator.java | 903 +---
.../aggregation/grouped/GroupedMinAccumulator.java | 494 +-
.../grouped/GroupedModeAccumulator.java | 323 +-
.../grouped/GroupedPercentileAccumulator.java | 78 +-
.../grouped/GroupedRegressionAccumulator.java | 29 +-
.../aggregation/grouped/GroupedSumAccumulator.java | 125 +-
.../grouped/GroupedVarianceAccumulator.java | 177 +-
.../aggregation/grouped/array/BinaryBigArray.java | 7 +
.../aggregation/grouped/array/BooleanBigArray.java | 5 +
.../aggregation/grouped/array/DoubleBigArray.java | 5 +
.../aggregation/grouped/array/FloatBigArray.java | 5 +
.../aggregation/grouped/array/IntBigArray.java | 5 +
.../aggregation/grouped/array/LongBigArray.java | 5 +
.../grouped/rate/GroupedNaiveDeltaAccumulator.java | 49 +-
.../rate/GroupedNaiveIncreaseAccumulator.java | 49 +-
.../grouped/rate/GroupedNaiveIrateAccumulator.java | 31 +-
.../grouped/rate/GroupedNaiveRateAccumulator.java | 46 +-
.../rate/GroupedOrderedDeltaAccumulator.java | 50 +-
.../rate/GroupedOrderedIncreaseAccumulator.java | 50 +-
.../rate/GroupedOrderedIrateAccumulator.java | 31 +-
.../rate/GroupedOrderedRateAccumulator.java | 47 +-
.../aggregation/rate/NaiveDeltaAccumulator.java | 47 +-
.../aggregation/rate/NaiveIncreaseAccumulator.java | 47 +-
.../aggregation/rate/NaiveIrateAccumulator.java | 29 +-
.../aggregation/rate/NaiveRateAccumulator.java | 44 +-
.../aggregation/rate/OrderedDeltaAccumulator.java | 47 +-
.../rate/OrderedIncreaseAccumulator.java | 47 +-
.../aggregation/rate/OrderedIrateAccumulator.java | 30 +-
.../aggregation/rate/OrderedRateAccumulator.java | 44 +-
.../aggregation/rate/RateFunctionValidation.java | 56 +-
.../relational/ColumnTransformerBuilder.java | 123 +-
.../calc/plan/planner/CommonOperatorUtils.java | 129 +-
.../calc/plan/planner/TableOperatorGenerator.java | 148 +-
.../AbstractGreatestLeastColumnTransformer.java | 47 +-
.../multi/BinaryGreatestColumnTransformer.java | 2 +-
.../column/multi/BinaryLeastColumnTransformer.java | 2 +-
.../multi/BooleanGreatestColumnTransformer.java | 2 +-
.../multi/BooleanLeastColumnTransformer.java | 2 +-
.../multi/DoubleGreatestColumnTransformer.java | 2 +-
.../column/multi/DoubleLeastColumnTransformer.java | 2 +-
.../multi/FloatGreatestColumnTransformer.java | 2 +-
.../column/multi/FloatLeastColumnTransformer.java | 2 +-
.../multi/Int32GreatestColumnTransformer.java | 2 +-
.../column/multi/Int32LeastColumnTransformer.java | 2 +-
.../multi/Int64GreatestColumnTransformer.java | 2 +-
.../column/multi/Int64LeastColumnTransformer.java | 2 +-
.../dag/column/unary/InColumnTransformer.java | 220 +-
.../AbstractCastFunctionColumnTransformer.java | 370 +-
.../scalar/CastFunctionColumnTransformer.java | 56 +-
.../unary/scalar/FormatColumnTransformer.java | 37 +-
.../unary/scalar/RoundColumnTransformer.java | 37 +-
.../scalar/RoundFunctionColumnTransformer.java | 39 +-
.../scalar/TryCastFunctionColumnTransformer.java | 58 +-
.../transformation/dag/util/CastFunctionUtils.java | 251 +-
.../datastructure/row/SerializableRowList.java | 64 +-
.../datastructure/tv/SerializableTVList.java | 40 +-
.../org/apache/iotdb/calc/utils/TypeServices.java | 5675 ++++++++++++++++++++
.../aggregation/LastDescendingInputTest.java | 108 +
.../aggregation/NumericBatchAggregationTest.java | 224 +
.../aggregation/NumericMomentBatchTest.java | 157 +
.../relational/aggregation/SumAccumulatorTest.java | 140 +
.../aggregation/VarianceAccumulatorTest.java | 125 +
.../GroupedApproxCountDistinctMaskTest.java | 50 +
.../aggregation/rate/RateBatchInputTest.java | 253 +
.../column/unary/scalar/NumericCastBatchTest.java | 184 +
.../apache/iotdb/calc/utils/TypeServicesTest.java | 416 ++
.../iotdb/confignode/i18n/ManagerMessages.java | 6 +
.../iotdb/confignode/i18n/ManagerMessages.java | 6 +
.../consensus/request/ConfigPhysicalPlan.java | 4 +
.../consensus/request/ConfigPhysicalPlanType.java | 3 +-
...ava => RollbackPreAlterColumnDataTypePlan.java} | 31 +-
.../iotdb/confignode/manager/ConfigManager.java | 5 +
.../iotdb/confignode/manager/ProcedureManager.java | 82 +-
.../manager/partition/PartitionManager.java | 21 +-
.../runtime/heartbeat/PipeHeartbeatParser.java | 20 +-
.../manager/schema/ClusterSchemaManager.java | 40 +-
.../persistence/executor/ConfigPlanExecutor.java | 4 +
.../persistence/schema/ClusterSchemaInfo.java | 103 +-
.../confignode/persistence/schema/ConfigMTree.java | 169 +-
.../table/AlterTableColumnDataTypeProcedure.java | 78 +-
.../impl/schema/table/CreateTableProcedure.java | 16 +-
.../request/ConfigPhysicalPlanSerDeTest.java | 15 +
.../ProcedureManagerReconstructRegionTest.java | 190 +
.../manager/ProcedureManagerTableTaskTest.java | 225 +
.../runtime/heartbeat/PipeHeartbeatParserTest.java | 86 +
.../persistence/schema/ConfigMTreeTest.java | 77 +-
.../persistence/schema/TablePreDeleteTest.java | 368 ++
.../AlterTableColumnDataTypeProcedureTest.java | 171 +
.../schema/table/CreateTableProcedureTest.java | 39 +
iotdb-core/datanode/pom.xml | 29 +-
.../apache/iotdb/db/i18n/DataNodeMiscMessages.java | 19 +-
.../apache/iotdb/db/i18n/DataNodePipeMessages.java | 12 +
.../iotdb/db/i18n/DataNodeQueryMessages.java | 47 +
.../iotdb/db/i18n/DataNodeSchemaMessages.java | 2 -
.../iotdb/db/i18n/StorageEngineMessages.java | 19 +
.../apache/iotdb/db/i18n/DataNodeMiscMessages.java | 19 +-
.../apache/iotdb/db/i18n/DataNodePipeMessages.java | 12 +
.../iotdb/db/i18n/DataNodeQueryMessages.java | 46 +
.../iotdb/db/i18n/DataNodeSchemaMessages.java | 2 -
.../iotdb/db/i18n/StorageEngineMessages.java | 19 +
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 6 +-
.../apache/iotdb/db/conf/DataNodeMemoryConfig.java | 42 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 33 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 121 +-
.../dataregion/PipeDataRegionSinkConstructor.java | 3 -
.../deletion/persist/PageCacheDeletionBuffer.java | 67 +-
.../event/common/row/PipeDataTypeTransformer.java | 34 +-
.../iotdb/db/pipe/event/common/row/PipeRow.java | 29 +-
.../pipe/event/common/tablet/PipeTabletUtils.java | 35 +-
.../tablet/parser/TabletInsertionEventParser.java | 209 +-
.../parser/scan/SinglePageWholeChunkReader.java | 41 +-
.../scan/TsFileInsertionEventScanParser.java | 128 +-
...ileInsertionEventTableParserTabletIterator.java | 68 +-
.../processor/aggregate/AggregateProcessor.java | 159 +-
.../aggregate/TimeSeriesRuntimeState.java | 23 +
.../CustomizedReadableIntermediateResults.java | 164 +-
.../numeric/AbstractSameTypeNumericOperator.java | 119 +-
.../transform/converter/ValueConverter.java | 141 +-
.../resource/memory/InsertNodeMemoryEstimator.java | 95 +-
.../pipe/resource/memory/PipeMemoryWeightUtil.java | 10 +-
.../evolvable/batch/PipeTabletEventPlainBatch.java | 53 +-
.../sink/protocol/opcda/OpcDaServerHandle.java | 73 +-
.../db/pipe/sink/protocol/opcda/OpcDaSink.java | 9 +-
.../sink/util/PipeTabletEventTransferUtils.java | 97 +
.../pipe/sink/util/TabletStatementConverter.java | 128 +-
.../sink/util/sorter/PipeInsertEventSorter.java | 106 +-
.../matcher/CachedSchemaPatternMatcher.java | 41 +-
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 38 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 41 +-
.../db/queryengine/common/MPPQueryContext.java | 47 +-
.../execution/aggregation/AccumulatorFactory.java | 34 +-
.../execution/aggregation/AvgAccumulator.java | 105 +-
.../execution/aggregation/ExtremeAccumulator.java | 264 +-
.../aggregation/FirstValueAccumulator.java | 336 +-
.../aggregation/FirstValueDescAccumulator.java | 79 +-
.../aggregation/LastValueAccumulator.java | 327 +-
.../aggregation/LastValueDescAccumulator.java | 89 +-
.../aggregation/MaxMinByBaseAccumulator.java | 315 +-
.../execution/aggregation/MaxValueAccumulator.java | 286 +-
.../execution/aggregation/MinValueAccumulator.java | 287 +-
.../execution/aggregation/SumAccumulator.java | 100 +-
.../execution/exchange/MPPDataExchangeManager.java | 44 +
.../execution/exchange/sink/SinkChannel.java | 49 +-
.../execution/exchange/source/SourceHandle.java | 158 +-
.../execution/operator/AggregationUtil.java | 34 +-
.../process/InsertTabletStatementGenerator.java | 137 +-
.../operator/process/TransformOperator.java | 43 +-
.../execution/operator/source/SeriesScanUtil.java | 526 +-
.../relational/LastQueryAggTableScanOperator.java | 28 +-
.../operator/window/WindowManagerFactory.java | 62 +-
.../config/executor/ClusterConfigTaskExecutor.java | 14 +
.../visitor/ExistUnknownTypeInExpression.java | 2 +-
.../visitor/GetMeasurementExpressionVisitor.java | 6 +
.../predicate/ConvertPredicateToFilterVisitor.java | 47 +-
.../plan/planner/LocalExecutionPlanner.java | 10 +-
.../plan/planner/OperatorGeneratorUtil.java | 28 +-
.../plan/planner/OperatorTreeGenerator.java | 39 +-
.../memory/OperatorMemoryNotEnoughException.java} | 24 +-
.../planner/plan/node/write/InsertRowNode.java | 218 +-
.../planner/plan/node/write/InsertTabletNode.java | 352 +-
.../predicate/ConvertPredicateToFilterVisitor.java | 85 +-
.../metadata/fetcher/TableDeviceSchemaFetcher.java | 3 +-
.../fetcher/TableHeaderSchemaValidator.java | 41 +-
.../distribute/TableDistributedPlanGenerator.java | 10 +-
...ithUncorrelatedScalarSubqueryReconstructor.java | 40 +-
.../scheduler/load/LoadTsFileDispatcherImpl.java | 169 +-
.../plan/statement/crud/InsertRowStatement.java | 29 +-
.../plan/statement/crud/InsertTabletStatement.java | 69 +-
...ializableRowRecordListBackedMultiColumnRow.java | 2 +-
.../dag/input/ConstantInputReader.java | 63 +-
.../unary/ArithmeticNegationTransformer.java | 41 +-
.../dag/transformer/unary/InTransformer.java | 131 +-
.../unary/scalar/CastFunctionTransformer.java | 530 +-
.../unary/scalar/DiffFunctionTransformer.java | 42 +-
.../unary/scalar/RoundFunctionTransformer.java | 45 +-
.../transformation/dag/util/TransformUtils.java | 119 +-
.../transformation/dag/util/TypeUtils.java | 61 +-
.../db/schemaengine/table/DataNodeTableCache.java | 86 +-
.../iotdb/db/storageengine/StorageEngine.java | 32 +
.../db/storageengine/dataregion/DataRegion.java | 20 +-
.../ReadChunkAlignedSeriesCompactionExecutor.java | 42 +-
.../readchunk/SingleSeriesCompactionExecutor.java | 32 +-
.../utils/writer/AbstractCompactionWriter.java | 96 +-
.../memtable/AlignedReadOnlyMemChunk.java | 126 +-
.../memtable/AlignedWritableMemChunk.java | 277 +-
.../dataregion/memtable/ReadOnlyMemChunk.java | 92 +-
.../dataregion/memtable/WritableMemChunk.java | 124 +-
.../read/reader/chunk/MemAlignedPageReader.java | 52 +-
.../read/reader/chunk/MemPageReader.java | 84 +-
.../dataregion/snapshot/SnapshotTaker.java | 6 +-
.../dataregion/utils/TsFileResourceUtils.java | 11 +-
.../db/storageengine/load/LoadTsFileManager.java | 78 +-
.../load/LoadTsFilePieceNodeAssembler.java | 170 +
.../load/splitter/AlignedChunkData.java | 94 +-
.../splitter/BatchedAlignedValueChunkData.java | 81 +-
.../load/splitter/NonAlignedChunkData.java | 71 +-
.../rescon/memory/PrimitiveArrayManager.java | 89 +-
.../agent/SubscriptionReceiverAgent.java | 86 +-
.../consensus/ConsensusLogToTabletConverter.java | 77 +-
.../receiver/SubscriptionReceiver.java | 8 +
.../receiver/SubscriptionReceiverV1.java | 42 +-
.../iotdb/db/tools/TsFileSplitByPartitionTool.java | 45 +-
.../org/apache/iotdb/db/tools/TsFileSplitTool.java | 33 +-
.../org/apache/iotdb/db/utils/CommonUtils.java | 157 +-
.../iotdb/db/utils/EncodingInferenceUtils.java | 30 +-
.../apache/iotdb/db/utils/QueryDataSetUtils.java | 446 +-
.../org/apache/iotdb/db/utils/SchemaUtils.java | 166 +-
.../org/apache/iotdb/db/utils/TabletDecoder.java | 80 +-
.../apache/iotdb/db/utils/TimeValuePairUtils.java | 67 +-
.../apache/iotdb/db/utils/TypeInferenceUtils.java | 31 +-
.../org/apache/iotdb/db/utils/TypeServices.java | 4376 +++++++++++++++
.../db/utils/datastructure/AlignedTVList.java | 687 +--
.../iotdb/db/utils/datastructure/BinaryTVList.java | 7 +-
.../db/utils/datastructure/BooleanTVList.java | 7 +-
.../iotdb/db/utils/datastructure/DoubleTVList.java | 8 +-
.../iotdb/db/utils/datastructure/FloatTVList.java | 6 +-
.../iotdb/db/utils/datastructure/IntTVList.java | 7 +-
.../iotdb/db/utils/datastructure/LongTVList.java | 7 +-
.../MergeSortMultiAlignedTVListIterator.java | 62 +-
.../MergeSortMultiTVListIterator.java | 49 +-
.../datastructure/MultiAlignedTVListIterator.java | 71 +-
.../utils/datastructure/MultiTVListIterator.java | 129 +-
.../iotdb/db/utils/datastructure/TVList.java | 334 +-
.../db/utils/windowing/window/WindowImpl.java | 75 +-
.../org/apache/iotdb/db/conf/PropertiesTest.java | 43 +-
.../subtask/sink/PipeSinkSubtaskManagerTest.java | 3 +-
.../persist/PageCacheDeletionBufferTest.java | 88 +
.../db/pipe/event/common/row/PipeRowTest.java | 115 +
.../pattern/CachedSchemaPatternMatcherTest.java | 83 +
.../aggregate/TimeSeriesRuntimeStateTest.java | 76 +
.../apache/iotdb/db/pipe/sink/PipeSinkTest.java | 93 -
.../DataNodeInternalRPCServiceImplLoadTest.java | 94 +
.../db/queryengine/common/MPPQueryContextTest.java | 58 +
.../execution/exchange/SinkChannelTest.java | 16 +-
.../execution/exchange/SourceHandleTest.java | 185 +-
.../db/queryengine/execution/exchange/Utils.java | 7 +
.../source/SeriesScanUtilCancellationTest.java | 399 ++
.../ConvertPredicateToFilterVisitorTest.java | 104 +
.../node/write/InsertTabletNodeSerdeTest.java | 71 +
.../plan/relational/analyzer/TreeViewTest.java | 5 +
.../fetcher/TableHeaderSchemaValidatorTest.java | 251 +
.../load/LoadTsFileDispatcherImplTest.java | 225 +
.../dag/adapter/RowGetDoubleTest.java | 98 +
.../dag/input/ConstantInputReaderTest.java | 78 +
.../dag/util/TransformUtilsTest.java | 117 +
.../schemaengine/table/DataNodeTableCacheTest.java | 191 +-
.../storageengine/dataregion/DataRegionTest.java | 43 +
.../utils/writer/AbstractCompactionWriterTest.java | 126 +-
.../compaction/utils/CompactionCheckerUtils.java | 9 +-
.../dataregion/memtable/PrimitiveMemTableTest.java | 23 +-
.../read/reader/common/AscFakedSeriesReader.java | 8 +-
.../read/reader/common/DescFakedSeriesReader.java | 8 +-
.../dataregion/snapshot/IoTDBSnapshotTest.java | 10 +-
.../load/LoadTsFilePieceNodeAssemblerTest.java | 215 +
.../agent/SubscriptionReceiverAgentTest.java | 361 +-
.../receiver/SubscriptionReceiverV1Test.java | 41 +
.../iotdb/db/utils/QueryDataSetUtilsTest.java | 109 +-
.../apache/iotdb/db/utils/SerializeUtilsTest.java | 132 +-
....java => TSDataTypeSwitchArchitectureTest.java} | 27 +-
.../iotdb/db/utils/TSDataTypeSwitchRule.java | 182 +
.../iotdb/db/utils/TSDataTypeSwitchRuleTest.java | 186 +
.../apache/iotdb/db/utils/TypeServicesTest.java | 305 ++
.../db/utils/datastructure/AlignedTVListTest.java | 90 +
iotdb-core/metrics/core/pom.xml | 5 +
.../metrics/core/reporter/IoTDBJmxReporter.java | 115 +-
.../iotdb/metrics/core/type/IoTDBAutoGauge.java | 5 +-
.../core/utils/IoTDBMetricObjNameFactory.java | 38 +-
.../metrics/core/utils/ObjectNameFactory.java | 45 +
.../metrics/core/MetricManagerLifecycleTest.java | 339 ++
.../core/reporter/IoTDBJmxReporterTest.java | 205 +
.../metrics/core/type/IoTDBAutoGaugeTest.java | 68 +
.../core/utils/IoTDBMetricObjNameFactoryTest.java | 123 +
.../iotdb/metrics/AbstractMetricManager.java | 215 +-
.../conf/iotdb-system.properties.template | 7 +
.../apache/iotdb/commons/i18n/ClientMessages.java | 3 +
.../apache/iotdb/commons/i18n/CommonMessages.java | 6 +
.../apache/iotdb/commons/i18n/ClientMessages.java | 3 +
.../apache/iotdb/commons/i18n/CommonMessages.java | 6 +
.../commons/audit/UserDataTransferErrorCode.java | 3 +-
.../apache/iotdb/commons/client/ClientManager.java | 19 +-
.../iotdb/commons/client/ClientManagerMetrics.java | 200 +-
...sException.java => ColumnInAlterException.java} | 13 +-
...ception.java => ColumnInDeletionException.java} | 13 +-
...xception.java => TableInDeletionException.java} | 15 +-
.../apache/iotdb/commons/path/PathPatternNode.java | 31 +-
.../apache/iotdb/commons/path/PathPatternUtil.java | 6 +-
.../agent/plugin/builtin/BuiltinPipePlugin.java | 7 -
.../agent/plugin/builtin/sink/opcua/OpcUaSink.java | 34 -
.../pipe/config/constant/PipeSinkConstant.java | 7 +-
.../plan/relational/type/InternalTypeManager.java | 67 +-
.../iotdb/commons/udf/builtin/TypeServices.java | 671 +++
.../apache/iotdb/commons/udf/builtin/UDTFAbs.java | 106 +-
.../iotdb/commons/udf/builtin/UDTFBottomK.java | 105 +-
.../commons/udf/builtin/UDTFChangePoints.java | 178 +-
.../commons/udf/builtin/UDTFCommonDerivative.java | 41 +-
.../udf/builtin/UDTFCommonValueDifference.java | 42 +-
.../iotdb/commons/udf/builtin/UDTFConst.java | 267 +-
.../udf/builtin/UDTFContinuouslySatisfy.java | 79 +-
.../iotdb/commons/udf/builtin/UDTFDerivative.java | 11 +
.../udf/builtin/UDTFEqualSizeBucketAggSample.java | 53 +-
.../udf/builtin/UDTFEqualSizeBucketM4Sample.java | 39 +-
.../builtin/UDTFEqualSizeBucketOutlierSample.java | 53 +-
.../builtin/UDTFEqualSizeBucketRandomSample.java | 40 +-
.../iotdb/commons/udf/builtin/UDTFInRange.java | 162 +-
.../apache/iotdb/commons/udf/builtin/UDTFM4.java | 36 +-
.../apache/iotdb/commons/udf/builtin/UDTFMath.java | 149 +-
.../udf/builtin/UDTFNonNegativeDerivative.java | 48 +-
.../builtin/UDTFNonNegativeValueDifference.java | 49 +-
.../iotdb/commons/udf/builtin/UDTFOnOff.java | 153 +-
.../iotdb/commons/udf/builtin/UDTFSelectK.java | 136 +-
.../apache/iotdb/commons/udf/builtin/UDTFTopK.java | 65 +-
.../commons/udf/builtin/UDTFValueDifference.java | 12 +
.../iotdb/commons/udf/builtin/UDTFValueTrend.java | 42 +-
.../iotdb/commons/udf/utils/MasterRepairUtil.java | 32 +-
.../commons/udf/utils/UDFDataTypeTransformer.java | 107 +-
.../apache/iotdb/commons/utils/SerializeUtils.java | 371 +-
.../commons/client/ClientManagerMetricsTest.java | 580 ++
.../iotdb/commons/path/PathPatternNodeTest.java | 71 +
.../relational/type/InternalTypeManagerTest.java | 61 +
.../service/metric/MetricReporterSwitchTest.java | 166 +
.../commons/udf/utils/MasterRepairUtilTest.java | 94 +
.../udf/utils/UDFDataTypeTransformerTest.java | 71 +
.../src/main/thrift/datanode.thrift | 11 +
.../opc-ua-sink-example}/pom.xml | 21 +-
.../java/org/apache/iotdb/opcua/ClientExample.java | 0
.../apache/iotdb/opcua/ClientExampleRunner.java | 0
.../java/org/apache/iotdb/opcua/ClientTest.java | 0
.../iotdb/opcua/IoTDBKeyStoreLoaderClient.java | 0
library-pipe/opc-ua-sink/README.md | 82 +
.../mqtt => library-pipe/opc-ua-sink}/pom.xml | 139 +-
.../iotdb/pipe/plugin/sink}/opcua/OpcUaSink.java | 91 +-
.../plugin/sink}/opcua/client/ClientRunner.java | 2 +-
.../opcua/client/IoTDBKeyStoreLoaderClient.java | 2 +-
.../sink}/opcua/client/IoTDBOpcUaClient.java | 10 +-
.../sink}/opcua/server/OpcUaKeyStoreLoader.java | 2 +-
.../plugin/sink}/opcua/server/OpcUaNameSpace.java | 143 +-
.../sink}/opcua/server/OpcUaServerBuilder.java | 2 +-
.../sink/opcua/server/OpcUaTypeServices.java | 145 +
.../pipe/plugin/sink/opcua/OpcUaSinkTest.java | 285 +
.../sink}/opcua/OpcUaSinkTsFileMetadataTest.java | 2 +-
.../opcua/OpcUaSinkTsFilePerformanceTest.java | 6 +-
.../sink}/opcua/client/ClientRunnerTest.java | 2 +-
.../sink}/opcua/client/IoTDBOpcUaClientTest.java | 9 +-
.../opcua/server/OpcUaNameSpaceMetadataTest.java | 9 +-
.../sink}/opcua/server/OpcUaServerBuilderTest.java | 2 +-
.../server/OpcUaTcpNoneCompatibilityTest.java | 2 +-
.../sink/opcua/server/OpcUaTypeServicesTest.java | 25 +-
{external-service-impl => library-pipe}/pom.xml | 59 +-
library-udf/pom.xml | 5 +
.../iotdb/library/i18n/LibraryUdfMessages.java | 15 +
.../iotdb/library/i18n/LibraryUdfMessages.java | 12 +
.../apache/iotdb/library/anomaly/UDTFKSigma.java | 62 +-
.../apache/iotdb/library/anomaly/UDTFRange.java | 53 +-
.../iotdb/library/anomaly/UDTFTwoSidedFilter.java | 38 +-
.../iotdb/library/dprofile/UDAFPercentile.java | 218 +-
.../iotdb/library/dprofile/UDAFQuantile.java | 137 +-
.../apache/iotdb/library/dprofile/UDAFSpread.java | 99 +-
.../iotdb/library/dprofile/UDTFDistinct.java | 299 +-
.../apache/iotdb/library/dprofile/UDTFSample.java | 50 +-
.../dprofile/util/ExactOrderStatistics.java | 210 +-
.../iotdb/library/drepair/UDTFTimestampRepair.java | 36 +-
.../iotdb/library/drepair/UDTFValueFill.java | 36 +-
.../iotdb/library/drepair/UDTFValueRepair.java | 37 +-
.../library/frequency/UDFEnvelopeAnalysis.java | 45 +-
.../apache/iotdb/library/match/UDAFDTWMatch.java | 26 +-
.../iotdb/library/match/UDAFPatternMatch.java | 25 +-
.../apache/iotdb/library/util/TypeServices.java | 317 ++
.../java/org/apache/iotdb/library/util/Util.java | 79 +-
.../org/apache/iotdb/library/UDFEnvelopeTest.java | 23 +
licenses/Bouncy Castle Licence | 17 +
pom.xml | 34 +-
493 files changed, 32441 insertions(+), 23833 deletions(-)
create mode 100644 architecture-test/pom.xml
copy
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/utils/CommonUtilsTest.java
=>
architecture-test/src/test/java/org/apache/iotdb/db/utils/TSDataTypeSwitchArchitectureTest.java
(58%)
create mode 100644
architecture-test/src/test/java/org/apache/iotdb/db/utils/TSDataTypeSwitchRule.java
create mode 100644
architecture-test/src/test/java/org/apache/iotdb/db/utils/TSDataTypeSwitchRuleTest.java
copy distribution/src/assembly/{external-service-impl.xml => library-pipe.xml}
(74%)
create mode 100644
external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol/utils/TypeServices.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/confignode/it/removeconfignode/IoTDBRemoveConfigNodeSchemaPartitionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/AbstractIoTDBMPPDataExchangeLargeTsBlockIT.java
copy
integration-test/src/test/java/org/apache/iotdb/relational/it/query/{old/alignbydevice/IoTDBAlignByDeviceWithTemplateTable2IT.java
=> recent/IoTDBMPPDataExchangeLargeTsBlock128KIT.java} (73%)
create mode 100644
iotdb-client/isession/src/main/java/org/apache/iotdb/isession/TypeServices.java
create mode 100644
iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/TypeServices.java
create mode 100644
iotdb-client/service-rpc/src/test/java/org/apache/iotdb/rpc/IoTDBJDBCDataSetTest.java
create mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/util/SessionTypeServices.java
copy
iotdb-client/subscription/src/main/java/org/apache/iotdb/rpc/subscription/exception/{SubscriptionIdentifierSemanticException.java
=> SubscriptionConsumerFencedException.java} (60%)
create mode 100644
iotdb-client/subscription/src/main/java/org/apache/iotdb/session/subscription/payload/TypeServices.java
create mode 100644
iotdb-client/subscription/src/test/java/org/apache/iotdb/session/subscription/consumer/base/SubscriptionProviderStatusTest.java
create mode 100644
iotdb-client/subscription/src/test/java/org/apache/iotdb/session/subscription/payload/TypeServicesTest.java
create mode 100644
iotdb-core/calc-commons/src/main/java/org/apache/iotdb/calc/utils/TypeServices.java
create mode 100644
iotdb-core/calc-commons/src/test/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/LastDescendingInputTest.java
create mode 100644
iotdb-core/calc-commons/src/test/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/NumericBatchAggregationTest.java
create mode 100644
iotdb-core/calc-commons/src/test/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/NumericMomentBatchTest.java
create mode 100644
iotdb-core/calc-commons/src/test/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/SumAccumulatorTest.java
create mode 100644
iotdb-core/calc-commons/src/test/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/VarianceAccumulatorTest.java
create mode 100644
iotdb-core/calc-commons/src/test/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/grouped/GroupedApproxCountDistinctMaskTest.java
create mode 100644
iotdb-core/calc-commons/src/test/java/org/apache/iotdb/calc/execution/operator/source/relational/aggregation/rate/RateBatchInputTest.java
create mode 100644
iotdb-core/calc-commons/src/test/java/org/apache/iotdb/calc/transformation/dag/column/unary/scalar/NumericCastBatchTest.java
create mode 100644
iotdb-core/calc-commons/src/test/java/org/apache/iotdb/calc/utils/TypeServicesTest.java
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/table/{SetTableColumnCommentPlan.java
=> RollbackPreAlterColumnDataTypePlan.java} (69%)
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/ProcedureManagerReconstructRegionTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/ProcedureManagerTableTaskTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/persistence/schema/TablePreDeleteTest.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/schema/table/AlterTableColumnDataTypeProcedureTest.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/util/PipeTabletEventTransferUtils.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{storageengine/dataregion/compaction/execute/exception/CompactionMemoryNotEnoughException.java
=> queryengine/plan/planner/memory/OperatorMemoryNotEnoughException.java} (56%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/LoadTsFilePieceNodeAssembler.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/TypeServices.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/consensus/deletion/persist/PageCacheDeletionBufferTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/event/common/row/PipeRowTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/processor/aggregate/TimeSeriesRuntimeStateTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/protocol/thrift/impl/DataNodeInternalRPCServiceImplLoadTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/source/SeriesScanUtilCancellationTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/expression/visitor/predicate/ConvertPredicateToFilterVisitorTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/fetcher/TableHeaderSchemaValidatorTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/adapter/RowGetDoubleTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/input/ConstantInputReaderTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/util/TransformUtilsTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/load/LoadTsFilePieceNodeAssemblerTest.java
copy
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/utils/{CommonUtilsTest.java
=> TSDataTypeSwitchArchitectureTest.java} (52%)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/utils/TSDataTypeSwitchRule.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/utils/TSDataTypeSwitchRuleTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/utils/TypeServicesTest.java
create mode 100644
iotdb-core/metrics/core/src/test/java/org/apache/iotdb/metrics/core/MetricManagerLifecycleTest.java
create mode 100644
iotdb-core/metrics/core/src/test/java/org/apache/iotdb/metrics/core/reporter/IoTDBJmxReporterTest.java
create mode 100644
iotdb-core/metrics/core/src/test/java/org/apache/iotdb/metrics/core/type/IoTDBAutoGaugeTest.java
create mode 100644
iotdb-core/metrics/core/src/test/java/org/apache/iotdb/metrics/core/utils/IoTDBMetricObjNameFactoryTest.java
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/exception/table/{ColumnNotExistsException.java
=> ColumnInAlterException.java} (72%)
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/exception/table/{ColumnNotExistsException.java
=> ColumnInDeletionException.java} (72%)
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/exception/table/{ColumnNotExistsException.java
=> TableInDeletionException.java} (69%)
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/builtin/sink/opcua/OpcUaSink.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/TypeServices.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/client/ClientManagerMetricsTest.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/path/PathPatternNodeTest.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/queryengine/plan/relational/type/InternalTypeManagerTest.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/service/metric/MetricReporterSwitchTest.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/udf/utils/MasterRepairUtilTest.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/udf/utils/UDFDataTypeTransformerTest.java
rename {example/pipe-opc-ua-sink => library-pipe/opc-ua-sink-example}/pom.xml
(82%)
rename {example/pipe-opc-ua-sink =>
library-pipe/opc-ua-sink-example}/src/main/java/org/apache/iotdb/opcua/ClientExample.java
(100%)
rename {example/pipe-opc-ua-sink =>
library-pipe/opc-ua-sink-example}/src/main/java/org/apache/iotdb/opcua/ClientExampleRunner.java
(100%)
rename {example/pipe-opc-ua-sink =>
library-pipe/opc-ua-sink-example}/src/main/java/org/apache/iotdb/opcua/ClientTest.java
(100%)
rename {example/pipe-opc-ua-sink =>
library-pipe/opc-ua-sink-example}/src/main/java/org/apache/iotdb/opcua/IoTDBKeyStoreLoaderClient.java
(100%)
create mode 100644 library-pipe/opc-ua-sink/README.md
copy {external-service-impl/mqtt => library-pipe/opc-ua-sink}/pom.xml (57%)
rename
{iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol =>
library-pipe/opc-ua-sink/src/main/java/org/apache/iotdb/pipe/plugin/sink}/opcua/OpcUaSink.java
(91%)
rename
{iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol =>
library-pipe/opc-ua-sink/src/main/java/org/apache/iotdb/pipe/plugin/sink}/opcua/client/ClientRunner.java
(99%)
rename
{iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol =>
library-pipe/opc-ua-sink/src/main/java/org/apache/iotdb/pipe/plugin/sink}/opcua/client/IoTDBKeyStoreLoaderClient.java
(98%)
rename
{iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol =>
library-pipe/opc-ua-sink/src/main/java/org/apache/iotdb/pipe/plugin/sink}/opcua/client/IoTDBOpcUaClient.java
(98%)
rename
{iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol =>
library-pipe/opc-ua-sink/src/main/java/org/apache/iotdb/pipe/plugin/sink}/opcua/server/OpcUaKeyStoreLoader.java
(98%)
rename
{iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol =>
library-pipe/opc-ua-sink/src/main/java/org/apache/iotdb/pipe/plugin/sink}/opcua/server/OpcUaNameSpace.java
(85%)
rename
{iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol =>
library-pipe/opc-ua-sink/src/main/java/org/apache/iotdb/pipe/plugin/sink}/opcua/server/OpcUaServerBuilder.java
(99%)
create mode 100644
library-pipe/opc-ua-sink/src/main/java/org/apache/iotdb/pipe/plugin/sink/opcua/server/OpcUaTypeServices.java
create mode 100644
library-pipe/opc-ua-sink/src/test/java/org/apache/iotdb/pipe/plugin/sink/opcua/OpcUaSinkTest.java
rename
{iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/sink/protocol =>
library-pipe/opc-ua-sink/src/test/java/org/apache/iotdb/pipe/plugin/sink}/opcua/OpcUaSinkTsFileMetadataTest.java
(99%)
rename
{iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/sink/protocol =>
library-pipe/opc-ua-sink/src/test/java/org/apache/iotdb/pipe/plugin/sink}/opcua/OpcUaSinkTsFilePerformanceTest.java
(98%)
rename
{iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/sink/protocol =>
library-pipe/opc-ua-sink/src/test/java/org/apache/iotdb/pipe/plugin/sink}/opcua/client/ClientRunnerTest.java
(98%)
rename
{iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/sink/protocol =>
library-pipe/opc-ua-sink/src/test/java/org/apache/iotdb/pipe/plugin/sink}/opcua/client/IoTDBOpcUaClientTest.java
(97%)
rename
{iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/sink/protocol =>
library-pipe/opc-ua-sink/src/test/java/org/apache/iotdb/pipe/plugin/sink}/opcua/server/OpcUaNameSpaceMetadataTest.java
(95%)
rename
{iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/sink/protocol =>
library-pipe/opc-ua-sink/src/test/java/org/apache/iotdb/pipe/plugin/sink}/opcua/server/OpcUaServerBuilderTest.java
(99%)
rename
{iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/sink/protocol =>
library-pipe/opc-ua-sink/src/test/java/org/apache/iotdb/pipe/plugin/sink}/opcua/server/OpcUaTcpNoneCompatibilityTest.java
(98%)
copy
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/exception/CpuNotEnoughExceptionTest.java
=>
library-pipe/opc-ua-sink/src/test/java/org/apache/iotdb/pipe/plugin/sink/opcua/server/OpcUaTypeServicesTest.java
(55%)
copy {external-service-impl => library-pipe}/pom.xml (50%)
create mode 100644
library-udf/src/main/java/org/apache/iotdb/library/util/TypeServices.java
create mode 100644 licenses/Bouncy Castle Licence
