SteveYurongSu commented on code in PR #9245:
URL: https://github.com/apache/iotdb/pull/9245#discussion_r1130330425


##########
antlr/src/main/antlr4/org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4:
##########
@@ -844,11 +844,11 @@ dropPipeSink
 
 // pipe statement
 createPipe
-    : CREATE PIPE pipeName=identifier TO pipeSinkName=identifier (FROM 
LR_BRACKET selectStatement RR_BRACKET)? (WITH syncAttributeClauses)?
+    : CREATE PIPE pipeName=identifier collectorAttributesClause? 
processorAttributesClause? connectorAttributesClause
     ;
 
 showPipe
-    : SHOW ((PIPE (pipeName=identifier)?) | PIPES)
+    : SHOW ((PIPE pipeName=identifier) | PIPES (WHERE PIPECONNECTOR USED BY 
pipeName=identifier)?)

Review Comment:
   : SHOW ((PIPE pipeName=identifier) | PIPES (WHERE CONNECTOR USED BY 
pipeName=identifier)?)
   
   PIPECONNECTOR -> CONNECTOR
   
   Then we can remove PIPECONNECTOR from 
antlr/src/main/antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4



-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]

Reply via email to