diff --git a/e2e-test/features/DesignTimeSLT.feature b/e2e-test/features/DesignTimeSLT.feature
new file mode 100644
index 0000000000..560e6f5f0c
--- /dev/null
+++ b/e2e-test/features/DesignTimeSLT.feature
@@ -0,0 +1,65 @@
+# Copyright © 2022 Cask Data, Inc.
+#
+# Licensed under the Apache License, Version 2.0 (the "License"); you may not
+# use this file except in compliance with the License. You may obtain a copy of
+# the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
+# WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
+# License for the specific language governing permissions and limitations under
+# the License.
+Feature: Design Time SLT Scenario
+
+  @SLT @Design-Time @Sanity
+  Scenario Outline: Validate mandatory SLT parameters is present and editable
+    Given Open CDF replication and initiate pipeline creation
+    When Select SAP SLT as source
+    Then Validate SLT parameter "<option>" can be set as "<input>"
+    Examples:
+      | option            | input         |
+      | gcsDataPath       | invalid       |
+      | guid              | invalidguid   |
+      | massTransferId    | ZZZ66         |
+      | sapJcoLibGcsPath  |gs://ga_slt_cdf|
+      | jco.client.ashost | invalid       |
+      | jco.client.sysnr  | abc           |
+      | jco.client.client | abc           |
+      | jco.client.lang   | invalid       |
+      | jco.client.user   | invalid       |
+      | jco.client.passwd | invalid       |
+
+  @SLT @Design-Time @Sanity
+  Scenario: Validate Replicate Existing Data can be set as false
+    Given Open CDF replication and initiate pipeline creation
+    When Select SAP SLT as source
+    Then Validate Replicate Existing Data can be set to false
+
+  @SLT @Design-Time @Sanity
+  Scenario: Validate suspend Slt Job can be set as true
+    Given Open CDF replication and initiate pipeline creation
+    When Select SAP SLT as source
+    Then Validate Suspend Slt Job can be set to true
+
+  @SLT @Design-Time @Sanity
+  Scenario Outline: Validate CDF replication job can be configured job for "<table>"
+    Given Create new MTID on "Automation" SAP
+    When Validate that MTID can be Updated using CDF_R_SLT_SETTINGS program
+    Then Verify that user is able to update table "<table>" to "replication" on LTRC
+    Given Open CDF replication and initiate pipeline creation
+    When Select SAP SLT as source and fill connection parameters
+    Then Click on next
+    Then Validate Table is available and  can be selected "<table>"
+    Then Click on next
+    Then Enter the BigQuery Properties for slt datasource
+    Then Click on next
+    Then Click on next
+    Then Click on next
+    Then Validate Replication Pipeline can be deployed
+    Then Verify that user is able to update table "<table>" to "stop_load" on LTRC
+    Examples:
+      | table |
+      | vbap |
+      | ekko  |
diff --git a/e2e-test/features/DesignTimeSLTError.feature b/e2e-test/features/DesignTimeSLTError.feature
new file mode 100644
index 0000000000..63503e26fa
--- /dev/null
+++ b/e2e-test/features/DesignTimeSLTError.feature
@@ -0,0 +1,34 @@
+# Copyright © 2022 Cask Data, Inc.
+#
+# Licensed under the Apache License, Version 2.0 (the "License"); you may not
+# use this file except in compliance with the License. You may obtain a copy of
+# the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
+# WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
+# License for the specific language governing permissions and limitations under
+# the License.
+Feature: Design Time SLT Negative Scenario
+
+  @SLT @Design-Time @Sanity @Negative
+  Scenario Outline: Validate for wrong parameters plugin throws proper error messages
+    Given Open CDF replication and initiate pipeline creation
+    When Create new MTID on "Automation" SAP
+    When Validate that MTID can be Updated using CDF_R_SLT_SETTINGS program
+    When Select SAP SLT as source and fill connection parameters
+    Then Verify that after setting SLT parameter <option> as <input> plugin is throws error <errorMessage>
+    Examples:
+      | option            | input           | errorMessage            |
+      | gcsDataPath       | invalid         | invalidgcsDataPath      |
+      | guid              | invalidguid     | invalidMTorGUID         |
+      | massTransferId    | ZZZ66           | invalidMTorGUID         |
+      | sapJcoLibGcsPath  | gs://ga_slt_cdf | invalidsapJcoLibGcsPath |
+      | jco.client.ashost | invalid         | invalidIP               |
+      | jco.client.sysnr  | abc             | invalidSysNr            |
+      | jco.client.client | abc             | invalidClient           |
+      | jco.client.lang   | invalid         | invalidLang             |
+      | jco.client.user   | invalid         | invalidCred             |
+      | jco.client.passwd | invalid         | invalidCred             |
diff --git a/e2e-test/features/RunTimeSLT.feature b/e2e-test/features/RunTimeSLT.feature
new file mode 100644
index 0000000000..a0f25ecc70
--- /dev/null
+++ b/e2e-test/features/RunTimeSLT.feature
@@ -0,0 +1,158 @@
+# Copyright © 2022 Cask Data, Inc.
+#
+# Licensed under the Apache License, Version 2.0 (the "License"); you may not
+# use this file except in compliance with the License. You may obtain a copy of
+# the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
+# WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
+# License for the specific language governing permissions and limitations under
+# the License.
+Feature:Run-Time SLT Scenario
+
+  @SLT @Run-Time @Sanity
+  Scenario: Validate that MTID can be created and updated using CDF_R_SLT_SETTINGS program
+    Given Create new MTID on "Automation" SAP
+    When Validate that MTID can be Updated using CDF_R_SLT_SETTINGS program
+
+  @SLT @Run-Time @Sanity
+  Scenario Outline: Validate that SLT job can be configured for table containing all data types
+    Given Create new MTID on "Automation" SAP
+    When Validate that MTID can be Updated using CDF_R_SLT_SETTINGS program
+    Then Verify that user is able to update table "<table>" to "stop_load" on LTRC
+    Given Open CDF replication and initiate pipeline creation
+    When Fetche the record count of table : "<table>" from SAP
+    Then Delete GCS folder for mass transfer id table "<table>"
+    Then Drop target BigQuery table "<table>"
+    Then Verify that user is able to update table "<table>" to "<mode>" on LTRC
+    When Select SAP SLT as source and fill connection parameters
+    Then Click on next
+    Then Validate Table is available and  can be selected "<table>"
+    Then Click on next
+    Then Enter the BigQuery Properties for slt datasource
+    Then Click on next
+    Then Click on next
+    Then Click on next
+    Then Validate Replication Pipeline can be deployed
+    Then Run the slt Pipeline in Runtime
+    Then Open Logs of SLT Pipeline
+    Then Wait till SLT pipeline is in running state and no error occurs
+    Then Close logs and stop the pipeline
+    Then Get Count of no of records transferred from SLT to BigQuery in "<table>"
+    Then Validate record count in BQ matches with count in SAP
+    Examples:
+      | table      | mode        |
+      | ZDATA_TYPE | replication |
+
+  @SLT @Run-Time @Sanity
+  Scenario Outline: Validate that SLT job can be configured for in LTRC and executed for Initial Load Mode
+    Given Create new MTID on "Automation" SAP
+    When Validate that MTID can be Updated using CDF_R_SLT_SETTINGS program
+    Then Verify that user is able to update table "<table>" to "stop_load" on LTRC
+    Given Open CDF replication and initiate pipeline creation
+    When Fetche the record count of table : "<table>" from SAP
+    Then Delete GCS folder for mass transfer id table "<table>"
+    Then Drop target BigQuery table "<table>"
+    Then Verify that user is able to update table "<table>" to "<mode>" on LTRC
+    When Select SAP SLT as source and fill connection parameters
+    Then Click on next
+    Then Validate Table is available and  can be selected "<table>"
+    Then Click on next
+    Then Enter the BigQuery Properties for slt datasource
+    Then Click on next
+    Then Click on next
+    Then Click on next
+    Then Validate Replication Pipeline can be deployed
+    Then Run the slt Pipeline in Runtime
+    Then Open Logs of SLT Pipeline
+    Then Wait till SLT pipeline is in running state and no error occurs
+    Then Close logs and stop the pipeline
+    Then Get Count of no of records transferred from SLT to BigQuery in "<table>"
+    Then Validate record count in BQ matches with count in SAP
+    Examples:
+      | table | mode         |
+      | adr6  | initial_load |
+      | t001  | initial_load |
+      | t006a | initial_load |
+      | t023t | initial_load |
+      | t023  | initial_load |
+
+
+  @SLT @Run-Time
+  Scenario Outline: Validate that SLT job can be configured for job in LTRC and executed in Replication mode
+    Given Create new MTID on "Automation" SAP
+    When Validate that MTID can be Updated using CDF_R_SLT_SETTINGS program
+    Then Verify that user is able to update table "<table>" to "stop_load" on LTRC
+    Given Open CDF replication and initiate pipeline creation
+    When Fetche the record count of table : "<table>" from SAP
+    Then Delete GCS folder for mass transfer id table "<table>"
+    Then Drop target BigQuery table "<table>"
+    Then Verify that user is able to update table "<table>" to "<mode>" on LTRC
+    When Select SAP SLT as source and fill connection parameters
+    Then Click on next
+    Then Validate Table is available and  can be selected "<table>"
+    Then Click on next
+    Then Enter the BigQuery Properties for slt datasource
+    Then Click on next
+    Then Click on next
+    Then Click on next
+    Then Validate Replication Pipeline can be deployed
+    Then Run the slt Pipeline in Runtime
+    Then Open Logs of SLT Pipeline
+    Then Wait till SLT pipeline is in running state and no error occurs
+    Then Get Count of no of records transferred from SLT to BigQuery in "<table>"
+    Then Validate record count in BQ matches with count in SAP
+    Then "<cud_type>" the "<count>" records with "<rfc>" in the sap table
+    Then Wait till SLT pipeline is in running state and no error occurs
+    Then Close logs and stop the pipeline
+    Then Get Count of no of records transferred from SLT to BigQuery in "<table>"
+    Then Validate record count in BQ matches with count in SAP
+    Then "<cud_type>" the "<count>" records with "<rfc>" in the sap table
+    Then Run the slt Pipeline in Runtime
+    Then Open Logs of SLT Pipeline
+    Then Wait till SLT pipeline is in running state and no error occurs
+    Then Close logs and stop the pipeline
+    When Fetche the record count of table : "<table>" from SAP
+    Then Get Count of no of records transferred from SLT to BigQuery in "<table>"
+    Then Validate record count in BQ matches with count in SAP
+    Then Verify that user is able to update table "<table>" to "stop_load" on LTRC
+    Examples:
+      | table | mode        | count | cud_type | rfc       |
+      | mara  | replication | 1     | create   | rfc_matnr |
+
+  @SLT @Run-Time
+  Scenario Outline: Verify only replication data transfers when Replicate Existing Data is false
+    Given Create new MTID on "Automation" SAP
+    When Validate that MTID can be Updated using CDF_R_SLT_SETTINGS program
+    Then Verify that user is able to update table "<table>" to "stop_load" on LTRC
+    Given Open CDF replication and initiate pipeline creation
+    When Fetche the record count of table : "<table>" from SAP
+    Then Delete GCS folder for mass transfer id table "<table>"
+    Then Drop target BigQuery table "<table>"
+    Then Verify that user is able to update table "<table>" to "<mode>" on LTRC
+    When Select SAP SLT as source and fill connection parameters
+    Then Validate Replicate Existing Data can be set to false
+    Then Click on next
+    Then Validate Table is available and  can be selected "<table>"
+    Then Click on next
+    Then Enter the BigQuery Properties for slt datasource
+    Then Click on next
+    Then Click on next
+    Then Click on next
+    Then Validate Replication Pipeline can be deployed
+    Then "<cud_type>" the "<count>" records with "<rfc>" in the sap table
+    Then Run the slt Pipeline in Runtime
+    Then Open Logs of SLT Pipeline
+    Then Wait till SLT pipeline is in running state and no error occurs
+    Then Close logs and stop the pipeline
+    When Fetche the record count of table : "<table>" from SAP
+    Then Verify that user is able to update table "<table>" to "stop_load" on LTRC
+    Then Delete the mtid
+    Then Get Count of no of records transferred from SLT to BigQuery in "<table>"
+    Then Validate only replication data is loaded ie "<count>"
+    Examples:
+      | table | mode        | count | cud_type | rfc       |
+      | mara  | replication | 1     | create   | rfc_matnr |
diff --git a/e2e-test/java/io/cdap/plugin/slt/actions/SLTActions.java b/e2e-test/java/io/cdap/plugin/slt/actions/SLTActions.java
new file mode 100644
index 0000000000..fc7990d875
--- /dev/null
+++ b/e2e-test/java/io/cdap/plugin/slt/actions/SLTActions.java
@@ -0,0 +1,101 @@
+/*
+ * Copyright © 2022 Cask Data, Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License"); you may not
+ * use this file except in compliance with the License. You may obtain a copy of
+ * the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
+ * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
+ * License for the specific language governing permissions and limitations under
+ * the License.
+ */
+package io.cdap.plugin.slt.actions;
+
+import io.cdap.e2e.utils.ElementHelper;
+import io.cdap.e2e.utils.PluginPropertyUtils;
+import io.cdap.plugin.slt.locators.SLTLocators;
+
+/**
+ * SLT Actions.
+ */
+public class SLTActions {
+
+    private static PluginPropertyUtils pluginPropertyUtils = new PluginPropertyUtils();
+
+    public static void enterName(String name) {
+        ElementHelper.sendKeys(SLTLocators.name, name);
+    }
+
+    public void enterMandatoryParameters(String gcpProjectId,
+                                         String gcsDataPath,
+                                         String massTransferId,
+                                         String sapJcoLibGcsPath,
+                                         String jcoclienthost,
+                                         String jcoclient,
+                                         String jcoclientsysnr,
+                                         String jcoclientuser,
+                                         String jcoclientpasswd) {
+        ElementHelper.replaceElementValue(SLTLocators.gcpProjectId,
+                                          pluginPropertyUtils.pluginProp(gcpProjectId));
+        ElementHelper.sendKeys(SLTLocators.gcsDataPath, pluginPropertyUtils.pluginProp(gcsDataPath));
+        ElementHelper.sendKeys(SLTLocators.massTransferId, massTransferId);
+        ElementHelper.sendKeys(SLTLocators.sapJcoLibGcsPath, pluginPropertyUtils.pluginProp(sapJcoLibGcsPath));
+        ElementHelper.sendKeys(SLTLocators.jcoClientHost, pluginPropertyUtils.pluginProp(jcoclienthost));
+        ElementHelper.sendKeys(SLTLocators.jcoClient, pluginPropertyUtils.pluginProp(jcoclient));
+        ElementHelper.sendKeys(SLTLocators.jcoClientSysnr, pluginPropertyUtils.pluginProp(jcoclientsysnr));
+        ElementHelper.sendKeys(SLTLocators.jcoClientUser, pluginPropertyUtils.pluginProp(jcoclientuser));
+        ElementHelper.sendKeys(SLTLocators.jcoClientPasswd, pluginPropertyUtils.pluginProp(jcoclientpasswd));
+    }
+
+    public void clickSltPlugin() {
+        ElementHelper.clickOnElement(SLTLocators.sltplugin);
+    }
+
+    public String getRowErrorBorderColor() {
+        return ElementHelper.getElementCssProperty(SLTLocators.rowError, "border-color");
+    }
+
+    public void clickNextButton() {
+        ElementHelper.clickOnElement(SLTLocators.next);
+    }
+
+    public void selectTable(String tableName) {
+        ElementHelper.clickOnElement(SLTLocators.table(tableName));
+    }
+
+    public void enterDatasetName(String stagingBucket) {
+        ElementHelper.sendKeys(SLTLocators.datasetName, stagingBucket);
+    }
+
+    public void deployPipelineClick() {
+        ElementHelper.clickOnElement(SLTLocators.deployPipeline);
+    }
+
+    public void startPipeline() {
+        ElementHelper.clickIfDisplayed(SLTLocators.start, 60l);
+    }
+
+    public void stopPipeline() {
+        ElementHelper.clickOnElement(SLTLocators.stop);
+    }
+
+    public void clickReplicateExistingData() {
+        ElementHelper.clickOnElement(SLTLocators.replicateExistingData);
+    }
+
+    public String getReplicateExistingDataText() {
+        return ElementHelper.getElementText(SLTLocators.replicateExistingData);
+    }
+
+    public void clickSuspendSltJob() {
+        ElementHelper.clickOnElement(SLTLocators.suspendSltJob);
+    }
+
+    public String getSuspendSltJobText() {
+        return ElementHelper.getElementText(SLTLocators.suspendSltJob);
+    }
+}
diff --git a/e2e-test/java/io/cdap/plugin/slt/actions/package-info.java b/e2e-test/java/io/cdap/plugin/slt/actions/package-info.java
new file mode 100644
index 0000000000..694132a3a9
--- /dev/null
+++ b/e2e-test/java/io/cdap/plugin/slt/actions/package-info.java
@@ -0,0 +1,20 @@
+/*
+ * Copyright © 2022 Cask Data, Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License"); you may not
+ * use this file except in compliance with the License. You may obtain a copy of
+ * the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
+ * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
+ * License for the specific language governing permissions and limitations under
+ * the License.
+ */
+
+/**
+ * contains Actions methods.
+ */
+package io.cdap.plugin.slt.actions;
diff --git a/e2e-test/java/io/cdap/plugin/slt/lib/libsapjco3.jnilib b/e2e-test/java/io/cdap/plugin/slt/lib/libsapjco3.jnilib
new file mode 100644
index 0000000000..1a56bb8652
Binary files /dev/null and b/e2e-test/java/io/cdap/plugin/slt/lib/libsapjco3.jnilib differ
diff --git a/e2e-test/java/io/cdap/plugin/slt/lib/libsapjco3.so b/e2e-test/java/io/cdap/plugin/slt/lib/libsapjco3.so
new file mode 100644
index 0000000000..b148fea4e5
Binary files /dev/null and b/e2e-test/java/io/cdap/plugin/slt/lib/libsapjco3.so differ
diff --git a/e2e-test/java/io/cdap/plugin/slt/locators/SLTLocators.java b/e2e-test/java/io/cdap/plugin/slt/locators/SLTLocators.java
new file mode 100644
index 0000000000..d6b82a3726
--- /dev/null
+++ b/e2e-test/java/io/cdap/plugin/slt/locators/SLTLocators.java
@@ -0,0 +1,136 @@
+/*
+ * Copyright © 2022 Cask Data, Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License"); you may not
+ * use this file except in compliance with the License. You may obtain a copy of
+ * the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
+ * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
+ * License for the specific language governing permissions and limitations under
+ * the License.
+ */
+
+package io.cdap.plugin.slt.locators;
+
+import io.cdap.e2e.utils.SeleniumDriver;
+import org.openqa.selenium.By;
+import org.openqa.selenium.WebElement;
+import org.openqa.selenium.support.FindBy;
+import org.openqa.selenium.support.How;
+
+/**
+ * SLT Plugin Locators.
+ */
+public class SLTLocators {
+
+    @FindBy(how = How.XPATH, using = "//input[@data-cy='name']")
+    public static WebElement name;
+
+    @FindBy(how = How.XPATH, using = "//input[@data-cy='gcpProjectId']")
+    public static WebElement gcpProjectId;
+
+    @FindBy(how = How.XPATH, using = "//div[contains(text(),'SAP Landscape Transformation (SLT)')]")
+    public static WebElement sltplugin;
+
+    @FindBy(how = How.XPATH, using = "//input[@data-cy='gcsDataPath']")
+    public static WebElement gcsDataPath;
+
+    @FindBy(how = How.XPATH, using = "//input[@data-cy='guid']")
+    public static WebElement guid;
+
+    @FindBy(how = How.XPATH, using = "//input[@data-cy='massTransferId']")
+    public static WebElement massTransferId;
+
+    @FindBy(how = How.XPATH, using = "//input[@data-cy='sapJcoLibGcsPath']")
+    public static WebElement sapJcoLibGcsPath;
+
+    @FindBy(how = How.XPATH, using = "//input[@data-cy='jco.client.ashost']")
+    public static WebElement jcoClientHost;
+
+    @FindBy(how = How.XPATH, using = "//input[@data-cy='jco.client.client']")
+    public static WebElement jcoClient;
+
+    @FindBy(how = How.XPATH, using = "//input[@data-cy='jco.client.sysnr']")
+    public static WebElement jcoClientSysnr;
+
+    @FindBy(how = How.XPATH, using = "//input[@data-cy='jco.client.user']")
+    public static WebElement jcoClientUser;
+
+    @FindBy(how = How.XPATH, using = "//input[@data-cy='jco.client.passwd']")
+    public static WebElement jcoClientPasswd;
+
+    @FindBy(how = How.XPATH, using = "//*[contains(text(),'Next')]")
+    public static WebElement next;
+
+    @FindBy(how = How.XPATH, using = "//input[@data-cy='project']")
+    public static WebElement project;
+
+    @FindBy(how = How.XPATH, using = "//input[@data-cy='datasetName']")
+    public static WebElement datasetName;
+
+    @FindBy(how = How.XPATH, using = "//span[contains(text(),'Configure target')]")
+    public static WebElement configure;
+
+    @FindBy(how = How.XPATH, using = "//span[contains(text(),'Configure advanced properties')]")
+    public static WebElement configureAdvance;
+
+    @FindBy(how = How.XPATH, using = "//span[contains(text(),'Review assessment')]")
+    public static WebElement review;
+
+    @FindBy(how = How.XPATH, using = "//span[contains(text(),'View summary')]")
+    public static WebElement viewSummary;
+
+    @FindBy(how = How.XPATH, using = "//span[contains(text(),'Deploy Replication Job')]")
+    public static WebElement deployPipeline;
+
+    @FindBy(how = How.XPATH, using = "//*[contains(text(), 'Logs')]")
+    public static WebElement logs;
+
+    @FindBy(how = How.XPATH, using = "(//*[contains(text(), 'View')])[1]")
+    public static WebElement advancedLogs;
+
+    @FindBy(how = How.XPATH, using = "//*[contains(text(), 'Running')]")
+    public static WebElement running;
+
+    @FindBy(how = How.XPATH, using = "//*[contains(text(),'Polling next set of files using prefix')]")
+    public static WebElement replication;
+
+    @FindBy(how = How.XPATH, using = "//*[contains(@class, 'icon-stop')]")
+    public static WebElement stop;
+
+    @FindBy(how = How.XPATH, using = "//div[contains(text(),'ERROR')]")
+    public static WebElement error;
+
+    @FindBy(how = How.XPATH, using = "(//div[contains(text(),'ERROR')])[3]")
+    public static WebElement error3;
+
+    @FindBy(how = How.XPATH, using = "//*[contains(text(),'Stopped')]")
+    public static WebElement stopped;
+
+    @FindBy(how = How.XPATH, using = "//*[@class='text-danger']/span")
+    public static WebElement rowError;
+
+    @FindBy(how = How.XPATH, using = "//*[@data-cy='switch-replicateExistingData']/div[2]")
+    public static WebElement replicateExistingData;
+
+    @FindBy(how = How.XPATH, using = "//*[@data-cy='switch-suspendSltJob']/div[2]")
+    public static WebElement suspendSltJob;
+
+    public static By start = By.xpath("//*[contains(@class, 'icon-play ')]");
+
+    public static By replicationStatus = By.xpath("//*[contains(text(),'replication status: Process: ')]");
+
+    public static WebElement table(String tableName) {
+        return SeleniumDriver.getDriver().findElement(By.xpath("//div[contains(text(),'" +
+                                                                 tableName + "')]/preceding-sibling::div//input"));
+    }
+
+    public static WebElement inputParameter(String inputParameter) {
+        return SeleniumDriver.getDriver().findElement(By.xpath("//*[@data-cy='" +
+                                                                 inputParameter + "' and contains(@class,'MuiInputBase-input')]"));
+    }
+}
diff --git a/e2e-test/java/io/cdap/plugin/slt/locators/package-info.java b/e2e-test/java/io/cdap/plugin/slt/locators/package-info.java
new file mode 100644
index 0000000000..3af66fc425
--- /dev/null
+++ b/e2e-test/java/io/cdap/plugin/slt/locators/package-info.java
@@ -0,0 +1,20 @@
+/*
+ * Copyright © 2022 Cask Data, Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License"); you may not
+ * use this file except in compliance with the License. You may obtain a copy of
+ * the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
+ * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
+ * License for the specific language governing permissions and limitations under
+ * the License.
+ */
+
+/**
+ * contains CDF Replicator plugin locators.
+ */
+package io.cdap.plugin.slt.locators;
diff --git a/e2e-test/java/io/cdap/plugin/slt/stepsdesign/StepDefinitionSLT.java b/e2e-test/java/io/cdap/plugin/slt/stepsdesign/StepDefinitionSLT.java
new file mode 100644
index 0000000000..c5e3144938
--- /dev/null
+++ b/e2e-test/java/io/cdap/plugin/slt/stepsdesign/StepDefinitionSLT.java
@@ -0,0 +1,471 @@
+/*
+ * Copyright © 2022 Cask Data, Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License"); you may not
+ * use this file except in compliance with the License. You may obtain a copy of
+ * the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
+ * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
+ * License for the specific language governing permissions and limitations under
+ * the License.
+ */
+package io.cdap.plugin.slt.stepsdesign;
+
+import com.fasterxml.jackson.databind.JsonNode;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.fasterxml.jackson.databind.node.ObjectNode;
+import com.google.adapter.connector.SAPAdapterImpl;
+import com.google.adapter.connector.SAPProperties;
+import com.google.adapter.exceptions.SystemException;
+import com.google.adapter.util.ErrorCapture;
+import com.google.adapter.util.ExceptionUtils;
+import com.google.api.gax.paging.Page;
+import com.google.cloud.bigquery.BigQueryException;
+import com.google.cloud.storage.Blob;
+import com.google.cloud.storage.Storage;
+import com.google.cloud.storage.StorageOptions;
+import com.sap.conn.jco.JCoException;
+import io.cdap.e2e.utils.*;
+import io.cdap.plugin.slt.actions.SLTActions;
+import io.cdap.plugin.slt.locators.SLTLocators;
+import io.cucumber.java.en.Given;
+import io.cucumber.java.en.Then;
+import io.cucumber.java.en.When;
+import org.junit.Assert;
+import org.openqa.selenium.support.ui.ExpectedConditions;
+import org.openqa.selenium.support.ui.WebDriverWait;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import stepsdesign.BeforeActions;
+
+import java.io.FileInputStream;
+import java.io.IOException;
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.HashMap;
+import java.util.Iterator;
+import java.util.List;
+import java.util.Map;
+import java.util.Properties;
+import java.util.UUID;
+
+import static io.cdap.e2e.utils.BigQueryClient.getSoleQueryResult;
+
+/**
+ * Contains SLT test scenarios step definitions.
+ */
+public class StepDefinitionSLT implements CdfHelper {
+
+  private static final Logger logger = LoggerFactory.getLogger(PluginPropertyUtils.class);
+  private SAPProperties sapProps;
+  private ErrorCapture errorCapture;
+  private SAPAdapterImpl sapAdapterImpl;
+  static String action;
+  private ExceptionUtils exceptionUtils;
+  public static SLTActions sltActions = new SLTActions();
+  public static SLTLocators sltLocators = new SLTLocators();
+  public static String rawLog = null;
+  BigQueryClient bqClient = new BigQueryClient();
+  static int sapRecordsCount;
+  static int bqRecordCount = 0;
+  private static ArrayList<String> tabs = null;
+  private static String parent = null;
+  private static Properties connection = new SAPProperties();
+  private List<String> fields = new ArrayList<>();
+  private static boolean isErrorPresent = false;
+  private static String mtId = null;
+  private static String guid = null;
+  static boolean errorExist = false;
+  static String color;
+  private static AssertionHelper assertionHelper = new AssertionHelper();
+  private static ElementHelper elementHelper = new ElementHelper();
+  private static WaitHelper waitHelper = new WaitHelper();
+  private static PluginPropertyUtils pluginPropertyUtils = new PluginPropertyUtils();
+
+
+  static {
+    sltLocators = SeleniumHelper.getPropertiesLocators(SLTLocators.class);
+    Properties prop = new Properties();
+    try {
+      prop.load(new FileInputStream("src/e2e-test/resources/Google_SAP_Connection.properties"));
+    } catch (IOException e) {
+      logger.error("Failed while reading SAP properties file" + e);
+    }
+    for (String property : prop.stringPropertyNames()) {
+      connection.put(property, prop.getProperty(property));
+    }
+  }
+
+  @Then("^Set Dummy MTID")
+  public void setDummyMTID() {
+    mtId = "02K";
+  }
+
+
+  @Given("^Open CDF replication and initiate pipeline creation")
+  public void open_cdf_replication() throws IOException, InterruptedException {
+    openCdf();
+    SeleniumDriver.getDriver().get("http://localhost:11011/cdap/ns/default/replication/create");
+    sltActions.enterName(UUID.randomUUID().toString().replaceAll("-", ""));
+    sltActions.clickNextButton();
+    isErrorPresent = false;
+    bqRecordCount = 0;
+    sapRecordsCount = 0;
+  }
+
+  @When("Select SAP SLT as source and fill connection parameters")
+  public void source_is_sap_slt() {
+    sltActions.clickSltPlugin();
+    sltActions.enterMandatoryParameters(
+      "gcpProjectId",
+      "gcsDataPath",
+      mtId,
+      "sapJcoLibGcsPath",
+      "jcoclienthost",
+      "jcoclient",
+      "jcoclientsysnr",
+      "jcoclientuser",
+      "jcoclientpasswd");
+  }
+
+  @When("Select SAP SLT as source")
+  public void source_is_sapslt() {
+    sltActions.clickSltPlugin();
+  }
+
+  @Then("Verify that after setting SLT parameter {string} as {string} plugin is throws error {string}")
+  public void userIsAbleToSetSLTParameterAsAndGettingRowForWrongInput(
+    String inputParameter, String inputValue, String errorMessage) {
+    errorExist = false;
+    elementHelper.replaceElementValue(sltLocators.inputParameter(inputParameter), inputValue);
+    sltActions.clickNextButton();
+    errorExist = pluginPropertyUtils.errorProp(errorMessage).
+      toLowerCase().contains(SLTLocators.rowError.getText().toLowerCase());
+    color = sltActions.getRowErrorBorderColor();
+    Assert.assertTrue(errorExist);
+    BeforeActions.scenario.write("Color of the text box" + color);
+    Assert.assertTrue(color.toLowerCase().contains("rgb(209, 86, 104)"));
+  }
+
+  @Then("Validate SLT parameter {string} can be set as {string}")
+  public void userIsAbleToSetSLTParameter(
+    String inputParameter, String inputValue) {
+    elementHelper.replaceElementValue(sltLocators.inputParameter(inputParameter), inputValue);
+  }
+
+  @Then("Validate Replicate Existing Data can be set to false")
+  public void replicate_existing_data() {
+    sltActions.clickReplicateExistingData();
+    assertionHelper.verifyElementContainsText(sltLocators.replicateExistingData,
+                                              "No");
+  }
+
+  @Then("Validate Suspend Slt Job can be set to true")
+  public void suspend_existing_job() {
+    sltActions.clickSuspendSltJob();
+    assertionHelper.verifyElementContainsText(sltLocators.suspendSltJob,
+                                              "Yes");
+  }
+
+  @Then("^Click on next$")
+  public void click_next() {
+    sltActions.clickNextButton();
+  }
+
+  @Then("Validate Table is available and  can be selected {string}")
+  public void select_table_something(String table) {
+    sltActions.selectTable(table.toLowerCase());
+  }
+
+  @Then("^Enter the BigQuery Properties for slt datasource$")
+  public void enter_the_bigquery_properties_for_slt_datasource_something() throws IOException {
+    elementHelper.replaceElementValue(sltLocators.project,
+                                      pluginPropertyUtils.pluginProp("bqProjectId"));
+    sltActions.enterDatasetName(pluginPropertyUtils.pluginProp("dataset"));
+  }
+
+  @Then("Validate Replication Pipeline can be deployed")
+  public void click_deployPipeline() {
+    sltActions.deployPipelineClick();
+  }
+
+  @Then("Run the slt Pipeline in Runtime")
+  public void run_the_slt_pipeline_in_runtime() throws Throwable {
+    sltActions.startPipeline();
+    waitHelper.waitForElementToBeDisplayed(sltLocators.running, 60);
+  }
+
+  @Then("Open Logs of SLT Pipeline")
+  public void open_logs_of_slt_pipeline() {
+    sltLocators.logs.click();
+    parent = SeleniumDriver.getDriver().getWindowHandle();
+    tabs = new ArrayList(SeleniumDriver.getDriver().getWindowHandles());
+    SeleniumDriver.getDriver().switchTo().window((String) tabs.get(tabs.indexOf(parent) + 1));
+    sltLocators.advancedLogs.click();
+  }
+
+  @Then("Wait till SLT pipeline is in running state and no error occurs")
+  public void wait_till_slt_pipeline_is_in_running_state() {
+    WebDriverWait wait = new WebDriverWait(SeleniumDriver.getDriver(), 1000000);
+    wait.until(ExpectedConditions.or(
+      ExpectedConditions.numberOfElementsToBeMoreThan(
+        sltLocators.replicationStatus, 2),
+      ExpectedConditions.visibilityOf(sltLocators.error3)));
+  }
+
+
+  @Then("Get Count of no of records transferred from SLT to BigQuery in {string}")
+  public void get_count_of_no_of_records_transferred_from_SLT_to_bigquery_in_something(String table) throws
+    IOException, InterruptedException {
+    String selectQuery = "SELECT count(*)  FROM `" +
+      pluginPropertyUtils.pluginProp("bqProjectId") + "." +
+      pluginPropertyUtils.pluginProp("dataset") + "." +
+      table.toLowerCase() + "`";
+
+    bqRecordCount = (Integer) getSoleQueryResult(selectQuery).
+      map(Integer::parseInt).orElse(0);
+  }
+
+  @Then("Drop target BigQuery table {string}")
+  public void drop_target_bigquery_table_something(String table) {
+    String selectQuery = null;
+    selectQuery = "DROP TABLE `" + pluginPropertyUtils.pluginProp("bqProjectId") +
+      "." + pluginPropertyUtils.pluginProp("dataset") + "." +
+      table.toLowerCase() + "`";
+    try {
+      bqRecordCount = (Integer) getSoleQueryResult(selectQuery).map(Integer::parseInt).orElse(0);
+    } catch (InterruptedException | IOException | BigQueryException e) {
+      System.out.println("BQ Table is not present, It will be created by BQ plugin");
+    }
+  }
+
+  @Then("Delete GCS folder for mass transfer id table {string}")
+  public void delete_gcs_folder_for_mass_transfer_id_something_table_something(String table) throws IOException {
+    Storage storage = StorageOptions.newBuilder().
+      setProjectId(pluginPropertyUtils.pluginProp("gcpProjectId")).
+      build().getService();
+    Page<Blob> blobs = storage.list(
+      pluginPropertyUtils.pluginProp("gcsDataPath").replaceAll("gs://", ""),
+      Storage.BlobListOption.prefix(mtId + "/" + table));
+    for (Blob blob : blobs.iterateAll()) {
+      System.out.println(blob.getName());
+      storage.delete(pluginPropertyUtils.pluginProp("gcsDataPath").replaceAll("gs://", ""),
+                     blob.getName());
+    }
+  }
+
+  @Then("Close logs and stop the pipeline")
+  public void close_logs_and_stop_the_pipeline() {
+    WebDriverWait wait = new WebDriverWait(SeleniumDriver.getDriver(), 1000000);
+    SeleniumDriver.getDriver().close();
+    SeleniumDriver.getDriver().switchTo().window(parent);
+    sltActions.stopPipeline();
+    wait.until(ExpectedConditions.visibilityOf(sltLocators.stopped));
+  }
+
+  @Then("Validate only replication data is loaded ie {string}")
+  public void user_is_able_to_validate_record_count_in_bq_matches_with_repl_count(String count) {
+    Assert.assertEquals(Integer.parseInt(count), bqRecordCount);
+    Assert.assertTrue(sapRecordsCount > bqRecordCount);
+  }
+
+  @Then("Validate record count in BQ matches with count in SAP")
+  public void user_is_able_to_validate_record_count_in_bq_matches_with_count_in_sap() {
+    Assert.assertEquals(sapRecordsCount, bqRecordCount);
+  }
+
+  @Then("Verify that user is able to update table {string} to {string} on LTRC")
+  public void slt_job_for_mtid_something_table_something_in_something_mode
+    (String table, String mode)
+    throws JCoException, InterruptedException {
+    if (mode.equalsIgnoreCase("initial_load")) {
+      action = "IM_START_LOAD";
+    } else if (mode.equalsIgnoreCase("replication")) {
+      action = "IM_START_REPL";
+    } else if (mode.equalsIgnoreCase("only_replication")) {
+      action = "IM_START_REP_ONLY";
+    } else if (mode.equalsIgnoreCase("stop_load")) {
+      action = "IM_STOP_REPLICATION";
+    } else if (mode.equalsIgnoreCase("start_recording")) {
+      action = "IM_START_RECORD";
+    }
+    sapProps = SAPProperties.getDefault(connection);
+    errorCapture = new ErrorCapture(exceptionUtils);
+    sapAdapterImpl = new SAPAdapterImpl(errorCapture, connection);
+
+    Map opProps = new HashMap<>();
+    opProps.put("RFC", "ZRFM_LTRC_OPERATIONS");
+    try {
+      ObjectMapper mapper = new ObjectMapper();
+      ObjectNode objectNode = mapper.createObjectNode();
+      objectNode.put("IM_MTID", mtId);
+      objectNode.put("IM_TABLES", table.toUpperCase());
+      objectNode.put(action, "X");
+      JsonNode response = sapAdapterImpl.executeRFC(objectNode.toString(), opProps, "", "");
+      BeforeActions.scenario.write("LTRC_OPERATIONS RFM response :-" + response);
+      Assert.assertTrue(response.toString().contains("\"MESSAGE_TYPE\":\"S\""));
+    } catch (Exception e) {
+      throw SystemException.throwException(e.getMessage(), e);
+    }
+    Thread.sleep(10000); //sleep required to wait for async operation to be executed on SAP
+  }
+
+  @When("Fetche the record count of table : {string} from SAP")
+  public void user_fetches_the_record_count_of_table_something_from_sap(String table)
+    throws JCoException {
+    sapProps = SAPProperties.getDefault(connection);
+    errorCapture = new ErrorCapture(exceptionUtils);
+    sapAdapterImpl = new SAPAdapterImpl(errorCapture, connection);
+    Map opProps = new HashMap<>();
+    opProps.put("RFC", "ZFM_TABLE_COUNT");
+    opProps.put("autoCommit", "true");
+    try {
+      ObjectMapper mapper = new ObjectMapper();
+      ObjectNode objectNode = mapper.createObjectNode();
+      objectNode.put("IM_TABLE", table.toUpperCase());
+      JsonNode response = sapAdapterImpl.executeRFC(objectNode.toString(), opProps, "", "");
+      sapRecordsCount = Integer.parseInt(response.get("EX_COUNT").toString().replaceAll("\"", ""));
+      BeforeActions.scenario.write("Total record count : " + sapRecordsCount);
+    } catch (Exception e) {
+      throw SystemException.throwException(e.getMessage(), e);
+    }
+  }
+
+  @Given("Create new MTID on {string} SAP")
+  public void user_creates_mtid_on_sap(String mtIdDes)
+    throws JCoException, InterruptedException {
+    if (mtId == null) {
+      sapProps = SAPProperties.getDefault(connection);
+      errorCapture = new ErrorCapture(exceptionUtils);
+      sapAdapterImpl = new SAPAdapterImpl(errorCapture, connection);
+      Map opProps = new HashMap<>();
+      opProps.put("RFC", "ZRFM_IUUC_CREATE_CONFIG");
+      opProps.put("autoCommit", "true");
+      try {
+        ObjectMapper mapper = new ObjectMapper();
+        ObjectNode objectNode = mapper.createObjectNode();
+        objectNode.put("IV_SCHEMA_NAME", mtIdDes);
+        objectNode.put("IV_SCHEMA_DESCR", mtIdDes);
+        objectNode.put("IV_APPLICATION", "ZGOOGLE_CDF");
+        objectNode.put("IV_REPLAY_JOBS", "009");
+        objectNode.put("IV_INIT_LOAD_JOBS", "009");
+        objectNode.put("IV_REPL_MODE", "1");
+        objectNode.put("IV_SOURCE_SYSTEM_TYPE", "SAP");
+        objectNode.put("IV_SOURCE_RFCDEST", "CQ1");
+        objectNode.put("IV_TARGET_RFCDEST", "NONE");
+        objectNode.put("IV_HANA_INSTANCE", "0");
+        objectNode.put("IV_HANA_PROXYPORT", "000");
+        objectNode.put("IV_RFC_CLIENT_ONLY", "X");
+        objectNode.put("IV_REUSE_SENDER", "X");
+        objectNode.put("IV_IL_SCENARIOIV_IL_SCENARIO", "1");
+        objectNode.put("IV_NUM_JOBS_ACPCALC", "000");
+        JsonNode response = sapAdapterImpl.executeRFC(objectNode.toString(), opProps, "", "");
+        mtId = response.get("EV_MT_ID").asText();
+        guid = response.get("EV_CONFIG_GUID").asText();
+        System.out.println("MT id : " + mtId + " guid : " + guid);
+      } catch (Exception e) {
+        throw SystemException.throwException(e.getMessage(), e);
+      }
+      Thread.sleep(6000); //sleep required to wait for async operation to be executed on SAP
+    }
+  }
+
+  @When("Validate that MTID can be Updated using CDF_R_SLT_SETTINGS program")
+  public void user_updates_mtid_in_program()
+    throws JCoException, InterruptedException {
+    sapProps = SAPProperties.getDefault(connection);
+    errorCapture = new ErrorCapture(exceptionUtils);
+    sapAdapterImpl = new SAPAdapterImpl(errorCapture, connection);
+    Map opProps = new HashMap<>();
+    opProps.put("RFC", "ZRFM_LTRC_ADVANCE_SETTINGS_1");
+    opProps.put("autoCommit", "true");
+    try {
+      ObjectMapper mapper = new ObjectMapper();
+      ObjectNode objectNode = mapper.createObjectNode();
+      objectNode.put("IM_TR_KEY", mtId);
+      objectNode.put("IM_MASS_TR_ID", mtId);
+      objectNode.put("IM_EXTRA_FLDS", "X");
+      objectNode.put("IM_GCP_KEY_NAME",
+                     pluginPropertyUtils.pluginProp("IM_GCP_KEY_NAME"));
+      objectNode.put("IM_GCS_BUCKET",
+                     pluginPropertyUtils.pluginProp("gcsDataPath").
+                       replaceAll("gs://", ""));
+      objectNode.put("IM_IS_SET_ACT", "X");
+      JsonNode response = sapAdapterImpl.executeRFC(objectNode.toString(), opProps, "", "");
+      BeforeActions.scenario.write("LTRC_ADVANCE_SETTINGS RFM Response : " + response);
+
+    } catch (Exception e) {
+      throw SystemException.throwException(e.getMessage(), e);
+    }
+    Thread.sleep(10000); //sleep required to wait for async operation to be executed on SAP
+  }
+
+  @When("Delete the mtid$")
+  public void user_deletes_mtid()
+    throws JCoException, InterruptedException {
+
+    sapProps = SAPProperties.getDefault(connection);
+    errorCapture = new ErrorCapture(exceptionUtils);
+    sapAdapterImpl = new SAPAdapterImpl(errorCapture, connection);
+
+    Map opProps = new HashMap<>();
+
+    opProps.put("RFC", "ZRFM_IUUC_REPL_DELETE_CONFIG");
+    opProps.put("autoCommit", "true");
+    try {
+      ObjectMapper mapper = new ObjectMapper();
+      ObjectNode objectNode = mapper.createObjectNode();
+      objectNode.put("IM_MT_ID", mtId);
+      objectNode.put("IV_CONFIG_GUID", guid);
+      JsonNode response = sapAdapterImpl.executeRFC(objectNode.toString(), opProps, "", "");
+      BeforeActions.scenario.write("MTID DELETE CONFIG RFM Response : " + response);
+    } catch (Exception e) {
+      throw SystemException.throwException(e.getMessage(), e);
+    }
+  }
+
+  @Then("{string} the {string} records with {string} in the sap table")
+  public void createTheRecordsInTheSLTDatasourceFromJCO(String process, String recordcount, String rfcName)
+    throws IOException, JCoException, InterruptedException {
+    action = process;
+    if (action.equalsIgnoreCase("create")) {
+      action = "I_NUM_C";
+    } else if (action.equalsIgnoreCase("delete")) {
+      action = "I_NUM_D";
+    } else if (action.equalsIgnoreCase("update")) {
+      action = "I_NUM_U";
+    }
+    sapProps = SAPProperties.getDefault(connection);
+    errorCapture = new ErrorCapture(exceptionUtils);
+    sapAdapterImpl = new SAPAdapterImpl(errorCapture, connection);
+
+    Map opProps = new HashMap<>();
+    opProps.put("RFC", pluginPropertyUtils.pluginProp(rfcName));
+    opProps.put("autoCommit", "true");
+    try {
+
+      ObjectMapper mapper = new ObjectMapper();
+      ObjectNode objectNode = mapper.createObjectNode();
+      objectNode.put(action, recordcount);
+      JsonNode response = sapAdapterImpl.executeRFC(objectNode.toString(), opProps, "", "");
+      System.out.println(response.asText());
+      int noOfRecords = Integer.parseInt(response.get("EX_COUNT").asText());
+      Iterator<JsonNode> iteratedData = response.get("EX_DATA").iterator();
+      while (iteratedData.hasNext()) {
+        JsonNode object = iteratedData.next();
+        Iterator<String> fieldName = object.fieldNames();
+        if (fieldName.hasNext()) {
+          fields.add(object.get(fieldName.next()).asText());
+        }
+      }
+      BeforeActions.scenario.write("No of records :-" + noOfRecords + Arrays.toString(fields.toArray()));
+    } catch (Exception e) {
+      throw SystemException.throwException(e.getMessage(), e);
+    }
+    Thread.sleep(6000); //sleep required to wait for SAP record creation
+  }
+}
diff --git a/e2e-test/java/io/cdap/plugin/slt/stepsdesign/package-info.java b/e2e-test/java/io/cdap/plugin/slt/stepsdesign/package-info.java
new file mode 100644
index 0000000000..d9231b8f93
--- /dev/null
+++ b/e2e-test/java/io/cdap/plugin/slt/stepsdesign/package-info.java
@@ -0,0 +1,19 @@
+/*
+ * Copyright © 2022 Cask Data, Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License"); you may not
+ * use this file except in compliance with the License. You may obtain a copy of
+ * the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
+ * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
+ * License for the specific language governing permissions and limitations under
+ * the License.
+ */
+/**
+ * Contains SLT test scenarios step definitions.
+ */
+package io.cdap.plugin.slt.stepsdesign;
diff --git a/e2e-test/java/io/cdap/plugin/slt/tests/runner/TestRunner.java b/e2e-test/java/io/cdap/plugin/slt/tests/runner/TestRunner.java
new file mode 100644
index 0000000000..af3c240d25
--- /dev/null
+++ b/e2e-test/java/io/cdap/plugin/slt/tests/runner/TestRunner.java
@@ -0,0 +1,36 @@
+/*
+ * Copyright © 2022 Cask Data, Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License"); you may not
+ * use this file except in compliance with the License. You may obtain a copy of
+ * the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
+ * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
+ * License for the specific language governing permissions and limitations under
+ * the License.
+ */
+package io.cdap.plugin.slt.tests.runner;
+
+import io.cucumber.junit.Cucumber;
+import io.cucumber.junit.CucumberOptions;
+import org.junit.runner.RunWith;
+
+
+/**
+ * Test Runner to execute cases.
+ */
+@RunWith(Cucumber.class)
+@CucumberOptions(
+        features = {"e2e-test/features"},
+        glue = {"io.cdap.plugin.slt.stepsdesign", "stepsdesign"},
+        tags = {"@SLT"},
+        monochrome = true,
+        plugin = {"pretty", "html:target/cucumber-html-report", "json:target/cucumber-reports/cucumber.json",
+                "junit:target/cucumber-reports/cucumber.xml"}
+)
+public class TestRunner {
+}
diff --git a/e2e-test/java/io/cdap/plugin/slt/tests/runner/package-info.java b/e2e-test/java/io/cdap/plugin/slt/tests/runner/package-info.java
new file mode 100644
index 0000000000..630c34082c
--- /dev/null
+++ b/e2e-test/java/io/cdap/plugin/slt/tests/runner/package-info.java
@@ -0,0 +1,19 @@
+/*
+ * Copyright © 2022 Cask Data, Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License"); you may not
+ * use this file except in compliance with the License. You may obtain a copy of
+ * the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
+ * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
+ * License for the specific language governing permissions and limitations under
+ * the License.
+ */
+/**
+ * contains SLT runner.
+ */
+package io.cdap.plugin.slt.tests.runner;
diff --git a/e2e-test/java/io/cdap/plugin/slt/utils/CDAPUtils.java b/e2e-test/java/io/cdap/plugin/slt/utils/CDAPUtils.java
new file mode 100644
index 0000000000..2f6555f158
--- /dev/null
+++ b/e2e-test/java/io/cdap/plugin/slt/utils/CDAPUtils.java
@@ -0,0 +1,59 @@
+/*
+ * Copyright © 2021 Cask Data, Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License"); you may not
+ * use this file except in compliance with the License. You may obtain a copy of
+ * the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
+ * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
+ * License for the specific language governing permissions and limitations under
+ * the License.
+ */
+package io.cdap.plugin.slt.utils;
+
+import org.apache.commons.lang3.StringUtils;
+import org.apache.log4j.Logger;
+import org.openqa.selenium.Keys;
+import org.openqa.selenium.WebElement;
+
+import java.io.FileInputStream;
+import java.io.IOException;
+import java.util.List;
+import java.util.Properties;
+
+/**
+ * CDAPUtils.
+ */
+public class CDAPUtils {
+
+  private static final Logger logger = Logger.getLogger(CDAPUtils.class);
+  private static Properties errorProp = new Properties();
+  public static Properties pluginProp = new Properties();
+
+  static {
+    try {
+      errorProp.load(new FileInputStream("e2e-test/resources/error_message.properties"));
+      pluginProp.load(new FileInputStream("e2e-test/resources/PluginParameters.properties"));
+    } catch (IOException e) {
+      logger.error("Error while reading file: " + e);
+    }
+  }
+
+  public static String getPluginProp(String property) throws IOException {
+    return pluginProp.getProperty(property);
+  }
+
+  public static void clearField(WebElement element) {
+    while (!element.getAttribute("value").equals(StringUtils.EMPTY)) {
+      element.sendKeys(Keys.BACK_SPACE);
+    }
+  }
+
+  public static String getErrorProp(String errorMessage) {
+    return errorProp.getProperty(errorMessage);
+  }
+}
diff --git a/e2e-test/java/io/cdap/plugin/slt/utils/package-info.java b/e2e-test/java/io/cdap/plugin/slt/utils/package-info.java
new file mode 100644
index 0000000000..6b80479877
--- /dev/null
+++ b/e2e-test/java/io/cdap/plugin/slt/utils/package-info.java
@@ -0,0 +1,19 @@
+/*
+ * Copyright © 2021 Cask Data, Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License"); you may not
+ * use this file except in compliance with the License. You may obtain a copy of
+ * the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
+ * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
+ * License for the specific language governing permissions and limitations under
+ * the License.
+ */
+/**
+ * contains SLT utils.
+ */
+package io.cdap.plugin.slt.utils;
diff --git a/e2e-test/resources/Google_SAP_Connection.properties b/e2e-test/resources/Google_SAP_Connection.properties
new file mode 100644
index 0000000000..9977ded343
--- /dev/null
+++ b/e2e-test/resources/Google_SAP_Connection.properties
@@ -0,0 +1,6 @@
+jco.client.client=100
+jco.client.lang=EN
+jco.client.sysnr=00
+jco.client.ashost=10.132.0.111
+jco.client.user=
+jco.client.passwd=
diff --git a/e2e-test/resources/PluginParameters.properties b/e2e-test/resources/PluginParameters.properties
new file mode 100644
index 0000000000..c98bd5d2b6
--- /dev/null
+++ b/e2e-test/resources/PluginParameters.properties
@@ -0,0 +1,11 @@
+gcpProjectId=sap-adapter
+gcsDataPath=gs://ga_slt_cdf
+sapJcoLibGcsPath=gs://cdf-sap-dependent-files
+jcoclienthost=10.132.0.111
+jcoclient=100
+jcoclientsysnr=00
+jcoclientuser=
+jcoclientpasswd=
+bqProjectId=cdf-athena
+dataset=sap_automation
+IM_GCP_KEY_NAME=CDFSLT
diff --git a/e2e-test/resources/error_message.properties b/e2e-test/resources/error_message.properties
new file mode 100644
index 0000000000..7d0563f829
--- /dev/null
+++ b/e2e-test/resources/error_message.properties
@@ -0,0 +1,8 @@
+invalidgcsDataPath=CDF_SAP_SLT_01502 - The specified data replication GCS path 'invalid' could not be found. Please ensure that it exists in GCS.
+invalidMTorGUID=CDF_SAP_SLT_01404 - Mass Transfer ID or GUID could not be found. Please ensure that it exists and is active in SAP SLT.
+invalidsapJcoLibGcsPath=CDF_SAP_01412 - One or more SAP JCo library files are missing. Please make sure the required JCo library (sapjco3.jar) and its associated OS dependent shared library (libsapjco3.so) were uploaded to your specified Google Cloud Storage bucket 'gs://ga_slt_cdf'.
+invalidIP=CDF_SAP_01404 - SAP connection test failed. Please verify the connection parameters. Root Cause: JCO_ERROR_COMMUNICATION - Connect to SAP gateway failed
+invalidSysNr=CDF_SAP_01404 - SAP connection test failed. Please verify the connection parameters. Root Cause: JCO_ERROR_CONFIGURATION - Parameter ABAP system number ('jco.client.sysnr') needs to be a two digit number string instead of 'abc'
+invalidClient=CDF_SAP_01404 - SAP connection test failed. Please verify the connection parameters. Root Cause: JCO_ERROR_CONFIGURATION - Parameter SAP client ('jco.client.client') needs to be a three digit number string instead of 'abc'
+invalidLang=CDF_SAP_01404 - SAP connection test failed. Please verify the connection parameters. Root Cause: JCO_ERROR_CONFIGURATION - Parameter logon language ('jco.client.lang') code 'invalid' is invalid
+invalidCred=CDF_SAP_01404 - SAP connection test failed. Please verify the connection parameters. Root Cause: JCO_ERROR_LOGON_FAILURE - Name or password is incorrect (repeat logon)