public static WatermarkGRPCInterceptor create() {
        INSTANCE = new WatermarkGRPCInterceptor();
        return INSTANCE;
    }
gRPCWatermarkInterceptor is a gRPC interceptor that checks if the watermark is exceeded before processing the request.
oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/watermark/WatermarkGRPCInterceptor.java