Quality pipelines detect and correct duplicates, nonstandard formats, missing values, typos, misplaced characters, and inconsistent case. Pipelines chain steps such as standardization, de-duplication, cleaning, validation, and reformatting. Each step uses output from the previous step. A pipeline transforms source data into clean, standardized data and outputs it to your source dataset, a new dataset, or a file. This helps ensure your data is accurate, consistent, unique, and valid before it reaches its destination.
Go to to view this page.
- Search: Type part of a pipeline name to filter results.
- Create Pipeline: Select to create a new pipeline.
- Refresh: Updates the pipeline list.
-
Name: Select the context menu next to a pipeline
name to Edit, Delete,
Rename, or Duplicate
it. Select Run configurations to create, edit,
or run a configuration.What's changed: In the new user experience, Edit appears as Open Pipeline. For more information on the new experience, see About the new user experience.
- Dataset: The dataset your pipeline processes. Select a dataset name to edit it.
- Status: Indicates whether the pipeline is error-free or invalid.
- Modified By: Shows who last updated the pipeline.
- Last Modified: Shows when the pipeline was last updated.
Examples:
- Address entity: Add the Verify Address and Geocoding step.
- Full Name or Company Name columns: Add the Parse Name step.
- Email or Mobile Phone columns: Add the Parse Email or Parse Phone Number step.
- Semantic First Name column: Add first name standardization in the Standardize Field step.
Pipeline editor interface: When you edit a pipeline, the pipeline editor initially displays two panels. The upper panel shows steps in the pipeline. You can add, remove, or edit steps in this panel. The lower panel displays sample data in table format. Each column represents a data field while each row represents a sample record. The top row shows name, semantic type, and field type for each data field.
When you select a step in the upper panel, it highlights columns affected by that step. Highlighted columns show data as it appears after the step is complete. While a step is selected, you can select the Transformation Preview checkbox to display sample values in the highlighted columns as they appear before and after the transformation.
Filter rows that match data in a pipeline:
- Above the sample data table, in the Column/Data box, choose Data.
- In the adjacent Search Field Name box, enter a string that matches the data that you are looking for in the table.
As you type, rows are hidden that do not contain matching data.
When you finish typing the search string, only those rows with data that matches the search string are visible in the table.
You can add a new step anywhere in a pipeline; at the beginning or end, before or after an existing step, or between steps. When you add or edit a step, the pipeline editor expands a settings panel from the right side of the window.
After you configure transformation options, use the Preview button before you save the settings to view the result of the transformation.
When you are satisfied with the results of a transformation, save and include it in the pipeline. Semantic type detection is applied to new columns as they are added by a step. The same semantic type as the original column is normally applied to a copied column. If the analysis detects the semantic type for a new column, it is displayed beneath the column name.
Create quality pipeline
You can edit the pipeline name by selecting the default name. Add and configure transformation steps as needed.
After the pipeline is created, you can add more fields by using the Add Input option.
- You can only choose the dataset that belongs to the same Agent as the primary input.
- If an incompatible input is added to the pipeline, you may not be able to configure it in the Run configuration, and an error will be thrown stating that incompatible inputs have been added to the pipeline. This will also be reflected in the data validation errors.
The Add Input interface provides dataset view and filtering options, including curated datasets from multiple sources. You can filter datasets by specific properties to quickly access datasets required for analysis and reporting. For more information, see View and filter catalog assets.
Manage pipeline operations
Quality pipeline settings
- Entity type: Shows the type of entity.
- Entity name: Specifies the name for the entity that shows above columns on the pipeline page. You can edit the name shown in this field.
- Map fields for this entity: You can change fields mapped to the entity field types.
- Name: Specifies the name for the run configuration.
- Connection: Specifies the connection to the source data.
- Source dataset: This specifies the dataset on which to run the pipeline. By default, the dataset used to build the pipeline shows here. Select the Browse button to choose a dataset in a connected database. Input fields for the pipeline must match input fields in the source dataset schema.
- Target options:
- Append to target dataset: Output is appended to columns in the target dataset. You can use this option when the schema of the pipeline output matches the target dataset schema. The pipeline engine verifies that the pipeline output schema and the target dataset schema match before it commences output to the target dataset.
- Overwrite to target dataset: Output
overwrites the target dataset. Choose one of two options from
the dropdown list.
- Truncate Dataset: Empties the dataset, then writes data to the same dataset. This choice deletes all data but preserves the dataset definition. You can use this option when the schema of the pipeline output matches the target dataset schema. The pipeline engine verifies that the pipeline output schema and the target dataset schema match before it commences output to the target dataset.
- Drop Dataset: Drop the target dataset, then create and write data to a new dataset. This choice recreates the dataset definition on the host server. The pipeline output does not have to match the target dataset schema and no verification is performed by the pipeline engine.
- Target dataset: This specifies the dataset in which to store the output results from the pipeline. Select the Browse button to choose a dataset in a connected database.
- Pipeline engine: Specifies the pipeline engine to run pipeline jobs. Select one of the pipeline engines from the list or select the Add button to create a new pipeline engine.
Profiling guidelines for pipeline performance for agent based connections
When you use an agent based connection to profile large datasets in pipelines, follow these best practices and system requirements to ensure performance and stability.
| Category | Details |
|---|---|
| Storage requirements |
|
| Database table optimization |
|
| Memory requirements |
|
| Parallel profiling jobs |
|
| Performance tuning with CPU |
|