You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampipes.apache.org by wi...@apache.org on 2020/04/22 12:58:40 UTC
[incubator-streampipes] branch edge-extensions updated (0da1709 ->
56ad0a9)
This is an automated email from the ASF dual-hosted git repository.
wiener pushed a change to branch edge-extensions
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes.git.
from 0da1709 Merge pull request #15 from fogsy-io/dev
new 7f6b869 remove evaluation inserts
add 974958a Add feature to select all fields in dashboard table widget
add 5976698 Use visualization name as default value for widget title in dashboard
add 7434684 Pipeline editor: Clear pipeline element filter when element type is changed
add f2bcd7f Add restrictedEditMode for more flexible modification of pipeline element options
add 172028f Delay trigger of mapping property selection
add b1bd78d Fix some issues in LICENSE and NOTICE files
add 64f6b27 STREAMPIPES-105: Create Kafka Publisher Sink
add 99c736a [STREAMPIPES-106] Upgrade Siddhi dependency to v5.1.12
add 43111e0 Merge branch 'STREAMPIPES-106' of https://github.com/grainier/incubator-streampipes into grainier-STREAMPIPES-106
add 1989343 Change Siddhi wrapper to work with new API
add aaa3e3e Merge branch 'grainier-STREAMPIPES-106' into dev
add b4091a6 [STREAMPIPES-108] Integrate CVE maven plugin
add 83be6aa Merge branch 'grainier-STREAMPIPES-108' into dev
add dab3353 Update NOTICE-binary file
new 56ad0a9 Merge branch 'dev' into edge-extensions
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
LICENSE | 28 +-
LICENSE-binary | 18 +-
NOTICE-binary | 760 ++++++++++++++++++++-
pom.xml | 35 +-
.../messaging/jms/ActiveMQPublisher.java | 3 +-
.../rest/impl/PipelineWithUserResource.java | 35 -
streampipes-wrapper-siddhi/pom.xml | 11 +-
.../wrapper/siddhi/engine/SiddhiDebugCallback.java | 2 +-
.../wrapper/siddhi/engine/SiddhiEventEngine.java | 15 +-
.../wrapper/siddhi/manager/SpSiddhiManager.java | 2 +-
....xml => owasp-dependency-check-suppression.xml} | 19 +-
.../static-mapping-nary.component.html | 13 +-
...nent.css => static-mapping-nary.component.scss} | 1 +
.../static-mapping-nary.component.ts | 42 +-
.../components/widgets/table/table-config.ts | 2 +-
...css => add-visualization-dialog.component.scss} | 0
.../add-visualization-dialog.component.ts | 7 +-
.../dashboard/registry/widget-config-builder.ts | 6 +-
.../customize/customize-dialog.component.ts | 3 +-
.../customize/customize-dialog.tmpl.html | 12 +-
.../customoutput/customoutput.component.ts | 3 +-
.../components/customoutput/customoutput.tmpl.html | 21 +-
.../property-selection.component.ts | 3 +-
.../propertyselection/property-selection.tmpl.html | 3 +-
.../components/fileupload/fileupload.component.ts | 3 +-
.../components/fileupload/fileupload.tmpl.html | 8 +-
.../mappingnary/mappingnary.component.ts | 3 +-
.../components/mappingnary/mappingnary.tmpl.html | 6 +-
.../mappingunary/mappingunary.component.ts | 1 +
.../mappingunary/mappingunary.controller.ts | 8 +-
.../components/mappingunary/mappingunary.tmpl.html | 5 +-
.../editor/components/oneof/oneof.controller.ts | 5 +
.../pipeline-element-icon-stand.component.ts | 3 +-
.../pipeline-element-icon-stand.controller.ts | 10 +-
.../pipeline-element-icon-stand.tmpl.html | 4 +-
.../pipeline-element-options.controller.ts | 3 +-
.../pipeline-element-options.tmpl.html | 2 +-
.../components/pipeline/pipeline.controller.ts | 2 +-
.../replaceoutput/replaceoutput.component.ts | 3 +-
.../replaceoutput/replaceoutput.tmpl.html | 2 +-
.../customize.controller.ts | 9 +-
.../customizeElementDialog.tmpl.html | 22 +-
ui/src/app/editor/editor.controller.ts | 24 +-
ui/src/app/editor/editor.html | 4 +-
.../services/editor-dialog-manager.service.ts | 5 +-
ui/src/scss/sp/buttons.scss | 6 +
46 files changed, 1039 insertions(+), 143 deletions(-)
copy tools/maven/{suppressions.xml => owasp-dependency-check-suppression.xml} (65%)
rename ui/src/app/connect/static-properties/static-mapping-nary/{static-mapping-nary.component.css => static-mapping-nary.component.scss} (95%)
rename ui/src/app/dashboard/dialogs/add-widget/{add-visualization-dialog.component.css => add-visualization-dialog.component.scss} (100%)
[incubator-streampipes] 01/02: remove evaluation inserts
Posted by wi...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
wiener pushed a commit to branch edge-extensions
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes.git
commit 7f6b869ac54561b655935744223625ca3f90ad70
Author: Patrick Wiener <wi...@fzi.de>
AuthorDate: Wed Apr 15 16:37:01 2020 +0200
remove evaluation inserts
---
.../rest/impl/PipelineWithUserResource.java | 35 ----------------------
1 file changed, 35 deletions(-)
diff --git a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/PipelineWithUserResource.java b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/PipelineWithUserResource.java
index d7c9806..61a2d1c 100644
--- a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/PipelineWithUserResource.java
+++ b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/PipelineWithUserResource.java
@@ -58,10 +58,6 @@ public class PipelineWithUserResource extends AbstractRestInterface implements I
private static final Logger logger = LoggerFactory.getLogger(PipelineWithUserResource.class);
- private static ArrayList<Integer> startMeasures = new ArrayList<>();
- private static ArrayList<Integer> stopMeasures = new ArrayList<>();
- private static int MAX_TEST_RUN = 10;
-
@Override
public Response getAvailable(String username) {
// TODO Auto-generated method stub
@@ -145,25 +141,10 @@ public class PipelineWithUserResource extends AbstractRestInterface implements I
public Response start(@PathParam("username") String username, @PathParam("pipelineId") String pipelineId) {
try {
- long start = System.currentTimeMillis();
-
Pipeline pipeline = getPipelineStorage()
.getPipeline(pipelineId);
PipelineOperationStatus status = Operations.startPipeline(pipeline);
- // TODO: PERFORMANCE_TEST delete afterwards
- int delta = (int) (System.currentTimeMillis() - start);
-
- startMeasures.add(delta);
- logger.info("add new measure {}", startMeasures);
- if (startMeasures.size() == MAX_TEST_RUN) {
- IntSummaryStatistics s = startMeasures
- .stream()
- .mapToInt((x) -> x)
- .summaryStatistics();
- logger.info("start test results over {} test runs: {}", String.valueOf(MAX_TEST_RUN), s.toString());
- }
-
return ok(status);
} catch (Exception e) {
e.printStackTrace();
@@ -177,25 +158,9 @@ public class PipelineWithUserResource extends AbstractRestInterface implements I
@GsonWithIds
public Response stop(@PathParam("username") String username, @PathParam("pipelineId") String pipelineId) {
- long start = System.currentTimeMillis();
-
logger.info("User: " + username + " stopped pipeline: " + pipelineId);
PipelineManagement pm = new PipelineManagement();
-
- // TODO: PERFORMANCE_TEST delete afterwards
- int delta = (int) (System.currentTimeMillis() - start);
-
- stopMeasures.add(delta);
- logger.info("add new stop measure {}", stopMeasures);
- if (stopMeasures.size() == MAX_TEST_RUN) {
- IntSummaryStatistics s = stopMeasures
- .stream()
- .mapToInt((x) -> x)
- .summaryStatistics();
- logger.info("stop test results over {} test runs: {}", String.valueOf(MAX_TEST_RUN), s.toString());
- }
-
return pm.stopPipeline(pipelineId);
}
[incubator-streampipes] 02/02: Merge branch 'dev' into
edge-extensions
Posted by wi...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
wiener pushed a commit to branch edge-extensions
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes.git
commit 56ad0a924fa957c74fe798f66b9471e70828ce33
Merge: 7f6b869 dab3353
Author: Patrick Wiener <wi...@fzi.de>
AuthorDate: Wed Apr 22 14:58:07 2020 +0200
Merge branch 'dev' into edge-extensions
LICENSE | 28 +-
LICENSE-binary | 18 +-
NOTICE-binary | 760 ++++++++++++++++++++-
pom.xml | 35 +-
.../messaging/jms/ActiveMQPublisher.java | 3 +-
streampipes-wrapper-siddhi/pom.xml | 11 +-
.../wrapper/siddhi/engine/SiddhiDebugCallback.java | 2 +-
.../wrapper/siddhi/engine/SiddhiEventEngine.java | 15 +-
.../wrapper/siddhi/manager/SpSiddhiManager.java | 2 +-
.../maven/owasp-dependency-check-suppression.xml | 28 +-
.../static-mapping-nary.component.html | 13 +-
...nent.css => static-mapping-nary.component.scss} | 1 +
.../static-mapping-nary.component.ts | 42 +-
.../components/widgets/table/table-config.ts | 2 +-
...css => add-visualization-dialog.component.scss} | 0
.../add-visualization-dialog.component.ts | 7 +-
.../dashboard/registry/widget-config-builder.ts | 6 +-
.../customize/customize-dialog.component.ts | 3 +-
.../customize/customize-dialog.tmpl.html | 12 +-
.../customoutput/customoutput.component.ts | 3 +-
.../components/customoutput/customoutput.tmpl.html | 21 +-
.../property-selection.component.ts | 3 +-
.../propertyselection/property-selection.tmpl.html | 3 +-
.../components/fileupload/fileupload.component.ts | 3 +-
.../components/fileupload/fileupload.tmpl.html | 8 +-
.../mappingnary/mappingnary.component.ts | 3 +-
.../components/mappingnary/mappingnary.tmpl.html | 6 +-
.../mappingunary/mappingunary.component.ts | 1 +
.../mappingunary/mappingunary.controller.ts | 8 +-
.../components/mappingunary/mappingunary.tmpl.html | 5 +-
.../editor/components/oneof/oneof.controller.ts | 5 +
.../pipeline-element-icon-stand.component.ts | 3 +-
.../pipeline-element-icon-stand.controller.ts | 10 +-
.../pipeline-element-icon-stand.tmpl.html | 4 +-
.../pipeline-element-options.controller.ts | 3 +-
.../pipeline-element-options.tmpl.html | 2 +-
.../components/pipeline/pipeline.controller.ts | 2 +-
.../replaceoutput/replaceoutput.component.ts | 3 +-
.../replaceoutput/replaceoutput.tmpl.html | 2 +-
.../customize.controller.ts | 9 +-
.../customizeElementDialog.tmpl.html | 22 +-
ui/src/app/editor/editor.controller.ts | 24 +-
ui/src/app/editor/editor.html | 4 +-
.../services/editor-dialog-manager.service.ts | 5 +-
ui/src/scss/sp/buttons.scss | 6 +
45 files changed, 1040 insertions(+), 116 deletions(-)