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 d19de0b2d59 fix
new 2a9df458e72 move SessionInfo
new 7266836a10b fix
new 919761eb940 move transformation.dag.column
new 3f9f6930c50 move fill
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 | 6 +-
.../protocol/table/v1/impl/RestApiServiceImpl.java | 5 +-
.../rest/protocol/v2/impl/RestApiServiceImpl.java | 2 +-
.../ArithmeticBinaryColumnTransformer.ftl | 18 +-
.../templates/ArithmeticColumnTransformerApi.ftl | 16 +-
.../templates/ArithmeticUnaryColumnTransformer.ftl | 6 +-
.../src/main/codegen/templates/constantFill.ftl | 6 +-
.../src/main/codegen/templates/linearFill.ftl | 4 +-
.../src/main/codegen/templates/previousFill.ftl | 6 +-
.../templates/previousFillWithTimeDuration.ftl | 8 +-
.../execution/operator/process/fill/IFill.java | 2 +-
.../operator/process/fill/IFillFilter.java | 2 +-
.../operator/process/fill/ILinearFill.java | 2 +-
.../filter/AbstractMonthIntervalFillFilter.java | 4 +-
.../fill/filter/FixedIntervalFillFilter.java | 4 +-
.../fill/filter/MonthIntervalMSFillFilter.java | 2 +-
.../fill/filter/MonthIntervalNSFillFilter.java | 2 +-
.../fill/filter/MonthIntervalUSFillFilter.java | 2 +-
.../process/fill/identity/IdentityFill.java | 4 +-
.../process/fill/identity/IdentityLinearFill.java | 4 +-
.../operator/process/fill/linear/LinearFill.java | 4 +-
.../relational/ColumnTransformerBuilder.java | 270 +++++++-------
.../plan/planner/OperatorGeneratorUtils.java | 174 +++++++++
.../plan/planner/TableOperatorGenerator.java | 28 +-
.../relational/metadata/CommonMetadataUtils.java | 185 ++++++++++
.../plan/udf/TableUDFUtils.java | 3 +-
.../AbstractCaseWhenThenColumnTransformer.java | 2 +-
.../transformation/dag/column/ColumnCache.java | 2 +-
.../dag/column/ColumnTransformer.java | 6 +-
.../dag/column/FailFunctionColumnTransformer.java | 2 +-
.../column/TableCaseWhenThenColumnTransformer.java | 2 +-
.../column/TreeCaseWhenThenColumnTransformer.java | 2 +-
.../ArithmeticAdditionColumnTransformer.java | 4 +-
.../binary/ArithmeticBinaryColumnTransformer.java | 4 +-
.../ArithmeticDivisionColumnTransformer.java | 4 +-
.../binary/ArithmeticModuloColumnTransformer.java | 4 +-
.../ArithmeticMultiplicationColumnTransformer.java | 4 +-
.../ArithmeticSubtractionColumnTransformer.java | 4 +-
.../dag/column/binary/BinaryColumnTransformer.java | 4 +-
.../binary/CompareBinaryColumnTransformer.java | 14 +-
.../binary/CompareEqualToColumnTransformer.java | 6 +-
.../CompareGreaterEqualColumnTransformer.java | 4 +-
.../CompareGreaterThanColumnTransformer.java | 4 +-
.../binary/CompareLessEqualColumnTransformer.java | 4 +-
.../binary/CompareLessThanColumnTransformer.java | 4 +-
.../binary/CompareNonEqualColumnTransformer.java | 6 +-
.../dag/column/binary/HmacColumnTransformer.java | 8 +-
.../dag/column/binary/Like2ColumnTransformer.java | 6 +-
.../column/binary/LogicAndColumnTransformer.java | 4 +-
.../binary/LogicBinaryColumnTransformer.java | 4 +-
.../column/binary/LogicOrColumnTransformer.java | 4 +-
.../binary/factory/HmacStrategiesFactory.java | 4 +-
.../dag/column/binary/strategies/HmacStrategy.java | 2 +-
.../dag/column/leaf/ConstantColumnTransformer.java | 2 +-
.../dag/column/leaf/IdentityColumnTransformer.java | 2 +-
.../dag/column/leaf/LeafColumnTransformer.java | 4 +-
.../dag/column/leaf/NullColumnTransformer.java | 2 +-
.../dag/column/leaf/TimeColumnTransformer.java | 2 +-
.../AbstractGreatestLeastColumnTransformer.java | 4 +-
.../multi/BinaryGreatestColumnTransformer.java | 4 +-
.../column/multi/BinaryLeastColumnTransformer.java | 4 +-
.../multi/BooleanGreatestColumnTransformer.java | 4 +-
.../multi/BooleanLeastColumnTransformer.java | 4 +-
.../column/multi/CoalesceColumnTransformer.java | 4 +-
.../multi/DoubleGreatestColumnTransformer.java | 4 +-
.../column/multi/DoubleLeastColumnTransformer.java | 4 +-
.../multi/FloatGreatestColumnTransformer.java | 4 +-
.../column/multi/FloatLeastColumnTransformer.java | 4 +-
.../multi/InBinaryMultiColumnTransformer.java | 4 +-
.../multi/InBooleanMultiColumnTransformer.java | 4 +-
.../multi/InDoubleMultiColumnTransformer.java | 4 +-
.../multi/InFloatMultiColumnTransformer.java | 4 +-
.../multi/InInt32MultiColumnTransformer.java | 4 +-
.../multi/InInt64MultiColumnTransformer.java | 4 +-
.../dag/column/multi/InMultiColumnTransformer.java | 4 +-
.../multi/Int32GreatestColumnTransformer.java | 4 +-
.../column/multi/Int32LeastColumnTransformer.java | 4 +-
.../multi/Int64GreatestColumnTransformer.java | 4 +-
.../column/multi/Int64LeastColumnTransformer.java | 4 +-
.../multi/LogicalAndMultiColumnTransformer.java | 4 +-
.../multi/LogicalMultiColumnTransformer.java | 4 +-
.../multi/LogicalOrMultiColumnTransformer.java | 4 +-
.../column/multi/MappableUDFColumnTransformer.java | 4 +-
.../dag/column/multi/MultiColumnTransformer.java | 4 +-
.../column/ternary/BetweenColumnTransformer.java | 16 +-
.../ternary/CompareTernaryColumnTransformer.java | 4 +-
.../dag/column/ternary/Like3ColumnTransformer.java | 8 +-
.../dag/column/ternary/LpadColumnTransformer.java | 6 +-
.../dag/column/ternary/RpadColumnTransformer.java | 6 +-
.../column/ternary/TernaryColumnTransformer.java | 4 +-
.../dag/column/ternary/utils/BytePaddingUtils.java | 2 +-
.../udf/UserDefineScalarFunctionTransformer.java | 6 +-
.../unary/ArithmeticNegationColumnTransformer.java | 4 +-
.../dag/column/unary/InColumnTransformer.java | 4 +-
.../dag/column/unary/IsNullColumnTransformer.java | 4 +-
.../dag/column/unary/LikeColumnTransformer.java | 6 +-
.../column/unary/LogicNotColumnTransformer.java | 4 +-
.../dag/column/unary/RegularColumnTransformer.java | 6 +-
.../dag/column/unary/UnaryColumnTransformer.java | 4 +-
.../column/unary/scalar/AbsColumnTransformer.java | 6 +-
.../scalar/AbstractBitwise2ColumnTransformer.java | 6 +-
.../scalar/AbstractBitwiseColumnTransformer.java | 6 +-
.../AbstractCastFunctionColumnTransformer.java | 36 +-
.../scalar/AbstractLengthColumnTransformer.java | 6 +-
.../column/unary/scalar/AcosColumnTransformer.java | 6 +-
.../column/unary/scalar/AsinColumnTransformer.java | 6 +-
.../column/unary/scalar/AtanColumnTransformer.java | 6 +-
.../unary/scalar/BitCount2ColumnTransformer.java | 8 +-
.../unary/scalar/BitCountColumnTransformer.java | 8 +-
.../unary/scalar/BitwiseAnd2ColumnTransformer.java | 6 +-
.../unary/scalar/BitwiseAndColumnTransformer.java | 6 +-
.../scalar/BitwiseLeftShift2ColumnTransformer.java | 6 +-
.../scalar/BitwiseLeftShiftColumnTransformer.java | 6 +-
.../unary/scalar/BitwiseNotColumnTransformer.java | 8 +-
.../unary/scalar/BitwiseOr2ColumnTransformer.java | 6 +-
.../unary/scalar/BitwiseOrColumnTransformer.java | 6 +-
.../BitwiseRightShift2ColumnTransformer.java | 6 +-
...wiseRightShiftArithmetic2ColumnTransformer.java | 6 +-
...twiseRightShiftArithmeticColumnTransformer.java | 6 +-
.../scalar/BitwiseRightShiftColumnTransformer.java | 6 +-
.../unary/scalar/BitwiseXor2ColumnTransformer.java | 6 +-
.../unary/scalar/BitwiseXorColumnTransformer.java | 6 +-
.../unary/scalar/BlobLengthColumnTransformer.java | 4 +-
.../scalar/BytesToDoubleColumnTransformer.java | 10 +-
.../scalar/BytesToFloatColumnTransformer.java | 10 +-
.../unary/scalar/BytesToIntColumnTransformer.java | 10 +-
.../unary/scalar/BytesToLongColumnTransformer.java | 10 +-
.../dag/column/unary/scalar/CRC32Transformer.java | 6 +-
.../scalar/CastFunctionColumnTransformer.java | 4 +-
.../column/unary/scalar/CeilColumnTransformer.java | 6 +-
.../unary/scalar/Concat2ColumnTransformer.java | 8 +-
.../unary/scalar/ConcatColumnTransformer.java | 6 +-
.../unary/scalar/ConcatMultiColumnTransformer.java | 6 +-
.../column/unary/scalar/CosColumnTransformer.java | 6 +-
.../column/unary/scalar/CoshColumnTransformer.java | 6 +-
.../scalar/DateBinFunctionColumnTransformer.java | 6 +-
.../unary/scalar/DegreesColumnTransformer.java | 6 +-
.../column/unary/scalar/DiffColumnTransformer.java | 6 +-
.../scalar/DiffFunctionColumnTransformer.java | 6 +-
.../scalar/DoubleToBytesColumnTransformer.java | 8 +-
.../unary/scalar/EndsWith2ColumnTransformer.java | 8 +-
.../unary/scalar/EndsWithColumnTransformer.java | 8 +-
.../column/unary/scalar/ExpColumnTransformer.java | 6 +-
.../column/unary/scalar/ExtractTransformer.java | 6 +-
.../scalar/FloatToBytesColumnTransformer.java | 8 +-
.../unary/scalar/FloorColumnTransformer.java | 6 +-
.../unary/scalar/FormatColumnTransformer.java | 6 +-
.../scalar/GenericCodecColumnTransformer.java | 10 +-
.../scalar/HmacConstantKeyColumnTransformer.java | 8 +-
.../unary/scalar/IntToBytesColumnTransformer.java | 8 +-
.../unary/scalar/LTrim2ColumnTransformer.java | 8 +-
.../unary/scalar/LTrimColumnTransformer.java | 8 +-
.../unary/scalar/LengthColumnTransformer.java | 4 +-
.../column/unary/scalar/LnColumnTransformer.java | 6 +-
.../unary/scalar/Log10ColumnTransformer.java | 6 +-
.../unary/scalar/LongToBytesColumnTransformer.java | 8 +-
.../unary/scalar/LowerColumnTransformer.java | 6 +-
.../scalar/ObjectLengthColumnTransformer.java | 4 +-
.../unary/scalar/RTrim2ColumnTransformer.java | 8 +-
.../unary/scalar/RTrimColumnTransformer.java | 8 +-
.../unary/scalar/RadiansColumnTransformer.java | 6 +-
.../unary/scalar/RegexpLike2ColumnTransformer.java | 6 +-
.../unary/scalar/RegexpLikeColumnTransformer.java | 6 +-
.../unary/scalar/Replace2ColumnTransformer.java | 6 +-
.../unary/scalar/Replace3ColumnTransformer.java | 6 +-
.../scalar/ReplaceFunctionColumnTransformer.java | 6 +-
.../unary/scalar/RoundColumnTransformer.java | 6 +-
.../scalar/RoundFunctionColumnTransformer.java | 6 +-
.../column/unary/scalar/SignColumnTransformer.java | 6 +-
.../column/unary/scalar/SinColumnTransformer.java | 6 +-
.../column/unary/scalar/SinhColumnTransformer.java | 6 +-
.../column/unary/scalar/SqrtColumnTransformer.java | 6 +-
.../unary/scalar/StartsWith2ColumnTransformer.java | 8 +-
.../unary/scalar/StartsWithColumnTransformer.java | 6 +-
.../unary/scalar/Strcmp2ColumnTransformer.java | 6 +-
.../unary/scalar/StrcmpColumnTransformer.java | 6 +-
.../unary/scalar/Strpos2ColumnTransformer.java | 6 +-
.../unary/scalar/StrposColumnTransformer.java | 6 +-
.../unary/scalar/SubString2ColumnTransformer.java | 6 +-
.../unary/scalar/SubString3ColumnTransformer.java | 8 +-
.../unary/scalar/SubStringColumnTransformer.java | 6 +-
.../column/unary/scalar/TanColumnTransformer.java | 6 +-
.../column/unary/scalar/TanhColumnTransformer.java | 6 +-
.../unary/scalar/Trim2ColumnTransformer.java | 8 +-
.../column/unary/scalar/TrimColumnTransformer.java | 6 +-
.../scalar/TryCastFunctionColumnTransformer.java | 4 +-
.../unary/scalar/UpperColumnTransformer.java | 6 +-
.../scalar/factory/CodecStrategiesFactory.java | 8 +-
.../factory/NumericCodecStrategiesFactory.java | 2 +-
.../unary/scalar/inteface/CodecStrategy.java | 2 +-
.../dag/column/unary/scalar/util/HexUtils.java | 2 +-
.../unary/scalar/util/SpookyHashV2Utils.java | 2 +-
.../unary/scalar/util/TransformerDebugUtils.java | 6 +-
.../transformation/dag/util/BitwiseUtils.java | 2 +-
.../dag/util/CastFunctionUtils.java} | 99 ++---
.../dag/util/CommonTransformUtils.java | 46 +++
.../common/SessionInfo.java | 21 +-
.../iotdb/db/node_commons/common/SqlDialect.java | 56 +++
.../function/InterpretedFunctionInvoker.java | 2 +-
.../relational/planner/node/AggregationNode.java | 2 +-
.../legacy/IoTDBLegacyPipeReceiverAgent.java | 2 +-
.../protocol/legacy/loader/DeletionLoader.java | 2 +-
.../protocol/legacy/loader/TsFileLoader.java | 2 +-
.../sink/protocol/writeback/WriteBackSink.java | 8 +-
.../source/dataregion/IoTDBDataRegionSource.java | 4 +-
.../schemaregion/IoTDBSchemaRegionSource.java | 4 +-
.../db/protocol/client/DataNodeInternalClient.java | 2 +-
.../iotdb/db/protocol/session/IClientSession.java | 41 +--
.../iotdb/db/protocol/session/SessionManager.java | 23 +-
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 22 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 2 +-
.../db/queryengine/common/MPPQueryContext.java | 1 +
.../TableDateBinTimeRangeIterator.java | 2 +-
.../fragment/FragmentInstanceContext.java | 2 +-
.../execution/operator/OperatorContext.java | 2 +-
.../operator/process/AbstractFillOperator.java | 2 +-
.../process/AbstractLinearFillOperator.java | 2 +-
.../operator/process/FilterAndProjectOperator.java | 20 +-
.../process/PreviousFillWithGroupOperator.java | 2 +-
.../operator/process/TableFillOperator.java | 2 +-
.../operator/process/TableLinearFillOperator.java | 2 +-
.../process/TableLinearFillWithGroupOperator.java | 2 +-
.../operator/process/TreeFillOperator.java | 2 +-
.../operator/process/TreeLinearFillOperator.java | 2 +-
.../process/gapfill/GapFillWGroupWMoOperator.java | 2 +-
.../process/gapfill/GapFillWGroupWoMoOperator.java | 2 +-
.../process/gapfill/GapFillWoGroupWMoOperator.java | 2 +-
.../gapfill/GapFillWoGroupWoMoOperator.java | 2 +-
.../schema/source/DeviceAttributeUpdater.java | 4 +-
.../schema/source/DeviceBlackListConstructor.java | 4 +-
.../schema/source/DevicePredicateFilter.java | 4 +-
.../schema/source/DevicePredicateHandler.java | 4 +-
.../operator/schema/source/DeviceUpdater.java | 4 +-
.../operator/source/ShowQueriesOperator.java | 4 +-
.../InformationSchemaContentSupplierFactory.java | 4 +-
.../relational/aggregation/AccumulatorFactory.java | 2 +-
.../execution/schedule/DriverScheduler.java | 2 +-
.../execution/schedule/IDriverScheduler.java | 2 +-
.../iotdb/db/queryengine/plan/Coordinator.java | 2 +-
.../plan/analyze/load/LoadTsFileAnalyzer.java | 8 +-
.../plan/execution/IQueryExecution.java | 4 +-
.../queryengine/plan/execution/QueryExecution.java | 4 +-
.../plan/execution/config/ConfigExecution.java | 4 +-
.../config/executor/ClusterConfigTaskExecutor.java | 5 +-
.../config/executor/IConfigTaskExecutor.java | 5 +-
.../config/metadata/ShowFunctionsTask.java | 2 +-
.../metadata/relational/DeleteDeviceTask.java | 2 +-
.../config/session/SetSqlDialectTask.java | 6 +-
.../multi/builtin/BuiltInScalarFunctionHelper.java | 2 +-
.../multi/builtin/helper/CastFunctionHelper.java | 331 +----------------
.../multi/builtin/helper/DiffFunctionHelper.java | 4 +-
.../builtin/helper/ReplaceFunctionHelper.java | 4 +-
.../multi/builtin/helper/RoundFunctionHelper.java | 4 +-
.../builtin/helper/SubStringFunctionHelper.java | 2 +-
.../plan/expression/unary/LikeExpression.java | 9 -
.../visitor/ColumnTransformerVisitor.java | 60 +--
.../db/queryengine/plan/parser/ASTVisitor.java | 7 +-
.../planner/DataNodeTableOperatorGenerator.java | 6 +-
.../plan/planner/LocalExecutionPlanner.java | 6 +-
.../plan/planner/OperatorGeneratorUtil.java | 2 +-
.../plan/planner/OperatorTreeGenerator.java | 180 +--------
.../plan/planner/plan/FragmentInstance.java | 2 +-
.../plan/relational/analyzer/Analyzer.java | 2 +-
.../relational/analyzer/ExpressionAnalyzer.java | 14 +-
.../relational/analyzer/ExpressionTreeUtils.java | 2 +-
.../relational/analyzer/StatementAnalyzer.java | 16 +-
.../analyzer/StatementAnalyzerFactory.java | 2 +-
.../predicate/ConvertPredicateToFilterVisitor.java | 2 +-
.../PredicatePushIntoMetadataChecker.java | 4 -
.../ConvertSchemaPredicateToFilterVisitor.java | 2 +-
.../plan/relational/metadata/Metadata.java | 2 +-
.../plan/relational/metadata/MetadataUtil.java | 2 +-
.../relational/metadata/TableMetadataImpl.java | 410 ++++++++-------------
.../fetcher/TableHeaderSchemaValidator.java | 6 +-
.../planner/IrExpressionInterpreter.java | 8 +-
.../plan/relational/planner/IrTypeAnalyzer.java | 2 +-
.../plan/relational/planner/LiteralEncoder.java | 6 +-
.../relational/planner/LiteralInterpreter.java | 2 +-
.../plan/relational/planner/QueryPlanner.java | 4 +-
.../plan/relational/planner/RelationPlanner.java | 2 +-
.../plan/relational/planner/SubqueryPlanner.java | 2 +-
.../relational/planner/TableLogicalPlanner.java | 6 +-
.../ir/GapFillStartAndEndTimeExtractVisitor.java | 2 +-
.../plan/relational/planner/ir/IrUtils.java | 2 +-
.../planner/iterative/IterativeOptimizer.java | 2 +-
.../plan/relational/planner/iterative/Rule.java | 2 +-
.../rule/CanonicalizeExpressionRewriter.java | 2 +-
.../planner/iterative/rule/InlineProjections.java | 2 +-
.../iterative/rule/PushDownLimitIntoWindow.java | 2 +-
.../iterative/rule/SimplifyExpressions.java | 2 +-
.../rule/TransformCorrelatedScalarSubquery.java | 2 +-
.../relational/planner/node/TableScanNode.java | 2 +-
.../schema/TableDeviceAttributeUpdateNode.java | 2 +-
.../planner/optimizations/PlanOptimizer.java | 2 +-
.../PushAggregationIntoTableScan.java | 2 +-
.../relational/sql/ast/AbstractTraverseDevice.java | 2 +-
.../plan/relational/sql/ast/DeleteDevice.java | 8 +-
.../plan/relational/sql/ast/SetSqlDialect.java | 8 +-
.../plan/relational/sql/parser/AstBuilder.java | 4 +-
.../plan/relational/sql/rewrite/ShowRewrite.java | 2 +-
.../relational/sql/rewrite/StatementRewrite.java | 2 +-
.../plan/statement/sys/SetSqlDialectStatement.java | 8 +-
.../binary/CompareEqualToTransformer.java | 5 +-
.../binary/CompareGreaterEqualTransformer.java | 5 +-
.../binary/CompareGreaterThanTransformer.java | 5 +-
.../binary/CompareLessEqualTransformer.java | 5 +-
.../binary/CompareLessThanTransformer.java | 5 +-
.../binary/CompareNonEqualTransformer.java | 5 +-
.../transformer/ternary/BetweenTransformer.java | 6 +-
.../unary/scalar/CastFunctionTransformer.java | 20 +-
.../scalar/SubStringFunctionColumnTransformer.java | 4 +-
.../unary/scalar/SubStringFunctionTransformer.java | 2 +-
.../transformation/dag/util/TransformUtils.java | 8 -
.../schemaregion/impl/SchemaRegionMemoryImpl.java | 8 +-
.../db/schemaengine/table/DataNodeTableCache.java | 4 +-
.../metrics/IoTDBInternalLocalReporter.java | 2 +-
.../db/storageengine/dataregion/DataRegion.java | 6 +-
.../converter/LoadTsFileDataTypeConverter.java | 5 +-
.../apache/iotdb/db/utils/DataNodeAuthUtils.java | 2 +-
.../SchemaRegionSimpleRecoverTest.java | 2 +-
.../execution/operator/FillOperatorTest.java | 10 +-
.../operator/MergeTreeSortOperatorTest.java | 6 +-
.../execution/operator/OperatorMemoryTest.java | 14 +-
.../operator/TreeLinearFillOperatorTest.java | 8 +-
.../fill/filter/MonthIntervalFillFilterTest.java | 4 +
.../db/queryengine/plan/analyze/AnalyzeTest.java | 2 +-
.../plan/optimization/LimitOffsetPushDownTest.java | 2 +-
.../plan/planner/FragmentInstanceSerdeTest.java | 2 +-
.../distribution/DistributionPlannerBasicTest.java | 10 +-
.../planner/logical/LogicalPlannerTestUtil.java | 2 +-
.../plan/relational/analyzer/AnalyzerTest.java | 9 +-
.../plan/relational/analyzer/AuthTest.java | 12 +-
.../analyzer/LimitOffsetPushDownTest.java | 6 +-
.../analyzer/RowPatternRecognitionTest.java | 7 +-
.../plan/relational/analyzer/TSBSMetadata.java | 8 +-
.../plan/relational/analyzer/TestMetadata.java | 10 +-
.../plan/relational/analyzer/TestUtils.java | 9 +-
.../plan/relational/planner/PlanTester.java | 8 +-
.../relational/planner/PredicateUtilsTest.java | 6 +-
.../AggregationDeviceTableScanMatcher.java | 2 +-
.../assertions/AggregationFunctionMatcher.java | 2 +-
.../planner/assertions/AggregationMatcher.java | 2 +-
.../planner/assertions/AggregationStepMatcher.java | 2 +-
.../planner/assertions/AliasMatcher.java | 2 +-
.../planner/assertions/AliasPresent.java | 2 +-
.../planner/assertions/AssignUniqueIdMatcher.java | 2 +-
.../assertions/BaseStrictSymbolsMatcher.java | 2 +-
.../planner/assertions/ColumnReference.java | 2 +-
.../planner/assertions/CteScanMatcher.java | 2 +-
.../planner/assertions/ExchangeNodeMatcher.java | 2 +-
.../planner/assertions/ExpressionMatcher.java | 2 +-
.../planner/assertions/FilterMatcher.java | 2 +-
.../planner/assertions/GroupMatcher.java | 2 +-
.../assertions/IdentityProjectionMatcher.java | 2 +-
.../InformationSchemaTableScanMatcher.java | 2 +-
.../relational/planner/assertions/JoinMatcher.java | 2 +-
.../planner/assertions/LimitMatcher.java | 2 +-
.../planner/assertions/MarkDistinctMatcher.java | 2 +-
.../relational/planner/assertions/Matcher.java | 2 +-
.../planner/assertions/NotPlanNodeMatcher.java | 2 +-
.../planner/assertions/OffsetMatcher.java | 2 +-
.../planner/assertions/OutputMatcher.java | 2 +-
.../relational/planner/assertions/PlanAssert.java | 6 +-
.../planner/assertions/PlanMatchPattern.java | 2 +-
.../planner/assertions/PlanMatchingVisitor.java | 2 +-
.../planner/assertions/PlanNodeMatcher.java | 2 +-
.../planner/assertions/PredicateMatcher.java | 2 +-
.../planner/assertions/RvalueMatcher.java | 2 +-
.../planner/assertions/SemiJoinMatcher.java | 2 +-
.../relational/planner/assertions/SortMatcher.java | 2 +-
.../assertions/StrictAssignedSymbolsMatcher.java | 2 +-
.../planner/assertions/StrictSymbolsMatcher.java | 2 +-
.../assertions/TableFunctionProcessorMatcher.java | 2 +-
.../planner/assertions/TableScanMatcher.java | 2 +-
.../relational/planner/assertions/TopKMatcher.java | 2 +-
.../planner/assertions/WindowFunctionMatcher.java | 2 +-
.../plan/statement/InsertStatementTest.java | 2 +-
.../builder/EvaluationDAGBuilderTest.java | 4 +-
...meticAndCompareBinaryColumnTransformerTest.java | 13 +-
.../binary/LogicBinaryColumnTransformerTest.java | 5 +-
.../binary/hmac/HmacMd5ColumnTransformerTest.java | 10 +-
.../binary/hmac/HmacSha1ColumnTransformerTest.java | 10 +-
.../hmac/HmacSha256ColumnTransformerTest.java | 10 +-
.../hmac/HmacSha512ColumnTransformerTest.java | 10 +-
.../column/ternary/LpadColumnTransformerTest.java | 3 +-
.../column/ternary/RpadColumnTransformerTest.java | 3 +-
.../column/unary/UnaryColumnTransformerTest.java | 9 +-
.../scalar/BlobLengthColumnTransformerTest.java | 3 +-
.../column/unary/scalar/DateBinFunctionTest.java | 2 +-
.../FromBigEndian32ColumnTransformerTest.java | 6 +-
.../FromBigEndian64ColumnTransformerTest.java | 6 +-
...omIEEE754_32BigEndianColumnTransformerTest.java | 6 +-
...omIEEE754_64BigEndianColumnTransformerTest.java | 6 +-
.../FromLittleEndian32ColumnTransformerTest.java | 6 +-
.../FromLittleEndian64ColumnTransformerTest.java | 6 +-
.../ToBigEndian32ColumnTransformerTest.java | 6 +-
.../ToBigEndian64ColumnTransformerTest.java | 6 +-
...ToIEEE754_32BigEndianColumnTransformerTest.java | 6 +-
...ToIEEE754_64BigEndianColumnTransformerTest.java | 6 +-
.../ToLittleEndian32ColumnTransformerTest.java | 6 +-
.../ToLittleEndian64ColumnTransformerTest.java | 6 +-
.../unary/scalar/ReverseColumnTransformerTest.java | 5 +-
.../FromBase32ColumnTransformerTest.java | 6 +-
.../FromBase64ColumnTransformerTest.java | 6 +-
.../FromBase64UrlColumnTransformerTest.java | 6 +-
.../ToBase32ColumnTransformerTest.java | 6 +-
.../ToBase64ColumnTransformerTest.java | 6 +-
.../ToBase64UrlColumnTransformerTest.java | 6 +-
.../scalar/hashing/Crc32ColumnTransformerTest.java | 4 +-
.../scalar/hashing/Md5ColumnTransformerTest.java | 6 +-
.../hashing/Murmur3ColumnTransformerTest.java | 6 +-
.../scalar/hashing/Sha1ColumnTransformerTest.java | 6 +-
.../hashing/Sha256ColumnTransformerTest.java | 6 +-
.../hashing/Sha512ColumnTransformerTest.java | 6 +-
.../SpookyHashV2_32ColumnTransformerTest.java | 6 +-
.../SpookyHashV2_64ColumnTransformerTest.java | 6 +-
.../hashing/XxHash64ColumnTransformerTest.java | 6 +-
.../hexEncoding/FromHexColumnTransformerTest.java | 6 +-
.../hexEncoding/ToHexColumnTransformerTest.java | 6 +-
.../transformation/dag/util/BitwiseUtilsTest.java | 17 +-
420 files changed, 1868 insertions(+), 2077 deletions(-)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/execution/operator/process/fill/IFill.java (92%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/execution/operator/process/fill/IFillFilter.java (93%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/execution/operator/process/fill/ILinearFill.java (97%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/execution/operator/process/fill/filter/AbstractMonthIntervalFillFilter.java
(89%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/execution/operator/process/fill/filter/FixedIntervalFillFilter.java
(89%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/execution/operator/process/fill/filter/MonthIntervalMSFillFilter.java
(95%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/execution/operator/process/fill/filter/MonthIntervalNSFillFilter.java
(96%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/execution/operator/process/fill/filter/MonthIntervalUSFillFilter.java
(96%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/execution/operator/process/fill/identity/IdentityFill.java (86%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/execution/operator/process/fill/identity/IdentityLinearFill.java
(90%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/execution/operator/process/fill/linear/LinearFill.java (98%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/execution/relational/ColumnTransformerBuilder.java (85%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/calc_commons/plan/planner/OperatorGeneratorUtils.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/calc_commons/plan/relational/metadata/CommonMetadataUtils.java
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/plan/udf/TableUDFUtils.java (95%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/AbstractCaseWhenThenColumnTransformer.java
(99%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/ColumnCache.java (96%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/ColumnTransformer.java (92%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/FailFunctionColumnTransformer.java (96%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/TableCaseWhenThenColumnTransformer.java
(95%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/TreeCaseWhenThenColumnTransformer.java
(97%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/binary/ArithmeticAdditionColumnTransformer.java
(88%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/binary/ArithmeticBinaryColumnTransformer.java
(94%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/binary/ArithmeticDivisionColumnTransformer.java
(88%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/binary/ArithmeticModuloColumnTransformer.java
(88%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/binary/ArithmeticMultiplicationColumnTransformer.java
(88%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/binary/ArithmeticSubtractionColumnTransformer.java
(88%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/binary/BinaryColumnTransformer.java
(95%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/binary/CompareBinaryColumnTransformer.java
(88%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/binary/CompareEqualToColumnTransformer.java
(84%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/binary/CompareGreaterEqualColumnTransformer.java
(88%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/binary/CompareGreaterThanColumnTransformer.java
(88%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/binary/CompareLessEqualColumnTransformer.java
(88%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/binary/CompareLessThanColumnTransformer.java
(88%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/binary/CompareNonEqualColumnTransformer.java
(84%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/binary/HmacColumnTransformer.java (90%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/binary/Like2ColumnTransformer.java (91%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/binary/LogicAndColumnTransformer.java
(96%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/binary/LogicBinaryColumnTransformer.java
(90%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/binary/LogicOrColumnTransformer.java
(96%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/binary/factory/HmacStrategiesFactory.java
(95%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/binary/strategies/HmacStrategy.java
(91%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/leaf/ConstantColumnTransformer.java
(96%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/leaf/IdentityColumnTransformer.java
(96%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/leaf/LeafColumnTransformer.java (88%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/leaf/NullColumnTransformer.java (94%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/leaf/TimeColumnTransformer.java (95%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/multi/AbstractGreatestLeastColumnTransformer.java
(95%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/multi/BinaryGreatestColumnTransformer.java
(91%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/multi/BinaryLeastColumnTransformer.java
(91%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/multi/BooleanGreatestColumnTransformer.java
(90%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/multi/BooleanLeastColumnTransformer.java
(90%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/multi/CoalesceColumnTransformer.java
(93%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/multi/DoubleGreatestColumnTransformer.java
(91%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/multi/DoubleLeastColumnTransformer.java
(91%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/multi/FloatGreatestColumnTransformer.java
(91%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/multi/FloatLeastColumnTransformer.java
(91%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/multi/InBinaryMultiColumnTransformer.java
(92%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/multi/InBooleanMultiColumnTransformer.java
(92%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/multi/InDoubleMultiColumnTransformer.java
(92%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/multi/InFloatMultiColumnTransformer.java
(92%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/multi/InInt32MultiColumnTransformer.java
(92%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/multi/InInt64MultiColumnTransformer.java
(92%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/multi/InMultiColumnTransformer.java
(92%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/multi/Int32GreatestColumnTransformer.java
(91%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/multi/Int32LeastColumnTransformer.java
(91%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/multi/Int64GreatestColumnTransformer.java
(91%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/multi/Int64LeastColumnTransformer.java
(91%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/multi/LogicalAndMultiColumnTransformer.java
(96%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/multi/LogicalMultiColumnTransformer.java
(90%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/multi/LogicalOrMultiColumnTransformer.java
(96%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/multi/MappableUDFColumnTransformer.java
(95%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/multi/MultiColumnTransformer.java (95%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/ternary/BetweenColumnTransformer.java
(86%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/ternary/CompareTernaryColumnTransformer.java
(89%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/ternary/Like3ColumnTransformer.java
(90%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/ternary/LpadColumnTransformer.java (91%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/ternary/RpadColumnTransformer.java (91%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/ternary/TernaryColumnTransformer.java
(96%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/ternary/utils/BytePaddingUtils.java
(97%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/udf/UserDefineScalarFunctionTransformer.java
(93%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/ArithmeticNegationColumnTransformer.java
(93%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/InColumnTransformer.java (97%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/IsNullColumnTransformer.java (92%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/LikeColumnTransformer.java (90%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/LogicNotColumnTransformer.java
(93%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/RegularColumnTransformer.java
(91%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/UnaryColumnTransformer.java (94%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/AbsColumnTransformer.java
(90%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/AbstractBitwise2ColumnTransformer.java
(89%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/AbstractBitwiseColumnTransformer.java
(88%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/AbstractCastFunctionColumnTransformer.java
(88%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/AbstractLengthColumnTransformer.java
(88%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/AcosColumnTransformer.java
(90%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/AsinColumnTransformer.java
(90%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/AtanColumnTransformer.java
(90%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/BitCount2ColumnTransformer.java
(87%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/BitCountColumnTransformer.java
(86%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/BitwiseAnd2ColumnTransformer.java
(86%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/BitwiseAndColumnTransformer.java
(85%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/BitwiseLeftShift2ColumnTransformer.java
(91%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/BitwiseLeftShiftColumnTransformer.java
(87%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/BitwiseNotColumnTransformer.java
(85%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/BitwiseOr2ColumnTransformer.java
(86%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/BitwiseOrColumnTransformer.java
(85%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/BitwiseRightShift2ColumnTransformer.java
(91%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/BitwiseRightShiftArithmetic2ColumnTransformer.java
(91%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/BitwiseRightShiftArithmeticColumnTransformer.java
(88%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/BitwiseRightShiftColumnTransformer.java
(87%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/BitwiseXor2ColumnTransformer.java
(86%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/BitwiseXorColumnTransformer.java
(85%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/BlobLengthColumnTransformer.java
(88%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/BytesToDoubleColumnTransformer.java
(84%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/BytesToFloatColumnTransformer.java
(84%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/BytesToIntColumnTransformer.java
(84%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/BytesToLongColumnTransformer.java
(84%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/CRC32Transformer.java (88%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/CastFunctionColumnTransformer.java
(94%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/CeilColumnTransformer.java
(90%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/Concat2ColumnTransformer.java
(86%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/ConcatColumnTransformer.java
(91%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/ConcatMultiColumnTransformer.java
(91%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/CosColumnTransformer.java
(90%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/CoshColumnTransformer.java
(90%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/DateBinFunctionColumnTransformer.java
(96%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/DegreesColumnTransformer.java
(90%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/DiffColumnTransformer.java
(91%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/DiffFunctionColumnTransformer.java
(92%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/DoubleToBytesColumnTransformer.java
(85%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/EndsWith2ColumnTransformer.java
(86%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/EndsWithColumnTransformer.java
(84%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/ExpColumnTransformer.java
(90%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/ExtractTransformer.java
(94%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/FloatToBytesColumnTransformer.java
(85%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/FloorColumnTransformer.java
(90%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/FormatColumnTransformer.java
(93%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/GenericCodecColumnTransformer.java
(86%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/HmacConstantKeyColumnTransformer.java
(86%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/IntToBytesColumnTransformer.java
(85%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/LTrim2ColumnTransformer.java
(86%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/LTrimColumnTransformer.java
(87%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/LengthColumnTransformer.java
(88%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/LnColumnTransformer.java
(90%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/Log10ColumnTransformer.java
(90%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/LongToBytesColumnTransformer.java
(84%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/LowerColumnTransformer.java
(89%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/ObjectLengthColumnTransformer.java
(88%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/RTrim2ColumnTransformer.java
(86%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/RTrimColumnTransformer.java
(87%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/RadiansColumnTransformer.java
(90%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/RegexpLike2ColumnTransformer.java
(90%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/RegexpLikeColumnTransformer.java
(89%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/Replace2ColumnTransformer.java
(92%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/Replace3ColumnTransformer.java
(93%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/ReplaceFunctionColumnTransformer.java
(90%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/RoundColumnTransformer.java
(93%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/RoundFunctionColumnTransformer.java
(92%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/SignColumnTransformer.java
(90%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/SinColumnTransformer.java
(90%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/SinhColumnTransformer.java
(90%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/SqrtColumnTransformer.java
(90%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/StartsWith2ColumnTransformer.java
(85%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/StartsWithColumnTransformer.java
(90%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/Strcmp2ColumnTransformer.java
(90%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/StrcmpColumnTransformer.java
(89%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/Strpos2ColumnTransformer.java
(90%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/StrposColumnTransformer.java
(89%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/SubString2ColumnTransformer.java
(91%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/SubString3ColumnTransformer.java
(91%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/SubStringColumnTransformer.java
(92%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/TanColumnTransformer.java
(90%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/TanhColumnTransformer.java
(90%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/Trim2ColumnTransformer.java
(86%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/TrimColumnTransformer.java
(91%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/TryCastFunctionColumnTransformer.java
(94%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/UpperColumnTransformer.java
(89%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/factory/CodecStrategiesFactory.java
(92%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/factory/NumericCodecStrategiesFactory.java
(98%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/inteface/CodecStrategy.java
(91%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/util/HexUtils.java (96%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/util/SpookyHashV2Utils.java
(99%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/column/unary/scalar/util/TransformerDebugUtils.java
(87%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
calc_commons}/transformation/dag/util/BitwiseUtils.java (99%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine/plan/expression/multi/builtin/helper/CastFunctionHelper.java
=> calc_commons/transformation/dag/util/CastFunctionUtils.java} (73%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/calc_commons/transformation/dag/util/CommonTransformUtils.java
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine =>
node_commons}/common/SessionInfo.java (90%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/node_commons/common/SqlDialect.java
