This is an automated email from the ASF dual-hosted git repository. xuekaifeng pushed a commit to branch xkf_id_table in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit b234a507afb4b53014981ea0d5effbd459a410a3 Merge: 61999aa 9d2df64 Author: 151250176 <[email protected]> AuthorDate: Mon Dec 13 14:43:47 2021 +0800 Merge branch 'master' of git://github.com/apache/iotdb into xkf_id_table Jenkinsfile | 42 +- .../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 6 +- .../DML-Data-Manipulation-Language.md | 277 ++++++-- .../DML-Data-Manipulation-Language.md | 276 ++++++-- .../apache/iotdb/db/integration/IoTDBAliasIT.java | 37 +- .../apache/iotdb/db/integration/IoTDBFillIT.java | 261 +++++++- .../iotdb/db/integration/IoTDBGroupByFillIT.java | 184 ++++-- .../db/integration/IoTDBGroupByFillMixPathsIT.java | 733 ++++++++++----------- .../aggregation/IoTDBUDFNestAggregationIT.java | 515 +++++++++++++++ .../IoTDBUserDefinedAggregationFunctionIT.java | 725 ++++++++++++++++++++ .../resources/conf/iotdb-engine.properties | 9 - .../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 22 - .../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 15 - .../db/cost/statistic/ConcurrentCircularArray.java | 67 -- .../iotdb/db/cost/statistic/Measurement.java | 423 ------------ .../iotdb/db/cost/statistic/MeasurementMBean.java | 60 -- .../apache/iotdb/db/qp/executor/PlanExecutor.java | 4 + .../qp/logical/crud/AggregationQueryOperator.java | 38 +- .../db/qp/logical/crud/FillClauseComponent.java | 9 + .../db/qp/logical/crud/FillQueryOperator.java | 4 +- .../logical/crud/GroupByFillClauseComponent.java | 9 + .../qp/logical/crud/GroupByFillQueryOperator.java | 2 + .../iotdb/db/qp/logical/crud/QueryOperator.java | 31 +- .../iotdb/db/qp/logical/crud/SelectComponent.java | 29 +- .../db/qp/logical/crud/UDAFQueryOperator.java | 179 +++++ ...DFQueryOperator.java => UDTFQueryOperator.java} | 6 +- .../iotdb/db/qp/physical/crud/FillQueryPlan.java | 9 + .../db/qp/physical/crud/GroupByTimeFillPlan.java | 9 + .../apache/iotdb/db/qp/physical/crud/UDAFPlan.java | 68 ++ .../apache/iotdb/db/qp/physical/crud/UDTFPlan.java | 17 +- .../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java | 143 +++- .../iotdb/db/qp/utils/GroupByLevelController.java | 83 ++- ...{UDFInputDataSet.java => IUDFInputDataSet.java} | 10 +- .../dataset/RawQueryDataSetWithValueFilter.java | 2 +- .../iotdb/db/query/dataset/UDFInputDataSet.java | 42 +- .../UDFRawQueryInputDataSetWithoutValueFilter.java | 2 +- .../db/query/dataset/UDTFAlignByTimeDataSet.java | 184 +++--- .../apache/iotdb/db/query/dataset/UDTFDataSet.java | 8 + .../db/query/dataset/UDTFNonAlignDataSet.java | 2 +- .../dataset/groupby/GroupByFillEngineDataSet.java | 22 +- .../groupby/GroupByFillWithValueFilterDataSet.java | 23 +- .../GroupByFillWithoutValueFilterDataSet.java | 24 +- .../iotdb/db/query/executor/FillQueryExecutor.java | 20 +- .../iotdb/db/query/executor/IQueryRouter.java | 6 + .../iotdb/db/query/executor/QueryRouter.java | 35 +- ...DTFQueryExecutor.java => UDFQueryExecutor.java} | 16 +- .../iotdb/db/query/executor/fill/ValueFill.java | 44 +- .../iotdb/db/query/expression/Expression.java | 48 +- .../iotdb/db/query/expression/ResultColumn.java | 17 + .../query/expression/binary/BinaryExpression.java | 24 +- .../db/query/expression/unary/ConstantOperand.java | 6 + .../query/expression/unary/FunctionExpression.java | 69 +- .../query/expression/unary/NegationExpression.java | 14 +- .../query/expression/unary/TimeSeriesOperand.java | 8 +- .../db/query/udf/core/executor/UDTFExecutor.java | 13 +- .../udf/core/layer/InputRowUtils.java} | 40 +- .../db/query/udf/core/layer/LayerCacheUtils.java | 53 +- .../layer/MultiInputColumnIntermediateLayer.java | 65 +- .../query/udf/core/layer/RawQueryInputLayer.java | 25 +- ...InputColumnMultiReferenceIntermediateLayer.java | 10 + ...nputColumnSingleReferenceIntermediateLayer.java | 11 +- .../udf/core/reader/ConstantLayerPointReader.java | 5 + .../db/query/udf/core/reader/LayerPointReader.java | 2 + .../db/query/udf/core/reader/LayerRowReader.java | 3 + .../transformer/ArithmeticBinaryTransformer.java | 12 +- .../transformer/ArithmeticNegationTransformer.java | 36 +- .../db/query/udf/core/transformer/Transformer.java | 10 +- .../core/transformer/TransparentTransformer.java | 93 +++ .../core/transformer/UDFQueryRowTransformer.java | 5 +- .../udf/core/transformer/UDFQueryTransformer.java | 14 +- .../row/ElasticSerializableRowRecordList.java | 30 +- .../row/SerializableRowRecordList.java | 3 +- .../tv/ElasticSerializableBinaryTVList.java | 8 +- .../tv/ElasticSerializableTVList.java | 47 ++ .../datastructure/tv/SerializableBinaryTVList.java | 5 +- .../tv/SerializableBooleanTVList.java | 5 +- .../datastructure/tv/SerializableDoubleTVList.java | 5 +- .../datastructure/tv/SerializableFloatTVList.java | 5 +- .../datastructure/tv/SerializableIntTVList.java | 3 +- .../datastructure/tv/SerializableLongTVList.java | 5 +- .../java/org/apache/iotdb/db/service/IoTDB.java | 2 - .../statistic => service/metrics}/Operation.java | 2 +- .../db/service/thrift/impl/TSServiceImpl.java | 125 +++- .../src/main/resources/iotdb/ui/static/index.html | 79 --- .../main/resources/iotdb/ui/static/iotdb-logo.png | Bin 1187 -> 0 bytes .../src/main/resources/iotdb/ui/static/webui.css | 194 ------ .../db/cost/statistic/PerformanceStatTest.java | 105 --- .../ElasticSerializableRowRecordListTest.java | 127 +++- .../ElasticSerializableTVListTest.java | 175 +++-- .../org/apache/iotdb/db/sink/MQTTSinkTest.java | 18 +- .../iotdb/tsfile/utils/ReadWriteIOUtils.java | 3 +- 91 files changed, 4270 insertions(+), 1991 deletions(-)
