Skip to content
Draft
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
28 changes: 14 additions & 14 deletions core-plugins/src/e2e-test/features/joiner/Joiner.feature
Original file line number Diff line number Diff line change
Expand Up @@ -19,46 +19,46 @@ Feature: Joiner analytics - Verify File source data transfer using Joiner analyt
@GCS_SOURCE_TEST @GCS_SOURCE_JOINER_TEST @GCS_SINK_TEST
Scenario: To verify data is getting transferred from File source to File sink plugin successfully with Joiner
Given Open Datafusion Project to configure pipeline
When Select plugin: "File" from the plugins list as: "Source"
When Select plugin: "File" from the plugins list as: "Source"
Then Move plugins: "File2" by xOffset 0 and yOffset 200
When Select plugin: "GCS" from the plugins list as: "Source"
When Select plugin: "GCS" from the plugins list as: "Source"
Then Move plugins: "GCS2" by xOffset 0 and yOffset 200
When Expand Plugin group in the LHS plugins list: "Analytics"
When Select plugin: "Joiner" from the plugins list as: "Analytics"
Then Connect plugins: "File" and "Joiner" to establish connection
Then Connect plugins: "File2" and "Joiner" to establish connection
Then Connect plugins: "GCS" and "Joiner" to establish connection
Then Connect plugins: "GCS2" and "Joiner" to establish connection
When Expand Plugin group in the LHS plugins list: "Sink"
When Select plugin: "File" from the plugins list as: "Sink"
Then Connect plugins: "Joiner" and "File3" to establish connection
Then Navigate to the properties page of plugin: "File"
When Select plugin: "GCS" from the plugins list as: "Sink"
Then Connect plugins: "Joiner" and "GCS3" to establish connection
Then Navigate to the properties page of plugin: "GCS"
Then Enter input plugin property: "referenceName" with value: "firstName"
Then Enter input plugin property: "path" with value: "gcsSourceBucket1"
Then Select dropdown plugin property: "format" with option value: "csv"
Then Click plugin property: "skipHeader"
Then Click plugin property: "enableQuotedValues"
Then Click on the Get Schema button
Then Verify the Output Schema matches the Expected Schema: "firstNameOutputSchema"
Then Validate "File" plugin properties
Then Validate "GCS" plugin properties
Then Close the Plugin Properties page
Then Navigate to the properties page of plugin: "File2"
Then Navigate to the properties page of plugin: "GCS2"
Then Enter input plugin property: "referenceName" with value: "lastName"
Then Enter input plugin property: "path" with value: "gcsSourceBucket2"
Then Select dropdown plugin property: "format" with option value: "csv"
Then Click plugin property: "skipHeader"
Then Click plugin property: "enableQuotedValues"
Then Click on the Get Schema button
Then Verify the Output Schema matches the Expected Schema: "lastNameOutputSchema"
Then Validate "File" plugin properties
Then Validate "GCS" plugin properties
Then Close the Plugin Properties page
Then Navigate to the properties page of plugin: "Joiner"
Then Expand fields
Then Uncheck plugin "File2" field "id" alias checkbox
Then Uncheck plugin "GCS2" field "id" alias checkbox
Then Select joiner type "Inner"
Then Enter numPartitions "expectedJoinerOutputPartitions"
Then Select dropdown plugin property: "inputsToLoadMemory" with option value: "File"
Then Select dropdown plugin property: "inputsToLoadMemory" with option value: "GCS"
Then Scroll to validation button and click
Then Validate "Joiner" plugin properties
Then Close the Plugin Properties page
Then Navigate to the properties page of plugin: "File3"
Then Navigate to the properties page of plugin: "GCS3"
Then Enter input plugin property: "referenceName" with value: "result"
Then Enter input plugin property: "path" with value: "gcsTargetBucket"
Then Select dropdown plugin property: "format" with option value: "csv"
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -7,4 +7,3 @@
7,Maye,Ferraretto
8,Bernie,Catterick
9,Heidie,Weafer
10,Lurette,Ivasechko
1 change: 0 additions & 1 deletion core-plugins/src/e2e-test/resources/testdata/last_name.csv
Original file line number Diff line number Diff line change
Expand Up @@ -8,4 +8,3 @@ id,last_name
7,Ferraretto
8,Catterick
9,Weafer
10,Ivasechko
5 changes: 5 additions & 0 deletions pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -1259,6 +1259,11 @@
<version>1.2.8</version>
<scope>runtime</scope>
</dependency>
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-api</artifactId>
<version>1.7.15</version>
</dependency>
</dependencies>

</profile>
Expand Down