# PIPELINES

This view stores high-level information about any pipelines that have been created in the cluster. Each row represents a single pipeline.

## information\_schema.PIPELINES Schema

| Column Name                | Description                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          |
| -------------------------- | ---------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------- |
| `DATABASE_NAME`            | The name of the database associated with the pipeline.                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                               |
| `PIPELINE_NAME`            | The name of the pipeline.                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                            |
| `PIPELINE_ID`              | The unique`ID`of the pipeline.                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                       |
| `CONFIG_JSON`              | The pipeline's configuration in JSON format. This JSON is read only, and it is automatically generated when your pipeline configuration changes. The JSON schema for this column is described in[CONFIG\_JSON Schema](https://docs.singlestore.com/#UUID-8d3e8462-d70c-6a53-5a46-7d1b3834eef8.md), and is intended for use in a Web-based application (such as MemSQL Ops withSingleStoreversions earlier than 7.5).                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                 |
| `STATE`                    | The current state of the pipeline. Possible values are`Running`,`Error`, and`Stopped`.<ul> <li><code>Running</code>: The pipeline is currently running. If the <code>pipelines_stop_on_error</code> variable is set to <code>ON</code>, the pipeline has not encountered any errors during extraction, transformation, or loading.</li> <li><code>Error</code>: The pipeline encountered an error and is currently stopped. When a pipeline is in the <code>Error</code> state, it must be manually started.If the <code>pipelines_stop_on_error</code> variable is set to <code>OFF</code>, a pipeline cannot enter the <code>Error</code> state. The pipeline will remain in the <code>Running</code> state until it’s manually stopped, and any errors that occur will be written to the <code>information_schema.PIPELINES_ERRORS</code> table.</li> <li><code>Detached</code>: The pipeline has been detached with <code>DETACH PIPELINE</code>. In this state the pipeline is not running extracts, transforms, or loads against its target table. Use <code>START PIPELINE</code> to reattach and run the pipeline again.</li> <li><code>Stopped</code>: The pipeline is currently stopped. The pipeline can only enter the <code>Stopped</code> state due to manual intervention.</li> </ul> |
| `SKIPPED_BATCH_PARTITIONS` | The sum of the number of batches that have been skipped in the pipeline. Batches may be skipped if the maximum number of batch retries was reached, which is set using the`pipelines_max_retries_per_batch_partition`variable.                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                       |
| `CREATE_TIME`              | The date/time when the pipeline was created or recreated by the`CREATE PIPELINE`or`CREATE OR REPLACE PIPELINE`statements.                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                            |
| `ALTER_TIME`               | The date/time when the pipeline was altered by an`ALTER PIPELINE`statement.                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                          |
| `CREATE_USER`              | The ID of the user who created the pipeline.                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                         |
| `ALTER_USER`               | The ID of the user who last used the`ALTER PIPELINE`command to alter a pipeline.                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                     |

## CONFIG\_JSON Schema

The `CONFIG_JSON` column in the `information_schema.PIPELINES` table contains a fixed set of read-only JSON key/value pairs. Some of these JSON values can also be seen by executing the `SHOW CREATE PIPELINE <pipeline-name>` statement. Each key/value pair is described below.

## Example `CONFIG_JSON` for Kafka Pipelines

```json
{
   "name":"mypipeline",
   "source_type":"KAFKA",
   "connection_string":"172.17.0.2\/test-topic",
   "batch_interval":0,
   "transform":["http:\/\/127.0.0.1:8000\/transform.py","",""],
   "dup_key_policy":null,
   "table":"messages",
   "fields_terminated_by":"\t",
   "fields_enclosed_by":"",
   "fields_escaped_by":"\\",
   "lines_terminated_by":"\n",
   "lines_starting_by":"",
   "extended_null":false,
   "column_list":null,
   "on_duplicate_key_update":null,
   "running":false
}

```

## Example `CONFIG_JSON` for S3 Pipelines

