This is an automated email from the ASF dual-hosted git repository.
justinchen pushed a change to branch load-may-fix
in repository https://gitbox.apache.org/repos/asf/iotdb.git
omit 498197b31e4 Add mqtt IT for json mode. (#17090)
omit 12b5bc3e9af Fix binary allocator test & querying type-altered chunks
in memory may affect the result of flush (#17105)
omit dad8ec8824e Remove text involve DataNodeId when assert two results.
(#17107)
omit d05276e2955 Decouple rest from iotdb-server using ExternalService
framework (#17099)
omit 11054f94e8c Fix allValueColDeletedMap index out of bound caused by
stale rowCount after TVList sort (#17098)
add 0aa1d9c3677 support that the user could specify the name of time
column(columnCategory is time)(#17048)
add dedf5b0945f Merge remote-tracking branch 'origin/master' into
UserDefinedTime
add 1e433efcba4 fix the optimization for LAST/FIRST/LAST_BY/FIRST_BY on
non-time columns, modify the AccumulatorFactory to explicitly verify if the
sort key in aggregations(last, first, last_by, first_by) is actually the time
column (#17074)
add 38c40b6319f Implemented load function for different time columns
(#17085)
add 6dc33198250 Merge remote-tracking branch 'origin/master' into
UserDefinedTime
add 4fe5f1a9420 add more IT (#17100)
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (498197b31e4)
\
N -- N -- N refs/heads/load-may-fix (4fe5f1a9420)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
distribution/pom.xml | 6 -
distribution/src/assembly/all.xml | 4 -
distribution/src/assembly/datanode.xml | 4 -
.../src/assembly/external-service-impl.xml | 4 -
external-service-impl/pom.xml | 2 -
external-service-impl/rest/pom.xml | 226 -----
integration-test/pom.xml | 7 -
integration-test/src/assembly/mpp-share.xml | 4 -
.../iotdb/it/utils/TsFileTableGenerator.java | 30 +-
.../iotdb/db/it/mqtt/IoTDBMQTTServiceJsonIT.java | 363 --------
.../db/it/query/IoTDBAggregationFirstByIT.java | 109 +++
.../it/query/IoTDBAggregationFirstByInGroupIT.java | 38 +
.../iotdb/db/it/query/IoTDBAggregationFirstIT.java | 164 ++++
.../it/query/IoTDBAggregationFirstInGroupIT.java | 38 +
.../db/it/query/IoTDBAggregationLastByIT.java | 108 +++
.../it/query/IoTDBAggregationLastByInGroupIT.java | 34 +
.../iotdb/db/it/query/IoTDBAggregationLastIT.java | 157 ++++
.../db/it/query/IoTDBAggregationLastInGroupIT.java | 38 +
.../db/it/schema/IoTDBAlterTimeSeriesTypeIT.java | 4 +-
.../relational/it/db/it/IoTDBLoadTsFileIT.java | 173 +++-
.../relational/it/mqtt/IoTDBMQTTServiceIT.java | 1 -
.../it/schema/IoTDBTableWithDefinedTimeIT.java | 228 +++++
.../it/schema/IoTDBUserDefinedTimeIT.java | 233 ++++++
iotdb-core/confignode/pom.xml | 6 +
.../confignode/persistence/schema/ConfigMTree.java | 12 +-
iotdb-core/datanode/pom.xml | 58 +-
.../db/protocol/rest}/filter/ApiOriginFilter.java | 2 +-
.../protocol/rest}/filter/AuthorizationFilter.java | 4 +-
.../rest}/filter/BasicSecurityContext.java | 2 +-
.../iotdb/db/protocol/rest}/filter/User.java | 2 +-
.../iotdb/db/protocol/rest}/filter/UserCache.java | 2 +-
.../rest}/handler/AuthorizationHandler.java | 4 +-
.../db/protocol/rest}/impl/PingApiServiceImpl.java | 6 +-
.../rest}/table/v1/handler/ExceptionHandler.java | 4 +-
.../table/v1/handler/ExecuteStatementHandler.java | 2 +-
.../table/v1/handler/QueryDataSetHandler.java | 6 +-
.../table/v1/handler/RequestValidationHandler.java | 6 +-
.../v1/handler/StatementConstructionHandler.java | 4 +-
.../rest}/table/v1/impl/RestApiServiceImpl.java | 26 +-
.../protocol/rest}/utils/InsertRowDataUtils.java | 2 +-
.../rest}/utils/InsertTabletSortDataUtils.java | 2 +-
.../rest/v1}/handler/ExceptionHandler.java | 4 +-
.../rest}/v1/handler/ExecuteStatementHandler.java | 2 +-
.../rest}/v1/handler/QueryDataSetHandler.java | 26 +-
.../rest}/v1/handler/RequestValidationHandler.java | 8 +-
.../v1/handler/StatementConstructionHandler.java | 4 +-
.../rest}/v1/impl/GrafanaApiServiceImpl.java | 18 +-
.../protocol/rest}/v1/impl/RestApiServiceImpl.java | 32 +-
.../rest/v2}/handler/ExceptionHandler.java | 4 +-
.../rest}/v2/handler/ExecuteStatementHandler.java | 2 +-
.../protocol/rest}/v2/handler/FastLastHandler.java | 10 +-
.../rest}/v2/handler/QueryDataSetHandler.java | 22 +-
.../rest}/v2/handler/RequestValidationHandler.java | 12 +-
.../v2/handler/StatementConstructionHandler.java | 8 +-
.../rest}/v2/impl/GrafanaApiServiceImpl.java | 18 +-
.../protocol/rest}/v2/impl/RestApiServiceImpl.java | 36 +-
.../TableInsertTabletStatementGenerator.java | 10 +-
.../operator/process/TableIntoOperator.java | 7 +-
.../relational/aggregation/AccumulatorFactory.java | 75 +-
.../plan/analyze/load/LoadTsFileAnalyzer.java | 3 +
.../analyze/load/LoadTsFileTableSchemaCache.java | 12 +-
.../execution/config/TableConfigTaskVisitor.java | 76 +-
.../plan/planner/LogicalPlanVisitor.java | 3 +-
.../plan/planner/TableOperatorGenerator.java | 79 +-
.../plan/node/load/LoadSingleTsFileNode.java | 18 +-
.../planner/plan/node/load/LoadTsFileNode.java | 14 +-
.../relational/analyzer/ExpressionAnalyzer.java | 97 +++
.../relational/analyzer/StatementAnalyzer.java | 24 +-
.../plan/relational/metadata/Metadata.java | 22 +-
.../relational/metadata/TableMetadataImpl.java | 23 +-
.../fetcher/TableHeaderSchemaValidator.java | 79 +-
.../plan/relational/planner/RelationPlanner.java | 6 +-
.../plan/relational/sql/ast/LoadTsFile.java | 11 +-
.../plan/relational/sql/parser/AstBuilder.java | 80 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 4 +
.../org/apache/iotdb/db/service}/RestService.java | 30 +-
.../externalservice/BuiltinExternalServices.java | 4 +-
.../memtable/AlignedReadOnlyMemChunk.java | 12 +-
.../dataregion/memtable/ReadOnlyMemChunk.java | 4 +-
.../org/apache/iotdb/db/utils/SchemaUtils.java | 5 +-
.../db/utils/datastructure/AlignedTVList.java | 6 +-
.../db/utils/datastructure/BackAlignedTVList.java | 3 +-
.../db/utils/datastructure/BackBinaryTVList.java | 3 +-
.../db/utils/datastructure/BackBooleanTVList.java | 3 +-
.../db/utils/datastructure/BackDoubleTVList.java | 3 +-
.../db/utils/datastructure/BackFloatTVList.java | 3 +-
.../db/utils/datastructure/BackIntTVList.java | 3 +-
.../db/utils/datastructure/BackLongTVList.java | 3 +-
.../db/utils/datastructure/QuickAlignedTVList.java | 3 +-
.../db/utils/datastructure/QuickBinaryTVList.java | 3 +-
.../db/utils/datastructure/QuickBooleanTVList.java | 3 +-
.../db/utils/datastructure/QuickDoubleTVList.java | 3 +-
.../db/utils/datastructure/QuickFloatTVList.java | 3 +-
.../db/utils/datastructure/QuickIntTVList.java | 3 +-
.../db/utils/datastructure/QuickLongTVList.java | 3 +-
.../iotdb/db/utils/datastructure/TVList.java | 2 +-
.../db/utils/datastructure/TimAlignedTVList.java | 3 +-
.../db/utils/datastructure/TimBinaryTVList.java | 3 +-
.../db/utils/datastructure/TimBooleanTVList.java | 3 +-
.../db/utils/datastructure/TimDoubleTVList.java | 3 +-
.../db/utils/datastructure/TimFloatTVList.java | 3 +-
.../iotdb/db/utils/datastructure/TimIntTVList.java | 3 +-
.../db/utils/datastructure/TimLongTVList.java | 3 +-
.../db/protocol/rest/GrafanaApiServiceTest.java | 219 +++--
.../db/protocol/rest/IoTDBRestServiceTest.java | 918 +++++++++++++++++++++
.../process/window/function/FunctionTestUtils.java | 8 +-
.../distribution/AggregationTableScanTest.java | 102 +++
.../plan/planner/node/load/LoadTsFileNodeTest.java | 2 +-
.../plan/relational/analyzer/AnalyzerTest.java | 6 +-
.../plan/relational/analyzer/TSBSMetadata.java | 6 +-
.../plan/relational/analyzer/TestMetadata.java | 6 +-
.../plan/statement/InsertStatementTest.java | 16 +-
.../dataregion/memtable/PrimitiveMemTableTest.java | 57 --
.../org/apache/iotdb/db/utils/SchemaUtilsTest.java | 18 +-
.../iotdb/commons/binaryallocator/arena/Arena.java | 7 +-
.../commons/schema/table/InformationSchema.java | 19 -
.../schema/table/TsFileTableSchemaUtil.java | 30 +-
.../apache/iotdb/commons/schema/table/TsTable.java | 79 +-
.../schema/table/column/TsTableColumnCategory.java | 4 +
.../apache/iotdb/commons/service/ServiceType.java | 1 +
.../schema/table/TsFileTableSchemaUtilTest.java | 16 +-
.../openapi}/pom.xml | 34 +-
.../src/main/openapi3/iotdb_rest_common.yaml | 0
.../src/main/openapi3/iotdb_rest_table_v1.yaml | 0
.../openapi}/src/main/openapi3/iotdb_rest_v1.yaml | 0
.../openapi}/src/main/openapi3/iotdb_rest_v2.yaml | 0
iotdb-protocol/pom.xml | 1 +
pom.xml | 2 +-
128 files changed, 3277 insertions(+), 1374 deletions(-)
delete mode 100644 external-service-impl/rest/pom.xml
delete mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/mqtt/IoTDBMQTTServiceJsonIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/schema/IoTDBTableWithDefinedTimeIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/schema/IoTDBUserDefinedTimeIT.java
rename
{external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol =>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest}/filter/ApiOriginFilter.java
(97%)
rename
{external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol =>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest}/filter/AuthorizationFilter.java
(98%)
rename
{external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol =>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest}/filter/BasicSecurityContext.java
(96%)
rename
{external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol =>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest}/filter/User.java
(96%)
rename
{external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol =>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest}/filter/UserCache.java
(97%)
rename
{external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol =>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest}/handler/AuthorizationHandler.java
(93%)
rename
{external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol =>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest}/impl/PingApiServiceImpl.java
(91%)
rename
{external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol =>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest}/table/v1/handler/ExceptionHandler.java
(97%)
rename
{external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol =>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest}/table/v1/handler/ExecuteStatementHandler.java
(99%)
rename
{external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol =>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest}/table/v1/handler/QueryDataSetHandler.java
(97%)
rename
{external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol =>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest}/table/v1/handler/RequestValidationHandler.java
(95%)
rename
{external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol =>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest}/table/v1/handler/StatementConstructionHandler.java
(98%)
rename
{external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol =>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest}/table/v1/impl/RestApiServiceImpl.java
(92%)
rename
{external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol =>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest}/utils/InsertRowDataUtils.java
(98%)
rename
{external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol =>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest}/utils/InsertTabletSortDataUtils.java
(97%)
rename
{external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol/v2 =>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest/v1}/handler/ExceptionHandler.java
(97%)
rename
{external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol =>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest}/v1/handler/ExecuteStatementHandler.java
(98%)
rename
{external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol =>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest}/v1/handler/QueryDataSetHandler.java
(93%)
rename
{external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol =>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest}/v1/handler/RequestValidationHandler.java
(90%)
rename
{external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol =>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest}/v1/handler/StatementConstructionHandler.java
(98%)
rename
{external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol =>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest}/v1/impl/GrafanaApiServiceImpl.java
(94%)
rename
{external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol =>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest}/v1/impl/RestApiServiceImpl.java
(91%)
rename
{external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol/v1 =>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest/v2}/handler/ExceptionHandler.java
(97%)
rename
{external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol =>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest}/v2/handler/ExecuteStatementHandler.java
(98%)
rename
{external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol =>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest}/v2/handler/FastLastHandler.java
(87%)
rename
{external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol =>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest}/v2/handler/QueryDataSetHandler.java
(94%)
rename
{external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol =>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest}/v2/handler/RequestValidationHandler.java
(93%)
rename
{external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol =>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest}/v2/handler/StatementConstructionHandler.java
(97%)
rename
{external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol =>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest}/v2/impl/GrafanaApiServiceImpl.java
(94%)
rename
{external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol =>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest}/v2/impl/RestApiServiceImpl.java
(94%)
rename {external-service-impl/rest/src/main/java/org/apache/iotdb/rest =>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/service}/RestService.java
(87%)
copy
integration-test/src/test/java/org/apache/iotdb/db/it/GrafanaApiServiceIT.java
=>
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/protocol/rest/GrafanaApiServiceTest.java
(73%)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/protocol/rest/IoTDBRestServiceTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/planner/distribution/AggregationTableScanTest.java
rename {external-service-impl/rest-openapi => iotdb-protocol/openapi}/pom.xml
(87%)
rename {external-service-impl/rest-openapi =>
iotdb-protocol/openapi}/src/main/openapi3/iotdb_rest_common.yaml (100%)
rename {external-service-impl/rest-openapi =>
iotdb-protocol/openapi}/src/main/openapi3/iotdb_rest_table_v1.yaml (100%)
rename {external-service-impl/rest-openapi =>
iotdb-protocol/openapi}/src/main/openapi3/iotdb_rest_v1.yaml (100%)
rename {external-service-impl/rest-openapi =>
iotdb-protocol/openapi}/src/main/openapi3/iotdb_rest_v2.yaml (100%)
