diff --git a/iotdb-api/pipe-api/src/main/java/org/apache/iotdb/pipe/api/PipeProcessor.java b/iotdb-api/pipe-api/src/main/java/org/apache/iotdb/pipe/api/PipeProcessor.java index 0e849ffd59679..7f7810993afb2 100644 --- a/iotdb-api/pipe-api/src/main/java/org/apache/iotdb/pipe/api/PipeProcessor.java +++ b/iotdb-api/pipe-api/src/main/java/org/apache/iotdb/pipe/api/PipeProcessor.java @@ -30,8 +30,8 @@ /** * {@link PipeProcessor} * - *

{@link PipeProcessor} is used to filter and transform the {@link Event} formed by the {@link - * PipeExtractor}. + *

{@link PipeProcessor} is used to filter and transform the {@link Event} supplied by the {@link + * PipeSource}. * *

The lifecycle of a {@link PipeProcessor} is as follows: * @@ -44,15 +44,14 @@ * to config the runtime behavior of the {@link PipeProcessor}. *

  • While the collaboration task is in progress: * *
  • When the collaboration task is cancelled (the `DROP PIPE` command is executed), the {@link * PipeProcessor#close() } method will be called. diff --git a/iotdb-api/pipe-api/src/main/java/org/apache/iotdb/pipe/api/PipeSource.java b/iotdb-api/pipe-api/src/main/java/org/apache/iotdb/pipe/api/PipeSource.java index def0e6e42ff4e..edcd2aa65562e 100644 --- a/iotdb-api/pipe-api/src/main/java/org/apache/iotdb/pipe/api/PipeSource.java +++ b/iotdb-api/pipe-api/src/main/java/org/apache/iotdb/pipe/api/PipeSource.java @@ -34,9 +34,10 @@ *

    The lifecycle of a {@link PipeSource} is as follows: * *