You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampipes.apache.org by go...@apache.org on 2021/10/22 11:30:42 UTC
[incubator-streampipes] 02/03: Merge branch 'edge-extensions' of
https://github.com/apache/incubator-streampipes into edge-extensions
This is an automated email from the ASF dual-hosted git repository.
gomm pushed a commit to branch edge-extensions
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes.git
commit 85e2a484adbcbcf2842d0bcff2ba8f2c4fbc7d70
Merge: d70a049 c5411c2
Author: daniel-gomm <da...@outlook.de>
AuthorDate: Wed Oct 20 18:44:46 2021 +0200
Merge branch 'edge-extensions' of https://github.com/apache/incubator-streampipes into edge-extensions
.../node/controller/config/EnvConfigParam.java | 3 +
.../node/controller/config/NodeConfiguration.java | 52 +++++++++++---
.../strategies/OffloadingStrategyFactory.java | 49 +++++++++----
.../relay/bridges/MultiBrokerBridge.java | 18 ++++-
.../apache/streampipes/performance/SineSignal.java | 83 ++++++++++++++++++++++
.../streampipes/performance/TestFactory.java | 2 +-
.../performance/performancetest/GenericTest.java | 4 +-
7 files changed, 185 insertions(+), 26 deletions(-)
diff --cc streampipes-performance-tests/src/main/java/org/apache/streampipes/performance/performancetest/GenericTest.java
index c890557,7b21bb6..2d8523c
--- a/streampipes-performance-tests/src/main/java/org/apache/streampipes/performance/performancetest/GenericTest.java
+++ b/streampipes-performance-tests/src/main/java/org/apache/streampipes/performance/performancetest/GenericTest.java
@@@ -69,12 -69,9 +69,14 @@@ public class GenericTest implements Tes
public void execute(int nrRuns) {
String testType = System.getenv("TEST_TYPE");
+ String offloadingThreshold = System.getenv("OFFLOADING_THRESHOLD");
+
Object[] line = null;
+
+ if (testType.equals("Reconfiguration") && nrRuns == 0){
+ executeOffloading();
+ return;
+ }
//Start Pipeline
if (!pipeline.isRunning()) {
long beforeStart = System.nanoTime();