SHOW CREATE PIPELINE

You can use the SHOW CREATE PIPELINE clause to output a CREATE PIPELINE statement that can be used to duplicate the configuration and state of an existing pipeline.

For more information about creating a pipeline, see CREATE PIPELINE.

Syntax

SHOW CREATE PIPELINE pipeline_name [EXTENDED]

Remarks

Note

The SHOW CREATE PIPELINE command hides all the sensitive data, such as credentials, URLs, etc, in the output for users without SUPER permissions. For users with SUPER permission, the sensitive information is visible in the output of the SHOW CREATE PIPELINE command. For more information about permissions, refer to Permissions Matrix.

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

Last modified: August 21, 2024

Was this article helpful?