This is an automated email from the ASF dual-hosted git repository.
shuwenwei pushed a change to branch calc_commons
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 6bedeaf179b fix
new 6eb454a3f0f refactor operator context
new bfcbb917299 move ObjectTypeUtils
new e40a0d998f5 fix
new c402ac68e64 fix
The 4 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:
.../org/apache/iotdb/mqtt/MPPPublishHandler.java | 2 +-
.../v1/handler/StatementConstructionHandler.java | 2 +-
.../v1/handler/StatementConstructionHandler.java | 2 +-
.../v2/handler/StatementConstructionHandler.java | 2 +-
.../org/apache/iotdb/it/env/cluster/EnvUtils.java | 2 +-
.../constant/BuiltinAggregationFunctionEnum.java | 2 +-
.../it/partition/IoTDBTimePartitionIT.java | 2 +-
.../confignode/it/procedure/IoTDBProcedureIT.java | 2 +-
.../scalar/IoTDBCastFunctionTableIT.java | 2 +-
.../scalar/IoTDBFormatFunctionTableIT.java | 2 +-
.../it/query/old/query/IoTDBArithmeticTableIT.java | 2 +-
.../view/old/query/IoTDBArithmeticTableViewIT.java | 2 +-
.../apache/iotdb/tool/data/AbstractDataTool.java | 4 +-
.../consensus/request/read/ttl/ShowTTLPlan.java | 2 +-
.../response/pipe/task/PipeTableResp.java | 2 +-
.../iotdb/confignode/manager/ProcedureManager.java | 2 +-
.../impl/region/AddRegionPeerProcedure.java | 2 +-
.../impl/region/ReconstructRegionProcedure.java | 2 +-
.../impl/region/RegionMigrateProcedure.java | 2 +-
.../impl/region/RemoveRegionPeerProcedure.java | 2 +-
.../ArithmeticBinaryColumnTransformer.ftl | 4 +-
.../exception/MemoryNotEnoughException.java | 2 +-
.../execution/operator/AbstractOperator.java | 4 +-
...atorContext.java => CommonOperatorContext.java} | 100 ++------
.../operator/GroupedTopNRowNumberAccumulator.java | 2 +-
.../calc_commons/execution/operator/Operator.java | 6 +-
.../SimpleTsBlockWithPositionComparator.java | 4 +-
.../process/AbstractConsumeAllOperator.java | 5 +-
.../operator/process/AbstractFillOperator.java | 8 +-
.../process/AbstractLinearFillOperator.java | 8 +-
.../operator/process/AbstractSortOperator.java | 22 +-
.../process/AggregationMergeSortOperator.java | 10 +-
.../operator/process/AssignUniqueIdOperator.java | 13 +-
.../operator/process/CollectOperator.java | 8 +-
.../operator/process/EnforceSingleRowOperator.java | 8 +-
.../operator/process/FilterAndProjectOperator.java | 8 +-
.../execution/operator/process/LimitOperator.java | 8 +-
.../operator/process/MappingCollectOperator.java | 6 +-
.../operator/process/MergeSortOperator.java | 10 +-
.../execution/operator/process/OffsetOperator.java | 8 +-
.../process/PatternRecognitionOperator.java | 14 +-
.../process/PreviousFillWithGroupOperator.java | 10 +-
.../execution/operator/process/SortOperator.java | 8 +-
.../operator/process/TableFillOperator.java | 7 +-
.../operator/process/TableLinearFillOperator.java | 4 +-
.../process/TableLinearFillWithGroupOperator.java | 6 +-
.../operator/process/TableMergeSortOperator.java | 6 +-
.../operator/process/TableSortOperator.java | 8 +-
.../operator/process/TableStreamSortOperator.java | 8 +-
.../operator/process/TableTopKOperator.java | 6 +-
.../execution/operator/process/TopKOperator.java | 14 +-
.../execution/operator/process/ValuesOperator.java | 8 +-
.../process/function/PartitionRecognizer.java | 2 +-
.../function/TableFunctionLeafOperator.java | 8 +-
.../process/function/TableFunctionOperator.java | 8 +-
.../operator/process/function/partition/Slice.java | 2 +-
.../{gapfill => }/AbstractGapFillOperator.java | 12 +-
.../AbstractGapFillWGroupOperator.java | 8 +-
.../AbstractGapFillWoGroupOperator.java | 8 +-
.../{gapfill => }/GapFillWGroupWMoOperator.java | 8 +-
.../{gapfill => }/GapFillWGroupWoMoOperator.java | 8 +-
.../{gapfill => }/GapFillWoGroupWMoOperator.java | 6 +-
.../{gapfill => }/GapFillWoGroupWoMoOperator.java | 6 +-
.../join/SimpleNestedLoopCrossJoinOperator.java | 10 +-
.../process/join/merge/MergeSortComparator.java | 2 +-
.../process/join/merge/SortKeyComparator.java | 2 +-
.../process/rowpattern/LogicalIndexNavigation.java | 14 ++
.../process/rowpattern/expression/Computation.java | 4 +-
.../matcher/IrRowPatternToProgramRewriter.java | 22 +-
.../operator/process/window/RowNumberOperator.java | 8 +-
.../process/window/TableWindowOperator.java | 14 +-
.../process/window/TopKRankingOperator.java | 8 +-
.../AbstractAsofMergeSortJoinOperator.java | 4 +-
.../relational/AbstractMergeSortJoinOperator.java | 10 +-
.../relational/AsofMergeSortInnerJoinOperator.java | 4 +-
.../relational/AsofMergeSortLeftJoinOperator.java | 4 +-
.../source/relational/MarkDistinctOperator.java | 14 +-
.../relational/MergeSortFullOuterJoinOperator.java | 4 +-
.../relational/MergeSortInnerJoinOperator.java | 4 +-
.../relational/MergeSortLeftJoinOperator.java | 4 +-
.../relational/MergeSortSemiJoinOperator.java | 4 +-
.../relational/aggregation/AccumulatorFactory.java | 2 +-
.../aggregation/AggregationOperator.java | 14 +-
.../relational/aggregation/RecordIterator.java | 2 +-
.../grouped/HashAggregationOperator.java | 12 +-
.../grouped/StreamingAggregationOperator.java | 8 +-
.../grouped/StreamingHashAggregationOperator.java | 14 +-
.../builder/InMemoryHashAggregationBuilder.java | 8 +-
.../relational/ColumnTransformerBuilder.java | 2 +-
.../plan/planner/CommonOperatorUtils.java | 2 +-
.../plan/planner/TableOperatorGenerator.java | 132 +++++------
.../planner/CastToTimestampLiteralVisitor.java | 2 +-
.../AbstractTemporaryQueryDataFileService.java | 2 +-
.../ITemporaryQueryDataFileServiceProvider.java | 2 +-
.../AbstractCastFunctionColumnTransformer.java | 2 +-
.../column/unary/scalar/ExtractTransformer.java | 8 +-
.../unary/scalar/FormatColumnTransformer.java | 2 +-
.../scalar/ObjectLengthColumnTransformer.java | 2 +-
.../transformation/dag/udf/UDTFExecutor.java | 2 +-
.../transformation/dag/util/CastFunctionUtils.java | 2 +-
.../datastructure/SerializableList.java | 2 +-
.../db/{ => calc_commons}/utils/HeapTraversal.java | 2 +-
.../db/calc_commons/utils/IObjectFileService.java} | 24 +-
.../utils/IObjectFileServiceProvider.java} | 6 +-
.../utils}/IObjectPath.java | 2 +-
.../{ => calc_commons}/utils/ObjectTypeUtils.java | 122 ++--------
.../utils/constant/SqlConstant.java | 2 +-
.../utils/datastructure/MergeSortHeap.java | 2 +-
.../utils/datastructure/MergeSortKey.java | 2 +-
.../utils/datastructure/SortKey.java | 2 +-
.../{ => calc_commons}/utils/sort/DiskSpiller.java | 4 +-
.../utils/sort/FileSpillerReader.java | 4 +-
.../utils/sort/MemoryReader.java | 4 +-
.../utils/sort/SortBufferManager.java | 4 +-
.../{ => calc_commons}/utils/sort/SortReader.java | 4 +-
.../utils/sort/TableDiskSpiller.java | 2 +-
.../utils/sort/TreeDiskSpiller.java | 2 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 22 --
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 21 +-
.../db/exception/query/OutOfTTLException.java | 2 +-
...ctory.java => ITableFunctionAINodeService.java} | 10 +-
.../ITableFunctionAINodeServiceProvider.java | 9 +-
.../relational/function/TableFunctionFactory.java | 2 +-
.../function/tvf/ClassifyTableFunction.java | 18 +-
.../function/tvf/ForecastTableFunction.java | 21 +-
.../plan/relational/metadata/ColumnMetadata.java | 2 +-
.../plan/relational/metadata/ColumnSchema.java | 2 +-
.../plan/relational/metadata/TableSchema.java | 2 +-
.../plan/relational/planner/node/Measure.java | 2 +-
.../planner/node/PatternRecognitionNode.java | 6 +-
.../{rowpattern => }/AggregationLabelSet.java | 2 +-
.../{rowpattern => }/AggregationValuePointer.java | 2 +-
.../{rowpattern => }/ClassifierValuePointer.java | 2 +-
.../ExpressionAndValuePointers.java | 2 +-
.../rowpattern/{rowpattern => }/IrAlternation.java | 2 +-
.../rowpattern/{rowpattern => }/IrAnchor.java | 4 +-
.../{rowpattern => }/IrConcatenation.java | 2 +-
.../rowpattern/{rowpattern => }/IrEmpty.java | 2 +-
.../rowpattern/{rowpattern => }/IrExclusion.java | 2 +-
.../rowpattern/{rowpattern => }/IrLabel.java | 2 +-
.../IrPatternAlternationOptimizer.java | 4 +-
.../rowpattern/{rowpattern => }/IrPermutation.java | 2 +-
.../rowpattern/{rowpattern => }/IrQuantified.java | 2 +-
.../rowpattern/{rowpattern => }/IrQuantifier.java | 2 +-
.../rowpattern/{rowpattern => }/IrRowPattern.java | 2 +-
.../{rowpattern => }/IrRowPatternFlattener.java | 2 +-
.../{rowpattern => }/IrRowPatternVisitor.java | 2 +-
.../{rowpattern => }/LogicalIndexPointer.java | 15 +-
.../{rowpattern => }/MatchNumberValuePointer.java | 2 +-
.../rowpattern/{rowpattern => }/Patterns.java | 12 +-
.../{rowpattern => }/ScalarValuePointer.java | 2 +-
.../rowpattern/{rowpattern => }/ValuePointer.java | 2 +-
.../plan/relational/sql/ast/Query.java | 2 +-
.../plan/udf/BuiltinAggregationFunction.java | 2 +-
.../plan/udf/BuiltinScalarFunction.java | 2 +-
.../udf/BuiltinTimeSeriesGeneratingFunction.java | 2 +-
.../plan/udf/TableUDFUtils.java | 30 ++-
.../plan/udf/UDFManagementService.java | 2 +-
.../plan/udf/UDTFForecast.java | 25 +-
.../db/{ => node_commons}/utils/DateTimeUtils.java | 238 +------------------
.../utils/TimestampPrecisionUtils.java | 2 +-
.../{ => node_commons}/utils/cte/CteDataStore.java | 14 +-
.../event/common/heartbeat/PipeHeartbeatEvent.java | 2 +-
.../processor/TumblingWindowingProcessor.java | 4 +-
.../tumbling/TumblingTimeSamplingProcessor.java | 2 +-
.../transform/converter/ValueConverter.java | 6 +-
.../sink/protocol/opcua/server/OpcUaNameSpace.java | 4 +-
...istoricalDataRegionTsFileAndDeletionSource.java | 2 +-
.../realtime/PipeRealtimeDataRegionSource.java | 2 +-
.../an/DataNodeTableFunctionAINodeService.java | 50 ++++
...ataNodeTableFunctionAINodeServiceProvider.java} | 19 +-
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 2 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 2 +-
.../db/queryengine/common/MPPQueryContext.java | 2 +-
.../execution/aggregation/UDAFAccumulator.java | 2 +-
.../timerangeiterator/AggrWindowIterator.java | 4 +-
.../TimeRangeIteratorFactory.java | 2 +-
.../db/queryengine/execution/driver/Driver.java | 2 +-
.../execution/driver/DriverContext.java | 2 +-
.../execution/executor/RegionWriteExecutor.java | 83 ++++---
.../fragment/FragmentInstanceContext.java | 2 +-
.../fragment/FragmentInstanceExecution.java | 4 +-
.../execution/operator/AggregationUtil.java | 2 +-
.../execution/operator/EmptyDataOperator.java | 1 -
.../execution/operator/ExplainAnalyzeOperator.java | 1 -
.../execution/operator/OperatorContext.java | 112 +++++++++
.../operator/process/AbstractIntoOperator.java | 2 +-
.../operator/process/AbstractTreeIntoOperator.java | 2 +-
.../process/ActiveRegionScanMergeOperator.java | 2 +-
.../operator/process/AggregationOperator.java | 2 +-
.../operator/process/ColumnInjectOperator.java | 2 +-
.../operator/process/DeviceViewIntoOperator.java | 2 +-
.../operator/process/DeviceViewOperator.java | 2 +-
.../operator/process/ProjectOperator.java | 2 +-
.../process/RawDataAggregationOperator.java | 2 +-
.../operator/process/SingleDeviceViewOperator.java | 2 +-
.../process/SingleInputAggregationOperator.java | 2 +-
.../process/SlidingWindowAggregationOperator.java | 2 +-
.../operator/process/TableIntoOperator.java | 4 +-
.../operator/process/TagAggregationOperator.java | 2 +-
.../operator/process/TransformOperator.java | 4 +-
.../operator/process/TreeFillOperator.java | 2 +-
.../operator/process/TreeIntoOperator.java | 2 +-
.../operator/process/TreeLinearFillOperator.java | 2 +-
.../operator/process/TreeMergeSortOperator.java | 4 +-
.../operator/process/TreeSortOperator.java | 6 +-
.../operator/process/TreeTopKOperator.java | 4 +-
.../operator/process/ai/InferenceOperator.java | 2 +-
.../process/copyto/TableCopyToOperator.java | 2 +-
.../process/copyto/tsfile/CopyToTsFileOptions.java | 6 +-
.../process/join/FullOuterTimeJoinOperator.java | 2 +-
.../process/join/HorizontallyConcatOperator.java | 2 +-
.../process/join/InnerTimeJoinOperator.java | 2 +-
.../process/join/LeftOuterTimeJoinOperator.java | 2 +-
.../join/TableLeftOuterTimeJoinOperator.java | 2 +-
.../join/merge/MergeSortComparatorUtils.java | 2 +-
.../last/AbstractUpdateLastCacheOperator.java | 2 +-
.../last/AlignedUpdateLastCacheOperator.java | 2 +-
.../AlignedUpdateViewPathLastCacheOperator.java | 2 +-
.../process/last/LastQueryCollectOperator.java | 2 +-
.../process/last/LastQueryMergeOperator.java | 2 +-
.../operator/process/last/LastQueryOperator.java | 2 +-
.../process/last/LastQuerySortOperator.java | 2 +-
.../process/last/LastQueryTransformOperator.java | 2 +-
.../process/last/UpdateLastCacheOperator.java | 2 +-
.../last/UpdateViewPathLastCacheOperator.java | 2 +-
.../schema/CountGroupByLevelMergeOperator.java | 2 +-
.../schema/CountGroupByLevelScanOperator.java | 2 +-
.../operator/schema/CountMergeOperator.java | 2 +-
.../schema/NodeManageMemoryMergeOperator.java | 2 +-
.../operator/schema/NodePathsConvertOperator.java | 2 +-
.../operator/schema/NodePathsCountOperator.java | 2 +-
.../operator/schema/SchemaCountOperator.java | 2 +-
.../operator/schema/SchemaFetchMergeOperator.java | 2 +-
.../operator/schema/SchemaFetchScanOperator.java | 2 +-
.../operator/schema/SchemaQueryMergeOperator.java | 2 +-
.../schema/SchemaQueryOrderByHeatOperator.java | 2 +-
.../operator/schema/SchemaQueryScanOperator.java | 2 +-
.../operator/sink/IdentitySinkOperator.java | 2 +-
.../operator/sink/ShuffleHelperOperator.java | 2 +-
.../AbstractSeriesAggregationScanOperator.java | 2 +-
.../source/ActiveDeviceRegionScanOperator.java | 2 +-
.../source/ActiveTimeSeriesRegionScanOperator.java | 2 +-
.../AlignedSeriesAggregationScanOperator.java | 2 +-
.../operator/source/AlignedSeriesScanOperator.java | 2 +-
.../operator/source/ExchangeOperator.java | 2 +-
.../operator/source/LastCacheScanOperator.java | 2 +-
.../source/SeriesAggregationScanOperator.java | 2 +-
.../operator/source/SeriesScanOperator.java | 2 +-
.../operator/source/ShowDiskUsageOperator.java | 2 +-
.../operator/source/ShowQueriesOperator.java | 4 +-
.../relational/AbstractAggTableScanOperator.java | 6 +-
.../relational/AbstractTableScanOperator.java | 6 +-
.../source/relational/CteScanOperator.java | 4 +-
.../relational/DeviceIteratorScanOperator.java | 2 +-
.../InformationSchemaContentSupplierFactory.java | 4 +-
.../InformationSchemaTableScanOperator.java | 2 +-
.../relational/LastQueryAggTableScanOperator.java | 2 +-
.../MeasurementToTableViewAdaptorUtils.java | 2 +-
.../relational/TreeToTableViewAdaptorOperator.java | 4 +-
.../execution/schedule/DriverScheduler.java | 2 +-
.../execution/schedule/IDriverScheduler.java | 2 +-
.../queryengine/plan/analyze/AnalyzeVisitor.java | 6 +-
.../plan/analyze/ExpressionAnalyzer.java | 6 +-
.../plan/analyze/ExpressionTypeAnalyzer.java | 2 +-
.../queryengine/plan/analyze/PredicateUtils.java | 2 +-
.../plan/analyze/TemplatedAggregationAnalyze.java | 2 +-
.../plan/analyze/load/LoadTsFileAnalyzer.java | 2 +-
.../analyze/load/LoadTsFileTableSchemaCache.java | 8 +-
.../load/TreeSchemaAutoCreatorAndVerifier.java | 2 +-
.../analyze/schema/ClusterSchemaFetchExecutor.java | 2 +-
.../config/executor/ClusterConfigTaskExecutor.java | 4 +-
.../config/metadata/GetTimeSlotListTask.java | 2 +-
.../config/metadata/ShowFunctionsTask.java | 8 +-
.../execution/config/metadata/ShowRegionTask.java | 2 +-
.../execution/config/sys/pipe/ShowPipeTask.java | 2 +-
.../plan/expression/ExpressionFactory.java | 2 +-
.../plan/expression/multi/FunctionExpression.java | 4 +-
.../multi/builtin/helper/CastFunctionHelper.java | 2 +-
.../builtin/helper/ReplaceFunctionHelper.java | 4 +-
.../multi/builtin/helper/RoundFunctionHelper.java | 2 +-
.../builtin/helper/SubStringFunctionHelper.java | 10 +-
.../visitor/CountTimeAggregationAmountVisitor.java | 2 +-
.../expression/visitor/ReconstructVisitor.java | 2 +-
.../cartesian/BindSchemaForExpressionVisitor.java | 4 +-
.../cartesian/BindSchemaForPredicateVisitor.java | 4 +-
...catDeviceAndBindSchemaForExpressionVisitor.java | 4 +-
.../ConcatExpressionWithSuffixPathsVisitor.java | 2 +-
.../predicate/ConvertPredicateToFilterVisitor.java | 2 +-
.../ConvertPredicateToTimeFilterVisitor.java | 2 +-
.../plan/optimization/AggregationPushDown.java | 4 +-
.../plan/optimization/LimitOffsetPushDown.java | 2 +-
.../db/queryengine/plan/parser/ASTVisitor.java | 61 ++---
.../plan/parser/StatementGenerator.java | 4 +-
.../planner/DataNodeTableOperatorGenerator.java | 42 ++--
.../plan/planner/LocalExecutionPlanner.java | 2 +-
.../plan/planner/LogicalPlanBuilder.java | 4 +-
.../plan/planner/OperatorTreeGenerator.java | 2 +-
.../plan/planner/distribution/SourceRewriter.java | 12 +-
.../planner/plan/node/write/InsertTabletNode.java | 2 +-
.../plan/planner/plan/node/write/ObjectNode.java | 2 +-
.../plan/parameter/AggregationDescriptor.java | 6 +-
.../CrossSeriesAggregationDescriptor.java | 2 +-
.../plan/parameter/GroupByTimeParameter.java | 2 +-
.../plan/relational/analyzer/Analysis.java | 4 +-
.../relational/analyzer/ExpressionAnalyzer.java | 8 +-
.../relational/analyzer/ExpressionTreeUtils.java | 2 +-
.../relational/analyzer/StatementAnalyzer.java | 6 +-
.../predicate/ConvertPredicateToFilterVisitor.java | 2 +-
.../plan/relational/metadata/Metadata.java | 1 +
.../plan/relational/metadata/MetadataUtil.java | 1 +
.../plan/relational/metadata/TableMetadata.java | 3 +
.../relational/metadata/TableMetadataImpl.java | 6 +-
.../relational/metadata/TreeDeviceViewSchema.java | 2 +
.../fetcher/TableHeaderSchemaValidator.java | 4 +-
.../plan/relational/planner/CteMaterializer.java | 6 +-
.../plan/relational/planner/RelationPlanner.java | 26 +--
.../relational/planner/TableLogicalPlanner.java | 4 +-
.../distribute/TableDistributedPlanGenerator.java | 4 +-
.../planner/ir/ReplaceSymbolInExpression.java | 2 +-
.../iterative/rule/ExpressionRewriteRuleSet.java | 4 +-
.../planner/iterative/rule/OptimizeRowPattern.java | 6 +-
.../rule/PrunePatternRecognitionSourceColumns.java | 2 +-
.../iterative/rule/PruneTableScanColumns.java | 2 +-
.../iterative/rule/SetOperationNodeTranslator.java | 4 +-
.../iterative/rule/SimplifyCountOverConstant.java | 2 +-
.../planner/node/AggregationTableScanNode.java | 6 +-
.../node/AggregationTreeDeviceViewScanNode.java | 2 +-
.../AlignedAggregationTreeDeviceViewScanNode.java | 2 +-
.../plan/relational/planner/node/CteScanNode.java | 2 +-
.../planner/node/DeviceTableScanNode.java | 2 +-
.../node/InformationSchemaTableScanNode.java | 2 +-
.../plan/relational/planner/node/IntoNode.java | 2 +-
...onAlignedAggregationTreeDeviceViewScanNode.java | 2 +-
...bleDiskUsageInformationSchemaTableScanNode.java | 2 +-
.../relational/planner/node/TableScanNode.java | 2 +-
.../node/TreeAlignedDeviceViewScanNode.java | 2 +-
.../planner/node/TreeDeviceViewScanNode.java | 2 +-
.../node/TreeNonAlignedDeviceViewScanNode.java | 2 +-
.../planner/optimizations/ParallelizeGrouping.java | 2 +-
.../PushLimitOffsetIntoTableScan.java | 2 +-
.../optimizations/PushPredicateIntoTableScan.java | 4 +-
.../planner/optimizations/SymbolMapper.java | 14 +-
.../TransformAggregationToStreamable.java | 2 +-
.../optimizations/TransformSortToStreamSort.java | 2 +-
.../optimizations/UnaliasSymbolReferences.java | 2 +-
.../rowpattern/RowPatternToIrRewriter.java | 30 +--
.../relational/sql/ast/WrappedInsertStatement.java | 4 +-
.../plan/relational/sql/parser/AstBuilder.java | 35 +--
.../plan/statement/crud/InsertBaseStatement.java | 2 +-
.../plan/statement/crud/InsertRowStatement.java | 2 +-
.../plan/statement/crud/InsertTabletStatement.java | 2 +-
.../plan/statement/crud/QueryStatement.java | 2 +-
.../db/queryengine/plan/udf/TreeUDFUtils.java | 2 +-
.../dag/udf/UDAFInformationInferrer.java | 2 +-
.../transformation/dag/udf/UDTFContext.java | 2 +-
.../dag/udf/UDTFInformationInferrer.java | 2 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 6 +-
...aNodeTemporaryQueryDataFileServiceProvider.java | 4 +-
.../db/service/TemporaryQueryDataFileService.java | 2 +-
.../db/storageengine/dataregion/DataRegion.java | 4 +-
.../memtable/AbstractWritableMemChunk.java | 2 +-
.../read/reader/chunk/DiskAlignedChunkLoader.java | 2 +-
.../read/reader/chunk/DiskChunkLoader.java | 2 +-
.../apache/iotdb/db/tools/IoTDBDataDirViewer.java | 2 +-
.../iotdb/db/tools/TsFileResourcePrinter.java | 2 +-
.../org/apache/iotdb/db/utils/CommonUtils.java | 6 +-
.../iotdb/db/utils/DataNodeDateTimeUtils.java | 259 +++++++++++++++++++++
.../iotdb/db/utils/DataNodeObjectFileService.java | 134 +++++++++++
...java => DataNodeObjectFileServiceProvider.java} | 18 +-
.../org/apache/iotdb/db/utils/SchemaUtils.java | 2 +-
.../apache/iotdb/db/utils/TypeInferenceUtils.java | 2 +-
.../apache/iotdb/db/utils/cte/MemoryReader.java | 1 +
...service.ITemporaryQueryDataFileServiceProvider} | 0
...b.calc_commons.utils.IObjectFileServiceProvider | 1 +
...al.function.ITableFunctionAINodeServiceProvider | 1 +
.../org/apache/iotdb/db/qp/sql/ASTVisitorTest.java | 2 +-
.../fragment/FragmentInstanceExecutionTest.java | 2 +-
.../operator/AggregationMergeSortOperatorTest.java | 3 +-
.../operator/AggregationOperatorTest.java | 1 -
.../execution/operator/CteScanOperatorTest.java | 7 +-
.../operator/DeviceViewIntoOperatorTest.java | 1 -
.../execution/operator/ExchangeOperatorTest.java | 1 -
.../execution/operator/FillOperatorTest.java | 1 -
.../operator/LastQueryMergeOperatorTest.java | 1 -
.../operator/MergeTreeSortOperatorTest.java | 3 +-
...nAlignedTreeDeviceViewScanOperatorTreeTest.java | 5 +-
.../execution/operator/OperatorMemoryTest.java | 1 -
.../operator/SortOperatorSortBranchTest.java | 3 +-
.../execution/operator/TransformOperatorTest.java | 1 -
.../execution/operator/TreeIntoOperatorTest.java | 1 -
.../operator/TreeLinearFillOperatorTest.java | 1 -
.../execution/operator/TreeSortOperatorTest.java | 3 +-
.../execution/operator/TreeTopKOperatorTest.java | 1 -
.../operator/ViewFromTreeAdaptorOperatorTest.java | 2 +-
.../process/TableStreamSortOperatorTest.java | 4 +-
.../gapfill/GapFillWGroupWMoOperatorTest.java | 8 +-
.../gapfill/GapFillWGroupWoMoOperatorTest.java | 8 +-
.../gapfill/GapFillWoGroupWMoOperatorTest.java | 6 +-
.../gapfill/GapFillWoGroupWoMoOperatorTest.java | 4 +-
.../process/join/InnerTimeJoinOperatorTest.java | 2 +-
.../join/LeftOuterTimeJoinOperatorTest.java | 2 +-
.../rowpattern/IrRowPatternOptimizationTest.java | 26 +--
.../operator/process/rowpattern/MatcherTest.java | 22 +-
.../process/tvf/TableFunctionOperatorTest.java | 2 +-
.../process/window/RowNumberOperatorTest.java | 2 +-
.../process/window/TableWindowOperatorTest.java | 2 +-
.../process/window/TopKRankingOperatorTest.java | 2 +-
.../schema/CountGroupByLevelMergeOperatorTest.java | 2 +-
.../operator/schema/SchemaCountOperatorTest.java | 2 +-
.../schema/SchemaQueryScanOperatorTest.java | 2 +-
.../source/relational/TableScanOperatorTest.java | 4 +-
.../execution/schedule/DriverSchedulerTest.java | 2 +-
.../ConvertPredicateToTimeFilterTest.java | 2 +-
.../plan/parser/StatementGeneratorTest.java | 2 +-
.../planner/node/process/IntoNodeSerdeTest.java | 2 +-
.../planner/node/source/SourceNodeSerdeTest.java | 2 +-
.../analyzer/AggregationCornerCaseTest.java | 2 +-
.../plan/relational/analyzer/AnalyzerTest.java | 4 +-
.../analyzer/AsofInnerJoinOperatorTest.java | 2 +-
.../relational/analyzer/ExtractExpressionTest.java | 2 +-
.../plan/relational/analyzer/JoinTest.java | 2 +-
.../plan/relational/analyzer/TSBSMetadata.java | 8 +-
.../plan/relational/analyzer/TestMetadata.java | 10 +-
.../plan/relational/analyzer/TestPlanBuilder.java | 2 +-
.../planner/PatternRecognitionNodeSerdeTest.java | 18 +-
.../planner/assertions/AliasMatcher.java | 2 +-
.../planner/assertions/ColumnReference.java | 4 +-
.../planner/assertions/PlanMatchingVisitor.java | 2 +-
.../planner/assertions/RvalueMatcher.java | 2 +-
.../predicate/TablePredicateConversionTest.java | 2 +-
.../plan/statement/InsertStatementTest.java | 4 +-
.../plan/statement/StatementTestUtils.java | 4 +-
.../dataregion/memtable/PrimitiveMemTableTest.java | 2 +-
.../apache/iotdb/db/utils/DateTimeUtilsTest.java | 153 +++++++-----
.../apache/iotdb/db/utils/EnvironmentUtils.java | 2 +-
.../org/apache/iotdb/db/utils/SchemaUtilsTest.java | 2 +-
.../db/utils/TimestampPrecisionUtilsTest.java | 2 +
.../db/utils/datastructure/MergeSortHeapTest.java | 3 +
.../apache/iotdb/db/utils/sort/SortUtilTest.java | 9 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 22 ++
441 files changed, 1808 insertions(+), 1558 deletions(-)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/exception/MemoryNotEnoughException.java (95%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/calc_commons/execution/operator/{OperatorContext.java
=> CommonOperatorContext.java} (55%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/calc_commons/execution/operator/process/gapfill/{gapfill
=> }/AbstractGapFillOperator.java (96%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/calc_commons/execution/operator/process/gapfill/{gapfill
=> }/AbstractGapFillWGroupOperator.java (90%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/calc_commons/execution/operator/process/gapfill/{gapfill
=> }/AbstractGapFillWoGroupOperator.java (88%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/calc_commons/execution/operator/process/gapfill/{gapfill
=> }/GapFillWGroupWMoOperator.java (91%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/calc_commons/execution/operator/process/gapfill/{gapfill
=> }/GapFillWGroupWoMoOperator.java (91%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/calc_commons/execution/operator/process/gapfill/{gapfill
=> }/GapFillWoGroupWMoOperator.java (93%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/calc_commons/execution/operator/process/gapfill/{gapfill
=> }/GapFillWoGroupWoMoOperator.java (93%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{node_commons =>
calc_commons}/service/AbstractTemporaryQueryDataFileService.java (99%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{node_commons =>
calc_commons}/service/ITemporaryQueryDataFileServiceProvider.java (94%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{ =>
calc_commons}/utils/HeapTraversal.java (97%)
copy
iotdb-core/{node-commons/src/main/java/org/apache/iotdb/commons/exception/runtime/RPCServiceException.java
=>
datanode/src/main/java/org/apache/iotdb/db/calc_commons/utils/IObjectFileService.java}
(66%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine/transformation/api/YieldableReader.java
=> calc_commons/utils/IObjectFileServiceProvider.java} (85%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{storageengine/dataregion
=> calc_commons/utils}/IObjectPath.java (97%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{ =>
calc_commons}/utils/ObjectTypeUtils.java (59%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{ =>
calc_commons}/utils/constant/SqlConstant.java (98%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{ =>
calc_commons}/utils/datastructure/MergeSortHeap.java (98%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{ =>
calc_commons}/utils/datastructure/MergeSortKey.java (96%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{ =>
calc_commons}/utils/datastructure/SortKey.java (94%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{ =>
calc_commons}/utils/sort/DiskSpiller.java (98%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{ =>
calc_commons}/utils/sort/FileSpillerReader.java (97%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{ =>
calc_commons}/utils/sort/MemoryReader.java (93%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{ =>
calc_commons}/utils/sort/SortBufferManager.java (95%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{ =>
calc_commons}/utils/sort/SortReader.java (92%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{ =>
calc_commons}/utils/sort/TableDiskSpiller.java (97%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{ =>
calc_commons}/utils/sort/TreeDiskSpiller.java (96%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/node_commons/plan/relational/function/{ITableFunctionFactory.java
=> ITableFunctionAINodeService.java} (79%)
copy
iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/TimeoutChangeableTransport.java
=>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/node_commons/plan/relational/function/ITableFunctionAINodeServiceProvider.java
(81%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
node_commons}/plan/relational/metadata/ColumnMetadata.java (98%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
node_commons}/plan/relational/metadata/ColumnSchema.java (98%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
node_commons}/plan/relational/metadata/TableSchema.java (99%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/node_commons/plan/relational/planner/rowpattern/{rowpattern
=> }/AggregationLabelSet.java (99%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/node_commons/plan/relational/planner/rowpattern/{rowpattern
=> }/AggregationValuePointer.java (99%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/node_commons/plan/relational/planner/rowpattern/{rowpattern
=> }/ClassifierValuePointer.java (99%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/node_commons/plan/relational/planner/rowpattern/{rowpattern
=> }/ExpressionAndValuePointers.java (99%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/node_commons/plan/relational/planner/rowpattern/{rowpattern
=> }/IrAlternation.java (99%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/node_commons/plan/relational/planner/rowpattern/{rowpattern
=> }/IrAnchor.java (96%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/node_commons/plan/relational/planner/rowpattern/{rowpattern
=> }/IrConcatenation.java (99%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/node_commons/plan/relational/planner/rowpattern/{rowpattern
=> }/IrEmpty.java (98%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/node_commons/plan/relational/planner/rowpattern/{rowpattern
=> }/IrExclusion.java (98%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/node_commons/plan/relational/planner/rowpattern/{rowpattern
=> }/IrLabel.java (99%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/node_commons/plan/relational/planner/rowpattern/{rowpattern
=> }/IrPatternAlternationOptimizer.java (98%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/node_commons/plan/relational/planner/rowpattern/{rowpattern
=> }/IrPermutation.java (99%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/node_commons/plan/relational/planner/rowpattern/{rowpattern
=> }/IrQuantified.java (99%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/node_commons/plan/relational/planner/rowpattern/{rowpattern
=> }/IrQuantifier.java (99%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/node_commons/plan/relational/planner/rowpattern/{rowpattern
=> }/IrRowPattern.java (99%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/node_commons/plan/relational/planner/rowpattern/{rowpattern
=> }/IrRowPatternFlattener.java (99%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/node_commons/plan/relational/planner/rowpattern/{rowpattern
=> }/IrRowPatternVisitor.java (98%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/node_commons/plan/relational/planner/rowpattern/{rowpattern
=> }/LogicalIndexPointer.java (91%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/node_commons/plan/relational/planner/rowpattern/{rowpattern
=> }/MatchNumberValuePointer.java (98%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/node_commons/plan/relational/planner/rowpattern/{rowpattern
=> }/Patterns.java (90%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/node_commons/plan/relational/planner/rowpattern/{rowpattern
=> }/ScalarValuePointer.java (99%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/node_commons/plan/relational/planner/rowpattern/{rowpattern
=> }/ValuePointer.java (96%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{calc_commons =>
node_commons}/plan/udf/BuiltinAggregationFunction.java (98%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{calc_commons =>
node_commons}/plan/udf/BuiltinScalarFunction.java (97%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{calc_commons =>
node_commons}/plan/udf/BuiltinTimeSeriesGeneratingFunction.java (99%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{calc_commons =>
node_commons}/plan/udf/TableUDFUtils.java (67%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{calc_commons =>
node_commons}/plan/udf/UDFManagementService.java (99%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{calc_commons =>
node_commons}/plan/udf/UDTFForecast.java (91%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{ =>
node_commons}/utils/DateTimeUtils.java (76%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{ =>
node_commons}/utils/TimestampPrecisionUtils.java (98%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{ =>
node_commons}/utils/cte/CteDataStore.java (87%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/client/an/DataNodeTableFunctionAINodeService.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/{basic/BasicOpenSessionResp.java
=> client/an/DataNodeTableFunctionAINodeServiceProvider.java} (64%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/OperatorContext.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/DataNodeDateTimeUtils.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/DataNodeObjectFileService.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/{SerializedSize.java
=> DataNodeObjectFileServiceProvider.java} (71%)
rename
iotdb-core/datanode/src/main/resources/META-INF/services/{org.apache.iotdb.db.node_commons.service.ITemporaryQueryDataFileServiceProvider
=>
org.apache.iotdb.db.calc_commons.service.ITemporaryQueryDataFileServiceProvider}
(100%)
create mode 100644
iotdb-core/datanode/src/main/resources/META-INF/services/org.apache.iotdb.db.calc_commons.utils.IObjectFileServiceProvider
create mode 100644
iotdb-core/datanode/src/main/resources/META-INF/services/org.apache.iotdb.db.node_commons.plan.relational.function.ITableFunctionAINodeServiceProvider
