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 7aea87b164d hb
add 76b2e2138c4 by
No new revisions were added by this update.
Summary of changes:
.../pipe/consensuspipe/ConsensusPipeManager.java | 2 +-
.../pipe/metric/PipeConsensusSyncLagManager.java | 24 +++++++-------
.../agent/task/connection/PipeEventCollector.java | 2 +-
.../event/common/heartbeat/PipeHeartbeatEvent.java | 38 +++++++++++-----------
.../client/IoTDBDataNodeAsyncClientManager.java | 4 +--
.../protocol/airgap/IoTDBDataRegionAirGapSink.java | 7 ++--
.../airgap/IoTDBSchemaRegionAirGapSink.java | 7 ++--
.../sink/protocol/legacy/IoTDBLegacyPipeSink.java | 23 +++++++------
.../db/pipe/sink/protocol/opcua/OpcUaSink.java | 2 +-
.../pipeconsensus/PipeConsensusAsyncSink.java | 1 -
.../pipeconsensus/PipeConsensusSyncSink.java | 1 -
.../thrift/async/IoTDBDataRegionAsyncSink.java | 8 ++---
.../async/handler/PipeTransferTsFileHandler.java | 4 +--
.../thrift/sync/IoTDBDataRegionSyncSink.java | 7 ++--
.../thrift/sync/IoTDBSchemaRegionSink.java | 7 ++--
.../sink/protocol/websocket/WebSocketSink.java | 16 ++++-----
...nnectorServer.java => WebSocketSinkServer.java} | 27 ++++++++-------
.../sink/protocol/writeback/WriteBackSink.java | 2 --
.../realtime/PipeRealtimeDataRegionSource.java | 2 +-
.../apache/iotdb/db/pipe/sink/PipeSinkTest.java | 6 ++--
.../sink/iotdb/thrift/IoTDBLegacyPipeSink.java | 6 ++--
.../builtin/sink/iotdb/thrift/IoTDBThriftSink.java | 8 ++---
.../sink/iotdb/thrift/IoTDBThriftSyncSink.java | 6 ++--
23 files changed, 100 insertions(+), 110 deletions(-)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/websocket/{WebSocketConnectorServer.java
=> WebSocketSinkServer.java} (94%)
