SHOW CREATE PIPELINE

Syntax

SHOW CREATE PIPELINE pipeline_name [EXTENDED]

Remarks

• See the Permission Matrix for the required permission.

Example

SHOW CREATE PIPELINE mypipeline EXTENDED;
+------------+-------------------------
| Pipeline   | Create Pipeline
+------------+-------------------------
| mypipeline | CREATE PIPELINE `mypipeline`
AS LOAD DATA KAFKA '127.0.0.1/my-topic'
BATCH_INTERVAL 0
IGNORE
INTO TABLE `t`
FIELDS TERMINATED BY ',' ENCLOSED BY '' ESCAPED BY '\\'
LINES TERMINATED BY '\n' STARTING BY ''
(`data`,`col1`,`col2`) |
| ALTER TABLE | ALTER PIPELINE `mypipeline` SET OFFSETS
'{\"8\":5}'

In the example above, the first column contains the name of the pipeline. The second column contains the CREATE PIPELINE statement used to create a new pipeline with the same configuration. The third and fourth column only appear when the EXTENDED clause is added to the statement. These columns contain the ALTER statements that can be used to set a new pipeline’s offsets to the same state as the current pipeline, namely to start reading from the most recently loaded offset.

Related Topics

• CREATE PIPELINE