This is an automated email from the ASF dual-hosted git repository.
haonan pushed a change to branch coveralls
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 2aea8fbfc3b try update
add d170afae358 Bump vite from 4.1.4 to 4.1.5 in /site/src/main (#10054)
add 397f36edafd [IOTDB-5973] Pipe: fix ClassCastException when using
pipe.core.event.view & support collector.pattern in historical collector
(#10058)
add de700e5eaab [IOTDB-5970] Fix the info of order by when sortkey doesn't
exist
add 37a539eb089 Pipe: refactor package structure (#10062)
add bc5d8e062cd remove duplicate log (#10055)
add 2dbdbe0b39b Support multiple creation of views & Fix illegal view
creation (#10060)
add 8d7a0a880f8 [IOTDB-5974] Pipe: Fix Recover ProgressIndex (#10070)
add d871ecbff1b Fix TsfileResource error after delete device in sequence
working memtable (#10067)
add a1d2f610383 Add into_operation_buffer_size_in_byte to configuration
file
add 9cbdea36b4c [IOTDB-5976] Pipe: optimized the feedback when pipe
procedure failed to pushPipeMetas (#10076)
add 7c89c5c2296 Fix storage engine memory config initialization (#10077)
add 14ae00eca74 Update the iotconsensus write-blocking prompt to make
error messages more friendly (#10082)
add 08281208099 [IOTDB-5977][IOTDB-5979][IOTDB-5981] Pipe: serveral bug
fixes in pipe execution engine (#10087)
add 05d2aabeb88 [IOTDB-5982] Modify the docs of GROUP BY
add 6d2c4408cd7 [IOTDB-5978] Pipe: ignore data in region "root.__system"
(#10093)
add ccdd24f34a3 Fix schema memory config initialization (#10079)
add 7b9402c1b5e [IOTDB-5975] Fix NPE in cpu metrics (#10071)
add 2d4eacad59a Fix reconnect logic of python client (#10096)
add e2fb98017e2 [IOTDB-5980] Pipe: drop not existed pipe will return
successful result (#10088)
add 93db171c273 Merge branch 'master' of https://github.com/apache/iotdb
into coveralls
add 1af43dc9dd0 update
No new revisions were added by this update.
Summary of changes:
.github/workflows/sonar-coveralls.yml | 4 +-
.../consensus/response/pipe/PipeResp.java | 48 -
.../pipe/runtime/PipeRuntimeCoordinator.java | 8 +-
.../manager/pipe/task/PipeTaskCoordinator.java | 12 +-
.../persistence/pipe/PipePluginInfo.java | 16 +-
.../confignode/persistence/pipe/PipeTaskInfo.java | 25 +-
.../{task => }/AbstractOperatePipeProcedureV2.java | 15 +-
.../impl}/pipe/PipeTaskOperation.java | 2 +-
.../pipe/plugin/CreatePipePluginProcedure.java | 8 +-
.../impl/pipe/plugin/DropPipePluginProcedure.java | 6 +-
.../runtime/PipeHandleLeaderChangeProcedure.java | 10 +-
.../runtime/PipeHandleMetaChangeProcedure.java | 8 +-
.../impl/pipe/runtime/PipeMetaSyncProcedure.java | 4 +-
.../impl/pipe/task/CreatePipeProcedureV2.java | 48 +-
.../impl/pipe/task/DropPipeProcedureV2.java | 25 +-
.../impl/pipe/task/StartPipeProcedureV2.java | 38 +-
.../impl/pipe/task/StopPipeProcedureV2.java | 37 +-
.../consensus/iot/IoTConsensusServerImpl.java | 7 +-
docs/UserGuide/Query-Data/Group-By.md | 1204 ++++++++++----------
docs/UserGuide/Query-Data/Overview.md | 2 +-
docs/zh/UserGuide/Query-Data/Group-By.md | 880 +++++++-------
.../iotdb/it/env/cluster/MppCommonConfig.java | 2 +-
.../view/IoTDBCreateAndShowViewIT.java | 162 ++-
.../org/apache/iotdb/util/AbstractSchemaIT.java | 3 +-
.../org/apache/iotdb/pipe/api/event/EventType.java | 26 -
.../event/dml/insertion/TabletInsertionEvent.java | 12 +-
.../event/dml/insertion/TsFileInsertionEvent.java | 8 -
iotdb-client/client-py/iotdb/Session.py | 20 +-
.../client-py/iotdb/sqlalchemy/IoTDBSQLCompiler.py | 56 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 1 +
.../metrics/metricsets/cpu/CpuUsageMetrics.java | 37 +-
.../resources/conf/iotdb-common.properties | 4 +
.../apache/iotdb/commons/conf/CommonConfig.java | 9 -
.../iotdb/commons/conf/CommonDescriptor.java | 4 -
.../consensus/index/impl/RecoverProgressIndex.java | 6 +
.../iotdb/commons/pipe/config/PipeConfig.java | 4 -
.../service/PipePluginExecutableManager.java | 6 +-
.../pipe/{task/meta => }/PipeMetaDeSerTest.java | 6 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 37 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 137 ++-
.../db/engine/storagegroup/TsFileProcessor.java | 17 +-
.../db/engine/storagegroup/TsFileResource.java | 13 +-
.../metadata/view/UnsupportedViewException.java | 36 +-
.../view/ViewContainsAggregationException.java | 15 +-
.../iotdb/db/metadata/view/ViewPathType.java | 8 +-
.../apache/iotdb/db/metadata/view/ViewPaths.java | 26 +
.../iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java | 99 +-
.../iotdb/db/mpp/plan/analyze/SelectIntoUtils.java | 7 +
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 63 +-
.../metadata/view/AlterLogicalViewStatement.java | 11 +
.../metadata/view/CreateLogicalViewStatement.java | 51 +-
.../db/pipe/agent/plugin/PipePluginAgent.java | 19 +-
.../pipe/agent/receiver/IoTDBThriftReceiver.java | 2 +-
.../db/pipe/agent/receiver/PipeReceiverAgent.java | 4 +-
.../db/pipe/agent/runtime/PipeAgentLauncher.java | 4 +-
.../db/pipe/agent/runtime/PipeRuntimeAgent.java | 12 +-
.../SimpleConsensusProgressIndexAssigner.java | 5 +-
.../iotdb/db/pipe/agent/task/PipeTaskAgent.java | 96 +-
.../collector/IoTDBDataRegionCollector.java | 22 +-
.../PipeHistoricalDataRegionCollector.java | 2 +-
.../PipeHistoricalDataRegionTsFileCollector.java | 43 +-
.../realtime/PipeRealtimeDataRegionCollector.java | 6 +-
.../PipeRealtimeDataRegionFakeCollector.java | 4 +-
.../PipeRealtimeDataRegionHybridCollector.java | 8 +-
.../PipeRealtimeDataRegionLogCollector.java | 8 +-
.../PipeRealtimeDataRegionTsFileCollector.java | 8 +-
.../realtime/assigner/DisruptorQueue.java | 2 +-
.../realtime/assigner/PipeDataRegionAssigner.java | 10 +-
.../realtime/epoch}/TsFileEpoch.java | 4 +-
.../realtime/epoch}/TsFileEpochManager.java | 7 +-
.../realtime/epoch}/TsFileEpochStateMigrator.java | 2 +-
.../listener/PipeInsertionDataNodeListener.java | 8 +-
.../matcher/CachedSchemaPatternMatcher.java | 6 +-
.../realtime/matcher/PipeDataRegionMatcher.java | 6 +-
.../IoTDBThriftConnectorClient.java | 2 +-
.../IoTDBThriftConnectorVersion.java | 2 +-
.../v1/IoTDBThriftConnectorV1.java | 43 +-
.../v1/IoTDBThriftReceiverV1.java | 16 +-
.../iotdb => connector}/v1/PipeRequestType.java | 2 +-
.../v1/reponse/PipeTransferFilePieceResp.java | 2 +-
.../v1/request/PipeTransferFilePieceReq.java | 6 +-
.../v1/request/PipeTransferFileSealReq.java | 6 +-
.../v1/request/PipeTransferHandshakeReq.java | 6 +-
.../v1/request/PipeTransferInsertNodeReq.java | 6 +-
.../v1/request/PipeTransferTabletReq.java | 6 +-
.../PipeHistoricalDataRegionFakeCollector.java | 56 -
.../event/impl/PipeEmptyTabletInsertionEvent.java | 39 -
.../TsFileInsertionDataContainer.java | 136 ---
.../TsFileInsertionDataTabletIterator.java | 287 -----
.../db/pipe/{core => }/event/EnrichedEvent.java | 2 +-
.../event/common/row}/PipeBinaryTransformer.java | 7 +-
.../event/common/row}/PipeDataTypeTransformer.java | 40 +-
.../view/access => event/common/row}/PipeRow.java | 45 +-
.../common/row}/PipeRowCollector.java | 36 +-
.../PipeInsertNodeTabletInsertionEvent.java | 37 +-
.../tablet/PipeRawTabletInsertionEvent.java} | 23 +-
.../tablet}/TabletInsertionDataContainer.java | 185 ++-
.../common/tsfile}/PipeTsFileInsertionEvent.java | 40 +-
.../tsfile/TsFileInsertionDataContainer.java | 192 ++++
.../tsfile/TsFileInsertionDataTabletIterator.java | 147 +++
.../event/realtime/PipeRealtimeCollectEvent.java | 5 +-
.../realtime/PipeRealtimeCollectEventFactory.java | 7 +-
.../executor/PipeConnectorSubtaskExecutor.java | 2 +-
.../executor/PipeProcessorSubtaskExecutor.java | 2 +-
.../processor/PipeDoNothingProcessor.java | 29 +-
.../apache/iotdb/db/pipe/task/PipeTaskBuilder.java | 1 -
.../BlockingPendingQueue.java | 2 +-
.../BoundedBlockingPendingQueue.java | 2 +-
.../task/{queue => connection}/EventSupplier.java | 2 +-
.../connection}/PipeEventCollector.java | 5 +-
.../UnboundedBlockingPendingQueue.java | 2 +-
.../db/pipe/task/stage/PipeTaskCollectorStage.java | 55 +-
.../db/pipe/task/stage/PipeTaskConnectorStage.java | 4 +-
.../db/pipe/task/stage/PipeTaskProcessorStage.java | 50 +-
.../db/pipe/task/subtask/PipeConnectorSubtask.java | 4 +-
.../subtask}/PipeConnectorSubtaskLifeCycle.java | 5 +-
.../subtask}/PipeConnectorSubtaskManager.java | 10 +-
.../db/pipe/task/subtask/PipeProcessorSubtask.java | 2 +-
.../iotdb/db/pipe/task/subtask/PipeSubtask.java | 2 +-
.../db/service/metrics/DataNodeMetricsHelper.java | 1 +
.../impl/DataNodeInternalRPCServiceImpl.java | 9 +-
.../file/UnsealedTsFileRecoverPerformer.java | 2 +-
.../db/engine/settle/SettleRequestHandlerTest.java | 1 -
.../db/engine/storagegroup/DataRegionTest.java | 27 +
.../collector/CachedSchemaPatternMatcherTest.java | 8 +-
.../collector/PipeRealtimeCollectTest.java | 10 +-
.../connector/PipeThriftRequestTest.java | 12 +-
.../PipeTabletInsertionEventTest.java} | 53 +-
.../event/TsFileInsertionDataContainerTest.java | 679 +++++++++++
.../PipeConnectorSubtaskExecutorTest.java | 5 +-
.../PipeProcessorSubtaskExecutorTest.java | 5 +-
.../{executor => }/PipeSubtaskExecutorTest.java | 3 +-
site/src/main/.vuepress/sidebar/V1.0.x/en.ts | 1 -
site/src/main/.vuepress/sidebar/V1.0.x/zh.ts | 1 -
site/src/main/.vuepress/sidebar/V1.1.x/en.ts | 2 +-
site/src/main/.vuepress/sidebar/V1.1.x/zh.ts | 2 +-
site/src/main/.vuepress/sidebar/V1.2.x/en.ts | 2 +-
site/src/main/.vuepress/sidebar/V1.2.x/zh.ts | 2 +-
site/src/main/.vuepress/sidebar/en.ts | 2 +-
site/src/main/.vuepress/sidebar/zh.ts | 2 +-
site/src/main/package-lock.json | 6 +-
.../iotdb/tsfile/fileSystem/FSFactoryProducer.java | 8 +
.../tsfile/fileSystem/fsFactory/HDFSFactory.java | 8 -
.../tsfile/fileSystem/fsFactory/OSFSFactory.java | 13 +-
.../iotdb/tsfile/read/TsFileSequenceReader.java | 18 +
145 files changed, 3495 insertions(+), 2528 deletions(-)
delete mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/pipe/PipeResp.java
rename
confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/{task
=> }/AbstractOperatePipeProcedureV2.java (92%)
rename confignode/src/main/java/org/apache/iotdb/confignode/{persistence =>
procedure/impl}/pipe/PipeTaskOperation.java (94%)
rename integration-test/src/test/java/org/apache/iotdb/db/it/{ =>
schema}/view/IoTDBCreateAndShowViewIT.java (61%)
delete mode 100644
iotdb-api/pipe-api/src/main/java/org/apache/iotdb/pipe/api/event/EventType.java
rename node-commons/src/test/java/org/apache/iotdb/commons/pipe/{task/meta =>
}/PipeMetaDeSerTest.java (91%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/pipe/PipeSinkResp.java
=>
server/src/main/java/org/apache/iotdb/db/exception/metadata/view/UnsupportedViewException.java
(53%)
rename
iotdb-api/pipe-api/src/main/java/org/apache/iotdb/pipe/api/exception/PipeManagementException.java
=>
server/src/main/java/org/apache/iotdb/db/exception/metadata/view/ViewContainsAggregationException.java
(65%)
rename server/src/main/java/org/apache/iotdb/db/pipe/{core =>
}/collector/IoTDBDataRegionCollector.java (91%)
rename server/src/main/java/org/apache/iotdb/db/pipe/{core =>
}/collector/historical/PipeHistoricalDataRegionCollector.java (94%)
rename server/src/main/java/org/apache/iotdb/db/pipe/{core =>
}/collector/historical/PipeHistoricalDataRegionTsFileCollector.java (82%)
rename server/src/main/java/org/apache/iotdb/db/pipe/{core =>
}/collector/realtime/PipeRealtimeDataRegionCollector.java (92%)
rename server/src/main/java/org/apache/iotdb/db/pipe/{core =>
}/collector/realtime/PipeRealtimeDataRegionFakeCollector.java (93%)
rename server/src/main/java/org/apache/iotdb/db/pipe/{core =>
}/collector/realtime/PipeRealtimeDataRegionHybridCollector.java (96%)
rename server/src/main/java/org/apache/iotdb/db/pipe/{core =>
}/collector/realtime/PipeRealtimeDataRegionLogCollector.java (93%)
rename server/src/main/java/org/apache/iotdb/db/pipe/{core =>
}/collector/realtime/PipeRealtimeDataRegionTsFileCollector.java (93%)
rename server/src/main/java/org/apache/iotdb/db/pipe/{core =>
}/collector/realtime/assigner/DisruptorQueue.java (98%)
rename server/src/main/java/org/apache/iotdb/db/pipe/{core =>
}/collector/realtime/assigner/PipeDataRegionAssigner.java (87%)
rename server/src/main/java/org/apache/iotdb/db/pipe/{core/event/realtime =>
collector/realtime/epoch}/TsFileEpoch.java (93%)
rename server/src/main/java/org/apache/iotdb/db/pipe/{core/event/realtime =>
collector/realtime/epoch}/TsFileEpochManager.java (89%)
rename server/src/main/java/org/apache/iotdb/db/pipe/{core/event/realtime =>
collector/realtime/epoch}/TsFileEpochStateMigrator.java (94%)
rename server/src/main/java/org/apache/iotdb/db/pipe/{core =>
}/collector/realtime/listener/PipeInsertionDataNodeListener.java (94%)
rename server/src/main/java/org/apache/iotdb/db/pipe/{core =>
}/collector/realtime/matcher/CachedSchemaPatternMatcher.java (97%)
rename server/src/main/java/org/apache/iotdb/db/pipe/{core =>
}/collector/realtime/matcher/PipeDataRegionMatcher.java (88%)
rename
server/src/main/java/org/apache/iotdb/db/pipe/{core/connector/impl/iotdb =>
connector}/IoTDBThriftConnectorClient.java (97%)
rename
server/src/main/java/org/apache/iotdb/db/pipe/{core/connector/impl/iotdb =>
connector}/IoTDBThriftConnectorVersion.java (94%)
rename
server/src/main/java/org/apache/iotdb/db/pipe/{core/connector/impl/iotdb =>
connector}/v1/IoTDBThriftConnectorV1.java (84%)
rename
server/src/main/java/org/apache/iotdb/db/pipe/{core/connector/impl/iotdb =>
connector}/v1/IoTDBThriftReceiverV1.java (94%)
rename
server/src/main/java/org/apache/iotdb/db/pipe/{core/connector/impl/iotdb =>
connector}/v1/PipeRequestType.java (96%)
rename
server/src/main/java/org/apache/iotdb/db/pipe/{core/connector/impl/iotdb =>
connector}/v1/reponse/PipeTransferFilePieceResp.java (97%)
rename
server/src/main/java/org/apache/iotdb/db/pipe/{core/connector/impl/iotdb =>
connector}/v1/request/PipeTransferFilePieceReq.java (92%)
rename
server/src/main/java/org/apache/iotdb/db/pipe/{core/connector/impl/iotdb =>
connector}/v1/request/PipeTransferFileSealReq.java (91%)
rename
server/src/main/java/org/apache/iotdb/db/pipe/{core/connector/impl/iotdb =>
connector}/v1/request/PipeTransferHandshakeReq.java (91%)
rename
server/src/main/java/org/apache/iotdb/db/pipe/{core/connector/impl/iotdb =>
connector}/v1/request/PipeTransferInsertNodeReq.java (94%)
rename
server/src/main/java/org/apache/iotdb/db/pipe/{core/connector/impl/iotdb =>
connector}/v1/request/PipeTransferTabletReq.java (97%)
delete mode 100644
server/src/main/java/org/apache/iotdb/db/pipe/core/collector/historical/PipeHistoricalDataRegionFakeCollector.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/pipe/core/event/impl/PipeEmptyTabletInsertionEvent.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/pipe/core/event/view/datastructure/TsFileInsertionDataContainer.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/pipe/core/event/view/datastructure/TsFileInsertionDataTabletIterator.java
rename server/src/main/java/org/apache/iotdb/db/pipe/{core =>
}/event/EnrichedEvent.java (99%)
rename {node-commons/src/main/java/org/apache/iotdb/commons/pipe/utils =>
server/src/main/java/org/apache/iotdb/db/pipe/event/common/row}/PipeBinaryTransformer.java
(92%)
rename {node-commons/src/main/java/org/apache/iotdb/commons/pipe/utils =>
server/src/main/java/org/apache/iotdb/db/pipe/event/common/row}/PipeDataTypeTransformer.java
(69%)
rename server/src/main/java/org/apache/iotdb/db/pipe/{core/event/view/access
=> event/common/row}/PipeRow.java (75%)
rename
server/src/main/java/org/apache/iotdb/db/pipe/{core/event/view/collector =>
event/common/row}/PipeRowCollector.java (67%)
rename server/src/main/java/org/apache/iotdb/db/pipe/{core/event/impl =>
event/common/tablet}/PipeInsertNodeTabletInsertionEvent.java (79%)
rename
server/src/main/java/org/apache/iotdb/db/pipe/{core/event/impl/PipeTabletTabletInsertionEvent.java
=> event/common/tablet/PipeRawTabletInsertionEvent.java} (72%)
rename
server/src/main/java/org/apache/iotdb/db/pipe/{core/event/view/datastructure =>
event/common/tablet}/TabletInsertionDataContainer.java (74%)
rename server/src/main/java/org/apache/iotdb/db/pipe/{core/event/impl =>
event/common/tsfile}/PipeTsFileInsertionEvent.java (85%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/pipe/event/common/tsfile/TsFileInsertionDataContainer.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/pipe/event/common/tsfile/TsFileInsertionDataTabletIterator.java
rename server/src/main/java/org/apache/iotdb/db/pipe/{core =>
}/event/realtime/PipeRealtimeCollectEvent.java (96%)
rename server/src/main/java/org/apache/iotdb/db/pipe/{core =>
}/event/realtime/PipeRealtimeCollectEventFactory.java (86%)
rename server/src/main/java/org/apache/iotdb/db/pipe/{core =>
}/processor/PipeDoNothingProcessor.java (79%)
rename server/src/main/java/org/apache/iotdb/db/pipe/task/{queue =>
connection}/BlockingPendingQueue.java (97%)
rename server/src/main/java/org/apache/iotdb/db/pipe/task/{queue =>
connection}/BoundedBlockingPendingQueue.java (95%)
rename server/src/main/java/org/apache/iotdb/db/pipe/task/{queue =>
connection}/EventSupplier.java (96%)
rename
server/src/main/java/org/apache/iotdb/db/pipe/{core/event/view/collector =>
task/connection}/PipeEventCollector.java (92%)
rename server/src/main/java/org/apache/iotdb/db/pipe/task/{queue =>
connection}/UnboundedBlockingPendingQueue.java (95%)
rename server/src/main/java/org/apache/iotdb/db/pipe/{core/connector/manager
=> task/subtask}/PipeConnectorSubtaskLifeCycle.java (93%)
rename server/src/main/java/org/apache/iotdb/db/pipe/{core/connector/manager
=> task/subtask}/PipeConnectorSubtaskManager.java (94%)
rename server/src/test/java/org/apache/iotdb/db/pipe/{core =>
}/collector/CachedSchemaPatternMatcherTest.java (95%)
rename server/src/test/java/org/apache/iotdb/db/pipe/{core =>
}/collector/PipeRealtimeCollectTest.java (96%)
rename server/src/test/java/org/apache/iotdb/db/pipe/{core =>
}/connector/PipeThriftRequestTest.java (89%)
rename
server/src/test/java/org/apache/iotdb/db/pipe/{core/event/PipeInsertNodeTabletInsertionEventTest.java
=> event/PipeTabletInsertionEventTest.java} (76%)
create mode 100644
server/src/test/java/org/apache/iotdb/db/pipe/event/TsFileInsertionDataContainerTest.java
rename server/src/test/java/org/apache/iotdb/db/pipe/execution/{executor =>
}/PipeConnectorSubtaskExecutorTest.java (87%)
rename server/src/test/java/org/apache/iotdb/db/pipe/execution/{executor =>
}/PipeProcessorSubtaskExecutorTest.java (89%)
rename server/src/test/java/org/apache/iotdb/db/pipe/execution/{executor =>
}/PipeSubtaskExecutorTest.java (97%)
