---
title: "Create Data Pipeline"
url: https://docs.catalyst.zoho.com/en/tutorials/churn-prediction/create-data-pipeline/
description: "churn prediction, Create a powerful ML pipeline that can be used to predict the churn using the Catalyst QuickML service."
last_updated: 2026-09-29T06:01:01Z
service: All Services
type: tutorial
related_links:
  - name: "Data Cleaning"
    url: /en/quickml/help/data-preprocessing/data-cleaning
  - name: "Data Transformation"
    url: /en/quickml/help/data-preprocessing/data-transformation
  - name: "Data Profiler and Viewer"
    url: /en/quickml/help/data-profiler-and-viewer/
---

# Create a data pipeline

Now that we’ve uploaded the dataset, we’ll create a **[data pipeline](https://docs.catalyst.zoho.com/en/quickml/help/pipeline-builder-interface/walkthrough/#pipeline)** with the dataset.

1. Navigate to the *Datasets component* in the left menu. There are two ways to create a data pipeline:
    - Click on the *dataset*, then click **Create Pipeline** in the top-right corner of the page.

    ![churn-13.webp](https://catalyst-docs-development.zohostratus.in/images/tutorials/churn-prediction/churn-13.webp)

    - Hover over the dataset name and click the pen icon.

    ![churn-14.webp](https://catalyst-docs-development.zohostratus.in/images/tutorials/churn-prediction/churn-14.webp)

> **Note:** In this step, we are uploading the Churn_1 dataset for preprocessing. The Churn_2 dataset will be incorporated into this during the upcoming preprocessing steps.

2. Name the pipeline "Churn Prediction Data Pipeline" and click **Create Pipeline**.

![churn-15.webp](https://catalyst-docs-development.zohostratus.in/images/tutorials/churn-prediction/churn-15.webp)

The **[pipeline builder interface](https://docs.catalyst.zoho.com/en/quickml/help/pipeline-builder-interface/walkthrough/#pipeline-builder-interface-1)** will be opened.

![churn-16.webp](https://catalyst-docs-development.zohostratus.in/images/tutorials/churn-prediction/churn-16.webp)

The following data preprocessing operations will be performed to clean, refine, and transform the datasets before executing the data pipeline. Each operation is represented by individual **[data nodes](https://docs.catalyst.zoho.com/en/quickml/help/data-preprocessing/data-cleaning/)** that will be used to build the pipeline.

# Data preprocessing with QuickML

**Stage 1: Adding datasets**

Using the *Add Dataset* node in QuickML, we can add a new dataset to the pipeline (please note that you must first upload the dataset you wish to add). Click **Data Extraction** in the left panel, and choose **Add Dataset**.  Here, we’re adding the Churn_2 dataset to merge with the existing dataset. In the node configuration, choose **Churn_dataset2** and click **save**.

![churn-17.webp](https://catalyst-docs-development.zohostratus.in/images/tutorials/churn-prediction/churn-17.webp)

**Stage 2: Combining two datasets**

Select **Data Transformation** in the left panel and choose **Union**. This will combine Churn_1 and Churn_2 into a single dataset. If any duplicate records exist in either dataset, select the *"Drop Duplicate Records"* checkbox while performing the operation. 

![churn-18.webp](https://catalyst-docs-development.zohostratus.in/images/tutorials/churn-prediction/churn-18.webp)

**Stage 3: Selecting or droping columns**

Selecting or dropping columns is a common step in data preprocessing for analysis and machine learning. The decision depends on the goals of your analysis or model.

In this case, the columns we don't need for model training are *security_no, joining_date, avg_frequency_login_days, last_visit_time, and referral_id*. With QuickML, you can easily select the relevant fields for model training using the **Select/Drop** node from the **Data Cleaning** component.

![churn-19.webp](https://catalyst-docs-development.zohostratus.in/images/tutorials/churn-prediction/churn-19.webp)

**Stage 4: Filling columns**

With the *Fill Columns* node in QuickML, we can easily fill column values based on specific conditions. You can replace null or non-null values according to your needs. 

In this case, we’re filling the *columns joined_through_referral and medium_of_operation* by replacing rows with a "?" value with the custom label *Not mentioned*. For the *points_in_wallet column*, we’re replacing empty values with a custom value of 0.

![churn-20.webp](https://catalyst-docs-development.zohostratus.in/images/tutorials/churn-prediction/churn-20.webp)

**Stage 5: Filtering data**

Filtering a dataset involves selecting a subset of rows from a DataFrame that meet certain criteria or conditions. Here, we’re using the **Filter** node from the **Data Cleaning** section to filter the *days_since_last_login, avg_time_spent, and points_in_wallet* columns whose values are greater than or equal to 0, and for columns *preferred_offer_types and region_category* that have non-empty values.

![churn-21.webp](https://catalyst-docs-development.zohostratus.in/images/tutorials/churn-prediction/churn-21.webp)

**Stage 6: Performing sentiment analysis**

Sentiment analysis is a technique used to determine the sentiment or emotional tone expressed in a piece of text, such as customer feedback or reviews. The goal is to classify the text as positive, negative, or neutral based on the emotions or opinions it conveys. 

Here, we have the column named *feedback*, which contains the feedback about the product. We can classify the values of the column as positive, negative, or neutral using the **Sentiment Analysis** node under *Zia Features*. Select the *Replace in place* checkbox if you want to replace the value of the feedback column with the result of the *Sentiment Analysis* node.

![churn-22.webp](https://catalyst-docs-development.zohostratus.in/images/tutorials/churn-prediction/churn-22.webp)

**Stage 7: Executing the pipeline**

Now, connect the **Sentiment Analysis** node to the **Destination** node. Once all of the nodes are connected, click the Save button to save the pipeline. Then click the **Execute** button to execute the pipeline.
 
![churn-23.webp](https://catalyst-docs-development.zohostratus.in/images/tutorials/churn-prediction/churn-23.webp)

You'll be redirected to a page that shows the executed pipeline with the execution status. 

![churn-24.webp](https://catalyst-docs-development.zohostratus.in/images/tutorials/churn-prediction/churn-24.webp)
 
Click on **Execution Stats** to access details regarding the compute usage.

![churn-25.webp](https://catalyst-docs-development.zohostratus.in/images/tutorials/churn-prediction/churn-25.webp)