public IoTDBDataNodeReceiverAgent thrift() {
    return thriftAgent;
  }
{@link PipeDataNodeReceiverAgent} is the entry point of all pipe receivers' logic.
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/receiver/PipeDataNodeReceiverAgent.java