This is an automated email from the ASF dual-hosted git repository.
haonan pushed a change to branch rc/1.2.0
in repository https://gitbox.apache.org/repos/asf/iotdb.git
discard a05fbfd3d7a [To rel/1.2] Support multiple creation of views & Fix
illegal view creation (#10061)
add b7df7af9a30 [IOTDB-5973] Pipe: fix ClassCastException when using
pipe.core.event.view & support collector.pattern in historical collector
(#10058) (#10063)
add 0c7ca402448 Pipe: refactor package structure (#10062) (#10065)
add 825b596e252 remove duplicate log (#10064)
add e7345fddf0f [To rel/1.2] Support multiple creation of views & Fix
illegal view creation (#10061)
add 0c35e5de5b8 Fix TsfileResource error after delete device in sequence
working memtable (#10068)
add 366efd9efde [To rel/1.2] Add into_operation_buffer_size_in_byte to
configuration file
add 2e6b083e08d [To rel/1.2] Update the iotconsensus write-blocking prompt
to make error messages more friendly (#10083)
add accd9e1430c [IOTDB-5974] Pipe: Fix Recover ProgressIndex (#10090)
add 2dd2f0f76cd [IOTDB-5976] Pipe: optimized the feedback when pipe
procedure failed to pushPipeMetas (#10084)
add 095a2194fad [IOTDB-5977][IOTDB-5979][IOTDB-5981] Pipe: serveral bug
fixes in pipe execution engine (#10087) (#10091)
add bf0860b9986 [To rel/1.2] Fix schema memory config initialization
(#10078)
add 89908d6612f Fix storage engine memory config initialization (#10077)
(#10092)
add cf957663539 [IOTDB-5982] Modify the docs of GROUP BY
add bf6f6d4a447 [To rel/1.2] [IOTDB-5975] Fix NPE in cpu metrics (#10073)
add 2005499bf60 Fix reconnect logic of python client (#10098)
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 (a05fbfd3d7a)
\
N -- N -- N refs/heads/rc/1.2.0 (2005499bf60)
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:
.../consensus/response/pipe/PipeResp.java | 48 -
.../consensus/response/pipe/PipeSinkResp.java | 48 -
.../persistence/pipe/PipePluginInfo.java | 16 +-
.../confignode/persistence/pipe/PipeTaskInfo.java | 23 +-
.../{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 | 36 +-
.../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 +++++++-------
.../org/apache/iotdb/pipe/api/event/EventType.java | 26 -
.../event/dml/insertion/TabletInsertionEvent.java | 12 +-
.../event/dml/insertion/TsFileInsertionEvent.java | 8 -
.../api/exception/PipeManagementException.java | 32 -
iotdb-client/client-py/iotdb/Session.py | 20 +-
.../client-py/iotdb/sqlalchemy/IoTDBSQLCompiler.py | 56 +-
.../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 +-
.../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 +-
.../iotdb/tsfile/fileSystem/FSFactoryProducer.java | 8 +
.../tsfile/fileSystem/fsFactory/HDFSFactory.java | 8 -
.../tsfile/fileSystem/fsFactory/OSFSFactory.java | 13 +-
.../iotdb/tsfile/read/TsFileSequenceReader.java | 18 +
122 files changed, 3052 insertions(+), 2509 deletions(-)
delete mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/pipe/PipeResp.java
delete mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/pipe/PipeSinkResp.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%)
delete mode 100644
iotdb-api/pipe-api/src/main/java/org/apache/iotdb/pipe/api/event/EventType.java
delete mode 100644
iotdb-api/pipe-api/src/main/java/org/apache/iotdb/pipe/api/exception/PipeManagementException.java
rename node-commons/src/test/java/org/apache/iotdb/commons/pipe/{task/meta =>
}/PipeMetaDeSerTest.java (91%)
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%)
