This is an automated email from the ASF dual-hosted git repository.
justinchen pushed a change to branch compation-log
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 6e36d243003 add write logger
add 488089ca395 Partial pipe
add f9ee3ec8508 Update logback-datanode.xml
add 16428a58685 Merge branch 'compation-log' of
https://github.com/apache/iotdb into log_local
No new revisions were added by this update.
Summary of changes:
.../src/assembly/resources/conf/logback-datanode.xml | 16 +++++-----------
.../db/pipe/agent/plugin/PipeDataNodePluginAgent.java | 2 +-
.../iotdb/db/pipe/agent/runtime/PipeAgentLauncher.java | 2 +-
.../db/pipe/agent/runtime/PipeDataNodeRuntimeAgent.java | 2 +-
.../pipe/agent/runtime/SimpleProgressIndexAssigner.java | 2 +-
.../iotdb/db/pipe/agent/task/PipeDataNodeTask.java | 2 +-
.../iotdb/db/pipe/agent/task/PipeDataNodeTaskAgent.java | 2 +-
.../pipe/agent/task/builder/PipeDataNodeTaskBuilder.java | 2 +-
.../pipe/agent/task/connection/PipeEventCollector.java | 2 +-
.../db/pipe/agent/task/stage/PipeTaskExtractorStage.java | 2 +-
.../task/subtask/connector/PipeConnectorSubtask.java | 2 +-
.../subtask/connector/PipeConnectorSubtaskLifeCycle.java | 2 +-
.../subtask/connector/PipeConnectorSubtaskManager.java | 2 +-
.../task/subtask/processor/PipeProcessorSubtask.java | 2 +-
.../subtask/processor/PipeProcessorSubtaskWorker.java | 2 +-
.../client/IoTDBDataNodeAsyncClientManager.java | 3 +--
.../client/IoTDBDataNodeCacheLeaderClientManager.java | 2 +-
.../connector/client/IoTDBDataNodeSyncClientManager.java | 3 +--
.../payload/evolvable/batch/PipeTabletEventBatch.java | 2 +-
.../evolvable/batch/PipeTabletEventPlainBatch.java | 2 +-
.../evolvable/batch/PipeTabletEventTsFileBatch.java | 2 +-
.../evolvable/batch/PipeTransferBatchReqBuilder.java | 2 +-
.../evolvable/request/PipeTransferTabletRawReq.java | 2 +-
.../iotdb/db/pipe/connector/payload/legacy/PipeData.java | 2 +-
.../protocol/airgap/IoTDBDataNodeAirGapConnector.java | 2 +-
.../protocol/airgap/IoTDBDataRegionAirGapConnector.java | 3 +--
.../airgap/IoTDBSchemaRegionAirGapConnector.java | 3 +--
.../protocol/legacy/IoTDBLegacyPipeConnector.java | 2 +-
.../db/pipe/connector/protocol/opcda/OpcDaConnector.java | 2 +-
.../pipe/connector/protocol/opcda/OpcDaServerHandle.java | 2 +-
.../db/pipe/connector/protocol/opcua/OpcUaConnector.java | 2 +-
.../connector/protocol/opcua/OpcUaKeyStoreLoader.java | 2 +-
.../connector/protocol/opcua/OpcUaServerBuilder.java | 2 +-
.../pipeconsensus/PipeConsensusAsyncConnector.java | 2 +-
.../pipeconsensus/PipeConsensusSyncConnector.java | 2 +-
.../handler/PipeConsensusTabletBatchEventHandler.java | 3 +--
.../PipeConsensusTabletInsertionEventHandler.java | 3 +--
.../PipeConsensusTsFileInsertionEventHandler.java | 3 +--
.../builder/PipeConsensusTransferBatchReqBuilder.java | 3 +--
.../payload/request/PipeConsensusTabletBinaryReq.java | 2 +-
.../request/PipeConsensusTabletInsertNodeReq.java | 3 +--
.../thrift/async/IoTDBDataRegionAsyncConnector.java | 2 +-
.../handler/PipeTransferTabletBatchEventHandler.java | 3 +--
.../handler/PipeTransferTabletInsertionEventHandler.java | 3 +--
.../thrift/async/handler/PipeTransferTsFileHandler.java | 2 +-
.../protocol/thrift/sync/IoTDBDataNodeSyncConnector.java | 2 +-
.../thrift/sync/IoTDBDataRegionSyncConnector.java | 2 +-
.../protocol/thrift/sync/IoTDBSchemaRegionConnector.java | 2 +-
.../connector/protocol/websocket/WebSocketConnector.java | 2 +-
.../protocol/websocket/WebSocketConnectorServer.java | 2 +-
.../connector/protocol/writeback/WriteBackConnector.java | 2 +-
.../pipe/consensus/ConsensusPipeDataNodeDispatcher.java | 3 +--
.../ConsensusPipeDataNodeRuntimeAgentGuardian.java | 3 +--
.../pipe/event/common/heartbeat/PipeHeartbeatEvent.java | 2 +-
.../common/schema/PipeSchemaRegionSnapshotEvent.java | 2 +-
.../tablet/PipeInsertNodeTabletInsertionEvent.java | 3 +--
.../common/tablet/TabletInsertionDataContainer.java | 2 +-
.../event/common/tsfile/PipeTsFileInsertionEvent.java | 2 +-
.../event/common/tsfile/TsFileInsertionPointCounter.java | 2 +-
.../tsfile/container/TsFileInsertionDataContainer.java | 2 +-
.../query/TsFileInsertionQueryDataContainer.java | 3 +--
.../dataregion/DataRegionWatermarkInjector.java | 2 +-
.../extractor/dataregion/IoTDBDataRegionExtractor.java | 2 +-
.../PipeHistoricalDataRegionTsFileExtractor.java | 3 +--
.../realtime/PipeRealtimeDataRegionExtractor.java | 3 +--
.../realtime/PipeRealtimeDataRegionHybridExtractor.java | 3 +--
.../realtime/PipeRealtimeDataRegionLogExtractor.java | 3 +--
.../realtime/PipeRealtimeDataRegionTsFileExtractor.java | 3 +--
.../assigner/DisruptorQueueExceptionHandler.java | 3 +--
.../realtime/assigner/PipeDataRegionAssigner.java | 2 +-
.../dataregion/realtime/epoch/TsFileEpochManager.java | 2 +-
.../realtime/matcher/CachedSchemaPatternMatcher.java | 2 +-
.../schemaregion/SchemaRegionListeningQueue.java | 2 +-
.../PipeDataNodeRemainingEventAndTimeMetrics.java | 3 +--
.../pipe/metric/overview/PipeTsFileToTabletsMetrics.java | 2 +-
.../metric/overview/PipeWALInsertNodeCacheMetrics.java | 2 +-
.../db/pipe/metric/processor/PipeProcessorMetrics.java | 2 +-
.../metric/schema/PipeSchemaRegionConnectorMetrics.java | 3 +--
.../metric/schema/PipeSchemaRegionExtractorMetrics.java | 3 +--
.../metric/schema/PipeSchemaRegionListenerMetrics.java | 3 +--
.../pipe/metric/sink/PipeDataRegionConnectorMetrics.java | 3 +--
.../iotdb/db/pipe/metric/source/PipeAssignerMetrics.java | 2 +-
.../metric/source/PipeDataRegionExtractorMetrics.java | 3 +--
.../aggregate/window/datastructure/TimeSeriesWindow.java | 2 +-
.../downsampling/PartialPathLastObjectCache.java | 2 +-
.../changing/ChangingValueSamplingProcessor.java | 3 +--
.../sdt/SwingingDoorTrendingSamplingProcessor.java | 3 +--
.../tumbling/TumblingTimeSamplingProcessor.java | 2 +-
.../db/pipe/processor/twostage/combiner/Combiner.java | 2 +-
.../processor/twostage/combiner/PipeCombineHandler.java | 2 +-
.../twostage/combiner/PipeCombineHandlerManager.java | 2 +-
.../exchange/receiver/TwoStageAggregateReceiver.java | 2 +-
.../exchange/sender/TwoStageAggregateSender.java | 2 +-
.../twostage/plugin/TwoStageCountProcessor.java | 2 +-
.../receiver/protocol/airgap/IoTDBAirGapReceiver.java | 2 +-
.../protocol/airgap/IoTDBAirGapReceiverAgent.java | 2 +-
.../protocol/legacy/IoTDBLegacyPipeReceiverAgent.java | 2 +-
.../receiver/protocol/legacy/loader/DeletionLoader.java | 2 +-
.../receiver/protocol/legacy/loader/TsFileLoader.java | 2 +-
.../protocol/pipeconsensus/PipeConsensusReceiver.java | 2 +-
.../pipeconsensus/PipeConsensusReceiverAgent.java | 2 +-
.../receiver/protocol/thrift/IoTDBDataNodeReceiver.java | 2 +-
.../statement/PipeConvertedInsertRowStatement.java | 3 +--
.../statement/PipeConvertedInsertTabletStatement.java | 3 +--
.../PipeStatementDataTypeConvertExecutionVisitor.java | 3 +--
...ipeDataNodeHardlinkOrCopiedFileDirStartupCleaner.java | 3 +--
.../pipe/resource/memory/InsertNodeMemoryEstimator.java | 2 +-
.../iotdb/db/pipe/resource/memory/PipeMemoryBlock.java | 2 +-
.../iotdb/db/pipe/resource/memory/PipeMemoryManager.java | 2 +-
.../db/pipe/resource/tsfile/PipeTsFileResource.java | 2 +-
.../pipe/resource/tsfile/PipeTsFileResourceManager.java | 2 +-
.../resource/tsfile/PipeTsFileResourceSegmentLock.java | 2 +-
.../iotdb/db/pipe/resource/wal/PipeWALResource.java | 2 +-
.../db/pipe/resource/wal/PipeWALResourceManager.java | 2 +-
.../iotdb/commons/pipe/agent/plugin/PipePluginAgent.java | 2 +-
.../agent/plugin/constructor/PipePluginConstructor.java | 2 +-
.../plugin/service/PipePluginExecutableManager.java | 2 +-
.../agent/runtime/AbstractPipePeriodicalJobExecutor.java | 3 +--
.../iotdb/commons/pipe/agent/task/PipeTaskAgent.java | 2 +-
.../pipe/agent/task/connection/BlockingPendingQueue.java | 2 +-
.../pipe/agent/task/execution/PipeSubtaskExecutor.java | 2 +-
.../pipe/agent/task/progress/PipeEventCommitManager.java | 2 +-
.../pipe/agent/task/progress/PipeEventCommitter.java | 2 +-
.../agent/task/subtask/PipeAbstractConnectorSubtask.java | 2 +-
.../pipe/agent/task/subtask/PipeReportableSubtask.java | 2 +-
.../commons/pipe/agent/task/subtask/PipeSubtask.java | 2 +-
.../org/apache/iotdb/commons/pipe/config/PipeConfig.java | 2 +-
.../pipe/connector/client/IoTDBClientManager.java | 2 +-
.../commons/pipe/connector/client/IoTDBSyncClient.java | 2 +-
.../pipe/connector/client/IoTDBSyncClientManager.java | 2 +-
.../pipe/connector/compressor/PipeCompressorFactory.java | 2 +-
.../thrift/common/PipeTransferSliceReqHandler.java | 2 +-
.../pipe/connector/protocol/IoTDBAirGapConnector.java | 2 +-
.../commons/pipe/connector/protocol/IoTDBConnector.java | 2 +-
.../pipe/connector/protocol/IoTDBSslSyncConnector.java | 2 +-
.../pipe/datastructure/options/PipeInclusionOptions.java | 2 +-
.../commons/pipe/datastructure/pattern/PipePattern.java | 2 +-
.../queue/ConcurrentIterableLinkedQueue.java | 2 +-
.../queue/listening/AbstractPipeListeningQueue.java | 2 +-
.../listening/AbstractSerializableListeningQueue.java | 3 +--
.../apache/iotdb/commons/pipe/event/EnrichedEvent.java | 2 +-
.../commons/pipe/metric/PipeEventCommitMetrics.java | 2 +-
.../iotdb/commons/pipe/receiver/IoTDBFileReceiver.java | 2 +-
.../iotdb/commons/pipe/receiver/IoTDBReceiverAgent.java | 2 +-
.../commons/pipe/receiver/PipeReceiverStatusHandler.java | 2 +-
.../iotdb/commons/pipe/resource/log/PipeLogStatus.java | 2 +-
.../pipe/resource/ref/PipePhantomReferenceManager.java | 2 +-
.../resource/snapshot/PipeSnapshotResourceManager.java | 2 +-
148 files changed, 152 insertions(+), 193 deletions(-)
