You are viewing an older version of this section. View current production version.
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]
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