```json
{
    "name": "my-s3-pipeline",
    "source_type": "S3",
    "connection_string": "my-s3-bucket-name",
    "config": "{\"region\": \"us-west-1\"}",
    "credentials": "{"aws_access_key_id": "your_access_key_id",
                      "aws_secret_access_key": "your_secret_access_key",
                      "aws_session_token": "your_temp_session_token",
                      "aws_web_identity_token": "your_aws_web_identiy_token",
                      "role_arn":"your_role_arn"}",
    "batch_interval": 2500,
    "max_partitions_per_batch": -1,
    "transform": null,
    "load_error_policy": null,
    "dup_key_policy": null,
    "table": "my_table_name",
    "fields_terminated_by": ",",
    "fields_enclosed_by": "",
    "fields_escaped_by": "\\",
    "lines_terminated_by": "\n",
    "lines_starting_by": "",
    "extended_null": false,
    "column_list": null,
    "on_duplicate_key_update": null
}

```

## CONFIG\_JSON Schema Definition

| Key Name                  | Value Description                                                                                                                                                                                                                                                                                                                      |
| ------------------------- | -------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------- |
| `name`                    | The name of the pipeline.                                                                                                                                                                                                                                                                                                              |
| `source_type`             | The data source type for the pipeline.                                                                                                                                                                                                                                                                                                 |
| `connection_string`       | The connection string (information varies depending on the type of[pipeline](https://docs.singlestore.com/db/v9.1/reference/sql-reference/pipelines-commands/create-pipeline.md)).                                                                                                                                                     |
| `config`                  | The configuration information provided when creating a pipeline.                                                                                                                                                                                                                                                                       |
| `credentials`             | A JSON object containing properties for the pipeline authentication/authorization. The exact information included varies depending on the type of pipeline.For users with`SUPER`permission the field shows the credentials used on pipeline creation and for users with lesser permissions the field shows "`<CREDENTIALS REDACTED>`". |
| `batch_interval`          | The time duration in milliseconds between batch extraction operations.                                                                                                                                                                                                                                                                 |
| `transform`               | The transform's URI, executable entry point, and arguments.                                                                                                                                                                                                                                                                            |
| `load_error_policy`       | The load error policy for the pipeline. For example, if`IGNORE`or`SKIP ... ERRORS`was specified during pipeline creation, they will appear as a JSON key/value pair like so:`{"load_error_policy": "skip_all_errors"}`                                                                                                                 |
| `dup_key_policy`          | The duplicate key policy that indicates how a row should be inserted if it contains a duplicate key value.                                                                                                                                                                                                                             |
| `table`                   | The name of the table in which to insert data.                                                                                                                                                                                                                                                                                         |
| `fields_terminated_by`    | The character that terminates a field.                                                                                                                                                                                                                                                                                                 |
| `fields_enclosed_by`      | The character that encloses a field.                                                                                                                                                                                                                                                                                                   |
| `fields_escaped_by`       | The character that escapes a field.                                                                                                                                                                                                                                                                                                    |
| `lines_terminated_by`     | The character that terminates a line.                                                                                                                                                                                                                                                                                                  |
| `lines_starting_by`       | The string prefix for a line.                                                                                                                                                                                                                                                                                                          |
| `extended_null`           | Specifies whether the non-quoted and case-insensitive string`null`will be loaded as a null type.                                                                                                                                                                                                                                       |
| `column_list`             | The column list to load data into.                                                                                                                                                                                                                                                                                                     |
| `on_duplicate_key_update` | Specifies whether duplicate keys will be updated or ignored.                                                                                                                                                                                                                                                                           |
| `running`                 | Specifies whether the pipeline is currently running. Current state of the pipeline is either`running`,`testing`,`profiling`,`running...foreground`,`error`, or`stopped`.                                                                                                                                                               |

***

Modified at: March 26, 2026

Source: [/db/v9.1/reference/information-schema-reference/data-ingest/pipelines/](https://docs.singlestore.com/db/v9.1/reference/information-schema-reference/data-ingest/pipelines/)

(An index of the documentation is available at /llms.txt)
