You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampipes.apache.org by ri...@apache.org on 2022/07/31 21:20:27 UTC
[incubator-streampipes] 01/06: [hotfix] Write tags in data explorer
This is an automated email from the ASF dual-hosted git repository.
riemer pushed a commit to branch STREAMPIPES-545
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes.git
commit 3a30261a0d798f7f588b6d144d44a22b34f675bd
Author: Dominik Riemer <do...@gmail.com>
AuthorDate: Fri Jul 29 15:55:51 2022 +0200
[hotfix] Write tags in data explorer
---
.../dataexplorer/commons/DataExplorerWriter.java | 2 +-
.../datalake-configuration.component.html | 13 ++++++++++++-
2 files changed, 13 insertions(+), 2 deletions(-)
diff --git a/streampipes-data-explorer-commons/src/main/java/org/apache/streampipes/dataexplorer/commons/DataExplorerWriter.java b/streampipes-data-explorer-commons/src/main/java/org/apache/streampipes/dataexplorer/commons/DataExplorerWriter.java
index 3f3a1edc6..afb7387e2 100644
--- a/streampipes-data-explorer-commons/src/main/java/org/apache/streampipes/dataexplorer/commons/DataExplorerWriter.java
+++ b/streampipes-data-explorer-commons/src/main/java/org/apache/streampipes/dataexplorer/commons/DataExplorerWriter.java
@@ -35,7 +35,7 @@ public class DataExplorerWriter {
} else if (data.get(key) instanceof Integer) {
builder.addField(key, (Integer) data.get(key));
} else {
- builder.addField(key, (String) data.get(key));
+ builder.tag(key, (String) data.get(key));
}
}
diff --git a/ui/src/app/configuration/datalake-configuration/datalake-configuration.component.html b/ui/src/app/configuration/datalake-configuration/datalake-configuration.component.html
index 07c6c0f3a..587a8b6b5 100644
--- a/ui/src/app/configuration/datalake-configuration/datalake-configuration.component.html
+++ b/ui/src/app/configuration/datalake-configuration/datalake-configuration.component.html
@@ -22,7 +22,18 @@
<div fxFlex="100" fxLayout="column" fxLayoutAlign="start start">
<sp-split-section title="Data Lake Settings" subtitle="Truncate and delete persisted data streams">
<div fxFlex="100" fxLayout="column">
- <div class="subsection-title">Existing data lake indices</div>
+ <div fxFlex="100" fxLayout="row">
+ <div fxFlex fxLayoutAlign="start center" class="subsection-title">Existing data lake indices</div>
+ <div fxLayout="row" fxLayoutAlign="end center">
+ <button color="accent"
+ mat-button
+ mat-icon-button
+ matTooltip="Refresh Schema"
+ (click)="loadAvailableMeasurements()">
+ <mat-icon>refresh</mat-icon>
+ </button>
+ </div>
+ </div>
<table fxFlex="100" mat-table data-cy="datalake-settings" [dataSource]="dataSource"
style="width: 100%;" matSort>