You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampipes.apache.org by ze...@apache.org on 2021/06/25 19:07:22 UTC
[incubator-streampipes] branch STREAMPIPES-380 updated:
[STREAMPIPES-380] Add output strategy to tests and two new pe test cases
This is an automated email from the ASF dual-hosted git repository.
zehnder pushed a commit to branch STREAMPIPES-380
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes.git
The following commit(s) were added to refs/heads/STREAMPIPES-380 by this push:
new efe45c1 [STREAMPIPES-380] Add output strategy to tests and two new pe test cases
efe45c1 is described below
commit efe45c156e1a358de4fac01fc5384c0d0e698c43
Author: Philipp Zehnder <ze...@fzi.de>
AuthorDate: Fri Jun 25 21:06:39 2021 +0200
[STREAMPIPES-380] Add output strategy to tests and two new pe test cases
---
.../fixtures/pipelineElement/projection1/description.json | 6 ++++++
ui/cypress/fixtures/pipelineElement/projection1/expected.csv | 6 ++++++
ui/cypress/fixtures/pipelineElement/projection1/input.csv | 6 ++++++
.../fixtures/pipelineElement/textFilter1/description.json | 8 ++++++++
ui/cypress/fixtures/pipelineElement/textFilter1/expected.csv | 4 ++++
ui/cypress/fixtures/pipelineElement/textFilter1/input.csv | 11 +++++++++++
.../integration/pipelineElement/SinglePipelineElement.ts | 2 +-
.../property-selection/property-selection.component.html | 3 ++-
8 files changed, 44 insertions(+), 2 deletions(-)
diff --git a/ui/cypress/fixtures/pipelineElement/projection1/description.json b/ui/cypress/fixtures/pipelineElement/projection1/description.json
new file mode 100644
index 0000000..a14790f
--- /dev/null
+++ b/ui/cypress/fixtures/pipelineElement/projection1/description.json
@@ -0,0 +1,6 @@
+{
+ "name": "projection",
+ "config": [
+ {"type": "checkbox", "selector": "timestamp", "value": "check"}
+ ]
+}
\ No newline at end of file
diff --git a/ui/cypress/fixtures/pipelineElement/projection1/expected.csv b/ui/cypress/fixtures/pipelineElement/projection1/expected.csv
new file mode 100644
index 0000000..4c7c805
--- /dev/null
+++ b/ui/cypress/fixtures/pipelineElement/projection1/expected.csv
@@ -0,0 +1,6 @@
+time;sp_internal_label;timestamp
+1623871499055;;1.623871499055E12
+1623871504082;;1.623871504082E12
+1623871505084;;1.623871505084E12
+1623871506086;;1.623871506086E12
+1623871507091;;1.623871507091E12
diff --git a/ui/cypress/fixtures/pipelineElement/projection1/input.csv b/ui/cypress/fixtures/pipelineElement/projection1/input.csv
new file mode 100644
index 0000000..d0785f5
--- /dev/null
+++ b/ui/cypress/fixtures/pipelineElement/projection1/input.csv
@@ -0,0 +1,6 @@
+timestamp;remove
+1623871499055;62.0
+1623871504082;56.0
+1623871505084;95.0
+1623871506086;77.0
+1623871507091;85.0
diff --git a/ui/cypress/fixtures/pipelineElement/textFilter1/description.json b/ui/cypress/fixtures/pipelineElement/textFilter1/description.json
new file mode 100644
index 0000000..0c00b1d
--- /dev/null
+++ b/ui/cypress/fixtures/pipelineElement/textFilter1/description.json
@@ -0,0 +1,8 @@
+{
+ "name": "text_filter",
+ "config": [
+ {"type": "drop-down", "selector": "text", "value": "randomchar"},
+ {"type": "radio", "selector": "operation", "value": "MATCHES"},
+ {"type": "input", "selector": "keyword", "value": "c"}
+ ]
+}
\ No newline at end of file
diff --git a/ui/cypress/fixtures/pipelineElement/textFilter1/expected.csv b/ui/cypress/fixtures/pipelineElement/textFilter1/expected.csv
new file mode 100644
index 0000000..c5305b1
--- /dev/null
+++ b/ui/cypress/fixtures/pipelineElement/textFilter1/expected.csv
@@ -0,0 +1,4 @@
+time;randomchar;sp_internal_label;timestamp
+1623871501064;c;;1.623871501064E12
+1623871504082;c;;1.623871504082E12
+1623871507091;c;;1.623871507091E12
diff --git a/ui/cypress/fixtures/pipelineElement/textFilter1/input.csv b/ui/cypress/fixtures/pipelineElement/textFilter1/input.csv
new file mode 100644
index 0000000..d931de3
--- /dev/null
+++ b/ui/cypress/fixtures/pipelineElement/textFilter1/input.csv
@@ -0,0 +1,11 @@
+timestamp;randomchar
+1623871499055;a
+1623871500059;b
+1623871501064;c
+1623871502070;a
+1623871503078;b
+1623871504082;c
+1623871505084;a
+1623871506086;b
+1623871507091;c
+1623871508093;a
diff --git a/ui/cypress/integration/pipelineElement/SinglePipelineElement.ts b/ui/cypress/integration/pipelineElement/SinglePipelineElement.ts
index f2a007b..767bee8 100644
--- a/ui/cypress/integration/pipelineElement/SinglePipelineElement.ts
+++ b/ui/cypress/integration/pipelineElement/SinglePipelineElement.ts
@@ -22,7 +22,7 @@ import { ProcessorTest } from '../../support/model/ProcessorTest';
const allTests = Cypress.env('processingElements');
allTests.forEach(test => {
- const testName = 'fieldRenamer1';
+ const testName = 'projection1';
const processorTest = test as ProcessorTest;
diff --git a/ui/src/app/editor/components/output-strategy/property-selection/property-selection.component.html b/ui/src/app/editor/components/output-strategy/property-selection/property-selection.component.html
index 732a3d0..baff41c 100644
--- a/ui/src/app/editor/components/output-strategy/property-selection/property-selection.component.html
+++ b/ui/src/app/editor/components/output-strategy/property-selection/property-selection.component.html
@@ -20,7 +20,8 @@
<div fxLayout="row">
<mat-checkbox [checked]="exists(eventProperty.runtimeId)"
(change)="toggle(eventProperty.runtimeId)"
- style="margin-right: 10px;" [disabled]="restrictedEditMode">
+ style="margin-right: 10px;" [disabled]="restrictedEditMode"
+ [attr.data-cy]="eventProperty.runtimeName">
</mat-checkbox>
<div>
<div *ngIf="eventProperty.label"><b>{{eventProperty.label}}</b><br/>