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/12/07 09:36:28 UTC
[incubator-streampipes] branch dev updated: [STREAMPIPES-449] Add test for rate limit with time window
This is an automated email from the ASF dual-hosted git repository.
zehnder pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes.git
The following commit(s) were added to refs/heads/dev by this push:
new 7e42f18 [STREAMPIPES-449] Add test for rate limit with time window
7e42f18 is described below
commit 7e42f1890522d2576a1d8d6f5564e6f5d06752a4
Author: Philipp Zehnder <ze...@fzi.de>
AuthorDate: Tue Dec 7 10:36:14 2021 +0100
[STREAMPIPES-449] Add test for rate limit with time window
---
.../filters-jvm/rateLimit2/description.json | 25 ++++++++++++++++++++++
.../filters-jvm/rateLimit2/expected.csv | 2 ++
.../filters-jvm/rateLimit2/input.csv | 13 +++++++++++
3 files changed, 40 insertions(+)
diff --git a/ui/cypress/fixtures/pipelineElement/filters-jvm/rateLimit2/description.json b/ui/cypress/fixtures/pipelineElement/filters-jvm/rateLimit2/description.json
new file mode 100644
index 0000000..cc4fcb5
--- /dev/null
+++ b/ui/cypress/fixtures/pipelineElement/filters-jvm/rateLimit2/description.json
@@ -0,0 +1,25 @@
+{
+ "name": "rate_limit",
+ "config": [
+ {
+ "type": "radio",
+ "selector": "grouping-enabled",
+ "value": "False"
+ },
+ {
+ "type": "radio",
+ "selector": "window-type",
+ "value": "Time Window"
+ },
+ {
+ "type": "input",
+ "selector": "undefined-time-window-size-0",
+ "value": "5000"
+ },
+ {
+ "type": "radio",
+ "selector": "event-selection",
+ "value": "First"
+ }
+ ]
+}
diff --git a/ui/cypress/fixtures/pipelineElement/filters-jvm/rateLimit2/expected.csv b/ui/cypress/fixtures/pipelineElement/filters-jvm/rateLimit2/expected.csv
new file mode 100644
index 0000000..99f0b54
--- /dev/null
+++ b/ui/cypress/fixtures/pipelineElement/filters-jvm/rateLimit2/expected.csv
@@ -0,0 +1,2 @@
+time;randomnumber
+1623871490000;62.0
diff --git a/ui/cypress/fixtures/pipelineElement/filters-jvm/rateLimit2/input.csv b/ui/cypress/fixtures/pipelineElement/filters-jvm/rateLimit2/input.csv
new file mode 100644
index 0000000..1fb3cae
--- /dev/null
+++ b/ui/cypress/fixtures/pipelineElement/filters-jvm/rateLimit2/input.csv
@@ -0,0 +1,13 @@
+timestamp;randomnumber
+1623871490000;62.0
+1623871491000;46.0
+1623871492000;41.0
+1623871493000;41.0
+1623871494000;22.0
+1623871495000;56.0
+1623871496000;95.0
+1623871497000;77.0
+1623871498000;85.0
+1623871499000;26.0
+1623871500000;21.0
+1623871510000;22.0