This is an automated email from the ASF dual-hosted git repository.
rong pushed a change to branch global-counter
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 06b19488dfd Merge branch 'master' of https://github.com/apache/iotdb
into global-counter
add dfcf4732f36 bugfix
No new revisions were added by this update.
Summary of changes:
.../dataregion/DataRegionWatermarkInjector.java | 14 +-
.../dataregion/IoTDBDataRegionExtractor.java | 2 +-
.../pipe/processor/twostage/combiner/Combiner.java | 2 +-
.../twostage/combiner/PipeCombineHandler.java | 55 ++++++-
.../combiner/PipeCombineHandlerManager.java | 2 +-
.../twostage/exchange/payload/CombineRequest.java | 19 +++
.../payload/FetchCombineResultRequest.java | 20 ++-
.../payload/FetchCombineResultResponse.java | 9 ++
.../receiver/TwoStageAggregateReceiver.java | 2 +
.../exchange/sender/TwoStageAggregateSender.java | 160 ++++++++++++---------
.../twostage/plugin/TwoStageCountProcessor.java | 134 +++++++++++------
.../pipe/processor/twostage/state/CountState.java | 4 +
.../consensus/index/impl/StateProgressIndex.java | 43 ++++--
13 files changed, 332 insertions(+), 134 deletions(-)
