This is an automated email from the ASF dual-hosted git repository.
jt2594838 pushed a change to branch fix_empty_wal_read
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 4f4faf06d26 check wal entry size in WALByteBufReader
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 02b8c6c0437 Bump ratis to 3.3.1 (#18605)
add f00b24c66eb Fix table-model pipe batch leader redirects (#18690)
add be8606615e5 Fix SinkChannel failure propagation test race (#18675)
add 56b09f28dec Fix schema cache pollution from LAST queries on virtual
regions (#18694)
add 6377522ce2c Fix pipe leader cache updates for multi-device redirects
(#18689)
add af6f8f52e5a [Test] Avoid metadata lease fencing in DataNode unit tests
(#18284)
add a3330994747 Fix scan termination for finished fragment instances
(#18701)
add e7ec99f5d17 Datanode: validate that a query id belongs to the calling
session (#18643)
add c2ea4a40704 Add ImportWAL tool with WAL replay controls (#18516)
add 02ae00db9bc Wait for region leader election before region migration
(#18699)
add fbd5fd22a6c Fix flaky SHOW RECEIVERS lifecycle test (#18700)
add 1fd8c320baf Merge branch 'master' into fix_empty_wal_read
No new revisions were added by this update.
Summary of changes:
architecture-test/pom.xml | 284 +
.../db/utils/TSDataTypeSwitchArchitectureTest.java | 26 +-
.../iotdb/db/utils/TSDataTypeSwitchRule.java | 182 +
.../iotdb/db/utils/TSDataTypeSwitchRuleTest.java | 186 +
.../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 +-
.../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 +-
.../IoTDBRemoveConfigNodeSchemaPartitionIT.java | 262 +
.../db/it/last/IoTDBLastQueryVirtualRegionIT.java | 137 +
.../auto/basic/IoTDBShowReceiversLifecycleIT.java | 2 +
.../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/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 +
.../payload/SubscriptionRecordHandler.java | 76 +-
.../session/subscription/payload/TypeServices.java | 115 +
.../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/manager/ConfigManager.java | 5 +
.../procedure/env/RegionMaintainHandler.java | 22 +-
.../procedure/env/RegionMaintainHandlerTest.java | 235 +
iotdb-core/datanode/pom.xml | 5 +
.../apache/iotdb/db/i18n/DataNodeMiscMessages.java | 9 +-
.../apache/iotdb/db/i18n/DataNodePipeMessages.java | 6 +
.../iotdb/db/i18n/DataNodeQueryMessages.java | 16 +
.../apache/iotdb/db/i18n/ImportWALMessages.java | 155 +
.../apache/iotdb/db/i18n/DataNodeMiscMessages.java | 9 +-
.../apache/iotdb/db/i18n/DataNodePipeMessages.java | 6 +
.../iotdb/db/i18n/DataNodeQueryMessages.java | 16 +
.../apache/iotdb/db/i18n/ImportWALMessages.java | 154 +
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 6 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 9 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 25 +-
.../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 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 36 +-
.../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 +-
.../PipeTransferTabletInsertNodeEventHandler.java | 13 +-
.../PipeTransferTabletInsertionEventHandler.java | 6 +-
.../thrift/sync/IoTDBDataRegionSyncSink.java | 4 +
.../pipe/sink/util/TabletStatementConverter.java | 128 +-
.../db/pipe/sink/util/cacher/LeaderCacheUtils.java | 42 +-
.../sink/util/sorter/PipeInsertEventSorter.java | 106 +-
.../matcher/CachedSchemaPatternMatcher.java | 41 +-
.../iotdb/db/protocol/session/ClientSession.java | 23 +
.../iotdb/db/protocol/session/IClientSession.java | 3 +
.../db/protocol/session/InternalClientSession.java | 5 +
.../db/protocol/session/MqttClientSession.java | 5 +
.../db/protocol/session/RestClientSession.java | 5 +
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 135 +-
.../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 +-
.../db/queryengine/execution/driver/Driver.java | 6 +
...java => FragmentInstanceFinishedException.java} | 16 +-
.../execution/operator/AggregationUtil.java | 34 +-
.../process/InsertTabletStatementGenerator.java | 137 +-
.../operator/process/TransformOperator.java | 43 +-
.../execution/operator/source/SeriesScanUtil.java | 506 +-
.../relational/LastQueryAggTableScanOperator.java | 28 +-
.../operator/window/WindowManagerFactory.java | 62 +-
.../visitor/ExistUnknownTypeInExpression.java | 2 +-
.../visitor/GetMeasurementExpressionVisitor.java | 6 +
.../predicate/ConvertPredicateToFilterVisitor.java | 47 +-
.../plan/planner/OperatorGeneratorUtil.java | 28 +-
.../plan/planner/OperatorTreeGenerator.java | 51 +-
.../planner/plan/node/write/InsertRowNode.java | 218 +-
.../planner/plan/node/write/InsertTabletNode.java | 352 +-
.../predicate/ConvertPredicateToFilterVisitor.java | 85 +-
...ithUncorrelatedScalarSubqueryReconstructor.java | 40 +-
.../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 +-
.../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 +-
.../dataregion/modification/TagPredicate.java | 24 +
.../read/reader/chunk/MemAlignedPageReader.java | 52 +-
.../read/reader/chunk/MemPageReader.java | 84 +-
.../dataregion/utils/TsFileResourceUtils.java | 11 +-
.../storageengine/dataregion/wal/io/WALReader.java | 8 +
.../db/storageengine/load/LoadTsFileManager.java | 11 +-
.../load/splitter/AlignedChunkData.java | 94 +-
.../splitter/BatchedAlignedValueChunkData.java | 81 +-
.../load/splitter/NonAlignedChunkData.java | 71 +-
.../rescon/memory/PrimitiveArrayManager.java | 89 +-
.../consensus/ConsensusLogToTabletConverter.java | 77 +-
.../java/org/apache/iotdb/db/tools/ImportWAL.java | 1752 ++++++
.../iotdb/db/tools/TableWALDeleteConverter.java | 226 +
.../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 +-
.../db/pipe/event/common/row/PipeRowTest.java | 115 +
.../pattern/CachedSchemaPatternMatcherTest.java | 83 +
.../aggregate/TimeSeriesRuntimeStateTest.java | 76 +
.../protocol/thrift/IoTDBDataNodeReceiverTest.java | 70 +
...peTransferTabletInsertNodeEventHandlerTest.java | 105 +
.../sink/util/cacher/LeaderCacheUtilsTest.java | 89 +
.../db/protocol/session/QueryOwnershipTest.java | 343 ++
.../SinkChannelFailurePropagationTest.java | 12 +-
.../source/SeriesScanUtilCancellationTest.java | 172 +-
.../schedule/DefaultDriverSchedulerTest.java | 81 +
.../ConvertPredicateToFilterVisitorTest.java | 104 +
.../plan/planner/LastQueryCacheTest.java | 236 +
.../node/write/InsertTabletNodeSerdeTest.java | 71 +
.../dag/adapter/RowGetDoubleTest.java | 98 +
.../dag/input/ConstantInputReaderTest.java | 78 +
.../dag/util/TransformUtilsTest.java | 117 +
.../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 +-
.../org/apache/iotdb/db/tools/ImportWALTest.java | 2038 +++++++
.../db/tools/TableWALDeleteConverterTest.java | 318 ++
.../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 +
.../src/test/resources/iotdb-system.properties | 3 +
.../agent/plugin/builtin/BuiltinPipePlugin.java | 2 -
.../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 +-
.../relational/type/InternalTypeManagerTest.java | 61 +
.../commons/udf/utils/MasterRepairUtilTest.java | 94 +
.../udf/utils/UDFDataTypeTransformerTest.java | 71 +
.../plugin/sink/opcua/server/OpcUaNameSpace.java | 139 +-
.../sink/opcua/server/OpcUaTypeServices.java | 145 +
.../sink/opcua/client/IoTDBOpcUaClientTest.java | 5 +-
.../opcua/server/OpcUaNameSpaceMetadataTest.java | 5 +-
.../sink/opcua/server/OpcUaTypeServicesTest.java | 25 +-
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 +
pom.xml | 5 +-
scripts/tools/README.md | 156 +
.../{tsfile/settle-tsfile.sh => import-wal.sh} | 40 +-
.../windows/import-wal.bat} | 34 +-
382 files changed, 30224 insertions(+), 22842 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
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/db/it/last/IoTDBLastQueryVirtualRegionIT.java
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
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/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
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/env/RegionMaintainHandlerTest.java
create mode 100644
iotdb-core/datanode/src/main/i18n/en/org/apache/iotdb/db/i18n/ImportWALMessages.java
create mode 100644
iotdb-core/datanode/src/main/i18n/zh/org/apache/iotdb/db/i18n/ImportWALMessages.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/fragment/{FragmentInstanceFailureListener.java
=> FragmentInstanceFinishedException.java} (59%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/tools/ImportWAL.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/tools/TableWALDeleteConverter.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/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/pipe/sink/protocol/thrift/async/handler/PipeTransferTabletInsertNodeEventHandlerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/protocol/session/QueryOwnershipTest.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/planner/LastQueryCacheTest.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/tools/ImportWALTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/tools/TableWALDeleteConverterTest.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/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/queryengine/plan/relational/type/InternalTypeManagerTest.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
create mode 100644
library-pipe/opc-ua-sink/src/main/java/org/apache/iotdb/pipe/plugin/sink/opcua/server/OpcUaTypeServices.java
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%)
create mode 100644
library-udf/src/main/java/org/apache/iotdb/library/util/TypeServices.java
create mode 100644 scripts/tools/README.md
copy scripts/tools/{tsfile/settle-tsfile.sh => import-wal.sh} (60%)
copy scripts/{sbin/windows/stop-standalone.bat =>
tools/windows/import-wal.bat} (62%)
