This is an automated email from the ASF dual-hosted git repository.
justinchen pushed a change to branch clean
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 44a2350ba82 mb
add f4cd533ce8d source
No new revisions were added by this update.
Summary of changes:
.../iotdb/session/it/IoTDBSessionSimpleIT.java | 1 +
.../iotdb/rpc/subscription/config/TopicConfig.java | 2 +-
.../pipe/agent/task/PipeConfigNodeSubtask.java | 8 ++--
.../pipe/agent/task/PipeConfigNodeTaskAgent.java | 2 +-
.../PipeConfigNodeRemainingTimeMetrics.java | 8 ++--
.../PipeConfigNodeRemainingTimeOperator.java | 4 +-
.../source/PipeConfigRegionSourceMetrics.java | 44 +++++++++++-----------
.../persistence/pipe/PipePluginInfo.java | 2 +-
.../mnode/impl/ConfigBasicInternalMNode.java | 1 +
.../consensus/config/PipeConsensusConfig.java | 16 ++++----
.../consensuspipe/ConsensusPipeDispatcher.java | 2 +-
.../pipe/agent/plugin/PipeDataNodePluginAgent.java | 6 +--
.../dataregion/PipeDataRegionPluginAgent.java | 16 ++++----
.../iotdb/db/pipe/agent/task/PipeDataNodeTask.java | 14 +++----
.../agent/task/builder/PipeDataNodeBuilder.java | 8 ++--
.../pipe/agent/task/stage/PipeTaskSourceStage.java | 18 ++++-----
.../task/subtask/sink/PipeSinkSubtaskManager.java | 2 +-
.../event/common/heartbeat/PipeHeartbeatEvent.java | 20 +++++-----
.../common/tsfile/PipeTsFileInsertionEvent.java | 2 +-
.../db/pipe/event/realtime/PipeRealtimeEvent.java | 8 ++--
.../PipeDataNodeRemainingEventAndTimeOperator.java | 6 +--
.../overview/PipeDataNodeSinglePipeMetrics.java | 4 +-
.../overview/PipeTsFileToTabletsMetrics.java | 4 +-
.../schema/PipeSchemaRegionSourceMetrics.java | 14 +++----
.../metric/source/PipeDataRegionSourceMetrics.java | 12 +++---
.../PipeRealtimeDataRegionHybridSource.java | 4 +-
.../realtime/PipeRealtimeDataRegionLogSource.java | 2 +-
.../realtime/PipeRealtimeDataRegionSource.java | 2 +-
.../realtime/assigner/PipeDataRegionAssigner.java | 2 +-
.../dataregion/realtime/epoch/TsFileEpoch.java | 2 +-
.../listener/PipeTimePartitionListener.java | 2 +-
.../realtime/matcher/PipeDataRegionMatcher.java | 2 +-
.../commons/pipe/agent/plugin/PipePluginAgent.java | 18 ++++-----
.../agent/plugin/builtin/BuiltinPipePlugin.java | 2 +-
.../plugin/builtin/source/iotdb/IoTDBSource.java | 6 +--
.../plugin/constructor/PipeSourceConstructor.java | 4 +-
.../commons/pipe/agent/task/PipeTaskAgent.java | 2 +-
.../pipe/agent/task/connection/EventSupplier.java | 4 +-
.../pipe/agent/task/meta/PipeStaticMeta.java | 4 +-
39 files changed, 141 insertions(+), 139 deletions(-)
