@Override
  public String toString() {
    return toStringHelper(this)
        .add("pipeName", pipeName)
        .add("creationTime", creationTime)
        .add("dataRegionId", dataRegionId)
        .add("pipeTaskMeta", pipeTaskMeta)
        .add("shouldExtractInsertion", shouldExtractInsertion)
        .add("shouldExtractDeletion", shouldExtractDeletion)
        .add("treePattern", treePattern)
        .add("tablePattern", tablePattern)
        .add("isDbNameCoveredByPattern", isDbNameCoveredByPattern)
        .add("realtimeDataExtractionStartTime", realtimeDataExtractionStartTime)
        .add("realtimeDataExtractionEndTime", realtimeDataExtractionEndTime)
        .add(
            "disableCheckingDataRegionTimePartitionCovering",
            disableCheckingDataRegionTimePartitionCovering)
        .add("startTimePartitionIdLowerBound", startTimePartitionIdLowerBound)
        .add("endTimePartitionIdUpperBound", endTimePartitionIdUpperBound)
        .add("dataRegionTimePartitionIdBound", dataRegionTimePartitionIdBound)
        .add("isForwardingPipeRequests", isForwardingPipeRequests)
        .add("shouldTransferModFile", shouldTransferModFile)
        .add("sloppyTimeRange", sloppyTimeRange)
        .add("sloppyPattern", sloppyPattern)
        .add("pendingQueue", pendingQueue)
        .add("isClosed", isClosed)
        .add("taskID", taskID)
        .toString();
  }
@param event the {@link Event} from the {@link StorageEngine}
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/extractor/dataregion/realtime/PipeRealtimeDataRegionExtractor.java