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/10/07 20:04:35 UTC
[incubator-streampipes] branch STREAMPIPES-438 updated (9f283bb ->
5d85311)
This is an automated email from the ASF dual-hosted git repository.
zehnder pushed a change to branch STREAMPIPES-438
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes.git.
from 9f283bb Remova REST endpoint for adapter templates
new a8717ec Remove old wrapper classes representing lists
new 5d85311 Remove DomainPropertyProbalilityList
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:
.../master/health/AdapterHealthCheck.java | 23 +-
.../master/management/DescriptionManagement.java | 39 +-
.../management/WorkerAdministrationManagement.java | 2 +-
.../management/DescriptionManagementTest.java | 11 +-
.../init/AdapterServiceResourceProvider.java | 7 +-
.../init/ConnectWorkerDescriptionProvider.java | 64 +-
.../worker/management/AdapterWorkerManagement.java | 85 +-
...pterResource.java => AdapterAssetResource.java} | 28 +-
...kerResource.java => AdapterWorkerResource.java} | 8 +-
.../container/worker/rest/GuessResource.java | 3 +-
.../container/worker/rest/ProtocolResource.java | 75 -
.../container/worker/rest/WelcomePageWorker.java | 108 -
.../container/worker/utils/AdapterUtils.java | 2 +-
.../container/worker/utils/AdapterUtilsTest.java | 8 -
.../connect/RunningAdapterInstances.java | 10 +-
.../connect/adapter/guess/SchemaGuesser.java | 101 +-
.../streampipes/connect/adapter/guess/Mock.java | 26 -
.../connect/adapter/guess/SchemaGuesserTest.java | 132 -
.../connect/adapter/AdapterDescriptionList.java | 50 -
.../connect/adapter/AdapterSetDescription.java | 9 -
.../connect/grounding/FormatDescriptionList.java | 63 -
.../connect/grounding/ProtocolDescriptionList.java | 58 -
.../connect/guess/DomainPropertyProbability.java | 53 -
.../guess/DomainPropertyProbabilityList.java | 56 -
.../model/connect/guess/GuessSchema.java | 30 +-
.../rest/impl/connect/DescriptionResource.java | 16 +-
.../sdk/builder/adapter/GuessSchemaBuilder.java | 10 -
.../format-configuration.component.ts | 5 +-
ui/src/app/connect/services/rest.service.ts | 18 +-
ui/src/app/core-model/gen/streampipes-model.ts | 4967 ++++++++++----------
30 files changed, 2544 insertions(+), 3523 deletions(-)
rename streampipes-connect-container-worker/src/main/java/org/apache/streampipes/connect/container/worker/rest/{AdapterResource.java => AdapterAssetResource.java} (71%)
rename streampipes-connect-container-worker/src/main/java/org/apache/streampipes/connect/container/worker/rest/{WorkerResource.java => AdapterWorkerResource.java} (95%)
delete mode 100644 streampipes-connect-container-worker/src/main/java/org/apache/streampipes/connect/container/worker/rest/ProtocolResource.java
delete mode 100644 streampipes-connect-container-worker/src/main/java/org/apache/streampipes/connect/container/worker/rest/WelcomePageWorker.java
delete mode 100644 streampipes-connect/src/test/java/org/apache/streampipes/connect/adapter/guess/Mock.java
delete mode 100644 streampipes-connect/src/test/java/org/apache/streampipes/connect/adapter/guess/SchemaGuesserTest.java
delete mode 100644 streampipes-model/src/main/java/org/apache/streampipes/model/connect/adapter/AdapterDescriptionList.java
delete mode 100644 streampipes-model/src/main/java/org/apache/streampipes/model/connect/grounding/FormatDescriptionList.java
delete mode 100644 streampipes-model/src/main/java/org/apache/streampipes/model/connect/grounding/ProtocolDescriptionList.java
delete mode 100644 streampipes-model/src/main/java/org/apache/streampipes/model/connect/guess/DomainPropertyProbability.java
delete mode 100644 streampipes-model/src/main/java/org/apache/streampipes/model/connect/guess/DomainPropertyProbabilityList.java
[incubator-streampipes] 02/02: Remove DomainPropertyProbalilityList
Posted by ze...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
zehnder pushed a commit to branch STREAMPIPES-438
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes.git
commit 5d85311f665a662f7f614cb99fc05503b10719d3
Author: Philipp Zehnder <ze...@fzi.de>
AuthorDate: Thu Oct 7 22:04:07 2021 +0200
Remove DomainPropertyProbalilityList
---
.../connect/adapter/guess/SchemaGuesser.java | 101 +---------------
.../streampipes/connect/adapter/guess/Mock.java | 26 ----
.../connect/adapter/guess/SchemaGuesserTest.java | 132 ---------------------
.../connect/guess/DomainPropertyProbability.java | 53 ---------
.../guess/DomainPropertyProbabilityList.java | 56 ---------
.../model/connect/guess/GuessSchema.java | 30 +----
.../sdk/builder/adapter/GuessSchemaBuilder.java | 10 --
7 files changed, 4 insertions(+), 404 deletions(-)
diff --git a/streampipes-connect/src/main/java/org/apache/streampipes/connect/adapter/guess/SchemaGuesser.java b/streampipes-connect/src/main/java/org/apache/streampipes/connect/adapter/guess/SchemaGuesser.java
index ec561bd..53be8ab 100644
--- a/streampipes-connect/src/main/java/org/apache/streampipes/connect/adapter/guess/SchemaGuesser.java
+++ b/streampipes-connect/src/main/java/org/apache/streampipes/connect/adapter/guess/SchemaGuesser.java
@@ -18,115 +18,16 @@
package org.apache.streampipes.connect.adapter.guess;
-import org.apache.http.client.fluent.Form;
-import org.apache.http.client.fluent.Request;
-import org.apache.streampipes.model.connect.guess.DomainPropertyProbability;
-import org.apache.streampipes.model.connect.guess.DomainPropertyProbabilityList;
import org.apache.streampipes.model.connect.guess.GuessSchema;
-import org.apache.streampipes.model.schema.EventProperty;
-import org.apache.streampipes.model.schema.EventPropertyNested;
import org.apache.streampipes.model.schema.EventSchema;
-import org.apache.streampipes.serializers.json.GsonSerializer;
-
-
-import java.io.IOException;
-import java.util.ArrayList;
-import java.util.List;
-import java.util.Map;
public class SchemaGuesser {
- public static int port = 80;
-
- public static GuessSchema guessSchma(EventSchema eventSchema, List<Map<String, Object>> nElements) {
+ public static GuessSchema guessSchma(EventSchema eventSchema) {
GuessSchema result = new GuessSchema();
-// List<DomainPropertyProbabilityList> allDomainPropertyProbabilities = getDomainPropertyProbabitlyList(eventSchema.getEventProperties(), nElements, new ArrayList<>());
-
result.setEventSchema(eventSchema);
- result.setPropertyProbabilityList(new ArrayList<>());
-
-
- return result;
- }
-
- private static List<DomainPropertyProbabilityList> getDomainPropertyProbabitlyList(List<EventProperty> eventProperties,
- List<Map<String, Object>> nEventsParsed,
- List<String> keys) {
-
- List<DomainPropertyProbabilityList> result = new ArrayList<>();
- for (EventProperty ep : eventProperties) {
- if (ep instanceof EventPropertyNested) {
- List<EventProperty> li = ((EventPropertyNested) ep).getEventProperties();
- keys.add(ep.getRuntimeName());
- result.addAll(getDomainPropertyProbabitlyList(li, nEventsParsed, keys));
- } else {
- List<Object> tmp = new ArrayList<>();
- for (Map<String, Object> event : nEventsParsed) {
- Map<String, Object> subEvent = event;
- for (String k : keys) {
- subEvent = (Map<String, Object>) subEvent.get(k);
- }
-
- if (subEvent != null) {
- tmp.add(subEvent.get(ep.getRuntimeName()));
- }
- }
-
- DomainPropertyProbabilityList resultList = getDomainPropertyProbability(tmp.toArray());
- resultList.setRuntimeName(ep.getRuntimeName());
- result.add(resultList);
- }
-
- }
return result;
}
-
- /**
- * TODO replace this method, change python API to variables of DomainPropertyProbabilityList
- * @param objects
- * @return
- */
- public static PropertyGuessResults requestProbabilitiesObject(Object[] objects) {
-
- String probabilitiesJsonString = requestProbabilitiesString(objects);
- PropertyGuessResults res = GsonSerializer.getGsonWithIds().fromJson(probabilitiesJsonString,
- PropertyGuessResults.class);
- return res;
- }
-
- public static String requestProbabilitiesString(Object[] objects) {
- String httpRequestBody = GsonSerializer.getGsonWithIds()
- .toJson(objects);
-
- String httpResp = "{\"result\": []}";
-
- try {
- httpResp = Request.Post("http://localhost:" + port +"/predict")
- .addHeader("Content-Type", "application/x-www-form-urlencoded; charset=UTF-8")
- .bodyForm(Form.form().add("X", httpRequestBody).build()).execute().returnContent().asString();
- } catch (IOException e) {
- e.printStackTrace();
- }
-
-
- return httpResp;
- }
-
- public static DomainPropertyProbabilityList getDomainPropertyProbability(Object[] sampleData) {
- PropertyGuessResults pgr = requestProbabilitiesObject(sampleData);
-
- DomainPropertyProbabilityList result = new DomainPropertyProbabilityList();
-
-
- for (PropertyGuesses pg : pgr.getResult()) {
- Double d = pg.getProbability();
- result.addDomainPropertyProbability(new DomainPropertyProbability(pg.getClazz(), d.toString()));
- }
-
-
- return result;
- }
-
}
diff --git a/streampipes-connect/src/test/java/org/apache/streampipes/connect/adapter/guess/Mock.java b/streampipes-connect/src/test/java/org/apache/streampipes/connect/adapter/guess/Mock.java
deleted file mode 100644
index c72b4ac..0000000
--- a/streampipes-connect/src/test/java/org/apache/streampipes/connect/adapter/guess/Mock.java
+++ /dev/null
@@ -1,26 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- *
- */
-
-package org.apache.streampipes.connect.adapter.guess;
-
-public class Mock {
- public static int PORT = 8042;
-
- public static String HOST = "http://localhost:" + PORT;
-
-}
diff --git a/streampipes-connect/src/test/java/org/apache/streampipes/connect/adapter/guess/SchemaGuesserTest.java b/streampipes-connect/src/test/java/org/apache/streampipes/connect/adapter/guess/SchemaGuesserTest.java
deleted file mode 100644
index d8e2660..0000000
--- a/streampipes-connect/src/test/java/org/apache/streampipes/connect/adapter/guess/SchemaGuesserTest.java
+++ /dev/null
@@ -1,132 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- *
- */
-
-package org.apache.streampipes.connect.adapter.guess;
-
-import com.github.tomakehurst.wiremock.junit.WireMockRule;
-import org.junit.Before;
-import org.junit.Rule;
-import org.junit.Test;
-
-import static com.github.tomakehurst.wiremock.client.WireMock.*;
-import static com.github.tomakehurst.wiremock.core.WireMockConfiguration.wireMockConfig;
-import static org.junit.Assert.assertEquals;
-import static org.junit.Assert.assertNotNull;
-
-public class SchemaGuesserTest {
-
- @Rule
- public WireMockRule wireMockRule = new WireMockRule(wireMockConfig().port(Mock.PORT));
-
- @Before
- public void setPort() {
- SchemaGuesser.port = Mock.PORT;
- }
-
- @Test
- public void requestProbabilitiesStringTest() {
-
- String expected = "{\"result\": []}";
-
- stubFor(post(urlEqualTo("/predict"))
- .willReturn(aResponse()
- .withStatus(200)
- .withBody(expected)));
-
- SchemaGuesser schemaGuesser = new SchemaGuesser();
-
- Double[] data = {1.1, 2.0};
- String result = schemaGuesser.requestProbabilitiesString(data);
-
- assertEquals(expected, result);
-
- }
-
- @Test
- public void requestProbabilitiesStringEndpointNotAvailableTest() {
-
- String expected = "{\"result\": []}";
-
- stubFor(post(urlEqualTo("/predict"))
- .willReturn(aResponse()
- .withStatus(404)));
-
- SchemaGuesser schemaGuesser = new SchemaGuesser();
-
- Double[] data = {1.1, 2.0};
- String result = schemaGuesser.requestProbabilitiesString(data);
-
- assertEquals(expected, result);
-
- }
-
-// @Test
-// public void getDomainPropertyProbabilityTest() {
-//
-// String payload = "{\n" +
-// " \"result\": [\n" +
-// " {\n" +
-// " \"class\": \"one\", \n" +
-// " \"probability\": 1.1\n" +
-// " }]}";
-//
-// stubFor(post(urlEqualTo("/predict"))
-// .willReturn(aResponse()
-// .withStatus(200)
-// .withBody(payload)));
-//
-//
-// String[] data = {"a"};
-// DomainPropertyProbabilityList result = SchemaGuesser.getDomainPropertyProbability(data);
-//
-// assertNotNull(result.getList());
-// assertEquals(1, result.getList().size());
-// assertEquals("one", result.getList().get(0).getDomainProperty());
-// assertEquals("1.1", result.getList().get(0).getProbability());
-// }
-
- @Test
- public void requestProbabilitiesObjectTest() {
-
- String payload = "{\n" +
- " \"result\": [\n" +
- " {\n" +
- " \"class\": \"one\", \n" +
- " \"probability\": 1\n" +
- " }]}";
-
- stubFor(post(urlEqualTo("/predict"))
- .willReturn(aResponse()
- .withStatus(200)
- .withBody(payload)
- ));
-
-
- SchemaGuesser schemaGuesser = new SchemaGuesser();
-
- Double[] data = {1.1};
- PropertyGuessResults result = schemaGuesser.requestProbabilitiesObject(data);
-
- assertNotNull(result.getResult());
- assertEquals(1, result.getResult().length);
- assertEquals("one", result.getResult()[0].getClazz());
- assertEquals(1, result.getResult()[0].getProbability(), 0.0);
- }
-
-
-}
\ No newline at end of file
diff --git a/streampipes-model/src/main/java/org/apache/streampipes/model/connect/guess/DomainPropertyProbability.java b/streampipes-model/src/main/java/org/apache/streampipes/model/connect/guess/DomainPropertyProbability.java
deleted file mode 100644
index 17d04af..0000000
--- a/streampipes-model/src/main/java/org/apache/streampipes/model/connect/guess/DomainPropertyProbability.java
+++ /dev/null
@@ -1,53 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- *
- */
-
-package org.apache.streampipes.model.connect.guess;
-
-import org.apache.streampipes.model.base.UnnamedStreamPipesEntity;
-
-public class DomainPropertyProbability extends UnnamedStreamPipesEntity {
-
- private String domainProperty;
-
- private String probability;
-
- public DomainPropertyProbability() {
- super();
- }
-
- public DomainPropertyProbability(String domainProperty, String probability) {
- this.domainProperty = domainProperty;
- this.probability = probability;
- }
-
- public String getDomainProperty() {
- return domainProperty;
- }
-
- public void setDomainProperty(String domainProperty) {
- this.domainProperty = domainProperty;
- }
-
- public String getProbability() {
- return probability;
- }
-
- public void setProbability(String probability) {
- this.probability = probability;
- }
-}
diff --git a/streampipes-model/src/main/java/org/apache/streampipes/model/connect/guess/DomainPropertyProbabilityList.java b/streampipes-model/src/main/java/org/apache/streampipes/model/connect/guess/DomainPropertyProbabilityList.java
deleted file mode 100644
index 9727ae1..0000000
--- a/streampipes-model/src/main/java/org/apache/streampipes/model/connect/guess/DomainPropertyProbabilityList.java
+++ /dev/null
@@ -1,56 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- *
- */
-
-package org.apache.streampipes.model.connect.guess;
-
-import org.apache.streampipes.model.base.UnnamedStreamPipesEntity;
-
-import java.util.ArrayList;
-import java.util.List;
-
-public class DomainPropertyProbabilityList extends UnnamedStreamPipesEntity {
-
- private String runtimeName;
-
- private List<DomainPropertyProbability> list;
-
- public DomainPropertyProbabilityList() {
- super();
- list = new ArrayList<>();
- }
-
- public List<DomainPropertyProbability> getList() {
- return list;
- }
-
- public void setList(List<DomainPropertyProbability> list) {
- this.list = list;
- }
-
- public String getRuntimeName() {
- return runtimeName;
- }
-
- public void setRuntimeName(String runtimeName) {
- this.runtimeName = runtimeName;
- }
-
- public void addDomainPropertyProbability(DomainPropertyProbability property) {
- this.list.add(property);
- }
-}
diff --git a/streampipes-model/src/main/java/org/apache/streampipes/model/connect/guess/GuessSchema.java b/streampipes-model/src/main/java/org/apache/streampipes/model/connect/guess/GuessSchema.java
index c4610d3..4bda9da 100644
--- a/streampipes-model/src/main/java/org/apache/streampipes/model/connect/guess/GuessSchema.java
+++ b/streampipes-model/src/main/java/org/apache/streampipes/model/connect/guess/GuessSchema.java
@@ -22,36 +22,19 @@ import org.apache.streampipes.model.base.UnnamedStreamPipesEntity;
import org.apache.streampipes.model.schema.EventSchema;
import org.apache.streampipes.model.shared.annotation.TsModel;
-import java.util.ArrayList;
-import java.util.List;
-
@TsModel
public class GuessSchema extends UnnamedStreamPipesEntity {
public EventSchema eventSchema;
- public List<DomainPropertyProbabilityList> propertyProbabilityList;
-
public GuessSchema() {
super();
- this.propertyProbabilityList = new ArrayList<>();
-
-
}
- public GuessSchema(EventSchema schema, List<DomainPropertyProbabilityList> propertyProbabilityList) {
- super();
- this.eventSchema = schema;
- this.propertyProbabilityList = propertyProbabilityList;
+ public GuessSchema(GuessSchema other) {
+ super(other);
+ this.eventSchema = other.getEventSchema() != null ? new EventSchema(other.getEventSchema()) : null;
}
-
- public GuessSchema(GuessSchema other) {
- super(other);
- this.eventSchema = other.getEventSchema() != null ? new EventSchema(other.getEventSchema()) : null;
- }
-
-
-
public EventSchema getEventSchema() {
return eventSchema;
}
@@ -60,11 +43,4 @@ public class GuessSchema extends UnnamedStreamPipesEntity {
this.eventSchema = eventSchema;
}
- public List<DomainPropertyProbabilityList> getPropertyProbabilityList() {
- return propertyProbabilityList;
- }
-
- public void setPropertyProbabilityList(List<DomainPropertyProbabilityList> propertyProbabilityList) {
- this.propertyProbabilityList = propertyProbabilityList;
- }
}
diff --git a/streampipes-sdk/src/main/java/org/apache/streampipes/sdk/builder/adapter/GuessSchemaBuilder.java b/streampipes-sdk/src/main/java/org/apache/streampipes/sdk/builder/adapter/GuessSchemaBuilder.java
index 798dabe..91e0da1 100644
--- a/streampipes-sdk/src/main/java/org/apache/streampipes/sdk/builder/adapter/GuessSchemaBuilder.java
+++ b/streampipes-sdk/src/main/java/org/apache/streampipes/sdk/builder/adapter/GuessSchemaBuilder.java
@@ -17,7 +17,6 @@
*/
package org.apache.streampipes.sdk.builder.adapter;
-import org.apache.streampipes.model.connect.guess.DomainPropertyProbabilityList;
import org.apache.streampipes.model.connect.guess.GuessSchema;
import org.apache.streampipes.model.schema.EventProperty;
import org.apache.streampipes.model.schema.EventSchema;
@@ -28,11 +27,9 @@ import java.util.List;
public class GuessSchemaBuilder {
private List<EventProperty> eventProperties;
- private List<DomainPropertyProbabilityList> domainPropertyProbabilitiesList;
private GuessSchemaBuilder() {
this.eventProperties = new ArrayList<>();
- this.domainPropertyProbabilitiesList = new ArrayList<>();
}
/**
@@ -48,12 +45,6 @@ public class GuessSchemaBuilder {
return this;
}
- public GuessSchemaBuilder domainPropertyProbability(DomainPropertyProbabilityList domainPropertyProbabilityList) {
- this.domainPropertyProbabilitiesList.add(domainPropertyProbabilityList);
-
- return this;
- }
-
public GuessSchema build() {
GuessSchema guessSchema = new GuessSchema();
EventSchema eventSchema = new EventSchema();
@@ -65,7 +56,6 @@ public class GuessSchemaBuilder {
eventSchema.setEventProperties(eventProperties);
guessSchema.setEventSchema(eventSchema);
- guessSchema.setPropertyProbabilityList(domainPropertyProbabilitiesList);
return guessSchema;
}
[incubator-streampipes] 01/02: Remove old wrapper classes
representing lists
Posted by ze...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
zehnder pushed a commit to branch STREAMPIPES-438
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes.git
commit a8717ec18b951e426e117ac503e9276cd68ad58d
Author: Philipp Zehnder <ze...@fzi.de>
AuthorDate: Thu Oct 7 21:48:38 2021 +0200
Remove old wrapper classes representing lists
---
.../master/health/AdapterHealthCheck.java | 23 +-
.../master/management/DescriptionManagement.java | 39 +-
.../management/WorkerAdministrationManagement.java | 2 +-
.../management/DescriptionManagementTest.java | 11 +-
.../init/AdapterServiceResourceProvider.java | 7 +-
.../init/ConnectWorkerDescriptionProvider.java | 64 +-
.../worker/management/AdapterWorkerManagement.java | 85 +-
...pterResource.java => AdapterAssetResource.java} | 28 +-
...kerResource.java => AdapterWorkerResource.java} | 8 +-
.../container/worker/rest/GuessResource.java | 3 +-
.../container/worker/rest/ProtocolResource.java | 75 -
.../container/worker/rest/WelcomePageWorker.java | 108 -
.../container/worker/utils/AdapterUtils.java | 2 +-
.../container/worker/utils/AdapterUtilsTest.java | 8 -
.../connect/RunningAdapterInstances.java | 10 +-
.../connect/adapter/AdapterDescriptionList.java | 50 -
.../connect/adapter/AdapterSetDescription.java | 9 -
.../connect/grounding/FormatDescriptionList.java | 63 -
.../connect/grounding/ProtocolDescriptionList.java | 58 -
.../rest/impl/connect/DescriptionResource.java | 16 +-
.../format-configuration.component.ts | 5 +-
ui/src/app/connect/services/rest.service.ts | 18 +-
ui/src/app/core-model/gen/streampipes-model.ts | 4967 ++++++++++----------
23 files changed, 2540 insertions(+), 3119 deletions(-)
diff --git a/streampipes-connect-container-master/src/main/java/org/apache/streampipes/connect/container/master/health/AdapterHealthCheck.java b/streampipes-connect-container-master/src/main/java/org/apache/streampipes/connect/container/master/health/AdapterHealthCheck.java
index f343c8b..42577ba 100644
--- a/streampipes-connect-container-master/src/main/java/org/apache/streampipes/connect/container/master/health/AdapterHealthCheck.java
+++ b/streampipes-connect-container-master/src/main/java/org/apache/streampipes/connect/container/master/health/AdapterHealthCheck.java
@@ -22,7 +22,7 @@ import org.apache.streampipes.connect.api.exception.AdapterException;
import org.apache.streampipes.connect.container.master.management.AdapterMasterManagement;
import org.apache.streampipes.model.connect.adapter.AdapterDescription;
import org.apache.streampipes.storage.api.IAdapterStorage;
-import org.apache.streampipes.storage.couchdb.impl.AdapterInstanceStorageImpl;
+import org.apache.streampipes.storage.couchdb.CouchDbStorageManager;
import java.util.List;
@@ -33,31 +33,26 @@ public class AdapterHealthCheck {
public void checkAndRestoreAdapters() {
AdapterMasterManagement adapterMasterManagement = new AdapterMasterManagement();
- IAdapterStorage adapterStorage = new AdapterInstanceStorageImpl();
+
+ IAdapterStorage adapterStorage = CouchDbStorageManager.INSTANCE.getAdapterInstanceStorage();
// Get all adapters
List<AdapterDescription> allRunningInstancesAdaperDescription = adapterStorage.getAllAdapters();
- // Group them by worker
-
for (AdapterDescription adapterDescription : allRunningInstancesAdaperDescription) {
- try {
-
- adapterMasterManagement.startStreamAdapter(adapterDescription.getElementId());
- } catch (AdapterException e) {
- e.printStackTrace();
- }
-
- }
// Ask worker if they are up and running
// If not
- // Find a worker to run them
-
// Invoke the adapters
+ try {
+ adapterMasterManagement.startStreamAdapter(adapterDescription.getElementId());
+ } catch (AdapterException e) {
+ e.printStackTrace();
+ }
+ }
}
diff --git a/streampipes-connect-container-master/src/main/java/org/apache/streampipes/connect/container/master/management/DescriptionManagement.java b/streampipes-connect-container-master/src/main/java/org/apache/streampipes/connect/container/master/management/DescriptionManagement.java
index 49f23b2..834c764 100644
--- a/streampipes-connect-container-master/src/main/java/org/apache/streampipes/connect/container/master/management/DescriptionManagement.java
+++ b/streampipes-connect-container-master/src/main/java/org/apache/streampipes/connect/container/master/management/DescriptionManagement.java
@@ -22,49 +22,30 @@ import org.apache.streampipes.connect.adapter.AdapterRegistry;
import org.apache.streampipes.connect.api.IFormat;
import org.apache.streampipes.connect.api.exception.AdapterException;
import org.apache.streampipes.model.connect.adapter.AdapterDescription;
-import org.apache.streampipes.model.connect.grounding.FormatDescriptionList;
-import org.apache.streampipes.model.connect.grounding.ProtocolDescription;
-import org.apache.streampipes.model.connect.grounding.ProtocolDescriptionList;
-import org.apache.streampipes.model.connect.worker.ConnectWorkerContainer;
+import org.apache.streampipes.model.connect.grounding.FormatDescription;
import org.apache.streampipes.storage.api.IAdapterStorage;
-import org.apache.streampipes.storage.couchdb.impl.AdapterDescriptionStorageImpl;
-import org.apache.streampipes.storage.couchdb.impl.ConnectionWorkerContainerStorageImpl;
+import org.apache.streampipes.storage.couchdb.CouchDbStorageManager;
+import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import java.util.Optional;
public class DescriptionManagement {
- @Deprecated
- public ProtocolDescriptionList getProtocols() {
- ConnectionWorkerContainerStorageImpl connectionWorkerContainerStorage = new ConnectionWorkerContainerStorageImpl();
-
- List<ConnectWorkerContainer> allWorkerContainter = connectionWorkerContainerStorage.getAllConnectWorkerContainers();
-
- ProtocolDescriptionList result = new ProtocolDescriptionList();
-
- for (ConnectWorkerContainer connectWorkerContainer : allWorkerContainter) {
- result.getList().addAll(connectWorkerContainer.getProtocols());
- }
-
- return result;
- }
-
- public FormatDescriptionList getFormats() {
+ public List<FormatDescription> getFormats() {
Map<String, IFormat> allFormats = AdapterRegistry.getAllFormats();
- FormatDescriptionList result = new FormatDescriptionList();
-
+ List<FormatDescription> result = new ArrayList<>();
for (IFormat f : allFormats.values()) {
- result.getList().add(f.declareModel());
+ result.add(f.declareModel());
}
return result;
}
public List<AdapterDescription> getAdapters() {
- IAdapterStorage adapterStorage = new AdapterDescriptionStorageImpl();
+ IAdapterStorage adapterStorage = CouchDbStorageManager.INSTANCE.getAdapterDescriptionStorage();
return adapterStorage.getAllAdapters();
}
@@ -74,12 +55,6 @@ public class DescriptionManagement {
.findFirst();
}
- public Optional<ProtocolDescription> getProtocol(String id) {
- return getProtocols().getList().stream()
- .filter(desc -> desc.getAppId().equals(id))
- .findFirst();
- }
-
public String getAssets(String baseUrl) throws AdapterException {
return WorkerRestClient.getAssets(baseUrl);
}
diff --git a/streampipes-connect-container-master/src/main/java/org/apache/streampipes/connect/container/master/management/WorkerAdministrationManagement.java b/streampipes-connect-container-master/src/main/java/org/apache/streampipes/connect/container/master/management/WorkerAdministrationManagement.java
index 254c651..42f954a 100644
--- a/streampipes-connect-container-master/src/main/java/org/apache/streampipes/connect/container/master/management/WorkerAdministrationManagement.java
+++ b/streampipes-connect-container-master/src/main/java/org/apache/streampipes/connect/container/master/management/WorkerAdministrationManagement.java
@@ -61,7 +61,7 @@ public class WorkerAdministrationManagement {
}
});
-// this.adapterHealthCheck.checkAndRestoreAdapters();
+ this.adapterHealthCheck.checkAndRestoreAdapters();
// Check if already registered
diff --git a/streampipes-connect-container-master/src/test/java/org/apache/streampipes/connect/container/master/management/DescriptionManagementTest.java b/streampipes-connect-container-master/src/test/java/org/apache/streampipes/connect/container/master/management/DescriptionManagementTest.java
index d8f6fd6..a83a585 100644
--- a/streampipes-connect-container-master/src/test/java/org/apache/streampipes/connect/container/master/management/DescriptionManagementTest.java
+++ b/streampipes-connect-container-master/src/test/java/org/apache/streampipes/connect/container/master/management/DescriptionManagementTest.java
@@ -21,7 +21,7 @@ package org.apache.streampipes.connect.container.master.management;
import org.apache.streampipes.connect.adapter.AdapterRegistry;
import org.apache.streampipes.connect.adapter.format.json.arraykey.JsonFormat;
import org.apache.streampipes.connect.api.IFormat;
-import org.apache.streampipes.model.connect.grounding.FormatDescriptionList;
+import org.apache.streampipes.model.connect.grounding.FormatDescription;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.mockito.Mockito;
@@ -31,6 +31,7 @@ import org.powermock.core.classloader.annotations.PrepareForTest;
import org.powermock.modules.junit4.PowerMockRunner;
import java.util.HashMap;
+import java.util.List;
import java.util.Map;
import static org.junit.Assert.assertEquals;
@@ -53,12 +54,12 @@ public class DescriptionManagementTest {
DescriptionManagement descriptionManagement = new DescriptionManagement();
- FormatDescriptionList result = descriptionManagement.getFormats();
+ List<FormatDescription> result = descriptionManagement.getFormats();
assertNotNull(result);
- assertNotNull(result.getList());
- assertEquals(1, result.getList().size());
- assertEquals(JsonFormat.ID, result.getList().get(0).getAppId());
+ assertNotNull(result);
+ assertEquals(1, result.size());
+ assertEquals(JsonFormat.ID, result.get(0).getAppId());
}
}
diff --git a/streampipes-connect-container-worker/src/main/java/org/apache/streampipes/connect/container/worker/init/AdapterServiceResourceProvider.java b/streampipes-connect-container-worker/src/main/java/org/apache/streampipes/connect/container/worker/init/AdapterServiceResourceProvider.java
index 2db077a..5450f0e 100644
--- a/streampipes-connect-container-worker/src/main/java/org/apache/streampipes/connect/container/worker/init/AdapterServiceResourceProvider.java
+++ b/streampipes-connect-container-worker/src/main/java/org/apache/streampipes/connect/container/worker/init/AdapterServiceResourceProvider.java
@@ -28,13 +28,12 @@ public class AdapterServiceResourceProvider implements ExtensionsResourceProvide
@Override
public List<Class<?>> getResourceClasses() {
- return Arrays.asList(WelcomePageWorker.class,
+ return Arrays.asList(
GuessResource.class,
RuntimeResolvableResource.class,
- WorkerResource.class,
+ AdapterWorkerResource.class,
MultiPartFeature.class,
- AdapterResource.class,
- ProtocolResource.class,
+ AdapterAssetResource.class,
HttpServerAdapterResource.class);
}
}
diff --git a/streampipes-connect-container-worker/src/main/java/org/apache/streampipes/connect/container/worker/init/ConnectWorkerDescriptionProvider.java b/streampipes-connect-container-worker/src/main/java/org/apache/streampipes/connect/container/worker/init/ConnectWorkerDescriptionProvider.java
index 255b814..0c9789d 100644
--- a/streampipes-connect-container-worker/src/main/java/org/apache/streampipes/connect/container/worker/init/ConnectWorkerDescriptionProvider.java
+++ b/streampipes-connect-container-worker/src/main/java/org/apache/streampipes/connect/container/worker/init/ConnectWorkerDescriptionProvider.java
@@ -32,7 +32,9 @@ import org.slf4j.LoggerFactory;
import java.io.IOException;
import java.util.ArrayList;
+import java.util.Collection;
import java.util.List;
+import java.util.Optional;
public class ConnectWorkerDescriptionProvider {
@@ -40,14 +42,51 @@ public class ConnectWorkerDescriptionProvider {
public List<AdapterDescription> getContainerDescription(String serviceGroup) {
- List<AdapterDescription> adapters = new ArrayList<>();
+ List<AdapterDescription> allAdapterDescriptions = new ArrayList<>();
+ allAdapterDescriptions.addAll(getSpecificAdapterDescriptions(serviceGroup));
+ allAdapterDescriptions.addAll(getGenericAdapterDescriptions(serviceGroup));
+
+ return allAdapterDescriptions;
+ }
+
+ public Optional<AdapterDescription> getAdapterDescription(String appId) {
+ List<AdapterDescription> allAdapterDescriptions = getContainerDescription("");
+ return allAdapterDescriptions
+ .stream()
+ .filter(ad -> ad.getAppId().equals(appId))
+ .findFirst();
+ }
+
+ private NamedStreamPipesEntity rewrite(NamedStreamPipesEntity entity) {
+ // TODO remove after full internationalization support has been implemented
+ if (entity.isIncludesLocales()) {
+ LabelGenerator lg = new LabelGenerator(entity);
+ try {
+ entity = lg.generateLabels();
+ } catch (IOException e) {
+ LOG.error("Could not load labels for: " + entity.getAppId());
+ }
+ }
+ return entity;
+ }
+
+ private List<AdapterDescription> getSpecificAdapterDescriptions(String serviceGroup) {
+ List<AdapterDescription> result = new ArrayList<>();
for (IAdapter<?> a : DeclarersSingleton.getInstance().getAllAdapters()) {
AdapterDescription desc = (AdapterDescription) rewrite(a.declareModel());
desc.setCorrespondingServiceGroup(serviceGroup);
- adapters.add(desc);
+ result.add(desc);
}
- for (IProtocol p : DeclarersSingleton.getInstance().getAllProtocols()) {
+ return result;
+ }
+
+ private List<AdapterDescription> getGenericAdapterDescriptions(String serviceGroup) {
+ List<AdapterDescription> result = new ArrayList<>();
+
+ Collection<IProtocol> allProtocols = DeclarersSingleton.getInstance().getAllProtocols();
+
+ for (IProtocol p : allProtocols) {
ProtocolDescription protocolDescription = (ProtocolDescription) rewrite(p.declareModel());
if (protocolDescription.getSourceType().equals(AdapterSourceType.STREAM.toString())) {
@@ -59,7 +98,7 @@ public class ConnectWorkerDescriptionProvider {
desc.setAppId(protocolDescription.getAppId());
desc.setProtocolDescription(protocolDescription);
desc.setCorrespondingServiceGroup(serviceGroup);
- adapters.add(desc);
+ result.add(desc);
} else if (protocolDescription.getSourceType().equals(AdapterSourceType.SET.toString())) {
GenericAdapterSetDescription desc = new GenericAdapterSetDescription();
desc.setName(protocolDescription.getName());
@@ -69,23 +108,10 @@ public class ConnectWorkerDescriptionProvider {
desc.setAppId(protocolDescription.getAppId());
desc.setProtocolDescription(protocolDescription);
desc.setCorrespondingServiceGroup(serviceGroup);
- adapters.add(desc);
+ result.add(desc);
}
}
- return adapters;
- }
-
- private NamedStreamPipesEntity rewrite(NamedStreamPipesEntity entity) {
- // TODO remove after full internationalization support has been implemented
- if (entity.isIncludesLocales()) {
- LabelGenerator lg = new LabelGenerator(entity);
- try {
- entity = lg.generateLabels();
- } catch (IOException e) {
- LOG.error("Could not load labels for: " + entity.getAppId());
- }
- }
- return entity;
+ return result;
}
}
diff --git a/streampipes-connect-container-worker/src/main/java/org/apache/streampipes/connect/container/worker/management/AdapterWorkerManagement.java b/streampipes-connect-container-worker/src/main/java/org/apache/streampipes/connect/container/worker/management/AdapterWorkerManagement.java
index 0ff1dd0..0e5b06c 100644
--- a/streampipes-connect-container-worker/src/main/java/org/apache/streampipes/connect/container/worker/management/AdapterWorkerManagement.java
+++ b/streampipes-connect-container-worker/src/main/java/org/apache/streampipes/connect/container/worker/management/AdapterWorkerManagement.java
@@ -18,108 +18,41 @@
package org.apache.streampipes.connect.container.worker.management;
-import org.apache.streampipes.config.backend.BackendConfig;
import org.apache.streampipes.connect.RunningAdapterInstances;
-import org.apache.streampipes.connect.adapter.model.generic.GenericAdapter;
import org.apache.streampipes.connect.api.IAdapter;
-import org.apache.streampipes.connect.api.IProtocol;
import org.apache.streampipes.connect.api.exception.AdapterException;
import org.apache.streampipes.connect.container.worker.utils.AdapterUtils;
-import org.apache.streampipes.container.init.DeclarersSingleton;
-import org.apache.streampipes.model.SpDataSet;
-import org.apache.streampipes.model.connect.adapter.*;
+import org.apache.streampipes.model.connect.adapter.AdapterDescription;
+import org.apache.streampipes.model.connect.adapter.AdapterSetDescription;
+import org.apache.streampipes.model.connect.adapter.AdapterStreamDescription;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-import java.util.Collection;
-
public class AdapterWorkerManagement {
private static final Logger logger = LoggerFactory.getLogger(AdapterWorkerManagement.class);
- public Collection<IProtocol> getAllProtocols() {
- return DeclarersSingleton.getInstance().getAllProtocols();
- }
-
- public IProtocol getProtocol(String id) {
- return DeclarersSingleton.getInstance().getProtocol(id);
- }
-
- public Collection<IAdapter> getAllAdapters() {
- return DeclarersSingleton.getInstance().getAllAdapters();
- }
-
- public IAdapter<?> getAdapter(String id) {
- return DeclarersSingleton.getInstance().getAdapter(id);
- }
-
public void invokeStreamAdapter(AdapterStreamDescription adapterStreamDescription) throws AdapterException {
-
-// Adapter adapter = AdapterDeclarerSingleton.getInstance().getAdapter(adapterStreamDescription.getAppId());
IAdapter<?> adapter = AdapterUtils.setAdapter(adapterStreamDescription);
- IProtocol protocol = null;
- if (adapterStreamDescription instanceof GenericAdapterStreamDescription) {
- //TODO Need to check with ElementId?
- //protocol = AdapterDeclarerSingleton.getInstance().getProtocol(((GenericAdapterStreamDescription) adapterStreamDescription).getProtocolDescription().getElementId());
- protocol = DeclarersSingleton.getInstance().getProtocol(((GenericAdapterStreamDescription) adapterStreamDescription).getProtocolDescription().getAppId());
- if (protocol == null) {
- protocol = DeclarersSingleton.getInstance().getProtocol(((GenericAdapterStreamDescription) adapterStreamDescription).getProtocolDescription().getAppId());
- }
- ((GenericAdapter) adapter).setProtocol(protocol);
- }
-
- RunningAdapterInstances.INSTANCE.addAdapter(adapterStreamDescription.getUri(), adapter);
+ RunningAdapterInstances.INSTANCE.addAdapter(adapterStreamDescription.getElementId(), adapter);
adapter.startAdapter();
-
}
public void stopStreamAdapter(AdapterStreamDescription adapterStreamDescription) throws AdapterException {
stopAdapter(adapterStreamDescription);
-
}
public void invokeSetAdapter (AdapterSetDescription adapterSetDescription) throws AdapterException {
IAdapter<?> adapter = AdapterUtils.setAdapter(adapterSetDescription);
- IProtocol protocol = null;
- if (adapterSetDescription instanceof GenericAdapterSetDescription) {
- protocol = DeclarersSingleton.getInstance().getProtocol(((GenericAdapterSetDescription) adapterSetDescription).getProtocolDescription().getAppId());
- ((GenericAdapter) adapter).setProtocol(protocol);
- }
-
- SpDataSet dataSet = adapterSetDescription.getDataSet();
-
- RunningAdapterInstances.INSTANCE.addAdapter(adapterSetDescription.getUri(), adapter);
+ RunningAdapterInstances.INSTANCE.addAdapter(adapterSetDescription.getElementId(), adapter);
adapter.changeEventGrounding(adapterSetDescription.getDataSet().getEventGrounding().getTransportProtocol());
- // Set adapters run the whole set in one thread, once all data is processed the corresponding pipeline is stopped
- Runnable r = () -> {
- try {
- adapter.startAdapter();
- } catch (AdapterException e) {
- e.printStackTrace();
- }
-
- if (adapterSetDescription.isStopPipeline()) {
-
- try {
- Thread.sleep(20000);
- } catch (InterruptedException e) {
- e.printStackTrace();
- }
- // TODO Service Discovery
- String url = AdapterUtils.getUrl(BackendConfig.INSTANCE.getBackendApiUrl(), dataSet.getCorrespondingPipeline());
- String result = AdapterUtils.stopPipeline(url);
- logger.info(result);
-
- }
- };
-
- new Thread(r).start();
+ adapter.startAdapter();
}
public void stopSetAdapter (AdapterSetDescription adapterSetDescription) throws AdapterException {
@@ -128,12 +61,12 @@ public class AdapterWorkerManagement {
private void stopAdapter(AdapterDescription adapterDescription) throws AdapterException {
- String adapterUri = adapterDescription.getUri();
+ String elementId = adapterDescription.getElementId();
- IAdapter<?> adapter = RunningAdapterInstances.INSTANCE.removeAdapter(adapterUri);
+ IAdapter<?> adapter = RunningAdapterInstances.INSTANCE.removeAdapter(elementId);
if (adapter == null) {
- throw new AdapterException("Adapter with id " + adapterUri + " was not found in this container and cannot be stopped.");
+ throw new AdapterException("Adapter with id " + elementId + " was not found in this container and cannot be stopped.");
}
adapter.stopAdapter();
diff --git a/streampipes-connect-container-worker/src/main/java/org/apache/streampipes/connect/container/worker/rest/AdapterResource.java b/streampipes-connect-container-worker/src/main/java/org/apache/streampipes/connect/container/worker/rest/AdapterAssetResource.java
similarity index 71%
rename from streampipes-connect-container-worker/src/main/java/org/apache/streampipes/connect/container/worker/rest/AdapterResource.java
rename to streampipes-connect-container-worker/src/main/java/org/apache/streampipes/connect/container/worker/rest/AdapterAssetResource.java
index 0c0d4f9..2a5bcf4 100644
--- a/streampipes-connect-container-worker/src/main/java/org/apache/streampipes/connect/container/worker/rest/AdapterResource.java
+++ b/streampipes-connect-container-worker/src/main/java/org/apache/streampipes/connect/container/worker/rest/AdapterAssetResource.java
@@ -19,9 +19,10 @@ package org.apache.streampipes.connect.container.worker.rest;
import com.google.common.base.Charsets;
import com.google.common.io.Resources;
-import org.apache.streampipes.connect.container.worker.management.AdapterWorkerManagement;
+import org.apache.streampipes.connect.container.worker.init.ConnectWorkerDescriptionProvider;
import org.apache.streampipes.container.assets.AssetZipGenerator;
import org.apache.streampipes.container.util.AssetsUtil;
+import org.apache.streampipes.model.connect.adapter.AdapterDescription;
import org.apache.streampipes.rest.shared.impl.AbstractSharedRestInterface;
import javax.ws.rs.GET;
@@ -32,15 +33,15 @@ import javax.ws.rs.core.MediaType;
import javax.ws.rs.core.Response;
import java.io.IOException;
import java.net.URL;
-import java.util.List;
+import java.util.Optional;
@Path("/api/v1/worker/adapters")
-public class AdapterResource extends AbstractSharedRestInterface {
+public class AdapterAssetResource extends AbstractSharedRestInterface {
- private AdapterWorkerManagement adapterWorkerManagement;
+ private ConnectWorkerDescriptionProvider connectWorkerDescriptionProvider;
- public AdapterResource() {
- this.adapterWorkerManagement = new AdapterWorkerManagement();
+ public AdapterAssetResource() {
+ this.connectWorkerDescriptionProvider = new ConnectWorkerDescriptionProvider();
}
@@ -48,13 +49,18 @@ public class AdapterResource extends AbstractSharedRestInterface {
@Path("/{id}/assets")
@Produces("application/zip")
public Response getAssets(@PathParam("id") String id) {
- List<String> includedAssets = this.adapterWorkerManagement.getAdapter(id).declareModel().getIncludedAssets();
- try {
- return ok(new AssetZipGenerator(id, includedAssets).makeZip());
- } catch (IOException e) {
- e.printStackTrace();
+ Optional<AdapterDescription> adapterDescription = this.connectWorkerDescriptionProvider.getAdapterDescription(id);
+ if (adapterDescription.isPresent()) {
+ try {
+ return ok(new AssetZipGenerator(id, adapterDescription.get().getIncludedAssets()).makeZip());
+ } catch (IOException e) {
+ e.printStackTrace();
+ return fail();
+ }
+ } else {
return fail();
}
+
}
@GET
diff --git a/streampipes-connect-container-worker/src/main/java/org/apache/streampipes/connect/container/worker/rest/WorkerResource.java b/streampipes-connect-container-worker/src/main/java/org/apache/streampipes/connect/container/worker/rest/AdapterWorkerResource.java
similarity index 95%
rename from streampipes-connect-container-worker/src/main/java/org/apache/streampipes/connect/container/worker/rest/WorkerResource.java
rename to streampipes-connect-container-worker/src/main/java/org/apache/streampipes/connect/container/worker/rest/AdapterWorkerResource.java
index cbc0537..d252a12 100644
--- a/streampipes-connect-container-worker/src/main/java/org/apache/streampipes/connect/container/worker/rest/WorkerResource.java
+++ b/streampipes-connect-container-worker/src/main/java/org/apache/streampipes/connect/container/worker/rest/AdapterWorkerResource.java
@@ -36,17 +36,17 @@ import javax.ws.rs.core.MediaType;
import javax.ws.rs.core.Response;
@Path("/api/v1/worker")
-public class WorkerResource extends AbstractSharedRestInterface {
+public class AdapterWorkerResource extends AbstractSharedRestInterface {
- private static final Logger logger = LoggerFactory.getLogger(WorkerResource.class);
+ private static final Logger logger = LoggerFactory.getLogger(AdapterWorkerResource.class);
private AdapterWorkerManagement adapterManagement;
- public WorkerResource() {
+ public AdapterWorkerResource() {
adapterManagement = new AdapterWorkerManagement();
}
- public WorkerResource(AdapterWorkerManagement adapterManagement) {
+ public AdapterWorkerResource(AdapterWorkerManagement adapterManagement) {
this.adapterManagement = adapterManagement;
}
diff --git a/streampipes-connect-container-worker/src/main/java/org/apache/streampipes/connect/container/worker/rest/GuessResource.java b/streampipes-connect-container-worker/src/main/java/org/apache/streampipes/connect/container/worker/rest/GuessResource.java
index ed51a40..39d8784 100644
--- a/streampipes-connect-container-worker/src/main/java/org/apache/streampipes/connect/container/worker/rest/GuessResource.java
+++ b/streampipes-connect-container-worker/src/main/java/org/apache/streampipes/connect/container/worker/rest/GuessResource.java
@@ -30,7 +30,6 @@ import org.slf4j.LoggerFactory;
import javax.ws.rs.POST;
import javax.ws.rs.Path;
-import javax.ws.rs.PathParam;
import javax.ws.rs.Produces;
import javax.ws.rs.core.MediaType;
import javax.ws.rs.core.Response;
@@ -55,7 +54,7 @@ public class GuessResource extends AbstractSharedRestInterface {
@JacksonSerialized
@Path("/schema")
@Produces(MediaType.APPLICATION_JSON)
- public Response guessSchema(AdapterDescription adapterDescription, @PathParam("username") String userName) {
+ public Response guessSchema(AdapterDescription adapterDescription) {
try {
GuessSchema result = guessManagement.guessSchema(adapterDescription);
diff --git a/streampipes-connect-container-worker/src/main/java/org/apache/streampipes/connect/container/worker/rest/ProtocolResource.java b/streampipes-connect-container-worker/src/main/java/org/apache/streampipes/connect/container/worker/rest/ProtocolResource.java
deleted file mode 100644
index 5dbd005..0000000
--- a/streampipes-connect-container-worker/src/main/java/org/apache/streampipes/connect/container/worker/rest/ProtocolResource.java
+++ /dev/null
@@ -1,75 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.streampipes.connect.container.worker.rest;
-
-import com.google.common.base.Charsets;
-import com.google.common.io.Resources;
-import org.apache.streampipes.connect.container.worker.management.AdapterWorkerManagement;
-import org.apache.streampipes.container.assets.AssetZipGenerator;
-import org.apache.streampipes.container.util.AssetsUtil;
-import org.apache.streampipes.rest.shared.impl.AbstractSharedRestInterface;
-
-import javax.ws.rs.GET;
-import javax.ws.rs.Path;
-import javax.ws.rs.PathParam;
-import javax.ws.rs.Produces;
-import javax.ws.rs.core.MediaType;
-import javax.ws.rs.core.Response;
-import java.io.IOException;
-import java.net.URL;
-import java.util.List;
-
-@Path("/api/v1/worker/protocols")
-public class ProtocolResource extends AbstractSharedRestInterface {
-
- private AdapterWorkerManagement adapterWorkerManagement;
-
- public ProtocolResource() {
- this.adapterWorkerManagement = new AdapterWorkerManagement();
- }
-
-
- @GET
- @Path("/{id}/assets")
- @Produces("application/zip")
- public Response getAssets(@PathParam("id") String id) {
- List<String> includedAssets = this.adapterWorkerManagement.getProtocol(id).declareModel().getIncludedAssets();
- try {
- return ok(new AssetZipGenerator(id, includedAssets).makeZip());
- } catch (IOException e) {
- e.printStackTrace();
- return fail();
- }
- }
-
- @GET
- @Path("/{id}/assets/icon")
- @Produces("image/png")
- public Response getIconAsset(@PathParam("id") String elementId) throws IOException {
- URL iconUrl = Resources.getResource(AssetsUtil.makeIconPath(elementId));
- return ok(Resources.toByteArray(iconUrl));
- }
-
- @GET
- @Path("/{id}/assets/documentation")
- @Produces(MediaType.TEXT_PLAIN)
- public String getDocumentationAsset(@PathParam("id") String elementId) throws IOException {
- URL documentationUrl = Resources.getResource(AssetsUtil.makeDocumentationPath(elementId));
- return Resources.toString(documentationUrl, Charsets.UTF_8);
- }
-}
diff --git a/streampipes-connect-container-worker/src/main/java/org/apache/streampipes/connect/container/worker/rest/WelcomePageWorker.java b/streampipes-connect-container-worker/src/main/java/org/apache/streampipes/connect/container/worker/rest/WelcomePageWorker.java
deleted file mode 100644
index c07ec73..0000000
--- a/streampipes-connect-container-worker/src/main/java/org/apache/streampipes/connect/container/worker/rest/WelcomePageWorker.java
+++ /dev/null
@@ -1,108 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- *
- */
-
-package org.apache.streampipes.connect.container.worker.rest;
-
-
-import org.apache.streampipes.connect.api.IAdapter;
-import org.apache.streampipes.connect.api.IProtocol;
-import org.apache.streampipes.connect.container.worker.management.AdapterWorkerManagement;
-import org.apache.streampipes.rest.shared.impl.AbstractSharedRestInterface;
-import org.rendersnake.HtmlCanvas;
-
-import javax.ws.rs.GET;
-import javax.ws.rs.Path;
-import javax.ws.rs.Produces;
-import javax.ws.rs.core.MediaType;
-import java.io.IOException;
-import java.util.Collection;
-
-@Path("/worker")
-public class WelcomePageWorker extends AbstractSharedRestInterface {
-
- private String id;
-
- private AdapterWorkerManagement adapterWorkerManagement;
-
- public WelcomePageWorker() {
- this.id = "Worker01";
- this.adapterWorkerManagement = new AdapterWorkerManagement();
- }
-
- public WelcomePageWorker(String id) {
- this.id = id;
- this.adapterWorkerManagement = new AdapterWorkerManagement();
- }
-
- @GET
- @Produces(MediaType.TEXT_HTML)
- public String getWelcomePageHtml() {
- return buildHtml();
- }
-
- private String buildHtml() {
- HtmlCanvas html = new HtmlCanvas();
- try {
- HtmlCanvas tmp = html
- .head()
- .title()
- .content("StreamPipes Connector Worker Container")
- ._head()
- .body()
- .h1().write("Worker Connector Container with ID: " + this.id)._h1();
-
- tmp = getAllRegisteredProtocols(tmp);
- tmp = getAllRegisteredAdapters(tmp);
-
- html = tmp
- ._body();
-
- } catch (IOException e) {
- e.printStackTrace();
- }
- return html.toHtml();
- }
-
- private HtmlCanvas getAllRegisteredProtocols(HtmlCanvas canvas) throws IOException {
- Collection<IProtocol> protocols = this.adapterWorkerManagement.getAllProtocols();
-
- canvas.h2().write("Protocols")._h2().ol();
-
- for (IProtocol p : protocols) {
- canvas.li().write(p.getId())._li();
- }
-
- canvas._ol();
-
- return canvas;
- }
-
- private HtmlCanvas getAllRegisteredAdapters(HtmlCanvas canvas) throws IOException {
- Collection<IAdapter> adapters = this.adapterWorkerManagement.getAllAdapters();
-
- canvas.h2().write("Adapters")._h2().ol();
-
- for (IAdapter a : adapters) {
- canvas.li().write(a.getId())._li();
- }
-
- canvas._ol();
-
- return canvas;
- }
-}
diff --git a/streampipes-connect-container-worker/src/main/java/org/apache/streampipes/connect/container/worker/utils/AdapterUtils.java b/streampipes-connect-container-worker/src/main/java/org/apache/streampipes/connect/container/worker/utils/AdapterUtils.java
index 3ca0ecb..72df3df 100644
--- a/streampipes-connect-container-worker/src/main/java/org/apache/streampipes/connect/container/worker/utils/AdapterUtils.java
+++ b/streampipes-connect-container-worker/src/main/java/org/apache/streampipes/connect/container/worker/utils/AdapterUtils.java
@@ -65,7 +65,7 @@ public class AdapterUtils {
if (adapterDescription instanceof GenericAdapterStreamDescription) {
adapter = (IAdapter<?>) new GenericDataStreamAdapter().getInstance((GenericAdapterStreamDescription) adapterDescription);
} else if (adapterDescription instanceof GenericAdapterSetDescription) {
- adapter = (IAdapter<?>) new GenericDataSetAdapter().getInstance((GenericAdapterSetDescription) adapterDescription);
+ adapter = new GenericDataSetAdapter().getInstance((GenericAdapterSetDescription) adapterDescription);
}
IProtocol protocol = null;
diff --git a/streampipes-connect-container-worker/src/test/java/org/apache/streampipes/connect/container/worker/utils/AdapterUtilsTest.java b/streampipes-connect-container-worker/src/test/java/org/apache/streampipes/connect/container/worker/utils/AdapterUtilsTest.java
index 4de2353..9f2c88e 100644
--- a/streampipes-connect-container-worker/src/test/java/org/apache/streampipes/connect/container/worker/utils/AdapterUtilsTest.java
+++ b/streampipes-connect-container-worker/src/test/java/org/apache/streampipes/connect/container/worker/utils/AdapterUtilsTest.java
@@ -49,12 +49,4 @@ public class AdapterUtilsTest {
WireMock.verify(WireMock.getRequestedFor(WireMock.urlMatching("/")));
}
- @Test
- public void getUrlTest() {
- String expected = "http://host:80/api/v2/pipelines/1/stopAdapter";
-
- String result = AdapterUtils.getUrl("host:80/", "1");
-
- assertEquals(expected, result);
- }
}
diff --git a/streampipes-connect/src/main/java/org/apache/streampipes/connect/RunningAdapterInstances.java b/streampipes-connect/src/main/java/org/apache/streampipes/connect/RunningAdapterInstances.java
index 2ac2058..22baaac 100644
--- a/streampipes-connect/src/main/java/org/apache/streampipes/connect/RunningAdapterInstances.java
+++ b/streampipes-connect/src/main/java/org/apache/streampipes/connect/RunningAdapterInstances.java
@@ -28,13 +28,13 @@ public enum RunningAdapterInstances {
private final Map<String, IAdapter<?>> runningInstances = new HashMap<>();
- public void addAdapter(String id, IAdapter<?> adapter) {
- runningInstances.put(id, adapter);
+ public void addAdapter(String elementId, IAdapter<?> adapter) {
+ runningInstances.put(elementId, adapter);
}
- public IAdapter<?> removeAdapter(String id) {
- IAdapter<?> result = runningInstances.get(id);
- runningInstances.remove(id);
+ public IAdapter<?> removeAdapter(String elementId) {
+ IAdapter<?> result = runningInstances.get(elementId);
+ runningInstances.remove(elementId);
return result;
}
diff --git a/streampipes-model/src/main/java/org/apache/streampipes/model/connect/adapter/AdapterDescriptionList.java b/streampipes-model/src/main/java/org/apache/streampipes/model/connect/adapter/AdapterDescriptionList.java
deleted file mode 100644
index 81b6484..0000000
--- a/streampipes-model/src/main/java/org/apache/streampipes/model/connect/adapter/AdapterDescriptionList.java
+++ /dev/null
@@ -1,50 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- *
- */
-
-package org.apache.streampipes.model.connect.adapter;
-
-import org.apache.streampipes.model.base.NamedStreamPipesEntity;
-import org.apache.streampipes.model.shared.annotation.TsModel;
-
-import java.util.ArrayList;
-import java.util.List;
-
-@TsModel
-@Deprecated
-public class AdapterDescriptionList extends NamedStreamPipesEntity {
-
- private List<AdapterDescription> list;
-
- public AdapterDescriptionList() {
- super("http://streampipes.org/adapterlist", "", "");
- list = new ArrayList<>();
- }
-
- public AdapterDescriptionList(List<AdapterDescription> adapterDescriptions) {
- super("http://streampipes.org/adapterlist", "", "");
- list = adapterDescriptions;
- }
-
- public List<AdapterDescription> getList() {
- return list;
- }
-
- public void setList(List<AdapterDescription> list) {
- this.list = list;
- }
-}
diff --git a/streampipes-model/src/main/java/org/apache/streampipes/model/connect/adapter/AdapterSetDescription.java b/streampipes-model/src/main/java/org/apache/streampipes/model/connect/adapter/AdapterSetDescription.java
index 44b023a..6d83ba8 100644
--- a/streampipes-model/src/main/java/org/apache/streampipes/model/connect/adapter/AdapterSetDescription.java
+++ b/streampipes-model/src/main/java/org/apache/streampipes/model/connect/adapter/AdapterSetDescription.java
@@ -43,8 +43,6 @@ public abstract class AdapterSetDescription extends AdapterDescription {
private SpDataSet dataSet;
- private boolean stopPipeline;
-
public SpDataSet getDataSet() {
return dataSet;
}
@@ -53,11 +51,4 @@ public abstract class AdapterSetDescription extends AdapterDescription {
this.dataSet = dataSet;
}
- public boolean isStopPipeline() {
- return stopPipeline;
- }
-
- public void setStopPipeline(boolean stopPipeline) {
- this.stopPipeline = stopPipeline;
- }
}
diff --git a/streampipes-model/src/main/java/org/apache/streampipes/model/connect/grounding/FormatDescriptionList.java b/streampipes-model/src/main/java/org/apache/streampipes/model/connect/grounding/FormatDescriptionList.java
deleted file mode 100644
index 1cf6103..0000000
--- a/streampipes-model/src/main/java/org/apache/streampipes/model/connect/grounding/FormatDescriptionList.java
+++ /dev/null
@@ -1,63 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- *
- */
-
-package org.apache.streampipes.model.connect.grounding;
-
-import org.apache.streampipes.model.base.NamedStreamPipesEntity;
-import org.apache.streampipes.model.shared.annotation.TsModel;
-
-import java.util.ArrayList;
-import java.util.List;
-
-@TsModel
-public class FormatDescriptionList extends NamedStreamPipesEntity {
-
- private List<FormatDescription> list;
-
- public FormatDescriptionList() {
- super("http://bla.de#2", "", "");
- list = new ArrayList<>();
- }
-
- public FormatDescriptionList(List<FormatDescription> formatDescriptions) {
- super("http://bla.de#2", "", "");
- list = formatDescriptions;
- }
-
- public FormatDescriptionList(FormatDescriptionList other) {
- super(other.getUri(), other.getName(), other.getName());
- if (other.getList() != null) {
- for (FormatDescription fd : other.getList()) {
- this.list.add(new FormatDescription(fd));
- }
-
- }
- }
-
- public void addDesctiption(FormatDescription formatDescription) {
- list.add(formatDescription);
- }
-
- public List<FormatDescription> getList() {
- return list;
- }
-
- public void setList(List<FormatDescription> list) {
- this.list = list;
- }
-}
diff --git a/streampipes-model/src/main/java/org/apache/streampipes/model/connect/grounding/ProtocolDescriptionList.java b/streampipes-model/src/main/java/org/apache/streampipes/model/connect/grounding/ProtocolDescriptionList.java
deleted file mode 100644
index 5b91368..0000000
--- a/streampipes-model/src/main/java/org/apache/streampipes/model/connect/grounding/ProtocolDescriptionList.java
+++ /dev/null
@@ -1,58 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- *
- */
-
-package org.apache.streampipes.model.connect.grounding;
-
-
-import org.apache.streampipes.model.base.NamedStreamPipesEntity;
-import org.apache.streampipes.model.shared.annotation.TsModel;
-
-import java.util.ArrayList;
-import java.util.List;
-
-@TsModel
-public class ProtocolDescriptionList extends NamedStreamPipesEntity {
-
- private List<ProtocolDescription> list;
-
- protected String label;
-
- public ProtocolDescriptionList() {
- super("http://bla.de#1", "", "");
- list = new ArrayList<>();
- }
-
- public ProtocolDescriptionList(List<ProtocolDescription> protocolDescriptions) {
- super("http://bla.de#1", "", "");
- list = protocolDescriptions;
- }
-
- public void addDesctiption(ProtocolDescription protocolDescription) {
- list.add(protocolDescription);
- }
-
- public List<ProtocolDescription> getList() {
- return list;
- }
-
- public void setList(List<ProtocolDescription> list) {
- this.list = list;
- }
-
-
-}
diff --git a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/connect/DescriptionResource.java b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/connect/DescriptionResource.java
index 2aed7d0..90e6508 100644
--- a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/connect/DescriptionResource.java
+++ b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/connect/DescriptionResource.java
@@ -22,8 +22,7 @@ import org.apache.streampipes.connect.api.exception.AdapterException;
import org.apache.streampipes.connect.container.master.management.DescriptionManagement;
import org.apache.streampipes.connect.container.master.management.WorkerUrlProvider;
import org.apache.streampipes.model.connect.adapter.AdapterDescription;
-import org.apache.streampipes.model.connect.grounding.FormatDescriptionList;
-import org.apache.streampipes.model.connect.grounding.ProtocolDescriptionList;
+import org.apache.streampipes.model.connect.grounding.FormatDescription;
import org.apache.streampipes.rest.shared.annotation.JacksonSerialized;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -53,18 +52,7 @@ public class DescriptionResource extends AbstractAdapterResource<DescriptionMana
@Path("/formats")
@Produces(MediaType.APPLICATION_JSON)
public Response getFormats() {
- FormatDescriptionList result = managementService.getFormats();
-
- return ok(result);
- }
-
- @Deprecated
- @GET
- @JacksonSerialized
- @Path("/protocols")
- @Produces(MediaType.APPLICATION_JSON)
- public Response getProtocols() {
- ProtocolDescriptionList result = managementService.getProtocols();
+ List<FormatDescription> result = managementService.getFormats();
return ok(result);
}
diff --git a/ui/src/app/connect/components/format-configuration/format-configuration.component.ts b/ui/src/app/connect/components/format-configuration/format-configuration.component.ts
index ccf3e64..a15ee95 100644
--- a/ui/src/app/connect/components/format-configuration/format-configuration.component.ts
+++ b/ui/src/app/connect/components/format-configuration/format-configuration.component.ts
@@ -70,13 +70,14 @@ export class FormatConfigurationComponent implements OnInit {
constructor(
private restService: RestService,
- private _formBuilder: FormBuilder) { }
+ private _formBuilder: FormBuilder) {
+ }
ngOnInit(): void {
// fetch all available formats from backend
this.restService.getFormats().subscribe(res => {
- this.allFormats = res.list;
+ this.allFormats = res;
});
// initialize form for validation
diff --git a/ui/src/app/connect/services/rest.service.ts b/ui/src/app/connect/services/rest.service.ts
index 6c3ca3f..c2e12a8 100644
--- a/ui/src/app/connect/services/rest.service.ts
+++ b/ui/src/app/connect/services/rest.service.ts
@@ -23,7 +23,7 @@ import { HttpClient } from '@angular/common/http';
import { from, Observable } from 'rxjs';
import { map } from 'rxjs/operators';
import { UnitDescription } from '../model/UnitDescription';
-import { AdapterDescription, FormatDescriptionList, GuessSchema, Message, SpDataStream } from '../../core-model/gen/streampipes-model';
+import { AdapterDescription, FormatDescription, GuessSchema, Message, SpDataStream } from '../../core-model/gen/streampipes-model';
import { PlatformServicesCommons } from '../../platform-services/apis/commons.service';
import { AuthStatusService } from '../../services/auth-status.service';
@@ -63,7 +63,7 @@ export class RestService {
getGuessSchema(adapter: AdapterDescription): Observable<GuessSchema> {
return this.http
- .post(this.connectPath + '/master/guess/schema', adapter)
+ .post(`${this.connectPath}/master/guess/schema`, adapter)
.pipe(map(response => {
return GuessSchema.fromData(response as GuessSchema);
}));
@@ -72,30 +72,28 @@ export class RestService {
getSourceDetails(sourceElementId): Observable<SpDataStream> {
return this.http
- .get(this.platformServicesCommons.apiBasePath() + '/streams/' + encodeURIComponent(sourceElementId)).pipe(map(response => {
+ .get(`${this.platformServicesCommons.apiBasePath()}/streams/${encodeURIComponent(sourceElementId)}`).pipe(map(response => {
return SpDataStream.fromData(response as SpDataStream);
}));
}
getRuntimeInfo(sourceDescription): Observable<any> {
- return this.http.post(this.platformServicesCommons.apiBasePath() + '/pipeline-element/runtime', sourceDescription, {
+ return this.http.post(`${this.platformServicesCommons.apiBasePath()}/pipeline-element/runtime`, sourceDescription, {
headers: { ignoreLoadingBar: '' }
});
}
- getFormats(): Observable<FormatDescriptionList> {
+ getFormats(): Observable<FormatDescription[]> {
return this.http
- .get(
- this.connectPath + '/master/description/formats'
- )
+ .get(`${this.connectPath}/master/description/formats`)
.pipe(map(response => {
- return FormatDescriptionList.fromData(response as FormatDescriptionList);
+ return (response as any[]).map(f => FormatDescription.fromData(f));
}));
}
getFittingUnits(unitDescription: UnitDescription): Observable<UnitDescription[]> {
return this.http
- .post<UnitDescription[]>(this.connectPath + '/master/unit', unitDescription)
+ .post<UnitDescription[]>(`${this.connectPath}/master/unit`, unitDescription)
.pipe(map(response => {
const descriptions = response as UnitDescription[];
return descriptions.filter(entry => entry.resource !== unitDescription.resource);
diff --git a/ui/src/app/core-model/gen/streampipes-model.ts b/ui/src/app/core-model/gen/streampipes-model.ts
index b7093ff..95e886a 100644
--- a/ui/src/app/core-model/gen/streampipes-model.ts
+++ b/ui/src/app/core-model/gen/streampipes-model.ts
@@ -1,3169 +1,3100 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- *
- */
-
/* tslint:disable */
/* eslint-disable */
// @ts-nocheck
-// Generated using typescript-generator version 2.27.744 on 2021-10-05 11:54:22.
+// Generated using typescript-generator version 2.27.744 on 2021-10-07 21:36:52.
export class AbstractStreamPipesEntity {
- '@class': 'org.apache.streampipes.model.base.AbstractStreamPipesEntity' | 'org.apache.streampipes.model.base.NamedStreamPipesEntity' | 'org.apache.streampipes.model.connect.adapter.AdapterDescription' | 'org.apache.streampipes.model.connect.adapter.AdapterSetDescription' | 'org.apache.streampipes.model.connect.adapter.GenericAdapterSetDescription' | 'org.apache.streampipes.model.connect.adapter.SpecificAdapterSetDescription' | 'org.apache.streampipes.model.connect.adapter.AdapterStream [...]
- elementId: string;
+ "@class": "org.apache.streampipes.model.base.AbstractStreamPipesEntity" | "org.apache.streampipes.model.base.NamedStreamPipesEntity" | "org.apache.streampipes.model.connect.adapter.AdapterDescription" | "org.apache.streampipes.model.connect.adapter.AdapterSetDescription" | "org.apache.streampipes.model.connect.adapter.GenericAdapterSetDescription" | "org.apache.streampipes.model.connect.adapter.SpecificAdapterSetDescription" | "org.apache.streampipes.model.connect.adapter.AdapterStre [...]
+ elementId: string;
- static fromData(data: AbstractStreamPipesEntity, target?: AbstractStreamPipesEntity): AbstractStreamPipesEntity {
- if (!data) {
- return data;
+ static fromData(data: AbstractStreamPipesEntity, target?: AbstractStreamPipesEntity): AbstractStreamPipesEntity {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new AbstractStreamPipesEntity();
+ instance["@class"] = data["@class"];
+ instance.elementId = data.elementId;
+ return instance;
}
- const instance = target || new AbstractStreamPipesEntity();
- instance['@class'] = data['@class'];
- instance.elementId = data.elementId;
- return instance;
- }
}
export class UnnamedStreamPipesEntity extends AbstractStreamPipesEntity {
- '@class': 'org.apache.streampipes.model.base.UnnamedStreamPipesEntity' | 'org.apache.streampipes.model.connect.guess.GuessSchema' | 'org.apache.streampipes.model.connect.rules.TransformationRuleDescription' | 'org.apache.streampipes.model.connect.rules.value.ValueTransformationRuleDescription' | 'org.apache.streampipes.model.connect.rules.value.AddTimestampRuleDescription' | 'org.apache.streampipes.model.connect.rules.value.AddValueTransformationRuleDescription' | 'org.apache.streampip [...]
+ "@class": "org.apache.streampipes.model.base.UnnamedStreamPipesEntity" | "org.apache.streampipes.model.connect.guess.GuessSchema" | "org.apache.streampipes.model.connect.rules.TransformationRuleDescription" | "org.apache.streampipes.model.connect.rules.value.ValueTransformationRuleDescription" | "org.apache.streampipes.model.connect.rules.value.AddTimestampRuleDescription" | "org.apache.streampipes.model.connect.rules.value.AddValueTransformationRuleDescription" | "org.apache.streamp [...]
- static fromData(data: UnnamedStreamPipesEntity, target?: UnnamedStreamPipesEntity): UnnamedStreamPipesEntity {
- if (!data) {
- return data;
+ static fromData(data: UnnamedStreamPipesEntity, target?: UnnamedStreamPipesEntity): UnnamedStreamPipesEntity {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new UnnamedStreamPipesEntity();
+ super.fromData(data, instance);
+ return instance;
}
- const instance = target || new UnnamedStreamPipesEntity();
- super.fromData(data, instance);
- return instance;
- }
}
export class MeasurementProperty extends UnnamedStreamPipesEntity {
- '@class': 'org.apache.streampipes.model.quality.MeasurementProperty' | 'org.apache.streampipes.model.quality.EventStreamQualityDefinition' | 'org.apache.streampipes.model.quality.Frequency' | 'org.apache.streampipes.model.quality.Latency' | 'org.apache.streampipes.model.quality.EventPropertyQualityDefinition' | 'org.apache.streampipes.model.quality.Accuracy' | 'org.apache.streampipes.model.quality.MeasurementRange' | 'org.apache.streampipes.model.quality.Precision' | 'org.apache.stream [...]
+ "@class": "org.apache.streampipes.model.quality.MeasurementProperty" | "org.apache.streampipes.model.quality.EventStreamQualityDefinition" | "org.apache.streampipes.model.quality.Frequency" | "org.apache.streampipes.model.quality.Latency" | "org.apache.streampipes.model.quality.EventPropertyQualityDefinition" | "org.apache.streampipes.model.quality.Accuracy" | "org.apache.streampipes.model.quality.MeasurementRange" | "org.apache.streampipes.model.quality.Precision" | "org.apache.stre [...]
- static fromData(data: MeasurementProperty, target?: MeasurementProperty): MeasurementProperty {
- if (!data) {
- return data;
+ static fromData(data: MeasurementProperty, target?: MeasurementProperty): MeasurementProperty {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new MeasurementProperty();
+ super.fromData(data, instance);
+ return instance;
}
- const instance = target || new MeasurementProperty();
- super.fromData(data, instance);
- return instance;
- }
- static fromDataUnion(data: MeasurementPropertyUnion): MeasurementPropertyUnion {
- if (!data) {
- return data;
- }
- switch (data['@class']) {
- case 'org.apache.streampipes.model.quality.EventPropertyQualityDefinition':
- return EventPropertyQualityDefinition.fromData(data);
- case 'org.apache.streampipes.model.quality.EventStreamQualityDefinition':
- return EventStreamQualityDefinition.fromData(data);
+ static fromDataUnion(data: MeasurementPropertyUnion): MeasurementPropertyUnion {
+ if (!data) {
+ return data;
+ }
+ switch (data["@class"]) {
+ case "org.apache.streampipes.model.quality.EventPropertyQualityDefinition":
+ return EventPropertyQualityDefinition.fromData(data);
+ case "org.apache.streampipes.model.quality.EventStreamQualityDefinition":
+ return EventStreamQualityDefinition.fromData(data);
+ }
}
- }
}
export class EventPropertyQualityDefinition extends MeasurementProperty {
- '@class': 'org.apache.streampipes.model.quality.EventPropertyQualityDefinition' | 'org.apache.streampipes.model.quality.Accuracy' | 'org.apache.streampipes.model.quality.MeasurementRange' | 'org.apache.streampipes.model.quality.Precision' | 'org.apache.streampipes.model.quality.Resolution';
-
- static fromData(data: EventPropertyQualityDefinition, target?: EventPropertyQualityDefinition): EventPropertyQualityDefinition {
- if (!data) {
- return data;
- }
- const instance = target || new EventPropertyQualityDefinition();
- super.fromData(data, instance);
- return instance;
- }
-
- static fromDataUnion(data: EventPropertyQualityDefinitionUnion): EventPropertyQualityDefinitionUnion {
- if (!data) {
- return data;
- }
- switch (data['@class']) {
- case 'org.apache.streampipes.model.quality.Accuracy':
- return Accuracy.fromData(data);
- case 'org.apache.streampipes.model.quality.MeasurementRange':
- return MeasurementRange.fromData(data);
- case 'org.apache.streampipes.model.quality.Precision':
- return Precision.fromData(data);
- case 'org.apache.streampipes.model.quality.Resolution':
- return Resolution.fromData(data);
+ "@class": "org.apache.streampipes.model.quality.EventPropertyQualityDefinition" | "org.apache.streampipes.model.quality.Accuracy" | "org.apache.streampipes.model.quality.MeasurementRange" | "org.apache.streampipes.model.quality.Precision" | "org.apache.streampipes.model.quality.Resolution";
+
+ static fromData(data: EventPropertyQualityDefinition, target?: EventPropertyQualityDefinition): EventPropertyQualityDefinition {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new EventPropertyQualityDefinition();
+ super.fromData(data, instance);
+ return instance;
+ }
+
+ static fromDataUnion(data: EventPropertyQualityDefinitionUnion): EventPropertyQualityDefinitionUnion {
+ if (!data) {
+ return data;
+ }
+ switch (data["@class"]) {
+ case "org.apache.streampipes.model.quality.Accuracy":
+ return Accuracy.fromData(data);
+ case "org.apache.streampipes.model.quality.MeasurementRange":
+ return MeasurementRange.fromData(data);
+ case "org.apache.streampipes.model.quality.Precision":
+ return Precision.fromData(data);
+ case "org.apache.streampipes.model.quality.Resolution":
+ return Resolution.fromData(data);
+ }
}
- }
}
export class Accuracy extends EventPropertyQualityDefinition {
- '@class': 'org.apache.streampipes.model.quality.Accuracy';
- quantityValue: number;
+ "@class": "org.apache.streampipes.model.quality.Accuracy";
+ quantityValue: number;
- static fromData(data: Accuracy, target?: Accuracy): Accuracy {
- if (!data) {
- return data;
+ static fromData(data: Accuracy, target?: Accuracy): Accuracy {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new Accuracy();
+ super.fromData(data, instance);
+ instance.quantityValue = data.quantityValue;
+ return instance;
}
- const instance = target || new Accuracy();
- super.fromData(data, instance);
- instance.quantityValue = data.quantityValue;
- return instance;
- }
}
export class NamedStreamPipesEntity extends AbstractStreamPipesEntity {
- '@class': 'org.apache.streampipes.model.base.NamedStreamPipesEntity' | 'org.apache.streampipes.model.connect.adapter.AdapterDescription' | 'org.apache.streampipes.model.connect.adapter.AdapterSetDescription' | 'org.apache.streampipes.model.connect.adapter.GenericAdapterSetDescription' | 'org.apache.streampipes.model.connect.adapter.SpecificAdapterSetDescription' | 'org.apache.streampipes.model.connect.adapter.AdapterStreamDescription' | 'org.apache.streampipes.model.connect.adapter.Gen [...]
- _rev: string;
- appId: string;
- applicationLinks: ApplicationLink[];
- connectedTo: string[];
- description: string;
- dom: string;
- iconUrl: string;
- includedAssets: string[];
- includedLocales: string[];
- includesAssets: boolean;
- includesLocales: boolean;
- internallyManaged: boolean;
- name: string;
- uri: string;
-
- static fromData(data: NamedStreamPipesEntity, target?: NamedStreamPipesEntity): NamedStreamPipesEntity {
- if (!data) {
- return data;
- }
- const instance = target || new NamedStreamPipesEntity();
- super.fromData(data, instance);
- instance.name = data.name;
- instance.description = data.description;
- instance.iconUrl = data.iconUrl;
- instance.appId = data.appId;
- instance.includesAssets = data.includesAssets;
- instance.includesLocales = data.includesLocales;
- instance.includedAssets = __getCopyArrayFn(__identity<string>())(data.includedAssets);
- instance.includedLocales = __getCopyArrayFn(__identity<string>())(data.includedLocales);
- instance.applicationLinks = __getCopyArrayFn(ApplicationLink.fromData)(data.applicationLinks);
- instance.internallyManaged = data.internallyManaged;
- instance.connectedTo = __getCopyArrayFn(__identity<string>())(data.connectedTo);
- instance.uri = data.uri;
- instance.dom = data.dom;
- instance._rev = data._rev;
- return instance;
- }
+ "@class": "org.apache.streampipes.model.base.NamedStreamPipesEntity" | "org.apache.streampipes.model.connect.adapter.AdapterDescription" | "org.apache.streampipes.model.connect.adapter.AdapterSetDescription" | "org.apache.streampipes.model.connect.adapter.GenericAdapterSetDescription" | "org.apache.streampipes.model.connect.adapter.SpecificAdapterSetDescription" | "org.apache.streampipes.model.connect.adapter.AdapterStreamDescription" | "org.apache.streampipes.model.connect.adapter.G [...]
+ _rev: string;
+ appId: string;
+ applicationLinks: ApplicationLink[];
+ connectedTo: string[];
+ description: string;
+ dom: string;
+ iconUrl: string;
+ includedAssets: string[];
+ includedLocales: string[];
+ includesAssets: boolean;
+ includesLocales: boolean;
+ internallyManaged: boolean;
+ name: string;
+ uri: string;
+
+ static fromData(data: NamedStreamPipesEntity, target?: NamedStreamPipesEntity): NamedStreamPipesEntity {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new NamedStreamPipesEntity();
+ super.fromData(data, instance);
+ instance.name = data.name;
+ instance.description = data.description;
+ instance.iconUrl = data.iconUrl;
+ instance.appId = data.appId;
+ instance.includesAssets = data.includesAssets;
+ instance.includesLocales = data.includesLocales;
+ instance.includedAssets = __getCopyArrayFn(__identity<string>())(data.includedAssets);
+ instance.includedLocales = __getCopyArrayFn(__identity<string>())(data.includedLocales);
+ instance.applicationLinks = __getCopyArrayFn(ApplicationLink.fromData)(data.applicationLinks);
+ instance.internallyManaged = data.internallyManaged;
+ instance.connectedTo = __getCopyArrayFn(__identity<string>())(data.connectedTo);
+ instance.uri = data.uri;
+ instance.dom = data.dom;
+ instance._rev = data._rev;
+ return instance;
+ }
}
export class AdapterDescription extends NamedStreamPipesEntity {
- '@class': 'org.apache.streampipes.model.connect.adapter.AdapterDescription' | 'org.apache.streampipes.model.connect.adapter.AdapterSetDescription' | 'org.apache.streampipes.model.connect.adapter.GenericAdapterSetDescription' | 'org.apache.streampipes.model.connect.adapter.SpecificAdapterSetDescription' | 'org.apache.streampipes.model.connect.adapter.AdapterStreamDescription' | 'org.apache.streampipes.model.connect.adapter.GenericAdapterStreamDescription' | 'org.apache.streampipes.model [...]
- adapterType: string;
- category: string[];
- config: StaticPropertyUnion[];
- correspondingServiceGroup: string;
- createdAt: number;
- eventGrounding: EventGrounding;
- icon: string;
- rules: TransformationRuleDescriptionUnion[];
- schemaRules: any[];
- selectedEndpointUrl: string;
- streamRules: any[];
- userName: string;
- valueRules: any[];
-
- static fromData(data: AdapterDescription, target?: AdapterDescription): AdapterDescription {
- if (!data) {
- return data;
- }
- const instance = target || new AdapterDescription();
- super.fromData(data, instance);
- instance.userName = data.userName;
- instance.eventGrounding = EventGrounding.fromData(data.eventGrounding);
- instance.adapterType = data.adapterType;
- instance.icon = data.icon;
- instance.config = __getCopyArrayFn(StaticProperty.fromDataUnion)(data.config);
- instance.rules = __getCopyArrayFn(TransformationRuleDescription.fromDataUnion)(data.rules);
- instance.category = __getCopyArrayFn(__identity<string>())(data.category);
- instance.createdAt = data.createdAt;
- instance.selectedEndpointUrl = data.selectedEndpointUrl;
- instance.correspondingServiceGroup = data.correspondingServiceGroup;
- instance.valueRules = __getCopyArrayFn(__identity<any>())(data.valueRules);
- instance.streamRules = __getCopyArrayFn(__identity<any>())(data.streamRules);
- instance.schemaRules = __getCopyArrayFn(__identity<any>())(data.schemaRules);
- return instance;
- }
-
- static fromDataUnion(data: AdapterDescriptionUnion): AdapterDescriptionUnion {
- if (!data) {
- return data;
- }
- switch (data['@class']) {
- case 'org.apache.streampipes.model.connect.adapter.GenericAdapterSetDescription':
- return GenericAdapterSetDescription.fromData(data);
- case 'org.apache.streampipes.model.connect.adapter.GenericAdapterStreamDescription':
- return GenericAdapterStreamDescription.fromData(data);
- case 'org.apache.streampipes.model.connect.adapter.SpecificAdapterStreamDescription':
- return SpecificAdapterStreamDescription.fromData(data);
- case 'org.apache.streampipes.model.connect.adapter.SpecificAdapterSetDescription':
- return SpecificAdapterSetDescription.fromData(data);
- }
- }
-}
-
-export class AdapterDescriptionList extends NamedStreamPipesEntity {
- '@class': 'org.apache.streampipes.model.connect.adapter.AdapterDescriptionList';
- list: AdapterDescriptionUnion[];
-
- static fromData(data: AdapterDescriptionList, target?: AdapterDescriptionList): AdapterDescriptionList {
- if (!data) {
- return data;
- }
- const instance = target || new AdapterDescriptionList();
- super.fromData(data, instance);
- instance.list = __getCopyArrayFn(AdapterDescription.fromDataUnion)(data.list);
- return instance;
- }
+ "@class": "org.apache.streampipes.model.connect.adapter.AdapterDescription" | "org.apache.streampipes.model.connect.adapter.AdapterSetDescription" | "org.apache.streampipes.model.connect.adapter.GenericAdapterSetDescription" | "org.apache.streampipes.model.connect.adapter.SpecificAdapterSetDescription" | "org.apache.streampipes.model.connect.adapter.AdapterStreamDescription" | "org.apache.streampipes.model.connect.adapter.GenericAdapterStreamDescription" | "org.apache.streampipes.mod [...]
+ adapterType: string;
+ category: string[];
+ config: StaticPropertyUnion[];
+ correspondingServiceGroup: string;
+ createdAt: number;
+ eventGrounding: EventGrounding;
+ icon: string;
+ rules: TransformationRuleDescriptionUnion[];
+ schemaRules: any[];
+ selectedEndpointUrl: string;
+ streamRules: any[];
+ userName: string;
+ valueRules: any[];
+
+ static fromData(data: AdapterDescription, target?: AdapterDescription): AdapterDescription {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new AdapterDescription();
+ super.fromData(data, instance);
+ instance.userName = data.userName;
+ instance.eventGrounding = EventGrounding.fromData(data.eventGrounding);
+ instance.adapterType = data.adapterType;
+ instance.icon = data.icon;
+ instance.config = __getCopyArrayFn(StaticProperty.fromDataUnion)(data.config);
+ instance.rules = __getCopyArrayFn(TransformationRuleDescription.fromDataUnion)(data.rules);
+ instance.category = __getCopyArrayFn(__identity<string>())(data.category);
+ instance.createdAt = data.createdAt;
+ instance.selectedEndpointUrl = data.selectedEndpointUrl;
+ instance.correspondingServiceGroup = data.correspondingServiceGroup;
+ instance.valueRules = __getCopyArrayFn(__identity<any>())(data.valueRules);
+ instance.streamRules = __getCopyArrayFn(__identity<any>())(data.streamRules);
+ instance.schemaRules = __getCopyArrayFn(__identity<any>())(data.schemaRules);
+ return instance;
+ }
+
+ static fromDataUnion(data: AdapterDescriptionUnion): AdapterDescriptionUnion {
+ if (!data) {
+ return data;
+ }
+ switch (data["@class"]) {
+ case "org.apache.streampipes.model.connect.adapter.GenericAdapterSetDescription":
+ return GenericAdapterSetDescription.fromData(data);
+ case "org.apache.streampipes.model.connect.adapter.GenericAdapterStreamDescription":
+ return GenericAdapterStreamDescription.fromData(data);
+ case "org.apache.streampipes.model.connect.adapter.SpecificAdapterStreamDescription":
+ return SpecificAdapterStreamDescription.fromData(data);
+ case "org.apache.streampipes.model.connect.adapter.SpecificAdapterSetDescription":
+ return SpecificAdapterSetDescription.fromData(data);
+ }
+ }
}
export class AdapterSetDescription extends AdapterDescription {
- '@class': 'org.apache.streampipes.model.connect.adapter.AdapterSetDescription' | 'org.apache.streampipes.model.connect.adapter.GenericAdapterSetDescription' | 'org.apache.streampipes.model.connect.adapter.SpecificAdapterSetDescription';
- dataSet: SpDataSet;
- stopPipeline: boolean;
+ "@class": "org.apache.streampipes.model.connect.adapter.AdapterSetDescription" | "org.apache.streampipes.model.connect.adapter.GenericAdapterSetDescription" | "org.apache.streampipes.model.connect.adapter.SpecificAdapterSetDescription";
+ dataSet: SpDataSet;
- static fromData(data: AdapterSetDescription, target?: AdapterSetDescription): AdapterSetDescription {
- if (!data) {
- return data;
+ static fromData(data: AdapterSetDescription, target?: AdapterSetDescription): AdapterSetDescription {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new AdapterSetDescription();
+ super.fromData(data, instance);
+ instance.dataSet = SpDataSet.fromData(data.dataSet);
+ return instance;
}
- const instance = target || new AdapterSetDescription();
- super.fromData(data, instance);
- instance.dataSet = SpDataSet.fromData(data.dataSet);
- instance.stopPipeline = data.stopPipeline;
- return instance;
- }
- static fromDataUnion(data: AdapterSetDescriptionUnion): AdapterSetDescriptionUnion {
- if (!data) {
- return data;
- }
- switch (data['@class']) {
- case 'org.apache.streampipes.model.connect.adapter.GenericAdapterSetDescription':
- return GenericAdapterSetDescription.fromData(data);
- case 'org.apache.streampipes.model.connect.adapter.SpecificAdapterSetDescription':
- return SpecificAdapterSetDescription.fromData(data);
+ static fromDataUnion(data: AdapterSetDescriptionUnion): AdapterSetDescriptionUnion {
+ if (!data) {
+ return data;
+ }
+ switch (data["@class"]) {
+ case "org.apache.streampipes.model.connect.adapter.GenericAdapterSetDescription":
+ return GenericAdapterSetDescription.fromData(data);
+ case "org.apache.streampipes.model.connect.adapter.SpecificAdapterSetDescription":
+ return SpecificAdapterSetDescription.fromData(data);
+ }
}
- }
}
export class AdapterStreamDescription extends AdapterDescription {
- '@class': 'org.apache.streampipes.model.connect.adapter.AdapterStreamDescription' | 'org.apache.streampipes.model.connect.adapter.GenericAdapterStreamDescription' | 'org.apache.streampipes.model.connect.adapter.SpecificAdapterStreamDescription';
- dataStream: SpDataStreamUnion;
- running: boolean;
-
- static fromData(data: AdapterStreamDescription, target?: AdapterStreamDescription): AdapterStreamDescription {
- if (!data) {
- return data;
+ "@class": "org.apache.streampipes.model.connect.adapter.AdapterStreamDescription" | "org.apache.streampipes.model.connect.adapter.GenericAdapterStreamDescription" | "org.apache.streampipes.model.connect.adapter.SpecificAdapterStreamDescription";
+ dataStream: SpDataStreamUnion;
+ running: boolean;
+
+ static fromData(data: AdapterStreamDescription, target?: AdapterStreamDescription): AdapterStreamDescription {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new AdapterStreamDescription();
+ super.fromData(data, instance);
+ instance.dataStream = SpDataStream.fromDataUnion(data.dataStream);
+ instance.running = data.running;
+ return instance;
+ }
+
+ static fromDataUnion(data: AdapterStreamDescriptionUnion): AdapterStreamDescriptionUnion {
+ if (!data) {
+ return data;
+ }
+ switch (data["@class"]) {
+ case "org.apache.streampipes.model.connect.adapter.SpecificAdapterStreamDescription":
+ return SpecificAdapterStreamDescription.fromData(data);
+ case "org.apache.streampipes.model.connect.adapter.SpecificAdapterStreamDescription":
+ return SpecificAdapterStreamDescription.fromData(data);
+ }
}
- const instance = target || new AdapterStreamDescription();
- super.fromData(data, instance);
- instance.dataStream = SpDataStream.fromDataUnion(data.dataStream);
- instance.running = data.running;
- return instance;
- }
-
- static fromDataUnion(data: AdapterStreamDescriptionUnion): AdapterStreamDescriptionUnion {
- if (!data) {
- return data;
- }
- switch (data['@class']) {
- case 'org.apache.streampipes.model.connect.adapter.SpecificAdapterStreamDescription':
- return SpecificAdapterStreamDescription.fromData(data);
- case 'org.apache.streampipes.model.connect.adapter.SpecificAdapterStreamDescription':
- return SpecificAdapterStreamDescription.fromData(data);
- }
- }
}
export class AdapterType {
- code: string;
- description: string;
- label: string;
+ code: string;
+ description: string;
+ label: string;
- static fromData(data: AdapterType, target?: AdapterType): AdapterType {
- if (!data) {
- return data;
+ static fromData(data: AdapterType, target?: AdapterType): AdapterType {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new AdapterType();
+ instance.label = data.label;
+ instance.description = data.description;
+ instance.code = data.code;
+ return instance;
}
- const instance = target || new AdapterType();
- instance.label = data.label;
- instance.description = data.description;
- instance.code = data.code;
- return instance;
- }
}
export class TransformationRuleDescription extends UnnamedStreamPipesEntity {
- '@class': 'org.apache.streampipes.model.connect.rules.TransformationRuleDescription' | 'org.apache.streampipes.model.connect.rules.value.ValueTransformationRuleDescription' | 'org.apache.streampipes.model.connect.rules.value.AddTimestampRuleDescription' | 'org.apache.streampipes.model.connect.rules.value.AddValueTransformationRuleDescription' | 'org.apache.streampipes.model.connect.rules.value.TimestampTranfsformationRuleDescription' | 'org.apache.streampipes.model.connect.rules.value. [...]
-
- static fromData(data: TransformationRuleDescription, target?: TransformationRuleDescription): TransformationRuleDescription {
- if (!data) {
- return data;
- }
- const instance = target || new TransformationRuleDescription();
- super.fromData(data, instance);
- return instance;
- }
-
- static fromDataUnion(data: TransformationRuleDescriptionUnion): TransformationRuleDescriptionUnion {
- if (!data) {
- return data;
- }
- switch (data['@class']) {
- case 'org.apache.streampipes.model.connect.rules.value.AddTimestampRuleDescription':
- return AddTimestampRuleDescription.fromData(data);
- case 'org.apache.streampipes.model.connect.rules.value.AddValueTransformationRuleDescription':
- return AddValueTransformationRuleDescription.fromData(data);
- case 'org.apache.streampipes.model.connect.rules.value.TimestampTranfsformationRuleDescription':
- return TimestampTranfsformationRuleDescription.fromData(data);
- case 'org.apache.streampipes.model.connect.rules.value.UnitTransformRuleDescription':
- return UnitTransformRuleDescription.fromData(data);
- case 'org.apache.streampipes.model.connect.rules.stream.EventRateTransformationRuleDescription':
- return EventRateTransformationRuleDescription.fromData(data);
- case 'org.apache.streampipes.model.connect.rules.stream.RemoveDuplicatesTransformationRuleDescription':
- return RemoveDuplicatesTransformationRuleDescription.fromData(data);
- case 'org.apache.streampipes.model.connect.rules.schema.CreateNestedRuleDescription':
- return CreateNestedRuleDescription.fromData(data);
- case 'org.apache.streampipes.model.connect.rules.schema.DeleteRuleDescription':
- return DeleteRuleDescription.fromData(data);
- case 'org.apache.streampipes.model.connect.rules.schema.RenameRuleDescription':
- return RenameRuleDescription.fromData(data);
- case 'org.apache.streampipes.model.connect.rules.schema.MoveRuleDescription':
- return MoveRuleDescription.fromData(data);
- case 'org.apache.streampipes.model.connect.rules.value.CorrectionValueTransformationRuleDescription':
- return CorrectionValueTransformationRuleDescription.fromData(data);
- }
- }
+ "@class": "org.apache.streampipes.model.connect.rules.TransformationRuleDescription" | "org.apache.streampipes.model.connect.rules.value.ValueTransformationRuleDescription" | "org.apache.streampipes.model.connect.rules.value.AddTimestampRuleDescription" | "org.apache.streampipes.model.connect.rules.value.AddValueTransformationRuleDescription" | "org.apache.streampipes.model.connect.rules.value.TimestampTranfsformationRuleDescription" | "org.apache.streampipes.model.connect.rules.valu [...]
+
+ static fromData(data: TransformationRuleDescription, target?: TransformationRuleDescription): TransformationRuleDescription {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new TransformationRuleDescription();
+ super.fromData(data, instance);
+ return instance;
+ }
+
+ static fromDataUnion(data: TransformationRuleDescriptionUnion): TransformationRuleDescriptionUnion {
+ if (!data) {
+ return data;
+ }
+ switch (data["@class"]) {
+ case "org.apache.streampipes.model.connect.rules.value.AddTimestampRuleDescription":
+ return AddTimestampRuleDescription.fromData(data);
+ case "org.apache.streampipes.model.connect.rules.value.AddValueTransformationRuleDescription":
+ return AddValueTransformationRuleDescription.fromData(data);
+ case "org.apache.streampipes.model.connect.rules.value.TimestampTranfsformationRuleDescription":
+ return TimestampTranfsformationRuleDescription.fromData(data);
+ case "org.apache.streampipes.model.connect.rules.value.UnitTransformRuleDescription":
+ return UnitTransformRuleDescription.fromData(data);
+ case "org.apache.streampipes.model.connect.rules.stream.EventRateTransformationRuleDescription":
+ return EventRateTransformationRuleDescription.fromData(data);
+ case "org.apache.streampipes.model.connect.rules.stream.RemoveDuplicatesTransformationRuleDescription":
+ return RemoveDuplicatesTransformationRuleDescription.fromData(data);
+ case "org.apache.streampipes.model.connect.rules.schema.CreateNestedRuleDescription":
+ return CreateNestedRuleDescription.fromData(data);
+ case "org.apache.streampipes.model.connect.rules.schema.DeleteRuleDescription":
+ return DeleteRuleDescription.fromData(data);
+ case "org.apache.streampipes.model.connect.rules.schema.RenameRuleDescription":
+ return RenameRuleDescription.fromData(data);
+ case "org.apache.streampipes.model.connect.rules.schema.MoveRuleDescription":
+ return MoveRuleDescription.fromData(data);
+ case "org.apache.streampipes.model.connect.rules.value.CorrectionValueTransformationRuleDescription":
+ return CorrectionValueTransformationRuleDescription.fromData(data);
+ }
+ }
}
export class ValueTransformationRuleDescription extends TransformationRuleDescription {
- '@class': 'org.apache.streampipes.model.connect.rules.value.ValueTransformationRuleDescription' | 'org.apache.streampipes.model.connect.rules.value.AddTimestampRuleDescription' | 'org.apache.streampipes.model.connect.rules.value.AddValueTransformationRuleDescription' | 'org.apache.streampipes.model.connect.rules.value.TimestampTranfsformationRuleDescription' | 'org.apache.streampipes.model.connect.rules.value.UnitTransformRuleDescription' | 'org.apache.streampipes.model.connect.rules.v [...]
-
- static fromData(data: ValueTransformationRuleDescription, target?: ValueTransformationRuleDescription): ValueTransformationRuleDescription {
- if (!data) {
- return data;
- }
- const instance = target || new ValueTransformationRuleDescription();
- super.fromData(data, instance);
- return instance;
- }
-
- static fromDataUnion(data: ValueTransformationRuleDescriptionUnion): ValueTransformationRuleDescriptionUnion {
- if (!data) {
- return data;
- }
- switch (data['@class']) {
- case 'org.apache.streampipes.model.connect.rules.value.AddTimestampRuleDescription':
- return AddTimestampRuleDescription.fromData(data);
- case 'org.apache.streampipes.model.connect.rules.value.AddValueTransformationRuleDescription':
- return AddValueTransformationRuleDescription.fromData(data);
- case 'org.apache.streampipes.model.connect.rules.value.TimestampTranfsformationRuleDescription':
- return TimestampTranfsformationRuleDescription.fromData(data);
- case 'org.apache.streampipes.model.connect.rules.value.UnitTransformRuleDescription':
- return UnitTransformRuleDescription.fromData(data);
- case 'org.apache.streampipes.model.connect.rules.value.CorrectionValueTransformationRuleDescription':
- return CorrectionValueTransformationRuleDescription.fromData(data);
+ "@class": "org.apache.streampipes.model.connect.rules.value.ValueTransformationRuleDescription" | "org.apache.streampipes.model.connect.rules.value.AddTimestampRuleDescription" | "org.apache.streampipes.model.connect.rules.value.AddValueTransformationRuleDescription" | "org.apache.streampipes.model.connect.rules.value.TimestampTranfsformationRuleDescription" | "org.apache.streampipes.model.connect.rules.value.UnitTransformRuleDescription" | "org.apache.streampipes.model.connect.rules [...]
+
+ static fromData(data: ValueTransformationRuleDescription, target?: ValueTransformationRuleDescription): ValueTransformationRuleDescription {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new ValueTransformationRuleDescription();
+ super.fromData(data, instance);
+ return instance;
+ }
+
+ static fromDataUnion(data: ValueTransformationRuleDescriptionUnion): ValueTransformationRuleDescriptionUnion {
+ if (!data) {
+ return data;
+ }
+ switch (data["@class"]) {
+ case "org.apache.streampipes.model.connect.rules.value.AddTimestampRuleDescription":
+ return AddTimestampRuleDescription.fromData(data);
+ case "org.apache.streampipes.model.connect.rules.value.AddValueTransformationRuleDescription":
+ return AddValueTransformationRuleDescription.fromData(data);
+ case "org.apache.streampipes.model.connect.rules.value.TimestampTranfsformationRuleDescription":
+ return TimestampTranfsformationRuleDescription.fromData(data);
+ case "org.apache.streampipes.model.connect.rules.value.UnitTransformRuleDescription":
+ return UnitTransformRuleDescription.fromData(data);
+ case "org.apache.streampipes.model.connect.rules.value.CorrectionValueTransformationRuleDescription":
+ return CorrectionValueTransformationRuleDescription.fromData(data);
+ }
}
- }
}
export class AddTimestampRuleDescription extends ValueTransformationRuleDescription {
- '@class': 'org.apache.streampipes.model.connect.rules.value.AddTimestampRuleDescription';
- runtimeKey: string;
+ "@class": "org.apache.streampipes.model.connect.rules.value.AddTimestampRuleDescription";
+ runtimeKey: string;
- static fromData(data: AddTimestampRuleDescription, target?: AddTimestampRuleDescription): AddTimestampRuleDescription {
- if (!data) {
- return data;
+ static fromData(data: AddTimestampRuleDescription, target?: AddTimestampRuleDescription): AddTimestampRuleDescription {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new AddTimestampRuleDescription();
+ super.fromData(data, instance);
+ instance.runtimeKey = data.runtimeKey;
+ return instance;
}
- const instance = target || new AddTimestampRuleDescription();
- super.fromData(data, instance);
- instance.runtimeKey = data.runtimeKey;
- return instance;
- }
}
export class AddValueTransformationRuleDescription extends ValueTransformationRuleDescription {
- '@class': 'org.apache.streampipes.model.connect.rules.value.AddValueTransformationRuleDescription';
- runtimeKey: string;
- staticValue: string;
+ "@class": "org.apache.streampipes.model.connect.rules.value.AddValueTransformationRuleDescription";
+ runtimeKey: string;
+ staticValue: string;
- static fromData(data: AddValueTransformationRuleDescription, target?: AddValueTransformationRuleDescription): AddValueTransformationRuleDescription {
- if (!data) {
- return data;
+ static fromData(data: AddValueTransformationRuleDescription, target?: AddValueTransformationRuleDescription): AddValueTransformationRuleDescription {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new AddValueTransformationRuleDescription();
+ super.fromData(data, instance);
+ instance.runtimeKey = data.runtimeKey;
+ instance.staticValue = data.staticValue;
+ return instance;
}
- const instance = target || new AddValueTransformationRuleDescription();
- super.fromData(data, instance);
- instance.runtimeKey = data.runtimeKey;
- instance.staticValue = data.staticValue;
- return instance;
- }
}
export class StaticProperty extends UnnamedStreamPipesEntity {
- '@class': 'org.apache.streampipes.model.staticproperty.StaticProperty' | 'org.apache.streampipes.model.staticproperty.CodeInputStaticProperty' | 'org.apache.streampipes.model.staticproperty.CollectionStaticProperty' | 'org.apache.streampipes.model.staticproperty.ColorPickerStaticProperty' | 'org.apache.streampipes.model.staticproperty.DomainStaticProperty' | 'org.apache.streampipes.model.staticproperty.FileStaticProperty' | 'org.apache.streampipes.model.staticproperty.FreeTextStaticPro [...]
- description: string;
- index: number;
- internalName: string;
- label: string;
- predefined: boolean;
- staticPropertyType: StaticPropertyType;
- valueRequired: boolean;
-
- static fromData(data: StaticProperty, target?: StaticProperty): StaticProperty {
- if (!data) {
- return data;
- }
- const instance = target || new StaticProperty();
- super.fromData(data, instance);
- instance.index = data.index;
- instance.label = data.label;
- instance.description = data.description;
- instance.internalName = data.internalName;
- instance.valueRequired = data.valueRequired;
- instance.predefined = data.predefined;
- instance.staticPropertyType = data.staticPropertyType;
- return instance;
- }
-
- static fromDataUnion(data: StaticPropertyUnion): StaticPropertyUnion {
- if (!data) {
- return data;
- }
- switch (data['@class']) {
- case 'org.apache.streampipes.model.staticproperty.AnyStaticProperty':
- return AnyStaticProperty.fromData(data);
- case 'org.apache.streampipes.model.staticproperty.CodeInputStaticProperty':
- return CodeInputStaticProperty.fromData(data);
- case 'org.apache.streampipes.model.staticproperty.CollectionStaticProperty':
- return CollectionStaticProperty.fromData(data);
- case 'org.apache.streampipes.model.staticproperty.ColorPickerStaticProperty':
- return ColorPickerStaticProperty.fromData(data);
- case 'org.apache.streampipes.model.staticproperty.DomainStaticProperty':
- return DomainStaticProperty.fromData(data);
- case 'org.apache.streampipes.model.staticproperty.FileStaticProperty':
- return FileStaticProperty.fromData(data);
- case 'org.apache.streampipes.model.staticproperty.FreeTextStaticProperty':
- return FreeTextStaticProperty.fromData(data);
- case 'org.apache.streampipes.model.staticproperty.MappingPropertyUnary':
- return MappingPropertyUnary.fromData(data);
- case 'org.apache.streampipes.model.staticproperty.MappingPropertyNary':
- return MappingPropertyNary.fromData(data);
- case 'org.apache.streampipes.model.staticproperty.MatchingStaticProperty':
- return MatchingStaticProperty.fromData(data);
- case 'org.apache.streampipes.model.staticproperty.OneOfStaticProperty':
- return OneOfStaticProperty.fromData(data);
- case 'org.apache.streampipes.model.staticproperty.RuntimeResolvableAnyStaticProperty':
- return RuntimeResolvableAnyStaticProperty.fromData(data);
- case 'org.apache.streampipes.model.staticproperty.RuntimeResolvableOneOfStaticProperty':
- return RuntimeResolvableOneOfStaticProperty.fromData(data);
- case 'org.apache.streampipes.model.staticproperty.SecretStaticProperty':
- return SecretStaticProperty.fromData(data);
- case 'org.apache.streampipes.model.staticproperty.StaticPropertyAlternative':
- return StaticPropertyAlternative.fromData(data);
- case 'org.apache.streampipes.model.staticproperty.StaticPropertyAlternatives':
- return StaticPropertyAlternatives.fromData(data);
- case 'org.apache.streampipes.model.staticproperty.StaticPropertyGroup':
- return StaticPropertyGroup.fromData(data);
- }
- }
+ "@class": "org.apache.streampipes.model.staticproperty.StaticProperty" | "org.apache.streampipes.model.staticproperty.CodeInputStaticProperty" | "org.apache.streampipes.model.staticproperty.CollectionStaticProperty" | "org.apache.streampipes.model.staticproperty.ColorPickerStaticProperty" | "org.apache.streampipes.model.staticproperty.DomainStaticProperty" | "org.apache.streampipes.model.staticproperty.FileStaticProperty" | "org.apache.streampipes.model.staticproperty.FreeTextStaticP [...]
+ description: string;
+ index: number;
+ internalName: string;
+ label: string;
+ predefined: boolean;
+ staticPropertyType: StaticPropertyType;
+ valueRequired: boolean;
+
+ static fromData(data: StaticProperty, target?: StaticProperty): StaticProperty {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new StaticProperty();
+ super.fromData(data, instance);
+ instance.index = data.index;
+ instance.label = data.label;
+ instance.description = data.description;
+ instance.internalName = data.internalName;
+ instance.valueRequired = data.valueRequired;
+ instance.predefined = data.predefined;
+ instance.staticPropertyType = data.staticPropertyType;
+ return instance;
+ }
+
+ static fromDataUnion(data: StaticPropertyUnion): StaticPropertyUnion {
+ if (!data) {
+ return data;
+ }
+ switch (data["@class"]) {
+ case "org.apache.streampipes.model.staticproperty.AnyStaticProperty":
+ return AnyStaticProperty.fromData(data);
+ case "org.apache.streampipes.model.staticproperty.CodeInputStaticProperty":
+ return CodeInputStaticProperty.fromData(data);
+ case "org.apache.streampipes.model.staticproperty.CollectionStaticProperty":
+ return CollectionStaticProperty.fromData(data);
+ case "org.apache.streampipes.model.staticproperty.ColorPickerStaticProperty":
+ return ColorPickerStaticProperty.fromData(data);
+ case "org.apache.streampipes.model.staticproperty.DomainStaticProperty":
+ return DomainStaticProperty.fromData(data);
+ case "org.apache.streampipes.model.staticproperty.FileStaticProperty":
+ return FileStaticProperty.fromData(data);
+ case "org.apache.streampipes.model.staticproperty.FreeTextStaticProperty":
+ return FreeTextStaticProperty.fromData(data);
+ case "org.apache.streampipes.model.staticproperty.MappingPropertyUnary":
+ return MappingPropertyUnary.fromData(data);
+ case "org.apache.streampipes.model.staticproperty.MappingPropertyNary":
+ return MappingPropertyNary.fromData(data);
+ case "org.apache.streampipes.model.staticproperty.MatchingStaticProperty":
+ return MatchingStaticProperty.fromData(data);
+ case "org.apache.streampipes.model.staticproperty.OneOfStaticProperty":
+ return OneOfStaticProperty.fromData(data);
+ case "org.apache.streampipes.model.staticproperty.RuntimeResolvableAnyStaticProperty":
+ return RuntimeResolvableAnyStaticProperty.fromData(data);
+ case "org.apache.streampipes.model.staticproperty.RuntimeResolvableOneOfStaticProperty":
+ return RuntimeResolvableOneOfStaticProperty.fromData(data);
+ case "org.apache.streampipes.model.staticproperty.SecretStaticProperty":
+ return SecretStaticProperty.fromData(data);
+ case "org.apache.streampipes.model.staticproperty.StaticPropertyAlternative":
+ return StaticPropertyAlternative.fromData(data);
+ case "org.apache.streampipes.model.staticproperty.StaticPropertyAlternatives":
+ return StaticPropertyAlternatives.fromData(data);
+ case "org.apache.streampipes.model.staticproperty.StaticPropertyGroup":
+ return StaticPropertyGroup.fromData(data);
+ }
+ }
}
export class SelectionStaticProperty extends StaticProperty {
- '@class': 'org.apache.streampipes.model.staticproperty.SelectionStaticProperty' | 'org.apache.streampipes.model.staticproperty.AnyStaticProperty' | 'org.apache.streampipes.model.staticproperty.RuntimeResolvableAnyStaticProperty' | 'org.apache.streampipes.model.staticproperty.OneOfStaticProperty' | 'org.apache.streampipes.model.staticproperty.RuntimeResolvableOneOfStaticProperty';
- horizontalRendering: boolean;
- options: Option[];
-
- static fromData(data: SelectionStaticProperty, target?: SelectionStaticProperty): SelectionStaticProperty {
- if (!data) {
- return data;
+ "@class": "org.apache.streampipes.model.staticproperty.SelectionStaticProperty" | "org.apache.streampipes.model.staticproperty.AnyStaticProperty" | "org.apache.streampipes.model.staticproperty.RuntimeResolvableAnyStaticProperty" | "org.apache.streampipes.model.staticproperty.OneOfStaticProperty" | "org.apache.streampipes.model.staticproperty.RuntimeResolvableOneOfStaticProperty";
+ horizontalRendering: boolean;
+ options: Option[];
+
+ static fromData(data: SelectionStaticProperty, target?: SelectionStaticProperty): SelectionStaticProperty {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new SelectionStaticProperty();
+ super.fromData(data, instance);
+ instance.options = __getCopyArrayFn(Option.fromData)(data.options);
+ instance.horizontalRendering = data.horizontalRendering;
+ return instance;
+ }
+
+ static fromDataUnion(data: SelectionStaticPropertyUnion): SelectionStaticPropertyUnion {
+ if (!data) {
+ return data;
+ }
+ switch (data["@class"]) {
+ case "org.apache.streampipes.model.staticproperty.AnyStaticProperty":
+ return AnyStaticProperty.fromData(data);
+ case "org.apache.streampipes.model.staticproperty.OneOfStaticProperty":
+ return OneOfStaticProperty.fromData(data);
+ }
}
- const instance = target || new SelectionStaticProperty();
- super.fromData(data, instance);
- instance.options = __getCopyArrayFn(Option.fromData)(data.options);
- instance.horizontalRendering = data.horizontalRendering;
- return instance;
- }
-
- static fromDataUnion(data: SelectionStaticPropertyUnion): SelectionStaticPropertyUnion {
- if (!data) {
- return data;
- }
- switch (data['@class']) {
- case 'org.apache.streampipes.model.staticproperty.AnyStaticProperty':
- return AnyStaticProperty.fromData(data);
- case 'org.apache.streampipes.model.staticproperty.OneOfStaticProperty':
- return OneOfStaticProperty.fromData(data);
- }
- }
}
export class AnyStaticProperty extends SelectionStaticProperty {
- '@class': 'org.apache.streampipes.model.staticproperty.AnyStaticProperty' | 'org.apache.streampipes.model.staticproperty.RuntimeResolvableAnyStaticProperty';
+ "@class": "org.apache.streampipes.model.staticproperty.AnyStaticProperty" | "org.apache.streampipes.model.staticproperty.RuntimeResolvableAnyStaticProperty";
- static fromData(data: AnyStaticProperty, target?: AnyStaticProperty): AnyStaticProperty {
- if (!data) {
- return data;
+ static fromData(data: AnyStaticProperty, target?: AnyStaticProperty): AnyStaticProperty {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new AnyStaticProperty();
+ super.fromData(data, instance);
+ return instance;
}
- const instance = target || new AnyStaticProperty();
- super.fromData(data, instance);
- return instance;
- }
}
export class OutputStrategy extends UnnamedStreamPipesEntity {
- '@class': 'org.apache.streampipes.model.output.OutputStrategy' | 'org.apache.streampipes.model.output.AppendOutputStrategy' | 'org.apache.streampipes.model.output.CustomOutputStrategy' | 'org.apache.streampipes.model.output.CustomTransformOutputStrategy' | 'org.apache.streampipes.model.output.FixedOutputStrategy' | 'org.apache.streampipes.model.output.KeepOutputStrategy' | 'org.apache.streampipes.model.output.ListOutputStrategy' | 'org.apache.streampipes.model.output.TransformOutputStr [...]
- name: string;
- renameRules: PropertyRenameRule[];
-
- static fromData(data: OutputStrategy, target?: OutputStrategy): OutputStrategy {
- if (!data) {
- return data;
- }
- const instance = target || new OutputStrategy();
- super.fromData(data, instance);
- instance.name = data.name;
- instance.renameRules = __getCopyArrayFn(PropertyRenameRule.fromData)(data.renameRules);
- return instance;
- }
-
- static fromDataUnion(data: OutputStrategyUnion): OutputStrategyUnion {
- if (!data) {
- return data;
- }
- switch (data['@class']) {
- case 'org.apache.streampipes.model.output.AppendOutputStrategy':
- return AppendOutputStrategy.fromData(data);
- case 'org.apache.streampipes.model.output.CustomOutputStrategy':
- return CustomOutputStrategy.fromData(data);
- case 'org.apache.streampipes.model.output.CustomTransformOutputStrategy':
- return CustomTransformOutputStrategy.fromData(data);
- case 'org.apache.streampipes.model.output.FixedOutputStrategy':
- return FixedOutputStrategy.fromData(data);
- case 'org.apache.streampipes.model.output.KeepOutputStrategy':
- return KeepOutputStrategy.fromData(data);
- case 'org.apache.streampipes.model.output.ListOutputStrategy':
- return ListOutputStrategy.fromData(data);
- case 'org.apache.streampipes.model.output.TransformOutputStrategy':
- return TransformOutputStrategy.fromData(data);
- case 'org.apache.streampipes.model.output.UserDefinedOutputStrategy':
- return UserDefinedOutputStrategy.fromData(data);
- }
- }
+ "@class": "org.apache.streampipes.model.output.OutputStrategy" | "org.apache.streampipes.model.output.AppendOutputStrategy" | "org.apache.streampipes.model.output.CustomOutputStrategy" | "org.apache.streampipes.model.output.CustomTransformOutputStrategy" | "org.apache.streampipes.model.output.FixedOutputStrategy" | "org.apache.streampipes.model.output.KeepOutputStrategy" | "org.apache.streampipes.model.output.ListOutputStrategy" | "org.apache.streampipes.model.output.TransformOutputS [...]
+ name: string;
+ renameRules: PropertyRenameRule[];
+
+ static fromData(data: OutputStrategy, target?: OutputStrategy): OutputStrategy {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new OutputStrategy();
+ super.fromData(data, instance);
+ instance.name = data.name;
+ instance.renameRules = __getCopyArrayFn(PropertyRenameRule.fromData)(data.renameRules);
+ return instance;
+ }
+
+ static fromDataUnion(data: OutputStrategyUnion): OutputStrategyUnion {
+ if (!data) {
+ return data;
+ }
+ switch (data["@class"]) {
+ case "org.apache.streampipes.model.output.AppendOutputStrategy":
+ return AppendOutputStrategy.fromData(data);
+ case "org.apache.streampipes.model.output.CustomOutputStrategy":
+ return CustomOutputStrategy.fromData(data);
+ case "org.apache.streampipes.model.output.CustomTransformOutputStrategy":
+ return CustomTransformOutputStrategy.fromData(data);
+ case "org.apache.streampipes.model.output.FixedOutputStrategy":
+ return FixedOutputStrategy.fromData(data);
+ case "org.apache.streampipes.model.output.KeepOutputStrategy":
+ return KeepOutputStrategy.fromData(data);
+ case "org.apache.streampipes.model.output.ListOutputStrategy":
+ return ListOutputStrategy.fromData(data);
+ case "org.apache.streampipes.model.output.TransformOutputStrategy":
+ return TransformOutputStrategy.fromData(data);
+ case "org.apache.streampipes.model.output.UserDefinedOutputStrategy":
+ return UserDefinedOutputStrategy.fromData(data);
+ }
+ }
}
export class AppendOutputStrategy extends OutputStrategy {
- '@class': 'org.apache.streampipes.model.output.AppendOutputStrategy';
- eventProperties: EventPropertyUnion[];
+ "@class": "org.apache.streampipes.model.output.AppendOutputStrategy";
+ eventProperties: EventPropertyUnion[];
- static fromData(data: AppendOutputStrategy, target?: AppendOutputStrategy): AppendOutputStrategy {
- if (!data) {
- return data;
+ static fromData(data: AppendOutputStrategy, target?: AppendOutputStrategy): AppendOutputStrategy {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new AppendOutputStrategy();
+ super.fromData(data, instance);
+ instance.eventProperties = __getCopyArrayFn(EventProperty.fromDataUnion)(data.eventProperties);
+ return instance;
}
- const instance = target || new AppendOutputStrategy();
- super.fromData(data, instance);
- instance.eventProperties = __getCopyArrayFn(EventProperty.fromDataUnion)(data.eventProperties);
- return instance;
- }
}
export class ApplicationLink extends UnnamedStreamPipesEntity {
- '@class': 'org.apache.streampipes.model.ApplicationLink';
- applicationDescription: string;
- applicationIconUrl: string;
- applicationLinkType: string;
- applicationName: string;
- applicationUrl: string;
-
- static fromData(data: ApplicationLink, target?: ApplicationLink): ApplicationLink {
- if (!data) {
- return data;
- }
- const instance = target || new ApplicationLink();
- super.fromData(data, instance);
- instance.applicationName = data.applicationName;
- instance.applicationDescription = data.applicationDescription;
- instance.applicationUrl = data.applicationUrl;
- instance.applicationIconUrl = data.applicationIconUrl;
- instance.applicationLinkType = data.applicationLinkType;
- return instance;
- }
+ "@class": "org.apache.streampipes.model.ApplicationLink";
+ applicationDescription: string;
+ applicationIconUrl: string;
+ applicationLinkType: string;
+ applicationName: string;
+ applicationUrl: string;
+
+ static fromData(data: ApplicationLink, target?: ApplicationLink): ApplicationLink {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new ApplicationLink();
+ super.fromData(data, instance);
+ instance.applicationName = data.applicationName;
+ instance.applicationDescription = data.applicationDescription;
+ instance.applicationUrl = data.applicationUrl;
+ instance.applicationIconUrl = data.applicationIconUrl;
+ instance.applicationLinkType = data.applicationLinkType;
+ return instance;
+ }
}
export class BoundPipelineElement extends UnnamedStreamPipesEntity {
- '@class': 'org.apache.streampipes.model.template.BoundPipelineElement';
- connectedTo: BoundPipelineElement[];
- pipelineElementTemplate: InvocableStreamPipesEntity;
+ "@class": "org.apache.streampipes.model.template.BoundPipelineElement";
+ connectedTo: BoundPipelineElement[];
+ pipelineElementTemplate: InvocableStreamPipesEntity;
- static fromData(data: BoundPipelineElement, target?: BoundPipelineElement): BoundPipelineElement {
- if (!data) {
- return data;
+ static fromData(data: BoundPipelineElement, target?: BoundPipelineElement): BoundPipelineElement {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new BoundPipelineElement();
+ super.fromData(data, instance);
+ instance.pipelineElementTemplate = InvocableStreamPipesEntity.fromData(data.pipelineElementTemplate);
+ instance.connectedTo = __getCopyArrayFn(BoundPipelineElement.fromData)(data.connectedTo);
+ return instance;
}
- const instance = target || new BoundPipelineElement();
- super.fromData(data, instance);
- instance.pipelineElementTemplate = InvocableStreamPipesEntity.fromData(data.pipelineElementTemplate);
- instance.connectedTo = __getCopyArrayFn(BoundPipelineElement.fromData)(data.connectedTo);
- return instance;
- }
}
export class CanvasPosition {
- x: number;
- y: number;
+ x: number;
+ y: number;
- static fromData(data: CanvasPosition, target?: CanvasPosition): CanvasPosition {
- if (!data) {
- return data;
+ static fromData(data: CanvasPosition, target?: CanvasPosition): CanvasPosition {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new CanvasPosition();
+ instance.x = data.x;
+ instance.y = data.y;
+ return instance;
}
- const instance = target || new CanvasPosition();
- instance.x = data.x;
- instance.y = data.y;
- return instance;
- }
}
export class Category {
- _id: string;
- _rev: string;
- internalName: string;
- name: string;
- superLabel: string;
- superLabelId: string;
-
- static fromData(data: Category, target?: Category): Category {
- if (!data) {
- return data;
- }
- const instance = target || new Category();
- instance.name = data.name;
- instance.internalName = data.internalName;
- instance.superLabelId = data.superLabelId;
- instance._id = data._id;
- instance._rev = data._rev;
- instance.superLabel = data.superLabel;
- return instance;
- }
+ _id: string;
+ _rev: string;
+ internalName: string;
+ name: string;
+ superLabel: string;
+ superLabelId: string;
+
+ static fromData(data: Category, target?: Category): Category {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new Category();
+ instance.name = data.name;
+ instance.internalName = data.internalName;
+ instance.superLabelId = data.superLabelId;
+ instance._id = data._id;
+ instance._rev = data._rev;
+ instance.superLabel = data.superLabel;
+ return instance;
+ }
}
export class CodeInputStaticProperty extends StaticProperty {
- '@class': 'org.apache.streampipes.model.staticproperty.CodeInputStaticProperty';
- codeTemplate: string;
- language: string;
- value: string;
+ "@class": "org.apache.streampipes.model.staticproperty.CodeInputStaticProperty";
+ codeTemplate: string;
+ language: string;
+ value: string;
- static fromData(data: CodeInputStaticProperty, target?: CodeInputStaticProperty): CodeInputStaticProperty {
- if (!data) {
- return data;
+ static fromData(data: CodeInputStaticProperty, target?: CodeInputStaticProperty): CodeInputStaticProperty {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new CodeInputStaticProperty();
+ super.fromData(data, instance);
+ instance.language = data.language;
+ instance.codeTemplate = data.codeTemplate;
+ instance.value = data.value;
+ return instance;
}
- const instance = target || new CodeInputStaticProperty();
- super.fromData(data, instance);
- instance.language = data.language;
- instance.codeTemplate = data.codeTemplate;
- instance.value = data.value;
- return instance;
- }
}
export class CollectionStaticProperty extends StaticProperty {
- '@class': 'org.apache.streampipes.model.staticproperty.CollectionStaticProperty';
- memberType: string;
- members: StaticPropertyUnion[];
- staticPropertyTemplate: StaticPropertyUnion;
+ "@class": "org.apache.streampipes.model.staticproperty.CollectionStaticProperty";
+ memberType: string;
+ members: StaticPropertyUnion[];
+ staticPropertyTemplate: StaticPropertyUnion;
- static fromData(data: CollectionStaticProperty, target?: CollectionStaticProperty): CollectionStaticProperty {
- if (!data) {
- return data;
+ static fromData(data: CollectionStaticProperty, target?: CollectionStaticProperty): CollectionStaticProperty {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new CollectionStaticProperty();
+ super.fromData(data, instance);
+ instance.staticPropertyTemplate = StaticProperty.fromDataUnion(data.staticPropertyTemplate);
+ instance.members = __getCopyArrayFn(StaticProperty.fromDataUnion)(data.members);
+ instance.memberType = data.memberType;
+ return instance;
}
- const instance = target || new CollectionStaticProperty();
- super.fromData(data, instance);
- instance.staticPropertyTemplate = StaticProperty.fromDataUnion(data.staticPropertyTemplate);
- instance.members = __getCopyArrayFn(StaticProperty.fromDataUnion)(data.members);
- instance.memberType = data.memberType;
- return instance;
- }
}
export class ColorPickerStaticProperty extends StaticProperty {
- '@class': 'org.apache.streampipes.model.staticproperty.ColorPickerStaticProperty';
- selectedColor: string;
+ "@class": "org.apache.streampipes.model.staticproperty.ColorPickerStaticProperty";
+ selectedColor: string;
- static fromData(data: ColorPickerStaticProperty, target?: ColorPickerStaticProperty): ColorPickerStaticProperty {
- if (!data) {
- return data;
+ static fromData(data: ColorPickerStaticProperty, target?: ColorPickerStaticProperty): ColorPickerStaticProperty {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new ColorPickerStaticProperty();
+ super.fromData(data, instance);
+ instance.selectedColor = data.selectedColor;
+ return instance;
}
- const instance = target || new ColorPickerStaticProperty();
- super.fromData(data, instance);
- instance.selectedColor = data.selectedColor;
- return instance;
- }
}
export class MessagesInfo {
- groupId: string;
- topicName: string;
+ groupId: string;
+ topicName: string;
- static fromData(data: MessagesInfo, target?: MessagesInfo): MessagesInfo {
- if (!data) {
- return data;
+ static fromData(data: MessagesInfo, target?: MessagesInfo): MessagesInfo {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new MessagesInfo();
+ instance.topicName = data.topicName;
+ instance.groupId = data.groupId;
+ return instance;
}
- const instance = target || new MessagesInfo();
- instance.topicName = data.topicName;
- instance.groupId = data.groupId;
- return instance;
- }
}
export class ConsumedMessagesInfo extends MessagesInfo {
- consumedMessagesSincePipelineStart: number;
- lag: number;
- totalMessagesSincePipelineStart: number;
+ consumedMessagesSincePipelineStart: number;
+ lag: number;
+ totalMessagesSincePipelineStart: number;
- static fromData(data: ConsumedMessagesInfo, target?: ConsumedMessagesInfo): ConsumedMessagesInfo {
- if (!data) {
- return data;
+ static fromData(data: ConsumedMessagesInfo, target?: ConsumedMessagesInfo): ConsumedMessagesInfo {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new ConsumedMessagesInfo();
+ super.fromData(data, instance);
+ instance.totalMessagesSincePipelineStart = data.totalMessagesSincePipelineStart;
+ instance.consumedMessagesSincePipelineStart = data.consumedMessagesSincePipelineStart;
+ instance.lag = data.lag;
+ return instance;
}
- const instance = target || new ConsumedMessagesInfo();
- super.fromData(data, instance);
- instance.totalMessagesSincePipelineStart = data.totalMessagesSincePipelineStart;
- instance.consumedMessagesSincePipelineStart = data.consumedMessagesSincePipelineStart;
- instance.lag = data.lag;
- return instance;
- }
}
export class CorrectionValueTransformationRuleDescription extends ValueTransformationRuleDescription {
- '@class': 'org.apache.streampipes.model.connect.rules.value.CorrectionValueTransformationRuleDescription';
- correctionValue: number;
- operator: string;
- runtimeKey: string;
+ "@class": "org.apache.streampipes.model.connect.rules.value.CorrectionValueTransformationRuleDescription";
+ correctionValue: number;
+ operator: string;
+ runtimeKey: string;
- static fromData(data: CorrectionValueTransformationRuleDescription, target?: CorrectionValueTransformationRuleDescription): CorrectionValueTransformationRuleDescription {
- if (!data) {
- return data;
+ static fromData(data: CorrectionValueTransformationRuleDescription, target?: CorrectionValueTransformationRuleDescription): CorrectionValueTransformationRuleDescription {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new CorrectionValueTransformationRuleDescription();
+ super.fromData(data, instance);
+ instance.runtimeKey = data.runtimeKey;
+ instance.correctionValue = data.correctionValue;
+ instance.operator = data.operator;
+ return instance;
}
- const instance = target || new CorrectionValueTransformationRuleDescription();
- super.fromData(data, instance);
- instance.runtimeKey = data.runtimeKey;
- instance.correctionValue = data.correctionValue;
- instance.operator = data.operator;
- return instance;
- }
}
export class SchemaTransformationRuleDescription extends TransformationRuleDescription {
- '@class': 'org.apache.streampipes.model.connect.rules.schema.SchemaTransformationRuleDescription' | 'org.apache.streampipes.model.connect.rules.schema.CreateNestedRuleDescription' | 'org.apache.streampipes.model.connect.rules.schema.DeleteRuleDescription' | 'org.apache.streampipes.model.connect.rules.schema.RenameRuleDescription' | 'org.apache.streampipes.model.connect.rules.schema.MoveRuleDescription';
+ "@class": "org.apache.streampipes.model.connect.rules.schema.SchemaTransformationRuleDescription" | "org.apache.streampipes.model.connect.rules.schema.CreateNestedRuleDescription" | "org.apache.streampipes.model.connect.rules.schema.DeleteRuleDescription" | "org.apache.streampipes.model.connect.rules.schema.RenameRuleDescription" | "org.apache.streampipes.model.connect.rules.schema.MoveRuleDescription";
- static fromData(data: SchemaTransformationRuleDescription, target?: SchemaTransformationRuleDescription): SchemaTransformationRuleDescription {
- if (!data) {
- return data;
+ static fromData(data: SchemaTransformationRuleDescription, target?: SchemaTransformationRuleDescription): SchemaTransformationRuleDescription {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new SchemaTransformationRuleDescription();
+ super.fromData(data, instance);
+ return instance;
}
- const instance = target || new SchemaTransformationRuleDescription();
- super.fromData(data, instance);
- return instance;
- }
}
export class CreateNestedRuleDescription extends SchemaTransformationRuleDescription {
- '@class': 'org.apache.streampipes.model.connect.rules.schema.CreateNestedRuleDescription';
- runtimeKey: string;
+ "@class": "org.apache.streampipes.model.connect.rules.schema.CreateNestedRuleDescription";
+ runtimeKey: string;
- static fromData(data: CreateNestedRuleDescription, target?: CreateNestedRuleDescription): CreateNestedRuleDescription {
- if (!data) {
- return data;
+ static fromData(data: CreateNestedRuleDescription, target?: CreateNestedRuleDescription): CreateNestedRuleDescription {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new CreateNestedRuleDescription();
+ super.fromData(data, instance);
+ instance.runtimeKey = data.runtimeKey;
+ return instance;
}
- const instance = target || new CreateNestedRuleDescription();
- super.fromData(data, instance);
- instance.runtimeKey = data.runtimeKey;
- return instance;
- }
}
export class CustomOutputStrategy extends OutputStrategy {
- '@class': 'org.apache.streampipes.model.output.CustomOutputStrategy';
- availablePropertyKeys: string[];
- outputRight: boolean;
- selectedPropertyKeys: string[];
+ "@class": "org.apache.streampipes.model.output.CustomOutputStrategy";
+ availablePropertyKeys: string[];
+ outputRight: boolean;
+ selectedPropertyKeys: string[];
- static fromData(data: CustomOutputStrategy, target?: CustomOutputStrategy): CustomOutputStrategy {
- if (!data) {
- return data;
+ static fromData(data: CustomOutputStrategy, target?: CustomOutputStrategy): CustomOutputStrategy {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new CustomOutputStrategy();
+ super.fromData(data, instance);
+ instance.selectedPropertyKeys = __getCopyArrayFn(__identity<string>())(data.selectedPropertyKeys);
+ instance.outputRight = data.outputRight;
+ instance.availablePropertyKeys = __getCopyArrayFn(__identity<string>())(data.availablePropertyKeys);
+ return instance;
}
- const instance = target || new CustomOutputStrategy();
- super.fromData(data, instance);
- instance.selectedPropertyKeys = __getCopyArrayFn(__identity<string>())(data.selectedPropertyKeys);
- instance.outputRight = data.outputRight;
- instance.availablePropertyKeys = __getCopyArrayFn(__identity<string>())(data.availablePropertyKeys);
- return instance;
- }
}
export class CustomTransformOutputStrategy extends OutputStrategy {
- '@class': 'org.apache.streampipes.model.output.CustomTransformOutputStrategy';
- eventProperties: EventPropertyUnion[];
+ "@class": "org.apache.streampipes.model.output.CustomTransformOutputStrategy";
+ eventProperties: EventPropertyUnion[];
- static fromData(data: CustomTransformOutputStrategy, target?: CustomTransformOutputStrategy): CustomTransformOutputStrategy {
- if (!data) {
- return data;
+ static fromData(data: CustomTransformOutputStrategy, target?: CustomTransformOutputStrategy): CustomTransformOutputStrategy {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new CustomTransformOutputStrategy();
+ super.fromData(data, instance);
+ instance.eventProperties = __getCopyArrayFn(EventProperty.fromDataUnion)(data.eventProperties);
+ return instance;
}
- const instance = target || new CustomTransformOutputStrategy();
- super.fromData(data, instance);
- instance.eventProperties = __getCopyArrayFn(EventProperty.fromDataUnion)(data.eventProperties);
- return instance;
- }
}
export class DashboardEntity {
- _id: string;
- _rev: string;
+ _id: string;
+ _rev: string;
- static fromData(data: DashboardEntity, target?: DashboardEntity): DashboardEntity {
- if (!data) {
- return data;
+ static fromData(data: DashboardEntity, target?: DashboardEntity): DashboardEntity {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new DashboardEntity();
+ instance._id = data._id;
+ instance._rev = data._rev;
+ return instance;
}
- const instance = target || new DashboardEntity();
- instance._id = data._id;
- instance._rev = data._rev;
- return instance;
- }
}
export class DashboardItem {
- cols: number;
- component: string;
- id: string;
- name: string;
- rows: number;
- settings: string[];
- x: number;
- y: number;
-
- static fromData(data: DashboardItem, target?: DashboardItem): DashboardItem {
- if (!data) {
- return data;
- }
- const instance = target || new DashboardItem();
- instance.id = data.id;
- instance.name = data.name;
- instance.component = data.component;
- instance.settings = __getCopyArrayFn(__identity<string>())(data.settings);
- instance.cols = data.cols;
- instance.rows = data.rows;
- instance.x = data.x;
- instance.y = data.y;
- return instance;
- }
+ cols: number;
+ component: string;
+ id: string;
+ name: string;
+ rows: number;
+ settings: string[];
+ x: number;
+ y: number;
+
+ static fromData(data: DashboardItem, target?: DashboardItem): DashboardItem {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new DashboardItem();
+ instance.id = data.id;
+ instance.name = data.name;
+ instance.component = data.component;
+ instance.settings = __getCopyArrayFn(__identity<string>())(data.settings);
+ instance.cols = data.cols;
+ instance.rows = data.rows;
+ instance.x = data.x;
+ instance.y = data.y;
+ return instance;
+ }
}
export class DashboardModel {
- _id: string;
- _rev: string;
- dashboardGeneralSettings: { [index: string]: any };
- dashboardTimeSettings: { [index: string]: any };
- description: string;
- displayHeader: boolean;
- id: string;
- name: string;
- widgets: DashboardItem[];
-
- static fromData(data: DashboardModel, target?: DashboardModel): DashboardModel {
- if (!data) {
- return data;
- }
- const instance = target || new DashboardModel();
- instance.id = data.id;
- instance.name = data.name;
- instance.description = data.description;
- instance.displayHeader = data.displayHeader;
- instance.dashboardTimeSettings = __getCopyObjectFn(__identity<any>())(data.dashboardTimeSettings);
- instance.dashboardGeneralSettings = __getCopyObjectFn(__identity<any>())(data.dashboardGeneralSettings);
- instance.widgets = __getCopyArrayFn(DashboardItem.fromData)(data.widgets);
- instance._id = data._id;
- instance._rev = data._rev;
- return instance;
- }
+ _id: string;
+ _rev: string;
+ dashboardGeneralSettings: { [index: string]: any };
+ dashboardTimeSettings: { [index: string]: any };
+ description: string;
+ displayHeader: boolean;
+ id: string;
+ name: string;
+ widgets: DashboardItem[];
+
+ static fromData(data: DashboardModel, target?: DashboardModel): DashboardModel {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new DashboardModel();
+ instance.id = data.id;
+ instance.name = data.name;
+ instance.description = data.description;
+ instance.displayHeader = data.displayHeader;
+ instance.dashboardTimeSettings = __getCopyObjectFn(__identity<any>())(data.dashboardTimeSettings);
+ instance.dashboardGeneralSettings = __getCopyObjectFn(__identity<any>())(data.dashboardGeneralSettings);
+ instance.widgets = __getCopyArrayFn(DashboardItem.fromData)(data.widgets);
+ instance._id = data._id;
+ instance._rev = data._rev;
+ return instance;
+ }
}
export class DashboardWidgetModel extends DashboardEntity {
- dashboardWidgetSettings: DashboardWidgetSettings;
- pipelineId: string;
- visualizationName: string;
- widgetId: string;
- widgetType: string;
-
- static fromData(data: DashboardWidgetModel, target?: DashboardWidgetModel): DashboardWidgetModel {
- if (!data) {
- return data;
- }
- const instance = target || new DashboardWidgetModel();
- super.fromData(data, instance);
- instance.widgetId = data.widgetId;
- instance.widgetType = data.widgetType;
- instance.dashboardWidgetSettings = DashboardWidgetSettings.fromData(data.dashboardWidgetSettings);
- instance.pipelineId = data.pipelineId;
- instance.visualizationName = data.visualizationName;
- return instance;
- }
+ dashboardWidgetSettings: DashboardWidgetSettings;
+ pipelineId: string;
+ visualizationName: string;
+ widgetId: string;
+ widgetType: string;
+
+ static fromData(data: DashboardWidgetModel, target?: DashboardWidgetModel): DashboardWidgetModel {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new DashboardWidgetModel();
+ super.fromData(data, instance);
+ instance.widgetId = data.widgetId;
+ instance.widgetType = data.widgetType;
+ instance.dashboardWidgetSettings = DashboardWidgetSettings.fromData(data.dashboardWidgetSettings);
+ instance.pipelineId = data.pipelineId;
+ instance.visualizationName = data.visualizationName;
+ return instance;
+ }
}
export class DashboardWidgetSettings extends UnnamedStreamPipesEntity {
- '@class': 'org.apache.streampipes.model.dashboard.DashboardWidgetSettings';
- config: StaticPropertyUnion[];
- requiredSchema: EventSchema;
- widgetDescription: string;
- widgetIconName: string;
- widgetLabel: string;
- widgetName: string;
-
- static fromData(data: DashboardWidgetSettings, target?: DashboardWidgetSettings): DashboardWidgetSettings {
- if (!data) {
- return data;
- }
- const instance = target || new DashboardWidgetSettings();
- super.fromData(data, instance);
- instance.widgetLabel = data.widgetLabel;
- instance.widgetName = data.widgetName;
- instance.config = __getCopyArrayFn(StaticProperty.fromDataUnion)(data.config);
- instance.requiredSchema = EventSchema.fromData(data.requiredSchema);
- instance.widgetIconName = data.widgetIconName;
- instance.widgetDescription = data.widgetDescription;
- return instance;
- }
+ "@class": "org.apache.streampipes.model.dashboard.DashboardWidgetSettings";
+ config: StaticPropertyUnion[];
+ requiredSchema: EventSchema;
+ widgetDescription: string;
+ widgetIconName: string;
+ widgetLabel: string;
+ widgetName: string;
+
+ static fromData(data: DashboardWidgetSettings, target?: DashboardWidgetSettings): DashboardWidgetSettings {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new DashboardWidgetSettings();
+ super.fromData(data, instance);
+ instance.widgetLabel = data.widgetLabel;
+ instance.widgetName = data.widgetName;
+ instance.config = __getCopyArrayFn(StaticProperty.fromDataUnion)(data.config);
+ instance.requiredSchema = EventSchema.fromData(data.requiredSchema);
+ instance.widgetIconName = data.widgetIconName;
+ instance.widgetDescription = data.widgetDescription;
+ return instance;
+ }
}
export class DataExplorerWidgetModel extends DashboardEntity {
- baseAppearanceConfig: { [index: string]: any };
- dataConfig: { [index: string]: any };
- measureName: string;
- pipelineId: string;
- visualizationConfig: { [index: string]: any };
- widgetId: string;
- widgetType: string;
-
- static fromData(data: DataExplorerWidgetModel, target?: DataExplorerWidgetModel): DataExplorerWidgetModel {
- if (!data) {
- return data;
- }
- const instance = target || new DataExplorerWidgetModel();
- super.fromData(data, instance);
- instance.widgetId = data.widgetId;
- instance.widgetType = data.widgetType;
- instance.baseAppearanceConfig = __getCopyObjectFn(__identity<any>())(data.baseAppearanceConfig);
- instance.visualizationConfig = __getCopyObjectFn(__identity<any>())(data.visualizationConfig);
- instance.dataConfig = __getCopyObjectFn(__identity<any>())(data.dataConfig);
- instance.pipelineId = data.pipelineId;
- instance.measureName = data.measureName;
- return instance;
- }
+ baseAppearanceConfig: { [index: string]: any };
+ dataConfig: { [index: string]: any };
+ measureName: string;
+ pipelineId: string;
+ visualizationConfig: { [index: string]: any };
+ widgetId: string;
+ widgetType: string;
+
+ static fromData(data: DataExplorerWidgetModel, target?: DataExplorerWidgetModel): DataExplorerWidgetModel {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new DataExplorerWidgetModel();
+ super.fromData(data, instance);
+ instance.widgetId = data.widgetId;
+ instance.widgetType = data.widgetType;
+ instance.baseAppearanceConfig = __getCopyObjectFn(__identity<any>())(data.baseAppearanceConfig);
+ instance.visualizationConfig = __getCopyObjectFn(__identity<any>())(data.visualizationConfig);
+ instance.dataConfig = __getCopyObjectFn(__identity<any>())(data.dataConfig);
+ instance.pipelineId = data.pipelineId;
+ instance.measureName = data.measureName;
+ return instance;
+ }
}
export class DataLakeMeasure extends UnnamedStreamPipesEntity {
- '@class': 'org.apache.streampipes.model.datalake.DataLakeMeasure';
- eventSchema: EventSchema;
- measureName: string;
- pipelineId: string;
- pipelineIsRunning: boolean;
- pipelineName: string;
-
- static fromData(data: DataLakeMeasure, target?: DataLakeMeasure): DataLakeMeasure {
- if (!data) {
- return data;
- }
- const instance = target || new DataLakeMeasure();
- super.fromData(data, instance);
- instance.measureName = data.measureName;
- instance.eventSchema = EventSchema.fromData(data.eventSchema);
- instance.pipelineId = data.pipelineId;
- instance.pipelineName = data.pipelineName;
- instance.pipelineIsRunning = data.pipelineIsRunning;
- return instance;
- }
+ "@class": "org.apache.streampipes.model.datalake.DataLakeMeasure";
+ eventSchema: EventSchema;
+ measureName: string;
+ pipelineId: string;
+ pipelineIsRunning: boolean;
+ pipelineName: string;
+
+ static fromData(data: DataLakeMeasure, target?: DataLakeMeasure): DataLakeMeasure {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new DataLakeMeasure();
+ super.fromData(data, instance);
+ instance.measureName = data.measureName;
+ instance.eventSchema = EventSchema.fromData(data.eventSchema);
+ instance.pipelineId = data.pipelineId;
+ instance.pipelineName = data.pipelineName;
+ instance.pipelineIsRunning = data.pipelineIsRunning;
+ return instance;
+ }
}
export class InvocableStreamPipesEntity extends NamedStreamPipesEntity {
- '@class': 'org.apache.streampipes.model.base.InvocableStreamPipesEntity' | 'org.apache.streampipes.model.graph.DataProcessorInvocation' | 'org.apache.streampipes.model.graph.DataSinkInvocation';
- belongsTo: string;
- configured: boolean;
- correspondingPipeline: string;
- correspondingUser: string;
- inputStreams: SpDataStreamUnion[];
- selectedEndpointUrl: string;
- staticProperties: StaticPropertyUnion[];
- statusInfoSettings: ElementStatusInfoSettings;
- streamRequirements: SpDataStreamUnion[];
- supportedGrounding: EventGrounding;
- uncompleted: boolean;
-
- static fromData(data: InvocableStreamPipesEntity, target?: InvocableStreamPipesEntity): InvocableStreamPipesEntity {
- if (!data) {
- return data;
- }
- const instance = target || new InvocableStreamPipesEntity();
- super.fromData(data, instance);
- instance.inputStreams = __getCopyArrayFn(SpDataStream.fromDataUnion)(data.inputStreams);
- instance.staticProperties = __getCopyArrayFn(StaticProperty.fromDataUnion)(data.staticProperties);
- instance.belongsTo = data.belongsTo;
- instance.statusInfoSettings = ElementStatusInfoSettings.fromData(data.statusInfoSettings);
- instance.supportedGrounding = EventGrounding.fromData(data.supportedGrounding);
- instance.correspondingPipeline = data.correspondingPipeline;
- instance.correspondingUser = data.correspondingUser;
- instance.streamRequirements = __getCopyArrayFn(SpDataStream.fromDataUnion)(data.streamRequirements);
- instance.configured = data.configured;
- instance.uncompleted = data.uncompleted;
- instance.selectedEndpointUrl = data.selectedEndpointUrl;
- return instance;
- }
+ "@class": "org.apache.streampipes.model.base.InvocableStreamPipesEntity" | "org.apache.streampipes.model.graph.DataProcessorInvocation" | "org.apache.streampipes.model.graph.DataSinkInvocation";
+ belongsTo: string;
+ configured: boolean;
+ correspondingPipeline: string;
+ correspondingUser: string;
+ inputStreams: SpDataStreamUnion[];
+ selectedEndpointUrl: string;
+ staticProperties: StaticPropertyUnion[];
+ statusInfoSettings: ElementStatusInfoSettings;
+ streamRequirements: SpDataStreamUnion[];
+ supportedGrounding: EventGrounding;
+ uncompleted: boolean;
+
+ static fromData(data: InvocableStreamPipesEntity, target?: InvocableStreamPipesEntity): InvocableStreamPipesEntity {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new InvocableStreamPipesEntity();
+ super.fromData(data, instance);
+ instance.inputStreams = __getCopyArrayFn(SpDataStream.fromDataUnion)(data.inputStreams);
+ instance.staticProperties = __getCopyArrayFn(StaticProperty.fromDataUnion)(data.staticProperties);
+ instance.belongsTo = data.belongsTo;
+ instance.statusInfoSettings = ElementStatusInfoSettings.fromData(data.statusInfoSettings);
+ instance.supportedGrounding = EventGrounding.fromData(data.supportedGrounding);
+ instance.correspondingPipeline = data.correspondingPipeline;
+ instance.correspondingUser = data.correspondingUser;
+ instance.streamRequirements = __getCopyArrayFn(SpDataStream.fromDataUnion)(data.streamRequirements);
+ instance.configured = data.configured;
+ instance.uncompleted = data.uncompleted;
+ instance.selectedEndpointUrl = data.selectedEndpointUrl;
+ return instance;
+ }
}
export class DataProcessorInvocation extends InvocableStreamPipesEntity {
- '@class': 'org.apache.streampipes.model.graph.DataProcessorInvocation';
- category: string[];
- outputStrategies: OutputStrategyUnion[];
- outputStream: SpDataStreamUnion;
- pathName: string;
-
- static fromData(data: DataProcessorInvocation, target?: DataProcessorInvocation): DataProcessorInvocation {
- if (!data) {
- return data;
- }
- const instance = target || new DataProcessorInvocation();
- super.fromData(data, instance);
- instance.outputStream = SpDataStream.fromDataUnion(data.outputStream);
- instance.outputStrategies = __getCopyArrayFn(OutputStrategy.fromDataUnion)(data.outputStrategies);
- instance.pathName = data.pathName;
- instance.category = __getCopyArrayFn(__identity<string>())(data.category);
- return instance;
- }
+ "@class": "org.apache.streampipes.model.graph.DataProcessorInvocation";
+ category: string[];
+ outputStrategies: OutputStrategyUnion[];
+ outputStream: SpDataStreamUnion;
+ pathName: string;
+
+ static fromData(data: DataProcessorInvocation, target?: DataProcessorInvocation): DataProcessorInvocation {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new DataProcessorInvocation();
+ super.fromData(data, instance);
+ instance.outputStream = SpDataStream.fromDataUnion(data.outputStream);
+ instance.outputStrategies = __getCopyArrayFn(OutputStrategy.fromDataUnion)(data.outputStrategies);
+ instance.pathName = data.pathName;
+ instance.category = __getCopyArrayFn(__identity<string>())(data.category);
+ return instance;
+ }
}
export class DataProcessorType {
- code: string;
- description: string;
- label: string;
+ code: string;
+ description: string;
+ label: string;
- static fromData(data: DataProcessorType, target?: DataProcessorType): DataProcessorType {
- if (!data) {
- return data;
+ static fromData(data: DataProcessorType, target?: DataProcessorType): DataProcessorType {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new DataProcessorType();
+ instance.label = data.label;
+ instance.description = data.description;
+ instance.code = data.code;
+ return instance;
}
- const instance = target || new DataProcessorType();
- instance.label = data.label;
- instance.description = data.description;
- instance.code = data.code;
- return instance;
- }
}
export class DataSeries {
- headers: string[];
- rows: any[][];
- tags: { [index: string]: string };
- total: number;
+ headers: string[];
+ rows: any[][];
+ tags: { [index: string]: string };
+ total: number;
- static fromData(data: DataSeries, target?: DataSeries): DataSeries {
- if (!data) {
- return data;
+ static fromData(data: DataSeries, target?: DataSeries): DataSeries {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new DataSeries();
+ instance.total = data.total;
+ instance.rows = __getCopyArrayFn(__getCopyArrayFn(__identity<any>()))(data.rows);
+ instance.tags = __getCopyObjectFn(__identity<string>())(data.tags);
+ instance.headers = __getCopyArrayFn(__identity<string>())(data.headers);
+ return instance;
}
- const instance = target || new DataSeries();
- instance.total = data.total;
- instance.rows = __getCopyArrayFn(__getCopyArrayFn(__identity<any>()))(data.rows);
- instance.tags = __getCopyObjectFn(__identity<string>())(data.tags);
- instance.headers = __getCopyArrayFn(__identity<string>())(data.headers);
- return instance;
- }
}
export class Message {
- elementName: string;
- notifications: Notification[];
- success: boolean;
+ elementName: string;
+ notifications: Notification[];
+ success: boolean;
- static fromData(data: Message, target?: Message): Message {
- if (!data) {
- return data;
+ static fromData(data: Message, target?: Message): Message {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new Message();
+ instance.success = data.success;
+ instance.elementName = data.elementName;
+ instance.notifications = __getCopyArrayFn(Notification.fromData)(data.notifications);
+ return instance;
}
- const instance = target || new Message();
- instance.success = data.success;
- instance.elementName = data.elementName;
- instance.notifications = __getCopyArrayFn(Notification.fromData)(data.notifications);
- return instance;
- }
}
export class DataSetModificationMessage extends Message {
- eventGrounding: EventGrounding;
- invocationId: string;
+ eventGrounding: EventGrounding;
+ invocationId: string;
- static fromData(data: DataSetModificationMessage, target?: DataSetModificationMessage): DataSetModificationMessage {
- if (!data) {
- return data;
+ static fromData(data: DataSetModificationMessage, target?: DataSetModificationMessage): DataSetModificationMessage {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new DataSetModificationMessage();
+ super.fromData(data, instance);
+ instance.eventGrounding = EventGrounding.fromData(data.eventGrounding);
+ instance.invocationId = data.invocationId;
+ return instance;
}
- const instance = target || new DataSetModificationMessage();
- super.fromData(data, instance);
- instance.eventGrounding = EventGrounding.fromData(data.eventGrounding);
- instance.invocationId = data.invocationId;
- return instance;
- }
}
export class DataSinkInvocation extends InvocableStreamPipesEntity {
- '@class': 'org.apache.streampipes.model.graph.DataSinkInvocation';
- category: string[];
+ "@class": "org.apache.streampipes.model.graph.DataSinkInvocation";
+ category: string[];
- static fromData(data: DataSinkInvocation, target?: DataSinkInvocation): DataSinkInvocation {
- if (!data) {
- return data;
+ static fromData(data: DataSinkInvocation, target?: DataSinkInvocation): DataSinkInvocation {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new DataSinkInvocation();
+ super.fromData(data, instance);
+ instance.category = __getCopyArrayFn(__identity<string>())(data.category);
+ return instance;
}
- const instance = target || new DataSinkInvocation();
- super.fromData(data, instance);
- instance.category = __getCopyArrayFn(__identity<string>())(data.category);
- return instance;
- }
}
export class DataSinkType {
- code: string;
- description: string;
- label: string;
+ code: string;
+ description: string;
+ label: string;
- static fromData(data: DataSinkType, target?: DataSinkType): DataSinkType {
- if (!data) {
- return data;
+ static fromData(data: DataSinkType, target?: DataSinkType): DataSinkType {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new DataSinkType();
+ instance.label = data.label;
+ instance.description = data.description;
+ instance.code = data.code;
+ return instance;
}
- const instance = target || new DataSinkType();
- instance.label = data.label;
- instance.description = data.description;
- instance.code = data.code;
- return instance;
- }
}
export class DataSourceDescription extends NamedStreamPipesEntity {
- '@class': 'org.apache.streampipes.model.graph.DataSourceDescription';
- correspondingSourceId: string;
- spDataStreams: SpDataStreamUnion[];
+ "@class": "org.apache.streampipes.model.graph.DataSourceDescription";
+ correspondingSourceId: string;
+ spDataStreams: SpDataStreamUnion[];
- static fromData(data: DataSourceDescription, target?: DataSourceDescription): DataSourceDescription {
- if (!data) {
- return data;
+ static fromData(data: DataSourceDescription, target?: DataSourceDescription): DataSourceDescription {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new DataSourceDescription();
+ super.fromData(data, instance);
+ instance.spDataStreams = __getCopyArrayFn(SpDataStream.fromDataUnion)(data.spDataStreams);
+ instance.correspondingSourceId = data.correspondingSourceId;
+ return instance;
}
- const instance = target || new DataSourceDescription();
- super.fromData(data, instance);
- instance.spDataStreams = __getCopyArrayFn(SpDataStream.fromDataUnion)(data.spDataStreams);
- instance.correspondingSourceId = data.correspondingSourceId;
- return instance;
- }
}
export class DeleteRuleDescription extends SchemaTransformationRuleDescription {
- '@class': 'org.apache.streampipes.model.connect.rules.schema.DeleteRuleDescription';
- runtimeKey: string;
+ "@class": "org.apache.streampipes.model.connect.rules.schema.DeleteRuleDescription";
+ runtimeKey: string;
- static fromData(data: DeleteRuleDescription, target?: DeleteRuleDescription): DeleteRuleDescription {
- if (!data) {
- return data;
+ static fromData(data: DeleteRuleDescription, target?: DeleteRuleDescription): DeleteRuleDescription {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new DeleteRuleDescription();
+ super.fromData(data, instance);
+ instance.runtimeKey = data.runtimeKey;
+ return instance;
}
- const instance = target || new DeleteRuleDescription();
- super.fromData(data, instance);
- instance.runtimeKey = data.runtimeKey;
- return instance;
- }
}
export class DomainPropertyProbability extends UnnamedStreamPipesEntity {
- '@class': 'org.apache.streampipes.model.connect.guess.DomainPropertyProbability';
- domainProperty: string;
- probability: string;
+ "@class": "org.apache.streampipes.model.connect.guess.DomainPropertyProbability";
+ domainProperty: string;
+ probability: string;
- static fromData(data: DomainPropertyProbability, target?: DomainPropertyProbability): DomainPropertyProbability {
- if (!data) {
- return data;
+ static fromData(data: DomainPropertyProbability, target?: DomainPropertyProbability): DomainPropertyProbability {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new DomainPropertyProbability();
+ super.fromData(data, instance);
+ instance.domainProperty = data.domainProperty;
+ instance.probability = data.probability;
+ return instance;
}
- const instance = target || new DomainPropertyProbability();
- super.fromData(data, instance);
- instance.domainProperty = data.domainProperty;
- instance.probability = data.probability;
- return instance;
- }
}
export class DomainPropertyProbabilityList extends UnnamedStreamPipesEntity {
- '@class': 'org.apache.streampipes.model.connect.guess.DomainPropertyProbabilityList';
- list: DomainPropertyProbability[];
- runtimeName: string;
+ "@class": "org.apache.streampipes.model.connect.guess.DomainPropertyProbabilityList";
+ list: DomainPropertyProbability[];
+ runtimeName: string;
- static fromData(data: DomainPropertyProbabilityList, target?: DomainPropertyProbabilityList): DomainPropertyProbabilityList {
- if (!data) {
- return data;
+ static fromData(data: DomainPropertyProbabilityList, target?: DomainPropertyProbabilityList): DomainPropertyProbabilityList {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new DomainPropertyProbabilityList();
+ super.fromData(data, instance);
+ instance.runtimeName = data.runtimeName;
+ instance.list = __getCopyArrayFn(DomainPropertyProbability.fromData)(data.list);
+ return instance;
}
- const instance = target || new DomainPropertyProbabilityList();
- super.fromData(data, instance);
- instance.runtimeName = data.runtimeName;
- instance.list = __getCopyArrayFn(DomainPropertyProbability.fromData)(data.list);
- return instance;
- }
}
export class DomainStaticProperty extends StaticProperty {
- '@class': 'org.apache.streampipes.model.staticproperty.DomainStaticProperty';
- requiredClass: string;
- supportedProperties: SupportedProperty[];
+ "@class": "org.apache.streampipes.model.staticproperty.DomainStaticProperty";
+ requiredClass: string;
+ supportedProperties: SupportedProperty[];
- static fromData(data: DomainStaticProperty, target?: DomainStaticProperty): DomainStaticProperty {
- if (!data) {
- return data;
+ static fromData(data: DomainStaticProperty, target?: DomainStaticProperty): DomainStaticProperty {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new DomainStaticProperty();
+ super.fromData(data, instance);
+ instance.requiredClass = data.requiredClass;
+ instance.supportedProperties = __getCopyArrayFn(SupportedProperty.fromData)(data.supportedProperties);
+ return instance;
}
- const instance = target || new DomainStaticProperty();
- super.fromData(data, instance);
- instance.requiredClass = data.requiredClass;
- instance.supportedProperties = __getCopyArrayFn(SupportedProperty.fromData)(data.supportedProperties);
- return instance;
- }
}
export class ElementComposition {
- description: string;
- name: string;
- sepas: DataProcessorInvocation[];
- streams: SpDataStreamUnion[];
+ description: string;
+ name: string;
+ sepas: DataProcessorInvocation[];
+ streams: SpDataStreamUnion[];
- static fromData(data: ElementComposition, target?: ElementComposition): ElementComposition {
- if (!data) {
- return data;
+ static fromData(data: ElementComposition, target?: ElementComposition): ElementComposition {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new ElementComposition();
+ instance.sepas = __getCopyArrayFn(DataProcessorInvocation.fromData)(data.sepas);
+ instance.streams = __getCopyArrayFn(SpDataStream.fromDataUnion)(data.streams);
+ instance.name = data.name;
+ instance.description = data.description;
+ return instance;
}
- const instance = target || new ElementComposition();
- instance.sepas = __getCopyArrayFn(DataProcessorInvocation.fromData)(data.sepas);
- instance.streams = __getCopyArrayFn(SpDataStream.fromDataUnion)(data.streams);
- instance.name = data.name;
- instance.description = data.description;
- return instance;
- }
}
export class ElementStatusInfoSettings extends UnnamedStreamPipesEntity {
- '@class': 'org.apache.streampipes.model.monitoring.ElementStatusInfoSettings';
- elementIdentifier: string;
- errorTopic: string;
- kafkaHost: string;
- kafkaPort: number;
- statsTopic: string;
-
- static fromData(data: ElementStatusInfoSettings, target?: ElementStatusInfoSettings): ElementStatusInfoSettings {
- if (!data) {
- return data;
- }
- const instance = target || new ElementStatusInfoSettings();
- super.fromData(data, instance);
- instance.elementIdentifier = data.elementIdentifier;
- instance.kafkaHost = data.kafkaHost;
- instance.kafkaPort = data.kafkaPort;
- instance.errorTopic = data.errorTopic;
- instance.statsTopic = data.statsTopic;
- return instance;
- }
+ "@class": "org.apache.streampipes.model.monitoring.ElementStatusInfoSettings";
+ elementIdentifier: string;
+ errorTopic: string;
+ kafkaHost: string;
+ kafkaPort: number;
+ statsTopic: string;
+
+ static fromData(data: ElementStatusInfoSettings, target?: ElementStatusInfoSettings): ElementStatusInfoSettings {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new ElementStatusInfoSettings();
+ super.fromData(data, instance);
+ instance.elementIdentifier = data.elementIdentifier;
+ instance.kafkaHost = data.kafkaHost;
+ instance.kafkaPort = data.kafkaPort;
+ instance.errorTopic = data.errorTopic;
+ instance.statsTopic = data.statsTopic;
+ return instance;
+ }
}
export class ValueSpecification extends UnnamedStreamPipesEntity {
- '@class': 'org.apache.streampipes.model.schema.ValueSpecification' | 'org.apache.streampipes.model.schema.QuantitativeValue' | 'org.apache.streampipes.model.schema.Enumeration';
+ "@class": "org.apache.streampipes.model.schema.ValueSpecification" | "org.apache.streampipes.model.schema.QuantitativeValue" | "org.apache.streampipes.model.schema.Enumeration";
- static fromData(data: ValueSpecification, target?: ValueSpecification): ValueSpecification {
- if (!data) {
- return data;
+ static fromData(data: ValueSpecification, target?: ValueSpecification): ValueSpecification {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new ValueSpecification();
+ super.fromData(data, instance);
+ return instance;
}
- const instance = target || new ValueSpecification();
- super.fromData(data, instance);
- return instance;
- }
- static fromDataUnion(data: ValueSpecificationUnion): ValueSpecificationUnion {
- if (!data) {
- return data;
- }
- switch (data['@class']) {
- case 'org.apache.streampipes.model.schema.QuantitativeValue':
- return QuantitativeValue.fromData(data);
- case 'org.apache.streampipes.model.schema.Enumeration':
- return Enumeration.fromData(data);
+ static fromDataUnion(data: ValueSpecificationUnion): ValueSpecificationUnion {
+ if (!data) {
+ return data;
+ }
+ switch (data["@class"]) {
+ case "org.apache.streampipes.model.schema.QuantitativeValue":
+ return QuantitativeValue.fromData(data);
+ case "org.apache.streampipes.model.schema.Enumeration":
+ return Enumeration.fromData(data);
+ }
}
- }
}
export class Enumeration extends ValueSpecification {
- '@class': 'org.apache.streampipes.model.schema.Enumeration';
- description: string;
- label: string;
- runtimeValues: string[];
+ "@class": "org.apache.streampipes.model.schema.Enumeration";
+ description: string;
+ label: string;
+ runtimeValues: string[];
- static fromData(data: Enumeration, target?: Enumeration): Enumeration {
- if (!data) {
- return data;
+ static fromData(data: Enumeration, target?: Enumeration): Enumeration {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new Enumeration();
+ super.fromData(data, instance);
+ instance.label = data.label;
+ instance.description = data.description;
+ instance.runtimeValues = __getCopyArrayFn(__identity<string>())(data.runtimeValues);
+ return instance;
}
- const instance = target || new Enumeration();
- super.fromData(data, instance);
- instance.label = data.label;
- instance.description = data.description;
- instance.runtimeValues = __getCopyArrayFn(__identity<string>())(data.runtimeValues);
- return instance;
- }
}
export class ErrorMessage extends Message {
- static fromData(data: ErrorMessage, target?: ErrorMessage): ErrorMessage {
- if (!data) {
- return data;
+ static fromData(data: ErrorMessage, target?: ErrorMessage): ErrorMessage {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new ErrorMessage();
+ super.fromData(data, instance);
+ return instance;
}
- const instance = target || new ErrorMessage();
- super.fromData(data, instance);
- return instance;
- }
}
export class EventGrounding extends UnnamedStreamPipesEntity {
- '@class': 'org.apache.streampipes.model.grounding.EventGrounding';
- transportFormats: TransportFormat[];
- transportProtocols: TransportProtocolUnion[];
+ "@class": "org.apache.streampipes.model.grounding.EventGrounding";
+ transportFormats: TransportFormat[];
+ transportProtocols: TransportProtocolUnion[];
- static fromData(data: EventGrounding, target?: EventGrounding): EventGrounding {
- if (!data) {
- return data;
+ static fromData(data: EventGrounding, target?: EventGrounding): EventGrounding {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new EventGrounding();
+ super.fromData(data, instance);
+ instance.transportProtocols = __getCopyArrayFn(TransportProtocol.fromDataUnion)(data.transportProtocols);
+ instance.transportFormats = __getCopyArrayFn(TransportFormat.fromData)(data.transportFormats);
+ return instance;
}
- const instance = target || new EventGrounding();
- super.fromData(data, instance);
- instance.transportProtocols = __getCopyArrayFn(TransportProtocol.fromDataUnion)(data.transportProtocols);
- instance.transportFormats = __getCopyArrayFn(TransportFormat.fromData)(data.transportFormats);
- return instance;
- }
}
export class EventProperty extends UnnamedStreamPipesEntity {
- '@class': 'org.apache.streampipes.model.schema.EventProperty' | 'org.apache.streampipes.model.schema.EventPropertyList' | 'org.apache.streampipes.model.schema.EventPropertyNested' | 'org.apache.streampipes.model.schema.EventPropertyPrimitive';
- description: string;
- domainProperties: string[];
- eventPropertyQualities: EventPropertyQualityDefinitionUnion[];
- index: number;
- label: string;
- propertyScope: string;
- required: boolean;
- requiresEventPropertyQualities: EventPropertyQualityRequirement[];
- runtimeId: string;
- runtimeName: string;
-
- static fromData(data: EventProperty, target?: EventProperty): EventProperty {
- if (!data) {
- return data;
- }
- const instance = target || new EventProperty();
- super.fromData(data, instance);
- instance.label = data.label;
- instance.description = data.description;
- instance.runtimeName = data.runtimeName;
- instance.required = data.required;
- instance.domainProperties = __getCopyArrayFn(__identity<string>())(data.domainProperties);
- instance.eventPropertyQualities = __getCopyArrayFn(EventPropertyQualityDefinition.fromDataUnion)(data.eventPropertyQualities);
- instance.requiresEventPropertyQualities = __getCopyArrayFn(EventPropertyQualityRequirement.fromData)(data.requiresEventPropertyQualities);
- instance.propertyScope = data.propertyScope;
- instance.index = data.index;
- instance.runtimeId = data.runtimeId;
- return instance;
- }
-
- static fromDataUnion(data: EventPropertyUnion): EventPropertyUnion {
- if (!data) {
- return data;
- }
- switch (data['@class']) {
- case 'org.apache.streampipes.model.schema.EventPropertyList':
- return EventPropertyList.fromData(data);
- case 'org.apache.streampipes.model.schema.EventPropertyNested':
- return EventPropertyNested.fromData(data);
- case 'org.apache.streampipes.model.schema.EventPropertyPrimitive':
- return EventPropertyPrimitive.fromData(data);
- }
- }
+ "@class": "org.apache.streampipes.model.schema.EventProperty" | "org.apache.streampipes.model.schema.EventPropertyList" | "org.apache.streampipes.model.schema.EventPropertyNested" | "org.apache.streampipes.model.schema.EventPropertyPrimitive";
+ description: string;
+ domainProperties: string[];
+ eventPropertyQualities: EventPropertyQualityDefinitionUnion[];
+ index: number;
+ label: string;
+ propertyScope: string;
+ required: boolean;
+ requiresEventPropertyQualities: EventPropertyQualityRequirement[];
+ runtimeId: string;
+ runtimeName: string;
+
+ static fromData(data: EventProperty, target?: EventProperty): EventProperty {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new EventProperty();
+ super.fromData(data, instance);
+ instance.label = data.label;
+ instance.description = data.description;
+ instance.runtimeName = data.runtimeName;
+ instance.required = data.required;
+ instance.domainProperties = __getCopyArrayFn(__identity<string>())(data.domainProperties);
+ instance.eventPropertyQualities = __getCopyArrayFn(EventPropertyQualityDefinition.fromDataUnion)(data.eventPropertyQualities);
+ instance.requiresEventPropertyQualities = __getCopyArrayFn(EventPropertyQualityRequirement.fromData)(data.requiresEventPropertyQualities);
+ instance.propertyScope = data.propertyScope;
+ instance.index = data.index;
+ instance.runtimeId = data.runtimeId;
+ return instance;
+ }
+
+ static fromDataUnion(data: EventPropertyUnion): EventPropertyUnion {
+ if (!data) {
+ return data;
+ }
+ switch (data["@class"]) {
+ case "org.apache.streampipes.model.schema.EventPropertyList":
+ return EventPropertyList.fromData(data);
+ case "org.apache.streampipes.model.schema.EventPropertyNested":
+ return EventPropertyNested.fromData(data);
+ case "org.apache.streampipes.model.schema.EventPropertyPrimitive":
+ return EventPropertyPrimitive.fromData(data);
+ }
+ }
}
export class EventPropertyList extends EventProperty {
- '@class': 'org.apache.streampipes.model.schema.EventPropertyList';
- eventProperty: EventPropertyUnion;
+ "@class": "org.apache.streampipes.model.schema.EventPropertyList";
+ eventProperty: EventPropertyUnion;
- static fromData(data: EventPropertyList, target?: EventPropertyList): EventPropertyList {
- if (!data) {
- return data;
+ static fromData(data: EventPropertyList, target?: EventPropertyList): EventPropertyList {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new EventPropertyList();
+ super.fromData(data, instance);
+ instance.eventProperty = EventProperty.fromDataUnion(data.eventProperty);
+ return instance;
}
- const instance = target || new EventPropertyList();
- super.fromData(data, instance);
- instance.eventProperty = EventProperty.fromDataUnion(data.eventProperty);
- return instance;
- }
}
export class EventPropertyNested extends EventProperty {
- '@class': 'org.apache.streampipes.model.schema.EventPropertyNested';
- eventProperties: EventPropertyUnion[];
+ "@class": "org.apache.streampipes.model.schema.EventPropertyNested";
+ eventProperties: EventPropertyUnion[];
- static fromData(data: EventPropertyNested, target?: EventPropertyNested): EventPropertyNested {
- if (!data) {
- return data;
+ static fromData(data: EventPropertyNested, target?: EventPropertyNested): EventPropertyNested {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new EventPropertyNested();
+ super.fromData(data, instance);
+ instance.eventProperties = __getCopyArrayFn(EventProperty.fromDataUnion)(data.eventProperties);
+ return instance;
}
- const instance = target || new EventPropertyNested();
- super.fromData(data, instance);
- instance.eventProperties = __getCopyArrayFn(EventProperty.fromDataUnion)(data.eventProperties);
- return instance;
- }
}
export class EventPropertyPrimitive extends EventProperty {
- '@class': 'org.apache.streampipes.model.schema.EventPropertyPrimitive';
- measurementUnit: string;
- runtimeType: string;
- valueSpecification: ValueSpecificationUnion;
+ "@class": "org.apache.streampipes.model.schema.EventPropertyPrimitive";
+ measurementUnit: string;
+ runtimeType: string;
+ valueSpecification: ValueSpecificationUnion;
- static fromData(data: EventPropertyPrimitive, target?: EventPropertyPrimitive): EventPropertyPrimitive {
- if (!data) {
- return data;
+ static fromData(data: EventPropertyPrimitive, target?: EventPropertyPrimitive): EventPropertyPrimitive {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new EventPropertyPrimitive();
+ super.fromData(data, instance);
+ instance.runtimeType = data.runtimeType;
+ instance.measurementUnit = data.measurementUnit;
+ instance.valueSpecification = ValueSpecification.fromDataUnion(data.valueSpecification);
+ return instance;
}
- const instance = target || new EventPropertyPrimitive();
- super.fromData(data, instance);
- instance.runtimeType = data.runtimeType;
- instance.measurementUnit = data.measurementUnit;
- instance.valueSpecification = ValueSpecification.fromDataUnion(data.valueSpecification);
- return instance;
- }
}
export class EventPropertyQualityRequirement extends UnnamedStreamPipesEntity {
- '@class': 'org.apache.streampipes.model.quality.EventPropertyQualityRequirement';
- maximumPropertyQuality: EventPropertyQualityDefinitionUnion;
- minimumPropertyQuality: EventPropertyQualityDefinitionUnion;
+ "@class": "org.apache.streampipes.model.quality.EventPropertyQualityRequirement";
+ maximumPropertyQuality: EventPropertyQualityDefinitionUnion;
+ minimumPropertyQuality: EventPropertyQualityDefinitionUnion;
- static fromData(data: EventPropertyQualityRequirement, target?: EventPropertyQualityRequirement): EventPropertyQualityRequirement {
- if (!data) {
- return data;
+ static fromData(data: EventPropertyQualityRequirement, target?: EventPropertyQualityRequirement): EventPropertyQualityRequirement {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new EventPropertyQualityRequirement();
+ super.fromData(data, instance);
+ instance.minimumPropertyQuality = EventPropertyQualityDefinition.fromDataUnion(data.minimumPropertyQuality);
+ instance.maximumPropertyQuality = EventPropertyQualityDefinition.fromDataUnion(data.maximumPropertyQuality);
+ return instance;
}
- const instance = target || new EventPropertyQualityRequirement();
- super.fromData(data, instance);
- instance.minimumPropertyQuality = EventPropertyQualityDefinition.fromDataUnion(data.minimumPropertyQuality);
- instance.maximumPropertyQuality = EventPropertyQualityDefinition.fromDataUnion(data.maximumPropertyQuality);
- return instance;
- }
}
export class StreamTransformationRuleDescription extends TransformationRuleDescription {
- '@class': 'org.apache.streampipes.model.connect.rules.stream.StreamTransformationRuleDescription' | 'org.apache.streampipes.model.connect.rules.stream.EventRateTransformationRuleDescription' | 'org.apache.streampipes.model.connect.rules.stream.RemoveDuplicatesTransformationRuleDescription';
+ "@class": "org.apache.streampipes.model.connect.rules.stream.StreamTransformationRuleDescription" | "org.apache.streampipes.model.connect.rules.stream.EventRateTransformationRuleDescription" | "org.apache.streampipes.model.connect.rules.stream.RemoveDuplicatesTransformationRuleDescription";
- static fromData(data: StreamTransformationRuleDescription, target?: StreamTransformationRuleDescription): StreamTransformationRuleDescription {
- if (!data) {
- return data;
+ static fromData(data: StreamTransformationRuleDescription, target?: StreamTransformationRuleDescription): StreamTransformationRuleDescription {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new StreamTransformationRuleDescription();
+ super.fromData(data, instance);
+ return instance;
}
- const instance = target || new StreamTransformationRuleDescription();
- super.fromData(data, instance);
- return instance;
- }
- static fromDataUnion(data: StreamTransformationRuleDescriptionUnion): StreamTransformationRuleDescriptionUnion {
- if (!data) {
- return data;
- }
- switch (data['@class']) {
- case 'org.apache.streampipes.model.connect.rules.stream.EventRateTransformationRuleDescription':
- return EventRateTransformationRuleDescription.fromData(data);
- case 'org.apache.streampipes.model.connect.rules.stream.RemoveDuplicatesTransformationRuleDescription':
- return RemoveDuplicatesTransformationRuleDescription.fromData(data);
+ static fromDataUnion(data: StreamTransformationRuleDescriptionUnion): StreamTransformationRuleDescriptionUnion {
+ if (!data) {
+ return data;
+ }
+ switch (data["@class"]) {
+ case "org.apache.streampipes.model.connect.rules.stream.EventRateTransformationRuleDescription":
+ return EventRateTransformationRuleDescription.fromData(data);
+ case "org.apache.streampipes.model.connect.rules.stream.RemoveDuplicatesTransformationRuleDescription":
+ return RemoveDuplicatesTransformationRuleDescription.fromData(data);
+ }
}
- }
}
export class EventRateTransformationRuleDescription extends StreamTransformationRuleDescription {
- '@class': 'org.apache.streampipes.model.connect.rules.stream.EventRateTransformationRuleDescription';
- aggregationTimeWindow: number;
- aggregationType: string;
+ "@class": "org.apache.streampipes.model.connect.rules.stream.EventRateTransformationRuleDescription";
+ aggregationTimeWindow: number;
+ aggregationType: string;
- static fromData(data: EventRateTransformationRuleDescription, target?: EventRateTransformationRuleDescription): EventRateTransformationRuleDescription {
- if (!data) {
- return data;
+ static fromData(data: EventRateTransformationRuleDescription, target?: EventRateTransformationRuleDescription): EventRateTransformationRuleDescription {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new EventRateTransformationRuleDescription();
+ super.fromData(data, instance);
+ instance.aggregationTimeWindow = data.aggregationTimeWindow;
+ instance.aggregationType = data.aggregationType;
+ return instance;
}
- const instance = target || new EventRateTransformationRuleDescription();
- super.fromData(data, instance);
- instance.aggregationTimeWindow = data.aggregationTimeWindow;
- instance.aggregationType = data.aggregationType;
- return instance;
- }
}
export class EventSchema extends UnnamedStreamPipesEntity {
- '@class': 'org.apache.streampipes.model.schema.EventSchema';
- eventProperties: EventPropertyUnion[];
+ "@class": "org.apache.streampipes.model.schema.EventSchema";
+ eventProperties: EventPropertyUnion[];
- static fromData(data: EventSchema, target?: EventSchema): EventSchema {
- if (!data) {
- return data;
+ static fromData(data: EventSchema, target?: EventSchema): EventSchema {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new EventSchema();
+ super.fromData(data, instance);
+ instance.eventProperties = __getCopyArrayFn(EventProperty.fromDataUnion)(data.eventProperties);
+ return instance;
}
- const instance = target || new EventSchema();
- super.fromData(data, instance);
- instance.eventProperties = __getCopyArrayFn(EventProperty.fromDataUnion)(data.eventProperties);
- return instance;
- }
}
export class EventStreamQualityDefinition extends MeasurementProperty {
- '@class': 'org.apache.streampipes.model.quality.EventStreamQualityDefinition' | 'org.apache.streampipes.model.quality.Frequency' | 'org.apache.streampipes.model.quality.Latency';
+ "@class": "org.apache.streampipes.model.quality.EventStreamQualityDefinition" | "org.apache.streampipes.model.quality.Frequency" | "org.apache.streampipes.model.quality.Latency";
- static fromData(data: EventStreamQualityDefinition, target?: EventStreamQualityDefinition): EventStreamQualityDefinition {
- if (!data) {
- return data;
+ static fromData(data: EventStreamQualityDefinition, target?: EventStreamQualityDefinition): EventStreamQualityDefinition {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new EventStreamQualityDefinition();
+ super.fromData(data, instance);
+ return instance;
}
- const instance = target || new EventStreamQualityDefinition();
- super.fromData(data, instance);
- return instance;
- }
- static fromDataUnion(data: EventStreamQualityDefinitionUnion): EventStreamQualityDefinitionUnion {
- if (!data) {
- return data;
- }
- switch (data['@class']) {
- case 'org.apache.streampipes.model.quality.Frequency':
- return Frequency.fromData(data);
- case 'org.apache.streampipes.model.quality.Latency':
- return Latency.fromData(data);
+ static fromDataUnion(data: EventStreamQualityDefinitionUnion): EventStreamQualityDefinitionUnion {
+ if (!data) {
+ return data;
+ }
+ switch (data["@class"]) {
+ case "org.apache.streampipes.model.quality.Frequency":
+ return Frequency.fromData(data);
+ case "org.apache.streampipes.model.quality.Latency":
+ return Latency.fromData(data);
+ }
}
- }
}
export class EventStreamQualityRequirement extends UnnamedStreamPipesEntity {
- '@class': 'org.apache.streampipes.model.quality.EventStreamQualityRequirement';
- maximumStreamQuality: EventStreamQualityDefinitionUnion;
- minimumStreamQuality: EventStreamQualityDefinitionUnion;
+ "@class": "org.apache.streampipes.model.quality.EventStreamQualityRequirement";
+ maximumStreamQuality: EventStreamQualityDefinitionUnion;
+ minimumStreamQuality: EventStreamQualityDefinitionUnion;
- static fromData(data: EventStreamQualityRequirement, target?: EventStreamQualityRequirement): EventStreamQualityRequirement {
- if (!data) {
- return data;
+ static fromData(data: EventStreamQualityRequirement, target?: EventStreamQualityRequirement): EventStreamQualityRequirement {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new EventStreamQualityRequirement();
+ super.fromData(data, instance);
+ instance.minimumStreamQuality = EventStreamQualityDefinition.fromDataUnion(data.minimumStreamQuality);
+ instance.maximumStreamQuality = EventStreamQualityDefinition.fromDataUnion(data.maximumStreamQuality);
+ return instance;
}
- const instance = target || new EventStreamQualityRequirement();
- super.fromData(data, instance);
- instance.minimumStreamQuality = EventStreamQualityDefinition.fromDataUnion(data.minimumStreamQuality);
- instance.maximumStreamQuality = EventStreamQualityDefinition.fromDataUnion(data.maximumStreamQuality);
- return instance;
- }
}
export class FileStaticProperty extends StaticProperty {
- '@class': 'org.apache.streampipes.model.staticproperty.FileStaticProperty';
- endpointUrl: string;
- locationPath: string;
- requiredFiletypes: string[];
+ "@class": "org.apache.streampipes.model.staticproperty.FileStaticProperty";
+ endpointUrl: string;
+ locationPath: string;
+ requiredFiletypes: string[];
- static fromData(data: FileStaticProperty, target?: FileStaticProperty): FileStaticProperty {
- if (!data) {
- return data;
+ static fromData(data: FileStaticProperty, target?: FileStaticProperty): FileStaticProperty {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new FileStaticProperty();
+ super.fromData(data, instance);
+ instance.endpointUrl = data.endpointUrl;
+ instance.locationPath = data.locationPath;
+ instance.requiredFiletypes = __getCopyArrayFn(__identity<string>())(data.requiredFiletypes);
+ return instance;
}
- const instance = target || new FileStaticProperty();
- super.fromData(data, instance);
- instance.endpointUrl = data.endpointUrl;
- instance.locationPath = data.locationPath;
- instance.requiredFiletypes = __getCopyArrayFn(__identity<string>())(data.requiredFiletypes);
- return instance;
- }
}
export class FixedOutputStrategy extends OutputStrategy {
- '@class': 'org.apache.streampipes.model.output.FixedOutputStrategy';
- eventProperties: EventPropertyUnion[];
+ "@class": "org.apache.streampipes.model.output.FixedOutputStrategy";
+ eventProperties: EventPropertyUnion[];
- static fromData(data: FixedOutputStrategy, target?: FixedOutputStrategy): FixedOutputStrategy {
- if (!data) {
- return data;
+ static fromData(data: FixedOutputStrategy, target?: FixedOutputStrategy): FixedOutputStrategy {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new FixedOutputStrategy();
+ super.fromData(data, instance);
+ instance.eventProperties = __getCopyArrayFn(EventProperty.fromDataUnion)(data.eventProperties);
+ return instance;
}
- const instance = target || new FixedOutputStrategy();
- super.fromData(data, instance);
- instance.eventProperties = __getCopyArrayFn(EventProperty.fromDataUnion)(data.eventProperties);
- return instance;
- }
}
export class FormatDescription extends NamedStreamPipesEntity {
- '@class': 'org.apache.streampipes.model.connect.grounding.FormatDescription';
- config: StaticPropertyUnion[];
-
- static fromData(data: FormatDescription, target?: FormatDescription): FormatDescription {
- if (!data) {
- return data;
- }
- const instance = target || new FormatDescription();
- super.fromData(data, instance);
- instance.config = __getCopyArrayFn(StaticProperty.fromDataUnion)(data.config);
- return instance;
- }
-}
-
-export class FormatDescriptionList extends NamedStreamPipesEntity {
- '@class': 'org.apache.streampipes.model.connect.grounding.FormatDescriptionList';
- list: FormatDescription[];
+ "@class": "org.apache.streampipes.model.connect.grounding.FormatDescription";
+ config: StaticPropertyUnion[];
- static fromData(data: FormatDescriptionList, target?: FormatDescriptionList): FormatDescriptionList {
- if (!data) {
- return data;
+ static fromData(data: FormatDescription, target?: FormatDescription): FormatDescription {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new FormatDescription();
+ super.fromData(data, instance);
+ instance.config = __getCopyArrayFn(StaticProperty.fromDataUnion)(data.config);
+ return instance;
}
- const instance = target || new FormatDescriptionList();
- super.fromData(data, instance);
- instance.list = __getCopyArrayFn(FormatDescription.fromData)(data.list);
- return instance;
- }
}
export class FreeTextStaticProperty extends StaticProperty {
- '@class': 'org.apache.streampipes.model.staticproperty.FreeTextStaticProperty';
- htmlAllowed: boolean;
- htmlFontFormat: boolean;
- mapsTo: string;
- multiLine: boolean;
- placeholdersSupported: boolean;
- requiredDatatype: string;
- requiredDomainProperty: string;
- value: string;
- valueSpecification: PropertyValueSpecification;
-
- static fromData(data: FreeTextStaticProperty, target?: FreeTextStaticProperty): FreeTextStaticProperty {
- if (!data) {
- return data;
- }
- const instance = target || new FreeTextStaticProperty();
- super.fromData(data, instance);
- instance.value = data.value;
- instance.requiredDatatype = data.requiredDatatype;
- instance.requiredDomainProperty = data.requiredDomainProperty;
- instance.mapsTo = data.mapsTo;
- instance.multiLine = data.multiLine;
- instance.htmlAllowed = data.htmlAllowed;
- instance.htmlFontFormat = data.htmlFontFormat;
- instance.placeholdersSupported = data.placeholdersSupported;
- instance.valueSpecification = PropertyValueSpecification.fromData(data.valueSpecification);
- return instance;
- }
+ "@class": "org.apache.streampipes.model.staticproperty.FreeTextStaticProperty";
+ htmlAllowed: boolean;
+ htmlFontFormat: boolean;
+ mapsTo: string;
+ multiLine: boolean;
+ placeholdersSupported: boolean;
+ requiredDatatype: string;
+ requiredDomainProperty: string;
+ value: string;
+ valueSpecification: PropertyValueSpecification;
+
+ static fromData(data: FreeTextStaticProperty, target?: FreeTextStaticProperty): FreeTextStaticProperty {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new FreeTextStaticProperty();
+ super.fromData(data, instance);
+ instance.value = data.value;
+ instance.requiredDatatype = data.requiredDatatype;
+ instance.requiredDomainProperty = data.requiredDomainProperty;
+ instance.mapsTo = data.mapsTo;
+ instance.multiLine = data.multiLine;
+ instance.htmlAllowed = data.htmlAllowed;
+ instance.htmlFontFormat = data.htmlFontFormat;
+ instance.placeholdersSupported = data.placeholdersSupported;
+ instance.valueSpecification = PropertyValueSpecification.fromData(data.valueSpecification);
+ return instance;
+ }
}
export class Frequency extends EventStreamQualityDefinition {
- '@class': 'org.apache.streampipes.model.quality.Frequency';
- quantityValue: number;
+ "@class": "org.apache.streampipes.model.quality.Frequency";
+ quantityValue: number;
- static fromData(data: Frequency, target?: Frequency): Frequency {
- if (!data) {
- return data;
+ static fromData(data: Frequency, target?: Frequency): Frequency {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new Frequency();
+ super.fromData(data, instance);
+ instance.quantityValue = data.quantityValue;
+ return instance;
}
- const instance = target || new Frequency();
- super.fromData(data, instance);
- instance.quantityValue = data.quantityValue;
- return instance;
- }
}
export interface GenericAdapterDescription {
- eventSchema: EventSchema;
- formatDescription: FormatDescription;
- protocolDescription: ProtocolDescription;
- rules: TransformationRuleDescriptionUnion[];
+ eventSchema: EventSchema;
+ formatDescription: FormatDescription;
+ protocolDescription: ProtocolDescription;
+ rules: TransformationRuleDescriptionUnion[];
}
export class GenericAdapterSetDescription extends AdapterSetDescription implements GenericAdapterDescription {
- '@class': 'org.apache.streampipes.model.connect.adapter.GenericAdapterSetDescription';
- eventSchema: EventSchema;
- formatDescription: FormatDescription;
- protocolDescription: ProtocolDescription;
+ "@class": "org.apache.streampipes.model.connect.adapter.GenericAdapterSetDescription";
+ eventSchema: EventSchema;
+ formatDescription: FormatDescription;
+ protocolDescription: ProtocolDescription;
- static fromData(data: GenericAdapterSetDescription, target?: GenericAdapterSetDescription): GenericAdapterSetDescription {
- if (!data) {
- return data;
+ static fromData(data: GenericAdapterSetDescription, target?: GenericAdapterSetDescription): GenericAdapterSetDescription {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new GenericAdapterSetDescription();
+ super.fromData(data, instance);
+ instance.formatDescription = FormatDescription.fromData(data.formatDescription);
+ instance.eventSchema = EventSchema.fromData(data.eventSchema);
+ instance.protocolDescription = ProtocolDescription.fromData(data.protocolDescription);
+ return instance;
}
- const instance = target || new GenericAdapterSetDescription();
- super.fromData(data, instance);
- instance.formatDescription = FormatDescription.fromData(data.formatDescription);
- instance.eventSchema = EventSchema.fromData(data.eventSchema);
- instance.protocolDescription = ProtocolDescription.fromData(data.protocolDescription);
- return instance;
- }
}
export class GenericAdapterStreamDescription extends AdapterStreamDescription implements GenericAdapterDescription {
- '@class': 'org.apache.streampipes.model.connect.adapter.GenericAdapterStreamDescription';
- eventSchema: EventSchema;
- formatDescription: FormatDescription;
- protocolDescription: ProtocolDescription;
+ "@class": "org.apache.streampipes.model.connect.adapter.GenericAdapterStreamDescription";
+ eventSchema: EventSchema;
+ formatDescription: FormatDescription;
+ protocolDescription: ProtocolDescription;
- static fromData(data: GenericAdapterStreamDescription, target?: GenericAdapterStreamDescription): GenericAdapterStreamDescription {
- if (!data) {
- return data;
+ static fromData(data: GenericAdapterStreamDescription, target?: GenericAdapterStreamDescription): GenericAdapterStreamDescription {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new GenericAdapterStreamDescription();
+ super.fromData(data, instance);
+ instance.formatDescription = FormatDescription.fromData(data.formatDescription);
+ instance.eventSchema = EventSchema.fromData(data.eventSchema);
+ instance.protocolDescription = ProtocolDescription.fromData(data.protocolDescription);
+ return instance;
}
- const instance = target || new GenericAdapterStreamDescription();
- super.fromData(data, instance);
- instance.formatDescription = FormatDescription.fromData(data.formatDescription);
- instance.eventSchema = EventSchema.fromData(data.eventSchema);
- instance.protocolDescription = ProtocolDescription.fromData(data.protocolDescription);
- return instance;
- }
}
export class GuessSchema extends UnnamedStreamPipesEntity {
- '@class': 'org.apache.streampipes.model.connect.guess.GuessSchema';
- eventSchema: EventSchema;
- propertyProbabilityList: DomainPropertyProbabilityList[];
+ "@class": "org.apache.streampipes.model.connect.guess.GuessSchema";
+ eventSchema: EventSchema;
+ propertyProbabilityList: DomainPropertyProbabilityList[];
- static fromData(data: GuessSchema, target?: GuessSchema): GuessSchema {
- if (!data) {
- return data;
+ static fromData(data: GuessSchema, target?: GuessSchema): GuessSchema {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new GuessSchema();
+ super.fromData(data, instance);
+ instance.eventSchema = EventSchema.fromData(data.eventSchema);
+ instance.propertyProbabilityList = __getCopyArrayFn(DomainPropertyProbabilityList.fromData)(data.propertyProbabilityList);
+ return instance;
}
- const instance = target || new GuessSchema();
- super.fromData(data, instance);
- instance.eventSchema = EventSchema.fromData(data.eventSchema);
- instance.propertyProbabilityList = __getCopyArrayFn(DomainPropertyProbabilityList.fromData)(data.propertyProbabilityList);
- return instance;
- }
}
export class TransportProtocol extends UnnamedStreamPipesEntity {
- '@class': 'org.apache.streampipes.model.grounding.TransportProtocol' | 'org.apache.streampipes.model.grounding.JmsTransportProtocol' | 'org.apache.streampipes.model.grounding.KafkaTransportProtocol' | 'org.apache.streampipes.model.grounding.MqttTransportProtocol';
- brokerHostname: string;
- topicDefinition: TopicDefinitionUnion;
-
- static fromData(data: TransportProtocol, target?: TransportProtocol): TransportProtocol {
- if (!data) {
- return data;
- }
- const instance = target || new TransportProtocol();
- super.fromData(data, instance);
- instance.brokerHostname = data.brokerHostname;
- instance.topicDefinition = TopicDefinition.fromDataUnion(data.topicDefinition);
- return instance;
- }
-
- static fromDataUnion(data: TransportProtocolUnion): TransportProtocolUnion {
- if (!data) {
- return data;
+ "@class": "org.apache.streampipes.model.grounding.TransportProtocol" | "org.apache.streampipes.model.grounding.JmsTransportProtocol" | "org.apache.streampipes.model.grounding.KafkaTransportProtocol" | "org.apache.streampipes.model.grounding.MqttTransportProtocol";
+ brokerHostname: string;
+ topicDefinition: TopicDefinitionUnion;
+
+ static fromData(data: TransportProtocol, target?: TransportProtocol): TransportProtocol {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new TransportProtocol();
+ super.fromData(data, instance);
+ instance.brokerHostname = data.brokerHostname;
+ instance.topicDefinition = TopicDefinition.fromDataUnion(data.topicDefinition);
+ return instance;
+ }
+
+ static fromDataUnion(data: TransportProtocolUnion): TransportProtocolUnion {
+ if (!data) {
+ return data;
+ }
+ switch (data["@class"]) {
+ case "org.apache.streampipes.model.grounding.JmsTransportProtocol":
+ return JmsTransportProtocol.fromData(data);
+ case "org.apache.streampipes.model.grounding.KafkaTransportProtocol":
+ return KafkaTransportProtocol.fromData(data);
+ case "org.apache.streampipes.model.grounding.MqttTransportProtocol":
+ return MqttTransportProtocol.fromData(data);
+ }
}
- switch (data['@class']) {
- case 'org.apache.streampipes.model.grounding.JmsTransportProtocol':
- return JmsTransportProtocol.fromData(data);
- case 'org.apache.streampipes.model.grounding.KafkaTransportProtocol':
- return KafkaTransportProtocol.fromData(data);
- case 'org.apache.streampipes.model.grounding.MqttTransportProtocol':
- return MqttTransportProtocol.fromData(data);
- }
- }
}
export class JmsTransportProtocol extends TransportProtocol {
- '@class': 'org.apache.streampipes.model.grounding.JmsTransportProtocol';
- port: number;
+ "@class": "org.apache.streampipes.model.grounding.JmsTransportProtocol";
+ port: number;
- static fromData(data: JmsTransportProtocol, target?: JmsTransportProtocol): JmsTransportProtocol {
- if (!data) {
- return data;
+ static fromData(data: JmsTransportProtocol, target?: JmsTransportProtocol): JmsTransportProtocol {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new JmsTransportProtocol();
+ super.fromData(data, instance);
+ instance.port = data.port;
+ return instance;
}
- const instance = target || new JmsTransportProtocol();
- super.fromData(data, instance);
- instance.port = data.port;
- return instance;
- }
}
export class KafkaTransportProtocol extends TransportProtocol {
- '@class': 'org.apache.streampipes.model.grounding.KafkaTransportProtocol';
- acks: string;
- batchSize: string;
- groupId: string;
- kafkaPort: number;
- lingerMs: number;
- maxRequestSize: string;
- messageMaxBytes: string;
- offset: string;
- zookeeperHost: string;
- zookeeperPort: number;
-
- static fromData(data: KafkaTransportProtocol, target?: KafkaTransportProtocol): KafkaTransportProtocol {
- if (!data) {
- return data;
- }
- const instance = target || new KafkaTransportProtocol();
- super.fromData(data, instance);
- instance.zookeeperHost = data.zookeeperHost;
- instance.zookeeperPort = data.zookeeperPort;
- instance.kafkaPort = data.kafkaPort;
- instance.lingerMs = data.lingerMs;
- instance.messageMaxBytes = data.messageMaxBytes;
- instance.maxRequestSize = data.maxRequestSize;
- instance.acks = data.acks;
- instance.batchSize = data.batchSize;
- instance.offset = data.offset;
- instance.groupId = data.groupId;
- return instance;
- }
+ "@class": "org.apache.streampipes.model.grounding.KafkaTransportProtocol";
+ acks: string;
+ batchSize: string;
+ groupId: string;
+ kafkaPort: number;
+ lingerMs: number;
+ maxRequestSize: string;
+ messageMaxBytes: string;
+ offset: string;
+ zookeeperHost: string;
+ zookeeperPort: number;
+
+ static fromData(data: KafkaTransportProtocol, target?: KafkaTransportProtocol): KafkaTransportProtocol {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new KafkaTransportProtocol();
+ super.fromData(data, instance);
+ instance.zookeeperHost = data.zookeeperHost;
+ instance.zookeeperPort = data.zookeeperPort;
+ instance.kafkaPort = data.kafkaPort;
+ instance.lingerMs = data.lingerMs;
+ instance.messageMaxBytes = data.messageMaxBytes;
+ instance.maxRequestSize = data.maxRequestSize;
+ instance.acks = data.acks;
+ instance.batchSize = data.batchSize;
+ instance.offset = data.offset;
+ instance.groupId = data.groupId;
+ return instance;
+ }
}
export class KeepOutputStrategy extends OutputStrategy {
- '@class': 'org.apache.streampipes.model.output.KeepOutputStrategy';
- eventName: string;
- keepBoth: boolean;
+ "@class": "org.apache.streampipes.model.output.KeepOutputStrategy";
+ eventName: string;
+ keepBoth: boolean;
- static fromData(data: KeepOutputStrategy, target?: KeepOutputStrategy): KeepOutputStrategy {
- if (!data) {
- return data;
+ static fromData(data: KeepOutputStrategy, target?: KeepOutputStrategy): KeepOutputStrategy {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new KeepOutputStrategy();
+ super.fromData(data, instance);
+ instance.eventName = data.eventName;
+ instance.keepBoth = data.keepBoth;
+ return instance;
}
- const instance = target || new KeepOutputStrategy();
- super.fromData(data, instance);
- instance.eventName = data.eventName;
- instance.keepBoth = data.keepBoth;
- return instance;
- }
}
export class Label {
- _id: string;
- _rev: string;
- categoryId: string;
- color: string;
- internalName: string;
- name: string;
-
- static fromData(data: Label, target?: Label): Label {
- if (!data) {
- return data;
- }
- const instance = target || new Label();
- instance.name = data.name;
- instance.color = data.color;
- instance.internalName = data.internalName;
- instance.categoryId = data.categoryId;
- instance._id = data._id;
- instance._rev = data._rev;
- return instance;
- }
+ _id: string;
+ _rev: string;
+ categoryId: string;
+ color: string;
+ internalName: string;
+ name: string;
+
+ static fromData(data: Label, target?: Label): Label {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new Label();
+ instance.name = data.name;
+ instance.color = data.color;
+ instance.internalName = data.internalName;
+ instance.categoryId = data.categoryId;
+ instance._id = data._id;
+ instance._rev = data._rev;
+ return instance;
+ }
}
export class Latency extends EventStreamQualityDefinition {
- '@class': 'org.apache.streampipes.model.quality.Latency';
- quantityValue: number;
+ "@class": "org.apache.streampipes.model.quality.Latency";
+ quantityValue: number;
- static fromData(data: Latency, target?: Latency): Latency {
- if (!data) {
- return data;
+ static fromData(data: Latency, target?: Latency): Latency {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new Latency();
+ super.fromData(data, instance);
+ instance.quantityValue = data.quantityValue;
+ return instance;
}
- const instance = target || new Latency();
- super.fromData(data, instance);
- instance.quantityValue = data.quantityValue;
- return instance;
- }
}
export class ListOutputStrategy extends OutputStrategy {
- '@class': 'org.apache.streampipes.model.output.ListOutputStrategy';
- propertyName: string;
+ "@class": "org.apache.streampipes.model.output.ListOutputStrategy";
+ propertyName: string;
- static fromData(data: ListOutputStrategy, target?: ListOutputStrategy): ListOutputStrategy {
- if (!data) {
- return data;
+ static fromData(data: ListOutputStrategy, target?: ListOutputStrategy): ListOutputStrategy {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new ListOutputStrategy();
+ super.fromData(data, instance);
+ instance.propertyName = data.propertyName;
+ return instance;
}
- const instance = target || new ListOutputStrategy();
- super.fromData(data, instance);
- instance.propertyName = data.propertyName;
- return instance;
- }
}
export class MappingProperty extends StaticProperty {
- '@class': 'org.apache.streampipes.model.staticproperty.MappingProperty' | 'org.apache.streampipes.model.staticproperty.MappingPropertyUnary' | 'org.apache.streampipes.model.staticproperty.MappingPropertyNary';
- mapsFromOptions: string[];
- propertyScope: string;
- requirementSelector: string;
-
- static fromData(data: MappingProperty, target?: MappingProperty): MappingProperty {
- if (!data) {
- return data;
+ "@class": "org.apache.streampipes.model.staticproperty.MappingProperty" | "org.apache.streampipes.model.staticproperty.MappingPropertyUnary" | "org.apache.streampipes.model.staticproperty.MappingPropertyNary";
+ mapsFromOptions: string[];
+ propertyScope: string;
+ requirementSelector: string;
+
+ static fromData(data: MappingProperty, target?: MappingProperty): MappingProperty {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new MappingProperty();
+ super.fromData(data, instance);
+ instance.requirementSelector = data.requirementSelector;
+ instance.mapsFromOptions = __getCopyArrayFn(__identity<string>())(data.mapsFromOptions);
+ instance.propertyScope = data.propertyScope;
+ return instance;
+ }
+
+ static fromDataUnion(data: MappingPropertyUnion): MappingPropertyUnion {
+ if (!data) {
+ return data;
+ }
+ switch (data["@class"]) {
+ case "org.apache.streampipes.model.staticproperty.MappingPropertyNary":
+ return MappingPropertyNary.fromData(data);
+ case "org.apache.streampipes.model.staticproperty.MappingPropertyUnary":
+ return MappingPropertyUnary.fromData(data);
+ }
}
- const instance = target || new MappingProperty();
- super.fromData(data, instance);
- instance.requirementSelector = data.requirementSelector;
- instance.mapsFromOptions = __getCopyArrayFn(__identity<string>())(data.mapsFromOptions);
- instance.propertyScope = data.propertyScope;
- return instance;
- }
-
- static fromDataUnion(data: MappingPropertyUnion): MappingPropertyUnion {
- if (!data) {
- return data;
- }
- switch (data['@class']) {
- case 'org.apache.streampipes.model.staticproperty.MappingPropertyNary':
- return MappingPropertyNary.fromData(data);
- case 'org.apache.streampipes.model.staticproperty.MappingPropertyUnary':
- return MappingPropertyUnary.fromData(data);
- }
- }
}
export class MappingPropertyNary extends MappingProperty {
- '@class': 'org.apache.streampipes.model.staticproperty.MappingPropertyNary';
- selectedProperties: string[];
+ "@class": "org.apache.streampipes.model.staticproperty.MappingPropertyNary";
+ selectedProperties: string[];
- static fromData(data: MappingPropertyNary, target?: MappingPropertyNary): MappingPropertyNary {
- if (!data) {
- return data;
+ static fromData(data: MappingPropertyNary, target?: MappingPropertyNary): MappingPropertyNary {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new MappingPropertyNary();
+ super.fromData(data, instance);
+ instance.selectedProperties = __getCopyArrayFn(__identity<string>())(data.selectedProperties);
+ return instance;
}
- const instance = target || new MappingPropertyNary();
- super.fromData(data, instance);
- instance.selectedProperties = __getCopyArrayFn(__identity<string>())(data.selectedProperties);
- return instance;
- }
}
export class MappingPropertyUnary extends MappingProperty {
- '@class': 'org.apache.streampipes.model.staticproperty.MappingPropertyUnary';
- selectedProperty: string;
+ "@class": "org.apache.streampipes.model.staticproperty.MappingPropertyUnary";
+ selectedProperty: string;
- static fromData(data: MappingPropertyUnary, target?: MappingPropertyUnary): MappingPropertyUnary {
- if (!data) {
- return data;
+ static fromData(data: MappingPropertyUnary, target?: MappingPropertyUnary): MappingPropertyUnary {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new MappingPropertyUnary();
+ super.fromData(data, instance);
+ instance.selectedProperty = data.selectedProperty;
+ return instance;
}
- const instance = target || new MappingPropertyUnary();
- super.fromData(data, instance);
- instance.selectedProperty = data.selectedProperty;
- return instance;
- }
}
export class MatchingStaticProperty extends StaticProperty {
- '@class': 'org.apache.streampipes.model.staticproperty.MatchingStaticProperty';
- matchLeft: string;
- matchRight: string;
+ "@class": "org.apache.streampipes.model.staticproperty.MatchingStaticProperty";
+ matchLeft: string;
+ matchRight: string;
- static fromData(data: MatchingStaticProperty, target?: MatchingStaticProperty): MatchingStaticProperty {
- if (!data) {
- return data;
+ static fromData(data: MatchingStaticProperty, target?: MatchingStaticProperty): MatchingStaticProperty {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new MatchingStaticProperty();
+ super.fromData(data, instance);
+ instance.matchLeft = data.matchLeft;
+ instance.matchRight = data.matchRight;
+ return instance;
}
- const instance = target || new MatchingStaticProperty();
- super.fromData(data, instance);
- instance.matchLeft = data.matchLeft;
- instance.matchRight = data.matchRight;
- return instance;
- }
}
export class MeasurementCapability extends UnnamedStreamPipesEntity {
- '@class': 'org.apache.streampipes.model.quality.MeasurementCapability';
- capability: string;
+ "@class": "org.apache.streampipes.model.quality.MeasurementCapability";
+ capability: string;
- static fromData(data: MeasurementCapability, target?: MeasurementCapability): MeasurementCapability {
- if (!data) {
- return data;
+ static fromData(data: MeasurementCapability, target?: MeasurementCapability): MeasurementCapability {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new MeasurementCapability();
+ super.fromData(data, instance);
+ instance.capability = data.capability;
+ return instance;
}
- const instance = target || new MeasurementCapability();
- super.fromData(data, instance);
- instance.capability = data.capability;
- return instance;
- }
}
export class MeasurementObject extends UnnamedStreamPipesEntity {
- '@class': 'org.apache.streampipes.model.quality.MeasurementObject';
- measuresObject: string;
+ "@class": "org.apache.streampipes.model.quality.MeasurementObject";
+ measuresObject: string;
- static fromData(data: MeasurementObject, target?: MeasurementObject): MeasurementObject {
- if (!data) {
- return data;
+ static fromData(data: MeasurementObject, target?: MeasurementObject): MeasurementObject {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new MeasurementObject();
+ super.fromData(data, instance);
+ instance.measuresObject = data.measuresObject;
+ return instance;
}
- const instance = target || new MeasurementObject();
- super.fromData(data, instance);
- instance.measuresObject = data.measuresObject;
- return instance;
- }
}
export class MeasurementRange extends EventPropertyQualityDefinition {
- '@class': 'org.apache.streampipes.model.quality.MeasurementRange';
- maxValue: number;
- minValue: number;
+ "@class": "org.apache.streampipes.model.quality.MeasurementRange";
+ maxValue: number;
+ minValue: number;
- static fromData(data: MeasurementRange, target?: MeasurementRange): MeasurementRange {
- if (!data) {
- return data;
+ static fromData(data: MeasurementRange, target?: MeasurementRange): MeasurementRange {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new MeasurementRange();
+ super.fromData(data, instance);
+ instance.minValue = data.minValue;
+ instance.maxValue = data.maxValue;
+ return instance;
}
- const instance = target || new MeasurementRange();
- super.fromData(data, instance);
- instance.minValue = data.minValue;
- instance.maxValue = data.maxValue;
- return instance;
- }
}
export class MoveRuleDescription extends SchemaTransformationRuleDescription {
- '@class': 'org.apache.streampipes.model.connect.rules.schema.MoveRuleDescription';
- newRuntimeKey: string;
- oldRuntimeKey: string;
+ "@class": "org.apache.streampipes.model.connect.rules.schema.MoveRuleDescription";
+ newRuntimeKey: string;
+ oldRuntimeKey: string;
- static fromData(data: MoveRuleDescription, target?: MoveRuleDescription): MoveRuleDescription {
- if (!data) {
- return data;
+ static fromData(data: MoveRuleDescription, target?: MoveRuleDescription): MoveRuleDescription {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new MoveRuleDescription();
+ super.fromData(data, instance);
+ instance.oldRuntimeKey = data.oldRuntimeKey;
+ instance.newRuntimeKey = data.newRuntimeKey;
+ return instance;
}
- const instance = target || new MoveRuleDescription();
- super.fromData(data, instance);
- instance.oldRuntimeKey = data.oldRuntimeKey;
- instance.newRuntimeKey = data.newRuntimeKey;
- return instance;
- }
}
export class MqttTransportProtocol extends TransportProtocol {
- '@class': 'org.apache.streampipes.model.grounding.MqttTransportProtocol';
- port: number;
+ "@class": "org.apache.streampipes.model.grounding.MqttTransportProtocol";
+ port: number;
- static fromData(data: MqttTransportProtocol, target?: MqttTransportProtocol): MqttTransportProtocol {
- if (!data) {
- return data;
+ static fromData(data: MqttTransportProtocol, target?: MqttTransportProtocol): MqttTransportProtocol {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new MqttTransportProtocol();
+ super.fromData(data, instance);
+ instance.port = data.port;
+ return instance;
}
- const instance = target || new MqttTransportProtocol();
- super.fromData(data, instance);
- instance.port = data.port;
- return instance;
- }
}
export class Notification {
- additionalInformation: string;
- description: string;
- title: string;
+ additionalInformation: string;
+ description: string;
+ title: string;
- static fromData(data: Notification, target?: Notification): Notification {
- if (!data) {
- return data;
+ static fromData(data: Notification, target?: Notification): Notification {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new Notification();
+ instance.title = data.title;
+ instance.description = data.description;
+ instance.additionalInformation = data.additionalInformation;
+ return instance;
}
- const instance = target || new Notification();
- instance.title = data.title;
- instance.description = data.description;
- instance.additionalInformation = data.additionalInformation;
- return instance;
- }
}
export class OneOfStaticProperty extends SelectionStaticProperty {
- '@class': 'org.apache.streampipes.model.staticproperty.OneOfStaticProperty' | 'org.apache.streampipes.model.staticproperty.RuntimeResolvableOneOfStaticProperty';
+ "@class": "org.apache.streampipes.model.staticproperty.OneOfStaticProperty" | "org.apache.streampipes.model.staticproperty.RuntimeResolvableOneOfStaticProperty";
- static fromData(data: OneOfStaticProperty, target?: OneOfStaticProperty): OneOfStaticProperty {
- if (!data) {
- return data;
+ static fromData(data: OneOfStaticProperty, target?: OneOfStaticProperty): OneOfStaticProperty {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new OneOfStaticProperty();
+ super.fromData(data, instance);
+ return instance;
}
- const instance = target || new OneOfStaticProperty();
- super.fromData(data, instance);
- return instance;
- }
- static fromDataUnion(data: OneOfStaticPropertyUnion): OneOfStaticPropertyUnion {
- if (!data) {
- return data;
- }
- switch (data['@class']) {
- case 'org.apache.streampipes.model.staticproperty.RuntimeResolvableOneOfStaticProperty':
- return RuntimeResolvableOneOfStaticProperty.fromData(data);
+ static fromDataUnion(data: OneOfStaticPropertyUnion): OneOfStaticPropertyUnion {
+ if (!data) {
+ return data;
+ }
+ switch (data["@class"]) {
+ case "org.apache.streampipes.model.staticproperty.RuntimeResolvableOneOfStaticProperty":
+ return RuntimeResolvableOneOfStaticProperty.fromData(data);
+ }
}
- }
}
export class Option extends UnnamedStreamPipesEntity {
- '@class': 'org.apache.streampipes.model.staticproperty.Option';
- internalName: string;
- name: string;
- selected: boolean;
+ "@class": "org.apache.streampipes.model.staticproperty.Option";
+ internalName: string;
+ name: string;
+ selected: boolean;
- static fromData(data: Option, target?: Option): Option {
- if (!data) {
- return data;
+ static fromData(data: Option, target?: Option): Option {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new Option();
+ super.fromData(data, instance);
+ instance.name = data.name;
+ instance.selected = data.selected;
+ instance.internalName = data.internalName;
+ return instance;
}
- const instance = target || new Option();
- super.fromData(data, instance);
- instance.name = data.name;
- instance.selected = data.selected;
- instance.internalName = data.internalName;
- return instance;
- }
}
export class PageResult extends DataSeries {
- page: number;
- pageSum: number;
+ page: number;
+ pageSum: number;
- static fromData(data: PageResult, target?: PageResult): PageResult {
- if (!data) {
- return data;
+ static fromData(data: PageResult, target?: PageResult): PageResult {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new PageResult();
+ super.fromData(data, instance);
+ instance.page = data.page;
+ instance.pageSum = data.pageSum;
+ return instance;
}
- const instance = target || new PageResult();
- super.fromData(data, instance);
- instance.page = data.page;
- instance.pageSum = data.pageSum;
- return instance;
- }
}
export class PersistedDataStream {
- measureName: string;
- pipelineId: string;
- pipelineName: string;
- schema: EventSchema;
+ measureName: string;
+ pipelineId: string;
+ pipelineName: string;
+ schema: EventSchema;
- static fromData(data: PersistedDataStream, target?: PersistedDataStream): PersistedDataStream {
- if (!data) {
- return data;
+ static fromData(data: PersistedDataStream, target?: PersistedDataStream): PersistedDataStream {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new PersistedDataStream();
+ instance.pipelineId = data.pipelineId;
+ instance.pipelineName = data.pipelineName;
+ instance.schema = EventSchema.fromData(data.schema);
+ instance.measureName = data.measureName;
+ return instance;
}
- const instance = target || new PersistedDataStream();
- instance.pipelineId = data.pipelineId;
- instance.pipelineName = data.pipelineName;
- instance.schema = EventSchema.fromData(data.schema);
- instance.measureName = data.measureName;
- return instance;
- }
}
export class Pipeline extends ElementComposition {
- _id: string;
- _rev: string;
- actions: DataSinkInvocation[];
- createdAt: number;
- createdByUser: string;
- healthStatus: PipelineHealthStatus;
- pipelineCategories: string[];
- pipelineNotifications: string[];
- publicElement: boolean;
- restartOnSystemReboot: boolean;
- running: boolean;
- startedAt: number;
-
- static fromData(data: Pipeline, target?: Pipeline): Pipeline {
- if (!data) {
- return data;
- }
- const instance = target || new Pipeline();
- super.fromData(data, instance);
- instance.actions = __getCopyArrayFn(DataSinkInvocation.fromData)(data.actions);
- instance.running = data.running;
- instance.restartOnSystemReboot = data.restartOnSystemReboot;
- instance.startedAt = data.startedAt;
- instance.createdAt = data.createdAt;
- instance.publicElement = data.publicElement;
- instance.createdByUser = data.createdByUser;
- instance.pipelineCategories = __getCopyArrayFn(__identity<string>())(data.pipelineCategories);
- instance.pipelineNotifications = __getCopyArrayFn(__identity<string>())(data.pipelineNotifications);
- instance.healthStatus = data.healthStatus;
- instance._id = data._id;
- instance._rev = data._rev;
- return instance;
- }
+ _id: string;
+ _rev: string;
+ actions: DataSinkInvocation[];
+ createdAt: number;
+ createdByUser: string;
+ healthStatus: PipelineHealthStatus;
+ pipelineCategories: string[];
+ pipelineNotifications: string[];
+ publicElement: boolean;
+ restartOnSystemReboot: boolean;
+ running: boolean;
+ startedAt: number;
+
+ static fromData(data: Pipeline, target?: Pipeline): Pipeline {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new Pipeline();
+ super.fromData(data, instance);
+ instance.actions = __getCopyArrayFn(DataSinkInvocation.fromData)(data.actions);
+ instance.running = data.running;
+ instance.restartOnSystemReboot = data.restartOnSystemReboot;
+ instance.startedAt = data.startedAt;
+ instance.createdAt = data.createdAt;
+ instance.publicElement = data.publicElement;
+ instance.createdByUser = data.createdByUser;
+ instance.pipelineCategories = __getCopyArrayFn(__identity<string>())(data.pipelineCategories);
+ instance.pipelineNotifications = __getCopyArrayFn(__identity<string>())(data.pipelineNotifications);
+ instance.healthStatus = data.healthStatus;
+ instance._id = data._id;
+ instance._rev = data._rev;
+ return instance;
+ }
}
export class PipelineCanvasComment {
- comment: string;
- position: CanvasPosition;
+ comment: string;
+ position: CanvasPosition;
- static fromData(data: PipelineCanvasComment, target?: PipelineCanvasComment): PipelineCanvasComment {
- if (!data) {
- return data;
+ static fromData(data: PipelineCanvasComment, target?: PipelineCanvasComment): PipelineCanvasComment {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new PipelineCanvasComment();
+ instance.comment = data.comment;
+ instance.position = CanvasPosition.fromData(data.position);
+ return instance;
}
- const instance = target || new PipelineCanvasComment();
- instance.comment = data.comment;
- instance.position = CanvasPosition.fromData(data.position);
- return instance;
- }
}
export class PipelineCanvasMetadata {
- _id: string;
- _rev: string;
- comments: PipelineCanvasComment[];
- pipelineElementMetadata: { [index: string]: PipelineElementMetadata };
- pipelineId: string;
-
- static fromData(data: PipelineCanvasMetadata, target?: PipelineCanvasMetadata): PipelineCanvasMetadata {
- if (!data) {
- return data;
- }
- const instance = target || new PipelineCanvasMetadata();
- instance.pipelineId = data.pipelineId;
- instance.pipelineElementMetadata = __getCopyObjectFn(PipelineElementMetadata.fromData)(data.pipelineElementMetadata);
- instance.comments = __getCopyArrayFn(PipelineCanvasComment.fromData)(data.comments);
- instance._id = data._id;
- instance._rev = data._rev;
- return instance;
- }
+ _id: string;
+ _rev: string;
+ comments: PipelineCanvasComment[];
+ pipelineElementMetadata: { [index: string]: PipelineElementMetadata };
+ pipelineId: string;
+
+ static fromData(data: PipelineCanvasMetadata, target?: PipelineCanvasMetadata): PipelineCanvasMetadata {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new PipelineCanvasMetadata();
+ instance.pipelineId = data.pipelineId;
+ instance.pipelineElementMetadata = __getCopyObjectFn(PipelineElementMetadata.fromData)(data.pipelineElementMetadata);
+ instance.comments = __getCopyArrayFn(PipelineCanvasComment.fromData)(data.comments);
+ instance._id = data._id;
+ instance._rev = data._rev;
+ return instance;
+ }
}
export class PipelineCategory {
- _id: string;
- _rev: string;
- categoryDescription: string;
- categoryName: string;
+ _id: string;
+ _rev: string;
+ categoryDescription: string;
+ categoryName: string;
- static fromData(data: PipelineCategory, target?: PipelineCategory): PipelineCategory {
- if (!data) {
- return data;
+ static fromData(data: PipelineCategory, target?: PipelineCategory): PipelineCategory {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new PipelineCategory();
+ instance.categoryName = data.categoryName;
+ instance.categoryDescription = data.categoryDescription;
+ instance._id = data._id;
+ instance._rev = data._rev;
+ return instance;
}
- const instance = target || new PipelineCategory();
- instance.categoryName = data.categoryName;
- instance.categoryDescription = data.categoryDescription;
- instance._id = data._id;
- instance._rev = data._rev;
- return instance;
- }
}
export class PipelineElementMetadata {
- customName: string;
- position: CanvasPosition;
+ customName: string;
+ position: CanvasPosition;
- static fromData(data: PipelineElementMetadata, target?: PipelineElementMetadata): PipelineElementMetadata {
- if (!data) {
- return data;
+ static fromData(data: PipelineElementMetadata, target?: PipelineElementMetadata): PipelineElementMetadata {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new PipelineElementMetadata();
+ instance.position = CanvasPosition.fromData(data.position);
+ instance.customName = data.customName;
+ return instance;
}
- const instance = target || new PipelineElementMetadata();
- instance.position = CanvasPosition.fromData(data.position);
- instance.customName = data.customName;
- return instance;
- }
}
export class PipelineElementMonitoringInfo {
- consumedMessageInfoExists: boolean;
- consumedMessagesInfos: ConsumedMessagesInfo[];
- pipelineElementId: string;
- pipelineElementName: string;
- producedMessageInfoExists: boolean;
- producedMessagesInfo: ProducedMessagesInfo;
-
- static fromData(data: PipelineElementMonitoringInfo, target?: PipelineElementMonitoringInfo): PipelineElementMonitoringInfo {
- if (!data) {
- return data;
- }
- const instance = target || new PipelineElementMonitoringInfo();
- instance.pipelineElementId = data.pipelineElementId;
- instance.pipelineElementName = data.pipelineElementName;
- instance.consumedMessageInfoExists = data.consumedMessageInfoExists;
- instance.producedMessageInfoExists = data.producedMessageInfoExists;
- instance.consumedMessagesInfos = __getCopyArrayFn(ConsumedMessagesInfo.fromData)(data.consumedMessagesInfos);
- instance.producedMessagesInfo = ProducedMessagesInfo.fromData(data.producedMessagesInfo);
- return instance;
- }
+ consumedMessageInfoExists: boolean;
+ consumedMessagesInfos: ConsumedMessagesInfo[];
+ pipelineElementId: string;
+ pipelineElementName: string;
+ producedMessageInfoExists: boolean;
+ producedMessagesInfo: ProducedMessagesInfo;
+
+ static fromData(data: PipelineElementMonitoringInfo, target?: PipelineElementMonitoringInfo): PipelineElementMonitoringInfo {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new PipelineElementMonitoringInfo();
+ instance.pipelineElementId = data.pipelineElementId;
+ instance.pipelineElementName = data.pipelineElementName;
+ instance.consumedMessageInfoExists = data.consumedMessageInfoExists;
+ instance.producedMessageInfoExists = data.producedMessageInfoExists;
+ instance.consumedMessagesInfos = __getCopyArrayFn(ConsumedMessagesInfo.fromData)(data.consumedMessagesInfos);
+ instance.producedMessagesInfo = ProducedMessagesInfo.fromData(data.producedMessagesInfo);
+ return instance;
+ }
}
export class PipelineElementRecommendation {
- count: number;
- description: string;
- elementId: string;
- name: string;
- weight: number;
-
- static fromData(data: PipelineElementRecommendation, target?: PipelineElementRecommendation): PipelineElementRecommendation {
- if (!data) {
- return data;
- }
- const instance = target || new PipelineElementRecommendation();
- instance.elementId = data.elementId;
- instance.name = data.name;
- instance.description = data.description;
- instance.weight = data.weight;
- instance.count = data.count;
- return instance;
- }
+ count: number;
+ description: string;
+ elementId: string;
+ name: string;
+ weight: number;
+
+ static fromData(data: PipelineElementRecommendation, target?: PipelineElementRecommendation): PipelineElementRecommendation {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new PipelineElementRecommendation();
+ instance.elementId = data.elementId;
+ instance.name = data.name;
+ instance.description = data.description;
+ instance.weight = data.weight;
+ instance.count = data.count;
+ return instance;
+ }
}
export class PipelineElementRecommendationMessage {
- possibleElements: PipelineElementRecommendation[];
- recommendedElements: PipelineElementRecommendation[];
- success: boolean;
+ possibleElements: PipelineElementRecommendation[];
+ recommendedElements: PipelineElementRecommendation[];
+ success: boolean;
- static fromData(data: PipelineElementRecommendationMessage, target?: PipelineElementRecommendationMessage): PipelineElementRecommendationMessage {
- if (!data) {
- return data;
+ static fromData(data: PipelineElementRecommendationMessage, target?: PipelineElementRecommendationMessage): PipelineElementRecommendationMessage {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new PipelineElementRecommendationMessage();
+ instance.possibleElements = __getCopyArrayFn(PipelineElementRecommendation.fromData)(data.possibleElements);
+ instance.recommendedElements = __getCopyArrayFn(PipelineElementRecommendation.fromData)(data.recommendedElements);
+ instance.success = data.success;
+ return instance;
}
- const instance = target || new PipelineElementRecommendationMessage();
- instance.possibleElements = __getCopyArrayFn(PipelineElementRecommendation.fromData)(data.possibleElements);
- instance.recommendedElements = __getCopyArrayFn(PipelineElementRecommendation.fromData)(data.recommendedElements);
- instance.success = data.success;
- return instance;
- }
}
export class PipelineElementStatus {
- elementId: string;
- elementName: string;
- optionalMessage: string;
- success: boolean;
+ elementId: string;
+ elementName: string;
+ optionalMessage: string;
+ success: boolean;
- static fromData(data: PipelineElementStatus, target?: PipelineElementStatus): PipelineElementStatus {
- if (!data) {
- return data;
+ static fromData(data: PipelineElementStatus, target?: PipelineElementStatus): PipelineElementStatus {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new PipelineElementStatus();
+ instance.elementId = data.elementId;
+ instance.elementName = data.elementName;
+ instance.optionalMessage = data.optionalMessage;
+ instance.success = data.success;
+ return instance;
}
- const instance = target || new PipelineElementStatus();
- instance.elementId = data.elementId;
- instance.elementName = data.elementName;
- instance.optionalMessage = data.optionalMessage;
- instance.success = data.success;
- return instance;
- }
}
export class PipelineElementTemplate {
- _id: string;
- _rev: string;
- basePipelineElementAppId: string;
- templateConfigs: { [index: string]: PipelineElementTemplateConfig };
- templateDescription: string;
- templateName: string;
-
- static fromData(data: PipelineElementTemplate, target?: PipelineElementTemplate): PipelineElementTemplate {
- if (!data) {
- return data;
- }
- const instance = target || new PipelineElementTemplate();
- instance.templateName = data.templateName;
- instance.templateDescription = data.templateDescription;
- instance.basePipelineElementAppId = data.basePipelineElementAppId;
- instance.templateConfigs = __getCopyObjectFn(PipelineElementTemplateConfig.fromData)(data.templateConfigs);
- instance._id = data._id;
- instance._rev = data._rev;
- return instance;
- }
+ _id: string;
+ _rev: string;
+ basePipelineElementAppId: string;
+ templateConfigs: { [index: string]: PipelineElementTemplateConfig };
+ templateDescription: string;
+ templateName: string;
+
+ static fromData(data: PipelineElementTemplate, target?: PipelineElementTemplate): PipelineElementTemplate {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new PipelineElementTemplate();
+ instance.templateName = data.templateName;
+ instance.templateDescription = data.templateDescription;
+ instance.basePipelineElementAppId = data.basePipelineElementAppId;
+ instance.templateConfigs = __getCopyObjectFn(PipelineElementTemplateConfig.fromData)(data.templateConfigs);
+ instance._id = data._id;
+ instance._rev = data._rev;
+ return instance;
+ }
}
export class PipelineElementTemplateConfig {
- displayed: boolean;
- editable: boolean;
- value: any;
+ displayed: boolean;
+ editable: boolean;
+ value: any;
- static fromData(data: PipelineElementTemplateConfig, target?: PipelineElementTemplateConfig): PipelineElementTemplateConfig {
- if (!data) {
- return data;
+ static fromData(data: PipelineElementTemplateConfig, target?: PipelineElementTemplateConfig): PipelineElementTemplateConfig {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new PipelineElementTemplateConfig();
+ instance.editable = data.editable;
+ instance.displayed = data.displayed;
+ instance.value = data.value;
+ return instance;
}
- const instance = target || new PipelineElementTemplateConfig();
- instance.editable = data.editable;
- instance.displayed = data.displayed;
- instance.value = data.value;
- return instance;
- }
}
export class PipelineModification {
- domId: string;
- elementId: string;
- inputStreams: SpDataStreamUnion[];
- outputStrategies: OutputStrategyUnion[];
- staticProperties: StaticPropertyUnion[];
-
- static fromData(data: PipelineModification, target?: PipelineModification): PipelineModification {
- if (!data) {
- return data;
- }
- const instance = target || new PipelineModification();
- instance.domId = data.domId;
- instance.elementId = data.elementId;
- instance.staticProperties = __getCopyArrayFn(StaticProperty.fromDataUnion)(data.staticProperties);
- instance.outputStrategies = __getCopyArrayFn(OutputStrategy.fromDataUnion)(data.outputStrategies);
- instance.inputStreams = __getCopyArrayFn(SpDataStream.fromDataUnion)(data.inputStreams);
- return instance;
- }
+ domId: string;
+ elementId: string;
+ inputStreams: SpDataStreamUnion[];
+ outputStrategies: OutputStrategyUnion[];
+ staticProperties: StaticPropertyUnion[];
+
+ static fromData(data: PipelineModification, target?: PipelineModification): PipelineModification {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new PipelineModification();
+ instance.domId = data.domId;
+ instance.elementId = data.elementId;
+ instance.staticProperties = __getCopyArrayFn(StaticProperty.fromDataUnion)(data.staticProperties);
+ instance.outputStrategies = __getCopyArrayFn(OutputStrategy.fromDataUnion)(data.outputStrategies);
+ instance.inputStreams = __getCopyArrayFn(SpDataStream.fromDataUnion)(data.inputStreams);
+ return instance;
+ }
}
export class PipelineModificationMessage extends Message {
- pipelineModifications: PipelineModification[];
+ pipelineModifications: PipelineModification[];
- static fromData(data: PipelineModificationMessage, target?: PipelineModificationMessage): PipelineModificationMessage {
- if (!data) {
- return data;
+ static fromData(data: PipelineModificationMessage, target?: PipelineModificationMessage): PipelineModificationMessage {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new PipelineModificationMessage();
+ super.fromData(data, instance);
+ instance.pipelineModifications = __getCopyArrayFn(PipelineModification.fromData)(data.pipelineModifications);
+ return instance;
}
- const instance = target || new PipelineModificationMessage();
- super.fromData(data, instance);
- instance.pipelineModifications = __getCopyArrayFn(PipelineModification.fromData)(data.pipelineModifications);
- return instance;
- }
}
export class PipelineMonitoringInfo {
- createdAt: number;
- pipelineElementMonitoringInfo: PipelineElementMonitoringInfo[];
- pipelineId: string;
- startedAt: number;
+ createdAt: number;
+ pipelineElementMonitoringInfo: PipelineElementMonitoringInfo[];
+ pipelineId: string;
+ startedAt: number;
- static fromData(data: PipelineMonitoringInfo, target?: PipelineMonitoringInfo): PipelineMonitoringInfo {
- if (!data) {
- return data;
+ static fromData(data: PipelineMonitoringInfo, target?: PipelineMonitoringInfo): PipelineMonitoringInfo {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new PipelineMonitoringInfo();
+ instance.pipelineId = data.pipelineId;
+ instance.createdAt = data.createdAt;
+ instance.startedAt = data.startedAt;
+ instance.pipelineElementMonitoringInfo = __getCopyArrayFn(PipelineElementMonitoringInfo.fromData)(data.pipelineElementMonitoringInfo);
+ return instance;
}
- const instance = target || new PipelineMonitoringInfo();
- instance.pipelineId = data.pipelineId;
- instance.createdAt = data.createdAt;
- instance.startedAt = data.startedAt;
- instance.pipelineElementMonitoringInfo = __getCopyArrayFn(PipelineElementMonitoringInfo.fromData)(data.pipelineElementMonitoringInfo);
- return instance;
- }
}
export class PipelineOperationStatus {
- elementStatus: PipelineElementStatus[];
- pipelineId: string;
- pipelineName: string;
- success: boolean;
- title: string;
-
- static fromData(data: PipelineOperationStatus, target?: PipelineOperationStatus): PipelineOperationStatus {
- if (!data) {
- return data;
- }
- const instance = target || new PipelineOperationStatus();
- instance.pipelineId = data.pipelineId;
- instance.pipelineName = data.pipelineName;
- instance.title = data.title;
- instance.success = data.success;
- instance.elementStatus = __getCopyArrayFn(PipelineElementStatus.fromData)(data.elementStatus);
- return instance;
- }
+ elementStatus: PipelineElementStatus[];
+ pipelineId: string;
+ pipelineName: string;
+ success: boolean;
+ title: string;
+
+ static fromData(data: PipelineOperationStatus, target?: PipelineOperationStatus): PipelineOperationStatus {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new PipelineOperationStatus();
+ instance.pipelineId = data.pipelineId;
+ instance.pipelineName = data.pipelineName;
+ instance.title = data.title;
+ instance.success = data.success;
+ instance.elementStatus = __getCopyArrayFn(PipelineElementStatus.fromData)(data.elementStatus);
+ return instance;
+ }
}
export class PipelinePreviewModel {
- previewId: string;
- supportedPipelineElementDomIds: string[];
+ previewId: string;
+ supportedPipelineElementDomIds: string[];
- static fromData(data: PipelinePreviewModel, target?: PipelinePreviewModel): PipelinePreviewModel {
- if (!data) {
- return data;
+ static fromData(data: PipelinePreviewModel, target?: PipelinePreviewModel): PipelinePreviewModel {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new PipelinePreviewModel();
+ instance.previewId = data.previewId;
+ instance.supportedPipelineElementDomIds = __getCopyArrayFn(__identity<string>())(data.supportedPipelineElementDomIds);
+ return instance;
}
- const instance = target || new PipelinePreviewModel();
- instance.previewId = data.previewId;
- instance.supportedPipelineElementDomIds = __getCopyArrayFn(__identity<string>())(data.supportedPipelineElementDomIds);
- return instance;
- }
}
export class PipelineStatusMessage {
- message: string;
- messageType: string;
- pipelineId: string;
- timestamp: number;
+ message: string;
+ messageType: string;
+ pipelineId: string;
+ timestamp: number;
- static fromData(data: PipelineStatusMessage, target?: PipelineStatusMessage): PipelineStatusMessage {
- if (!data) {
- return data;
+ static fromData(data: PipelineStatusMessage, target?: PipelineStatusMessage): PipelineStatusMessage {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new PipelineStatusMessage();
+ instance.pipelineId = data.pipelineId;
+ instance.timestamp = data.timestamp;
+ instance.messageType = data.messageType;
+ instance.message = data.message;
+ return instance;
}
- const instance = target || new PipelineStatusMessage();
- instance.pipelineId = data.pipelineId;
- instance.timestamp = data.timestamp;
- instance.messageType = data.messageType;
- instance.message = data.message;
- return instance;
- }
}
export class PipelineTemplateDescription extends NamedStreamPipesEntity {
- '@class': 'org.apache.streampipes.model.template.PipelineTemplateDescription';
- boundTo: BoundPipelineElement[];
- pipelineTemplateDescription: string;
- pipelineTemplateId: string;
- pipelineTemplateName: string;
-
- static fromData(data: PipelineTemplateDescription, target?: PipelineTemplateDescription): PipelineTemplateDescription {
- if (!data) {
- return data;
- }
- const instance = target || new PipelineTemplateDescription();
- super.fromData(data, instance);
- instance.boundTo = __getCopyArrayFn(BoundPipelineElement.fromData)(data.boundTo);
- instance.pipelineTemplateName = data.pipelineTemplateName;
- instance.pipelineTemplateDescription = data.pipelineTemplateDescription;
- instance.pipelineTemplateId = data.pipelineTemplateId;
- return instance;
- }
+ "@class": "org.apache.streampipes.model.template.PipelineTemplateDescription";
+ boundTo: BoundPipelineElement[];
+ pipelineTemplateDescription: string;
+ pipelineTemplateId: string;
+ pipelineTemplateName: string;
+
+ static fromData(data: PipelineTemplateDescription, target?: PipelineTemplateDescription): PipelineTemplateDescription {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new PipelineTemplateDescription();
+ super.fromData(data, instance);
+ instance.boundTo = __getCopyArrayFn(BoundPipelineElement.fromData)(data.boundTo);
+ instance.pipelineTemplateName = data.pipelineTemplateName;
+ instance.pipelineTemplateDescription = data.pipelineTemplateDescription;
+ instance.pipelineTemplateId = data.pipelineTemplateId;
+ return instance;
+ }
}
export class PipelineTemplateInvocation extends UnnamedStreamPipesEntity {
- '@class': 'org.apache.streampipes.model.template.PipelineTemplateInvocation';
- dataSetId: string;
- kviName: string;
- pipelineTemplateDescription: PipelineTemplateDescription;
- pipelineTemplateId: string;
- staticProperties: StaticPropertyUnion[];
-
- static fromData(data: PipelineTemplateInvocation, target?: PipelineTemplateInvocation): PipelineTemplateInvocation {
- if (!data) {
- return data;
- }
- const instance = target || new PipelineTemplateInvocation();
- super.fromData(data, instance);
- instance.kviName = data.kviName;
- instance.dataSetId = data.dataSetId;
- instance.pipelineTemplateId = data.pipelineTemplateId;
- instance.pipelineTemplateDescription = PipelineTemplateDescription.fromData(data.pipelineTemplateDescription);
- instance.staticProperties = __getCopyArrayFn(StaticProperty.fromDataUnion)(data.staticProperties);
- return instance;
- }
+ "@class": "org.apache.streampipes.model.template.PipelineTemplateInvocation";
+ dataSetId: string;
+ kviName: string;
+ pipelineTemplateDescription: PipelineTemplateDescription;
+ pipelineTemplateId: string;
+ staticProperties: StaticPropertyUnion[];
+
+ static fromData(data: PipelineTemplateInvocation, target?: PipelineTemplateInvocation): PipelineTemplateInvocation {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new PipelineTemplateInvocation();
+ super.fromData(data, instance);
+ instance.kviName = data.kviName;
+ instance.dataSetId = data.dataSetId;
+ instance.pipelineTemplateId = data.pipelineTemplateId;
+ instance.pipelineTemplateDescription = PipelineTemplateDescription.fromData(data.pipelineTemplateDescription);
+ instance.staticProperties = __getCopyArrayFn(StaticProperty.fromDataUnion)(data.staticProperties);
+ return instance;
+ }
}
export class Precision extends EventPropertyQualityDefinition {
- '@class': 'org.apache.streampipes.model.quality.Precision';
- quantityValue: number;
+ "@class": "org.apache.streampipes.model.quality.Precision";
+ quantityValue: number;
- static fromData(data: Precision, target?: Precision): Precision {
- if (!data) {
- return data;
+ static fromData(data: Precision, target?: Precision): Precision {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new Precision();
+ super.fromData(data, instance);
+ instance.quantityValue = data.quantityValue;
+ return instance;
}
- const instance = target || new Precision();
- super.fromData(data, instance);
- instance.quantityValue = data.quantityValue;
- return instance;
- }
}
export class ProducedMessagesInfo extends MessagesInfo {
- totalProducedMessages: number;
- totalProducedMessagesSincePipelineStart: number;
+ totalProducedMessages: number;
+ totalProducedMessagesSincePipelineStart: number;
- static fromData(data: ProducedMessagesInfo, target?: ProducedMessagesInfo): ProducedMessagesInfo {
- if (!data) {
- return data;
+ static fromData(data: ProducedMessagesInfo, target?: ProducedMessagesInfo): ProducedMessagesInfo {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new ProducedMessagesInfo();
+ super.fromData(data, instance);
+ instance.totalProducedMessages = data.totalProducedMessages;
+ instance.totalProducedMessagesSincePipelineStart = data.totalProducedMessagesSincePipelineStart;
+ return instance;
}
- const instance = target || new ProducedMessagesInfo();
- super.fromData(data, instance);
- instance.totalProducedMessages = data.totalProducedMessages;
- instance.totalProducedMessagesSincePipelineStart = data.totalProducedMessagesSincePipelineStart;
- return instance;
- }
}
export class PropertyRenameRule extends UnnamedStreamPipesEntity {
- '@class': 'org.apache.streampipes.model.output.PropertyRenameRule';
- newRuntimeName: string;
- runtimeId: string;
+ "@class": "org.apache.streampipes.model.output.PropertyRenameRule";
+ newRuntimeName: string;
+ runtimeId: string;
- static fromData(data: PropertyRenameRule, target?: PropertyRenameRule): PropertyRenameRule {
- if (!data) {
- return data;
+ static fromData(data: PropertyRenameRule, target?: PropertyRenameRule): PropertyRenameRule {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new PropertyRenameRule();
+ super.fromData(data, instance);
+ instance.runtimeId = data.runtimeId;
+ instance.newRuntimeName = data.newRuntimeName;
+ return instance;
}
- const instance = target || new PropertyRenameRule();
- super.fromData(data, instance);
- instance.runtimeId = data.runtimeId;
- instance.newRuntimeName = data.newRuntimeName;
- return instance;
- }
}
export class PropertyValueSpecification extends UnnamedStreamPipesEntity {
- '@class': 'org.apache.streampipes.model.staticproperty.PropertyValueSpecification';
- maxValue: number;
- minValue: number;
- step: number;
+ "@class": "org.apache.streampipes.model.staticproperty.PropertyValueSpecification";
+ maxValue: number;
+ minValue: number;
+ step: number;
- static fromData(data: PropertyValueSpecification, target?: PropertyValueSpecification): PropertyValueSpecification {
- if (!data) {
- return data;
+ static fromData(data: PropertyValueSpecification, target?: PropertyValueSpecification): PropertyValueSpecification {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new PropertyValueSpecification();
+ super.fromData(data, instance);
+ instance.minValue = data.minValue;
+ instance.maxValue = data.maxValue;
+ instance.step = data.step;
+ return instance;
}
- const instance = target || new PropertyValueSpecification();
- super.fromData(data, instance);
- instance.minValue = data.minValue;
- instance.maxValue = data.maxValue;
- instance.step = data.step;
- return instance;
- }
}
export class ProtocolDescription extends NamedStreamPipesEntity {
- '@class': 'org.apache.streampipes.model.connect.grounding.ProtocolDescription';
- category: string[];
- config: StaticPropertyUnion[];
- sourceType: string;
-
- static fromData(data: ProtocolDescription, target?: ProtocolDescription): ProtocolDescription {
- if (!data) {
- return data;
- }
- const instance = target || new ProtocolDescription();
- super.fromData(data, instance);
- instance.sourceType = data.sourceType;
- instance.config = __getCopyArrayFn(StaticProperty.fromDataUnion)(data.config);
- instance.category = __getCopyArrayFn(__identity<string>())(data.category);
- return instance;
- }
-}
+ "@class": "org.apache.streampipes.model.connect.grounding.ProtocolDescription";
+ category: string[];
+ config: StaticPropertyUnion[];
+ sourceType: string;
-export class ProtocolDescriptionList extends NamedStreamPipesEntity {
- '@class': 'org.apache.streampipes.model.connect.grounding.ProtocolDescriptionList';
- list: ProtocolDescription[];
-
- static fromData(data: ProtocolDescriptionList, target?: ProtocolDescriptionList): ProtocolDescriptionList {
- if (!data) {
- return data;
+ static fromData(data: ProtocolDescription, target?: ProtocolDescription): ProtocolDescription {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new ProtocolDescription();
+ super.fromData(data, instance);
+ instance.sourceType = data.sourceType;
+ instance.config = __getCopyArrayFn(StaticProperty.fromDataUnion)(data.config);
+ instance.category = __getCopyArrayFn(__identity<string>())(data.category);
+ return instance;
}
- const instance = target || new ProtocolDescriptionList();
- super.fromData(data, instance);
- instance.list = __getCopyArrayFn(ProtocolDescription.fromData)(data.list);
- return instance;
- }
}
export class QuantitativeValue extends ValueSpecification {
- '@class': 'org.apache.streampipes.model.schema.QuantitativeValue';
- maxValue: number;
- minValue: number;
- step: number;
+ "@class": "org.apache.streampipes.model.schema.QuantitativeValue";
+ maxValue: number;
+ minValue: number;
+ step: number;
- static fromData(data: QuantitativeValue, target?: QuantitativeValue): QuantitativeValue {
- if (!data) {
- return data;
+ static fromData(data: QuantitativeValue, target?: QuantitativeValue): QuantitativeValue {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new QuantitativeValue();
+ super.fromData(data, instance);
+ instance.minValue = data.minValue;
+ instance.maxValue = data.maxValue;
+ instance.step = data.step;
+ return instance;
}
- const instance = target || new QuantitativeValue();
- super.fromData(data, instance);
- instance.minValue = data.minValue;
- instance.maxValue = data.maxValue;
- instance.step = data.step;
- return instance;
- }
}
export class RemoveDuplicatesTransformationRuleDescription extends StreamTransformationRuleDescription {
- '@class': 'org.apache.streampipes.model.connect.rules.stream.RemoveDuplicatesTransformationRuleDescription';
- filterTimeWindow: string;
+ "@class": "org.apache.streampipes.model.connect.rules.stream.RemoveDuplicatesTransformationRuleDescription";
+ filterTimeWindow: string;
- static fromData(data: RemoveDuplicatesTransformationRuleDescription, target?: RemoveDuplicatesTransformationRuleDescription): RemoveDuplicatesTransformationRuleDescription {
- if (!data) {
- return data;
+ static fromData(data: RemoveDuplicatesTransformationRuleDescription, target?: RemoveDuplicatesTransformationRuleDescription): RemoveDuplicatesTransformationRuleDescription {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new RemoveDuplicatesTransformationRuleDescription();
+ super.fromData(data, instance);
+ instance.filterTimeWindow = data.filterTimeWindow;
+ return instance;
}
- const instance = target || new RemoveDuplicatesTransformationRuleDescription();
- super.fromData(data, instance);
- instance.filterTimeWindow = data.filterTimeWindow;
- return instance;
- }
}
export class RenameRuleDescription extends SchemaTransformationRuleDescription {
- '@class': 'org.apache.streampipes.model.connect.rules.schema.RenameRuleDescription';
- newRuntimeKey: string;
- oldRuntimeKey: string;
+ "@class": "org.apache.streampipes.model.connect.rules.schema.RenameRuleDescription";
+ newRuntimeKey: string;
+ oldRuntimeKey: string;
- static fromData(data: RenameRuleDescription, target?: RenameRuleDescription): RenameRuleDescription {
- if (!data) {
- return data;
+ static fromData(data: RenameRuleDescription, target?: RenameRuleDescription): RenameRuleDescription {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new RenameRuleDescription();
+ super.fromData(data, instance);
+ instance.oldRuntimeKey = data.oldRuntimeKey;
+ instance.newRuntimeKey = data.newRuntimeKey;
+ return instance;
}
- const instance = target || new RenameRuleDescription();
- super.fromData(data, instance);
- instance.oldRuntimeKey = data.oldRuntimeKey;
- instance.newRuntimeKey = data.newRuntimeKey;
- return instance;
- }
}
export class Resolution extends EventPropertyQualityDefinition {
- '@class': 'org.apache.streampipes.model.quality.Resolution';
- quantityValue: number;
+ "@class": "org.apache.streampipes.model.quality.Resolution";
+ quantityValue: number;
- static fromData(data: Resolution, target?: Resolution): Resolution {
- if (!data) {
- return data;
+ static fromData(data: Resolution, target?: Resolution): Resolution {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new Resolution();
+ super.fromData(data, instance);
+ instance.quantityValue = data.quantityValue;
+ return instance;
}
- const instance = target || new Resolution();
- super.fromData(data, instance);
- instance.quantityValue = data.quantityValue;
- return instance;
- }
}
export class RuntimeOptionsRequest extends UnnamedStreamPipesEntity {
- '@class': 'org.apache.streampipes.model.runtime.RuntimeOptionsRequest' | 'org.apache.streampipes.model.runtime.RuntimeOptionsResponse';
- appId: string;
- belongsTo: string;
- inputStreams: SpDataStreamUnion[];
- requestId: string;
- staticProperties: StaticPropertyUnion[];
-
- static fromData(data: RuntimeOptionsRequest, target?: RuntimeOptionsRequest): RuntimeOptionsRequest {
- if (!data) {
- return data;
- }
- const instance = target || new RuntimeOptionsRequest();
- super.fromData(data, instance);
- instance.requestId = data.requestId;
- instance.appId = data.appId;
- instance.staticProperties = __getCopyArrayFn(StaticProperty.fromDataUnion)(data.staticProperties);
- instance.inputStreams = __getCopyArrayFn(SpDataStream.fromDataUnion)(data.inputStreams);
- instance.belongsTo = data.belongsTo;
- return instance;
- }
+ "@class": "org.apache.streampipes.model.runtime.RuntimeOptionsRequest" | "org.apache.streampipes.model.runtime.RuntimeOptionsResponse";
+ appId: string;
+ belongsTo: string;
+ inputStreams: SpDataStreamUnion[];
+ requestId: string;
+ staticProperties: StaticPropertyUnion[];
+
+ static fromData(data: RuntimeOptionsRequest, target?: RuntimeOptionsRequest): RuntimeOptionsRequest {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new RuntimeOptionsRequest();
+ super.fromData(data, instance);
+ instance.requestId = data.requestId;
+ instance.appId = data.appId;
+ instance.staticProperties = __getCopyArrayFn(StaticProperty.fromDataUnion)(data.staticProperties);
+ instance.inputStreams = __getCopyArrayFn(SpDataStream.fromDataUnion)(data.inputStreams);
+ instance.belongsTo = data.belongsTo;
+ return instance;
+ }
}
export class RuntimeOptionsResponse extends RuntimeOptionsRequest {
- '@class': 'org.apache.streampipes.model.runtime.RuntimeOptionsResponse';
- options: Option[];
+ "@class": "org.apache.streampipes.model.runtime.RuntimeOptionsResponse";
+ options: Option[];
- static fromData(data: RuntimeOptionsResponse, target?: RuntimeOptionsResponse): RuntimeOptionsResponse {
- if (!data) {
- return data;
+ static fromData(data: RuntimeOptionsResponse, target?: RuntimeOptionsResponse): RuntimeOptionsResponse {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new RuntimeOptionsResponse();
+ super.fromData(data, instance);
+ instance.options = __getCopyArrayFn(Option.fromData)(data.options);
+ return instance;
}
- const instance = target || new RuntimeOptionsResponse();
- super.fromData(data, instance);
- instance.options = __getCopyArrayFn(Option.fromData)(data.options);
- return instance;
- }
}
export class RuntimeResolvableAnyStaticProperty extends AnyStaticProperty {
- '@class': 'org.apache.streampipes.model.staticproperty.RuntimeResolvableAnyStaticProperty';
- dependsOn: string[];
+ "@class": "org.apache.streampipes.model.staticproperty.RuntimeResolvableAnyStaticProperty";
+ dependsOn: string[];
- static fromData(data: RuntimeResolvableAnyStaticProperty, target?: RuntimeResolvableAnyStaticProperty): RuntimeResolvableAnyStaticProperty {
- if (!data) {
- return data;
+ static fromData(data: RuntimeResolvableAnyStaticProperty, target?: RuntimeResolvableAnyStaticProperty): RuntimeResolvableAnyStaticProperty {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new RuntimeResolvableAnyStaticProperty();
+ super.fromData(data, instance);
+ instance.dependsOn = __getCopyArrayFn(__identity<string>())(data.dependsOn);
+ return instance;
}
- const instance = target || new RuntimeResolvableAnyStaticProperty();
- super.fromData(data, instance);
- instance.dependsOn = __getCopyArrayFn(__identity<string>())(data.dependsOn);
- return instance;
- }
}
export class RuntimeResolvableOneOfStaticProperty extends OneOfStaticProperty {
- '@class': 'org.apache.streampipes.model.staticproperty.RuntimeResolvableOneOfStaticProperty';
- dependsOn: string[];
+ "@class": "org.apache.streampipes.model.staticproperty.RuntimeResolvableOneOfStaticProperty";
+ dependsOn: string[];
- static fromData(data: RuntimeResolvableOneOfStaticProperty, target?: RuntimeResolvableOneOfStaticProperty): RuntimeResolvableOneOfStaticProperty {
- if (!data) {
- return data;
+ static fromData(data: RuntimeResolvableOneOfStaticProperty, target?: RuntimeResolvableOneOfStaticProperty): RuntimeResolvableOneOfStaticProperty {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new RuntimeResolvableOneOfStaticProperty();
+ super.fromData(data, instance);
+ instance.dependsOn = __getCopyArrayFn(__identity<string>())(data.dependsOn);
+ return instance;
}
- const instance = target || new RuntimeResolvableOneOfStaticProperty();
- super.fromData(data, instance);
- instance.dependsOn = __getCopyArrayFn(__identity<string>())(data.dependsOn);
- return instance;
- }
}
export class SecretStaticProperty extends StaticProperty {
- '@class': 'org.apache.streampipes.model.staticproperty.SecretStaticProperty';
- encrypted: boolean;
- value: string;
+ "@class": "org.apache.streampipes.model.staticproperty.SecretStaticProperty";
+ encrypted: boolean;
+ value: string;
- static fromData(data: SecretStaticProperty, target?: SecretStaticProperty): SecretStaticProperty {
- if (!data) {
- return data;
+ static fromData(data: SecretStaticProperty, target?: SecretStaticProperty): SecretStaticProperty {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new SecretStaticProperty();
+ super.fromData(data, instance);
+ instance.value = data.value;
+ instance.encrypted = data.encrypted;
+ return instance;
}
- const instance = target || new SecretStaticProperty();
- super.fromData(data, instance);
- instance.value = data.value;
- instance.encrypted = data.encrypted;
- return instance;
- }
}
export class TopicDefinition extends UnnamedStreamPipesEntity {
- '@class': 'org.apache.streampipes.model.grounding.TopicDefinition' | 'org.apache.streampipes.model.grounding.SimpleTopicDefinition' | 'org.apache.streampipes.model.grounding.WildcardTopicDefinition';
- actualTopicName: string;
+ "@class": "org.apache.streampipes.model.grounding.TopicDefinition" | "org.apache.streampipes.model.grounding.SimpleTopicDefinition" | "org.apache.streampipes.model.grounding.WildcardTopicDefinition";
+ actualTopicName: string;
- static fromData(data: TopicDefinition, target?: TopicDefinition): TopicDefinition {
- if (!data) {
- return data;
+ static fromData(data: TopicDefinition, target?: TopicDefinition): TopicDefinition {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new TopicDefinition();
+ super.fromData(data, instance);
+ instance.actualTopicName = data.actualTopicName;
+ return instance;
}
- const instance = target || new TopicDefinition();
- super.fromData(data, instance);
- instance.actualTopicName = data.actualTopicName;
- return instance;
- }
- static fromDataUnion(data: TopicDefinitionUnion): TopicDefinitionUnion {
- if (!data) {
- return data;
- }
- switch (data['@class']) {
- case 'org.apache.streampipes.model.grounding.SimpleTopicDefinition':
- return SimpleTopicDefinition.fromData(data);
- case 'org.apache.streampipes.model.grounding.WildcardTopicDefinition':
- return WildcardTopicDefinition.fromData(data);
+ static fromDataUnion(data: TopicDefinitionUnion): TopicDefinitionUnion {
+ if (!data) {
+ return data;
+ }
+ switch (data["@class"]) {
+ case "org.apache.streampipes.model.grounding.SimpleTopicDefinition":
+ return SimpleTopicDefinition.fromData(data);
+ case "org.apache.streampipes.model.grounding.WildcardTopicDefinition":
+ return WildcardTopicDefinition.fromData(data);
+ }
}
- }
}
export class SimpleTopicDefinition extends TopicDefinition {
- '@class': 'org.apache.streampipes.model.grounding.SimpleTopicDefinition';
+ "@class": "org.apache.streampipes.model.grounding.SimpleTopicDefinition";
- static fromData(data: SimpleTopicDefinition, target?: SimpleTopicDefinition): SimpleTopicDefinition {
- if (!data) {
- return data;
+ static fromData(data: SimpleTopicDefinition, target?: SimpleTopicDefinition): SimpleTopicDefinition {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new SimpleTopicDefinition();
+ super.fromData(data, instance);
+ return instance;
}
- const instance = target || new SimpleTopicDefinition();
- super.fromData(data, instance);
- return instance;
- }
}
export class SpDataStream extends NamedStreamPipesEntity {
- '@class': 'org.apache.streampipes.model.SpDataStream' | 'org.apache.streampipes.model.SpDataSet';
- category: string[];
- correspondingAdapterId: string;
- eventGrounding: EventGrounding;
- eventSchema: EventSchema;
- hasEventStreamQualities: EventStreamQualityDefinitionUnion[];
- index: number;
- measurementCapability: MeasurementCapability[];
- measurementObject: MeasurementObject[];
- requiresEventStreamQualities: EventStreamQualityRequirement[];
-
- static fromData(data: SpDataStream, target?: SpDataStream): SpDataStream {
- if (!data) {
- return data;
- }
- const instance = target || new SpDataStream();
- super.fromData(data, instance);
- instance.hasEventStreamQualities = __getCopyArrayFn(EventStreamQualityDefinition.fromDataUnion)(data.hasEventStreamQualities);
- instance.requiresEventStreamQualities = __getCopyArrayFn(EventStreamQualityRequirement.fromData)(data.requiresEventStreamQualities);
- instance.eventGrounding = EventGrounding.fromData(data.eventGrounding);
- instance.eventSchema = EventSchema.fromData(data.eventSchema);
- instance.measurementCapability = __getCopyArrayFn(MeasurementCapability.fromData)(data.measurementCapability);
- instance.measurementObject = __getCopyArrayFn(MeasurementObject.fromData)(data.measurementObject);
- instance.index = data.index;
- instance.correspondingAdapterId = data.correspondingAdapterId;
- instance.category = __getCopyArrayFn(__identity<string>())(data.category);
- return instance;
- }
-
- static fromDataUnion(data: SpDataStreamUnion): SpDataStreamUnion {
- if (!data) {
- return data;
- }
- switch (data['@class']) {
- case 'org.apache.streampipes.model.SpDataStream':
- return SpDataStream.fromData(data);
- case 'org.apache.streampipes.model.SpDataSet':
- return SpDataSet.fromData(data);
- }
- }
+ "@class": "org.apache.streampipes.model.SpDataStream" | "org.apache.streampipes.model.SpDataSet";
+ category: string[];
+ correspondingAdapterId: string;
+ eventGrounding: EventGrounding;
+ eventSchema: EventSchema;
+ hasEventStreamQualities: EventStreamQualityDefinitionUnion[];
+ index: number;
+ measurementCapability: MeasurementCapability[];
+ measurementObject: MeasurementObject[];
+ requiresEventStreamQualities: EventStreamQualityRequirement[];
+
+ static fromData(data: SpDataStream, target?: SpDataStream): SpDataStream {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new SpDataStream();
+ super.fromData(data, instance);
+ instance.hasEventStreamQualities = __getCopyArrayFn(EventStreamQualityDefinition.fromDataUnion)(data.hasEventStreamQualities);
+ instance.requiresEventStreamQualities = __getCopyArrayFn(EventStreamQualityRequirement.fromData)(data.requiresEventStreamQualities);
+ instance.eventGrounding = EventGrounding.fromData(data.eventGrounding);
+ instance.eventSchema = EventSchema.fromData(data.eventSchema);
+ instance.measurementCapability = __getCopyArrayFn(MeasurementCapability.fromData)(data.measurementCapability);
+ instance.measurementObject = __getCopyArrayFn(MeasurementObject.fromData)(data.measurementObject);
+ instance.index = data.index;
+ instance.correspondingAdapterId = data.correspondingAdapterId;
+ instance.category = __getCopyArrayFn(__identity<string>())(data.category);
+ return instance;
+ }
+
+ static fromDataUnion(data: SpDataStreamUnion): SpDataStreamUnion {
+ if (!data) {
+ return data;
+ }
+ switch (data["@class"]) {
+ case "org.apache.streampipes.model.SpDataStream":
+ return SpDataStream.fromData(data);
+ case "org.apache.streampipes.model.SpDataSet":
+ return SpDataSet.fromData(data);
+ }
+ }
}
export class SpDataSet extends SpDataStream {
- '@class': 'org.apache.streampipes.model.SpDataSet';
- actualTopicName: string;
- brokerHostname: string;
- correspondingPipeline: string;
- datasetInvocationId: string;
- selectedEndpointUrl: string;
- supportedGrounding: EventGrounding;
-
- static fromData(data: SpDataSet, target?: SpDataSet): SpDataSet {
- if (!data) {
- return data;
- }
- const instance = target || new SpDataSet();
- super.fromData(data, instance);
- instance.supportedGrounding = EventGrounding.fromData(data.supportedGrounding);
- instance.datasetInvocationId = data.datasetInvocationId;
- instance.correspondingPipeline = data.correspondingPipeline;
- instance.selectedEndpointUrl = data.selectedEndpointUrl;
- instance.brokerHostname = data.brokerHostname;
- instance.actualTopicName = data.actualTopicName;
- return instance;
- }
+ "@class": "org.apache.streampipes.model.SpDataSet";
+ actualTopicName: string;
+ brokerHostname: string;
+ correspondingPipeline: string;
+ datasetInvocationId: string;
+ selectedEndpointUrl: string;
+ supportedGrounding: EventGrounding;
+
+ static fromData(data: SpDataSet, target?: SpDataSet): SpDataSet {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new SpDataSet();
+ super.fromData(data, instance);
+ instance.supportedGrounding = EventGrounding.fromData(data.supportedGrounding);
+ instance.datasetInvocationId = data.datasetInvocationId;
+ instance.correspondingPipeline = data.correspondingPipeline;
+ instance.selectedEndpointUrl = data.selectedEndpointUrl;
+ instance.actualTopicName = data.actualTopicName;
+ instance.brokerHostname = data.brokerHostname;
+ return instance;
+ }
}
export class SpQueryResult {
- allDataSeries: DataSeries[];
- headers: string[];
- sourceIndex: number;
- total: number;
+ allDataSeries: DataSeries[];
+ headers: string[];
+ sourceIndex: number;
+ total: number;
- static fromData(data: SpQueryResult, target?: SpQueryResult): SpQueryResult {
- if (!data) {
- return data;
+ static fromData(data: SpQueryResult, target?: SpQueryResult): SpQueryResult {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new SpQueryResult();
+ instance.total = data.total;
+ instance.headers = __getCopyArrayFn(__identity<string>())(data.headers);
+ instance.allDataSeries = __getCopyArrayFn(DataSeries.fromData)(data.allDataSeries);
+ instance.sourceIndex = data.sourceIndex;
+ return instance;
}
- const instance = target || new SpQueryResult();
- instance.total = data.total;
- instance.headers = __getCopyArrayFn(__identity<string>())(data.headers);
- instance.allDataSeries = __getCopyArrayFn(DataSeries.fromData)(data.allDataSeries);
- instance.sourceIndex = data.sourceIndex;
- return instance;
- }
}
export class SpecificAdapterSetDescription extends AdapterSetDescription {
- '@class': 'org.apache.streampipes.model.connect.adapter.SpecificAdapterSetDescription';
+ "@class": "org.apache.streampipes.model.connect.adapter.SpecificAdapterSetDescription";
- static fromData(data: SpecificAdapterSetDescription, target?: SpecificAdapterSetDescription): SpecificAdapterSetDescription {
- if (!data) {
- return data;
+ static fromData(data: SpecificAdapterSetDescription, target?: SpecificAdapterSetDescription): SpecificAdapterSetDescription {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new SpecificAdapterSetDescription();
+ super.fromData(data, instance);
+ return instance;
}
- const instance = target || new SpecificAdapterSetDescription();
- super.fromData(data, instance);
- return instance;
- }
}
export class SpecificAdapterStreamDescription extends AdapterStreamDescription {
- '@class': 'org.apache.streampipes.model.connect.adapter.SpecificAdapterStreamDescription';
+ "@class": "org.apache.streampipes.model.connect.adapter.SpecificAdapterStreamDescription";
- static fromData(data: SpecificAdapterStreamDescription, target?: SpecificAdapterStreamDescription): SpecificAdapterStreamDescription {
- if (!data) {
- return data;
+ static fromData(data: SpecificAdapterStreamDescription, target?: SpecificAdapterStreamDescription): SpecificAdapterStreamDescription {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new SpecificAdapterStreamDescription();
+ super.fromData(data, instance);
+ return instance;
}
- const instance = target || new SpecificAdapterStreamDescription();
- super.fromData(data, instance);
- return instance;
- }
}
export class StaticPropertyAlternative extends StaticProperty {
- '@class': 'org.apache.streampipes.model.staticproperty.StaticPropertyAlternative';
- selected: boolean;
- staticProperty: StaticPropertyUnion;
+ "@class": "org.apache.streampipes.model.staticproperty.StaticPropertyAlternative";
+ selected: boolean;
+ staticProperty: StaticPropertyUnion;
- static fromData(data: StaticPropertyAlternative, target?: StaticPropertyAlternative): StaticPropertyAlternative {
- if (!data) {
- return data;
+ static fromData(data: StaticPropertyAlternative, target?: StaticPropertyAlternative): StaticPropertyAlternative {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new StaticPropertyAlternative();
+ super.fromData(data, instance);
+ instance.selected = data.selected;
+ instance.staticProperty = StaticProperty.fromDataUnion(data.staticProperty);
+ return instance;
}
- const instance = target || new StaticPropertyAlternative();
- super.fromData(data, instance);
- instance.selected = data.selected;
- instance.staticProperty = StaticProperty.fromDataUnion(data.staticProperty);
- return instance;
- }
}
export class StaticPropertyAlternatives extends StaticProperty {
- '@class': 'org.apache.streampipes.model.staticproperty.StaticPropertyAlternatives';
- alternatives: StaticPropertyAlternative[];
+ "@class": "org.apache.streampipes.model.staticproperty.StaticPropertyAlternatives";
+ alternatives: StaticPropertyAlternative[];
- static fromData(data: StaticPropertyAlternatives, target?: StaticPropertyAlternatives): StaticPropertyAlternatives {
- if (!data) {
- return data;
+ static fromData(data: StaticPropertyAlternatives, target?: StaticPropertyAlternatives): StaticPropertyAlternatives {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new StaticPropertyAlternatives();
+ super.fromData(data, instance);
+ instance.alternatives = __getCopyArrayFn(StaticPropertyAlternative.fromData)(data.alternatives);
+ return instance;
}
- const instance = target || new StaticPropertyAlternatives();
- super.fromData(data, instance);
- instance.alternatives = __getCopyArrayFn(StaticPropertyAlternative.fromData)(data.alternatives);
- return instance;
- }
}
export class StaticPropertyGroup extends StaticProperty {
- '@class': 'org.apache.streampipes.model.staticproperty.StaticPropertyGroup';
- horizontalRendering: boolean;
- showLabel: boolean;
- staticProperties: StaticPropertyUnion[];
+ "@class": "org.apache.streampipes.model.staticproperty.StaticPropertyGroup";
+ horizontalRendering: boolean;
+ showLabel: boolean;
+ staticProperties: StaticPropertyUnion[];
- static fromData(data: StaticPropertyGroup, target?: StaticPropertyGroup): StaticPropertyGroup {
- if (!data) {
- return data;
+ static fromData(data: StaticPropertyGroup, target?: StaticPropertyGroup): StaticPropertyGroup {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new StaticPropertyGroup();
+ super.fromData(data, instance);
+ instance.staticProperties = __getCopyArrayFn(StaticProperty.fromDataUnion)(data.staticProperties);
+ instance.showLabel = data.showLabel;
+ instance.horizontalRendering = data.horizontalRendering;
+ return instance;
}
- const instance = target || new StaticPropertyGroup();
- super.fromData(data, instance);
- instance.staticProperties = __getCopyArrayFn(StaticProperty.fromDataUnion)(data.staticProperties);
- instance.showLabel = data.showLabel;
- instance.horizontalRendering = data.horizontalRendering;
- return instance;
- }
}
export class SuccessMessage extends Message {
- static fromData(data: SuccessMessage, target?: SuccessMessage): SuccessMessage {
- if (!data) {
- return data;
+ static fromData(data: SuccessMessage, target?: SuccessMessage): SuccessMessage {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new SuccessMessage();
+ super.fromData(data, instance);
+ return instance;
}
- const instance = target || new SuccessMessage();
- super.fromData(data, instance);
- return instance;
- }
}
export class SupportedProperty extends UnnamedStreamPipesEntity {
- '@class': 'org.apache.streampipes.model.staticproperty.SupportedProperty';
- propertyId: string;
- value: string;
- valueRequired: boolean;
+ "@class": "org.apache.streampipes.model.staticproperty.SupportedProperty";
+ propertyId: string;
+ value: string;
+ valueRequired: boolean;
- static fromData(data: SupportedProperty, target?: SupportedProperty): SupportedProperty {
- if (!data) {
- return data;
+ static fromData(data: SupportedProperty, target?: SupportedProperty): SupportedProperty {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new SupportedProperty();
+ super.fromData(data, instance);
+ instance.propertyId = data.propertyId;
+ instance.valueRequired = data.valueRequired;
+ instance.value = data.value;
+ return instance;
}
- const instance = target || new SupportedProperty();
- super.fromData(data, instance);
- instance.propertyId = data.propertyId;
- instance.valueRequired = data.valueRequired;
- instance.value = data.value;
- return instance;
- }
}
export class TimestampTranfsformationRuleDescription extends ValueTransformationRuleDescription {
- '@class': 'org.apache.streampipes.model.connect.rules.value.TimestampTranfsformationRuleDescription';
- formatString: string;
- mode: string;
- multiplier: number;
- runtimeKey: string;
-
- static fromData(data: TimestampTranfsformationRuleDescription, target?: TimestampTranfsformationRuleDescription): TimestampTranfsformationRuleDescription {
- if (!data) {
- return data;
- }
- const instance = target || new TimestampTranfsformationRuleDescription();
- super.fromData(data, instance);
- instance.runtimeKey = data.runtimeKey;
- instance.mode = data.mode;
- instance.formatString = data.formatString;
- instance.multiplier = data.multiplier;
- return instance;
- }
+ "@class": "org.apache.streampipes.model.connect.rules.value.TimestampTranfsformationRuleDescription";
+ formatString: string;
+ mode: string;
+ multiplier: number;
+ runtimeKey: string;
+
+ static fromData(data: TimestampTranfsformationRuleDescription, target?: TimestampTranfsformationRuleDescription): TimestampTranfsformationRuleDescription {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new TimestampTranfsformationRuleDescription();
+ super.fromData(data, instance);
+ instance.runtimeKey = data.runtimeKey;
+ instance.mode = data.mode;
+ instance.formatString = data.formatString;
+ instance.multiplier = data.multiplier;
+ return instance;
+ }
}
export class TransformOperation extends UnnamedStreamPipesEntity {
- '@class': 'org.apache.streampipes.model.output.TransformOperation';
- mappingPropertyInternalName: string;
- sourceStaticProperty: string;
- targetValue: string;
- transformationScope: string;
-
- static fromData(data: TransformOperation, target?: TransformOperation): TransformOperation {
- if (!data) {
- return data;
- }
- const instance = target || new TransformOperation();
- super.fromData(data, instance);
- instance.mappingPropertyInternalName = data.mappingPropertyInternalName;
- instance.sourceStaticProperty = data.sourceStaticProperty;
- instance.transformationScope = data.transformationScope;
- instance.targetValue = data.targetValue;
- return instance;
- }
+ "@class": "org.apache.streampipes.model.output.TransformOperation";
+ mappingPropertyInternalName: string;
+ sourceStaticProperty: string;
+ targetValue: string;
+ transformationScope: string;
+
+ static fromData(data: TransformOperation, target?: TransformOperation): TransformOperation {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new TransformOperation();
+ super.fromData(data, instance);
+ instance.mappingPropertyInternalName = data.mappingPropertyInternalName;
+ instance.sourceStaticProperty = data.sourceStaticProperty;
+ instance.transformationScope = data.transformationScope;
+ instance.targetValue = data.targetValue;
+ return instance;
+ }
}
export class TransformOutputStrategy extends OutputStrategy {
- '@class': 'org.apache.streampipes.model.output.TransformOutputStrategy';
- transformOperations: TransformOperation[];
+ "@class": "org.apache.streampipes.model.output.TransformOutputStrategy";
+ transformOperations: TransformOperation[];
- static fromData(data: TransformOutputStrategy, target?: TransformOutputStrategy): TransformOutputStrategy {
- if (!data) {
- return data;
+ static fromData(data: TransformOutputStrategy, target?: TransformOutputStrategy): TransformOutputStrategy {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new TransformOutputStrategy();
+ super.fromData(data, instance);
+ instance.transformOperations = __getCopyArrayFn(TransformOperation.fromData)(data.transformOperations);
+ return instance;
}
- const instance = target || new TransformOutputStrategy();
- super.fromData(data, instance);
- instance.transformOperations = __getCopyArrayFn(TransformOperation.fromData)(data.transformOperations);
- return instance;
- }
}
export class TransportFormat extends UnnamedStreamPipesEntity {
- '@class': 'org.apache.streampipes.model.grounding.TransportFormat';
- rdfType: string[];
+ "@class": "org.apache.streampipes.model.grounding.TransportFormat";
+ rdfType: string[];
- static fromData(data: TransportFormat, target?: TransportFormat): TransportFormat {
- if (!data) {
- return data;
+ static fromData(data: TransportFormat, target?: TransportFormat): TransportFormat {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new TransportFormat();
+ super.fromData(data, instance);
+ instance.rdfType = __getCopyArrayFn(__identity<string>())(data.rdfType);
+ return instance;
}
- const instance = target || new TransportFormat();
- super.fromData(data, instance);
- instance.rdfType = __getCopyArrayFn(__identity<string>())(data.rdfType);
- return instance;
- }
}
export class UnitTransformRuleDescription extends ValueTransformationRuleDescription {
- '@class': 'org.apache.streampipes.model.connect.rules.value.UnitTransformRuleDescription';
- fromUnitRessourceURL: string;
- runtimeKey: string;
- toUnitRessourceURL: string;
+ "@class": "org.apache.streampipes.model.connect.rules.value.UnitTransformRuleDescription";
+ fromUnitRessourceURL: string;
+ runtimeKey: string;
+ toUnitRessourceURL: string;
- static fromData(data: UnitTransformRuleDescription, target?: UnitTransformRuleDescription): UnitTransformRuleDescription {
- if (!data) {
- return data;
+ static fromData(data: UnitTransformRuleDescription, target?: UnitTransformRuleDescription): UnitTransformRuleDescription {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new UnitTransformRuleDescription();
+ super.fromData(data, instance);
+ instance.runtimeKey = data.runtimeKey;
+ instance.fromUnitRessourceURL = data.fromUnitRessourceURL;
+ instance.toUnitRessourceURL = data.toUnitRessourceURL;
+ return instance;
}
- const instance = target || new UnitTransformRuleDescription();
- super.fromData(data, instance);
- instance.runtimeKey = data.runtimeKey;
- instance.fromUnitRessourceURL = data.fromUnitRessourceURL;
- instance.toUnitRessourceURL = data.toUnitRessourceURL;
- return instance;
- }
}
export class UserDefinedOutputStrategy extends OutputStrategy {
- '@class': 'org.apache.streampipes.model.output.UserDefinedOutputStrategy';
- eventProperties: EventPropertyUnion[];
+ "@class": "org.apache.streampipes.model.output.UserDefinedOutputStrategy";
+ eventProperties: EventPropertyUnion[];
- static fromData(data: UserDefinedOutputStrategy, target?: UserDefinedOutputStrategy): UserDefinedOutputStrategy {
- if (!data) {
- return data;
+ static fromData(data: UserDefinedOutputStrategy, target?: UserDefinedOutputStrategy): UserDefinedOutputStrategy {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new UserDefinedOutputStrategy();
+ super.fromData(data, instance);
+ instance.eventProperties = __getCopyArrayFn(EventProperty.fromDataUnion)(data.eventProperties);
+ return instance;
}
- const instance = target || new UserDefinedOutputStrategy();
- super.fromData(data, instance);
- instance.eventProperties = __getCopyArrayFn(EventProperty.fromDataUnion)(data.eventProperties);
- return instance;
- }
}
export class VisualizablePipeline {
- pipelineId: string;
- pipelineName: string;
- schema: EventSchema;
- topic: string;
- visualizationName: string;
-
- static fromData(data: VisualizablePipeline, target?: VisualizablePipeline): VisualizablePipeline {
- if (!data) {
- return data;
- }
- const instance = target || new VisualizablePipeline();
- instance.pipelineId = data.pipelineId;
- instance.schema = EventSchema.fromData(data.schema);
- instance.visualizationName = data.visualizationName;
- instance.topic = data.topic;
- instance.pipelineName = data.pipelineName;
- return instance;
- }
+ pipelineId: string;
+ pipelineName: string;
+ schema: EventSchema;
+ topic: string;
+ visualizationName: string;
+
+ static fromData(data: VisualizablePipeline, target?: VisualizablePipeline): VisualizablePipeline {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new VisualizablePipeline();
+ instance.pipelineId = data.pipelineId;
+ instance.schema = EventSchema.fromData(data.schema);
+ instance.visualizationName = data.visualizationName;
+ instance.topic = data.topic;
+ instance.pipelineName = data.pipelineName;
+ return instance;
+ }
}
export class WildcardTopicDefinition extends TopicDefinition {
- '@class': 'org.apache.streampipes.model.grounding.WildcardTopicDefinition';
- wildcardTopicMappings: WildcardTopicMapping[];
- wildcardTopicName: string;
+ "@class": "org.apache.streampipes.model.grounding.WildcardTopicDefinition";
+ wildcardTopicMappings: WildcardTopicMapping[];
+ wildcardTopicName: string;
- static fromData(data: WildcardTopicDefinition, target?: WildcardTopicDefinition): WildcardTopicDefinition {
- if (!data) {
- return data;
+ static fromData(data: WildcardTopicDefinition, target?: WildcardTopicDefinition): WildcardTopicDefinition {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new WildcardTopicDefinition();
+ super.fromData(data, instance);
+ instance.wildcardTopicName = data.wildcardTopicName;
+ instance.wildcardTopicMappings = __getCopyArrayFn(WildcardTopicMapping.fromData)(data.wildcardTopicMappings);
+ return instance;
}
- const instance = target || new WildcardTopicDefinition();
- super.fromData(data, instance);
- instance.wildcardTopicName = data.wildcardTopicName;
- instance.wildcardTopicMappings = __getCopyArrayFn(WildcardTopicMapping.fromData)(data.wildcardTopicMappings);
- return instance;
- }
}
export class WildcardTopicMapping extends UnnamedStreamPipesEntity {
- '@class': 'org.apache.streampipes.model.grounding.WildcardTopicMapping';
- mappedRuntimeName: string;
- mappingId: string;
- selectedMapping: string;
- topicParameterType: string;
-
- static fromData(data: WildcardTopicMapping, target?: WildcardTopicMapping): WildcardTopicMapping {
- if (!data) {
- return data;
- }
- const instance = target || new WildcardTopicMapping();
- super.fromData(data, instance);
- instance.topicParameterType = data.topicParameterType;
- instance.mappingId = data.mappingId;
- instance.mappedRuntimeName = data.mappedRuntimeName;
- instance.selectedMapping = data.selectedMapping;
- return instance;
- }
-}
-
-export type AdapterDescriptionUnion =
- GenericAdapterSetDescription
- | GenericAdapterStreamDescription
- | SpecificAdapterStreamDescription
- | SpecificAdapterSetDescription;
+ "@class": "org.apache.streampipes.model.grounding.WildcardTopicMapping";
+ mappedRuntimeName: string;
+ mappingId: string;
+ selectedMapping: string;
+ topicParameterType: string;
+
+ static fromData(data: WildcardTopicMapping, target?: WildcardTopicMapping): WildcardTopicMapping {
+ if (!data) {
+ return data;
+ }
+ const instance = target || new WildcardTopicMapping();
+ super.fromData(data, instance);
+ instance.topicParameterType = data.topicParameterType;
+ instance.mappingId = data.mappingId;
+ instance.mappedRuntimeName = data.mappedRuntimeName;
+ instance.selectedMapping = data.selectedMapping;
+ return instance;
+ }
+}
+
+export type AdapterDescriptionUnion = GenericAdapterSetDescription | GenericAdapterStreamDescription | SpecificAdapterStreamDescription | SpecificAdapterSetDescription;
export type AdapterSetDescriptionUnion = GenericAdapterSetDescription | SpecificAdapterSetDescription;
@@ -3181,116 +3112,56 @@ export type MeasurementPropertyUnion = EventPropertyQualityDefinition | EventStr
export type OneOfStaticPropertyUnion = RuntimeResolvableOneOfStaticProperty;
-export type OutputStrategyUnion =
- AppendOutputStrategy
- | CustomOutputStrategy
- | CustomTransformOutputStrategy
- | FixedOutputStrategy
- | KeepOutputStrategy
- | ListOutputStrategy
- | TransformOutputStrategy
- | UserDefinedOutputStrategy;
+export type OutputStrategyUnion = AppendOutputStrategy | CustomOutputStrategy | CustomTransformOutputStrategy | FixedOutputStrategy | KeepOutputStrategy | ListOutputStrategy | TransformOutputStrategy | UserDefinedOutputStrategy;
-export type PipelineHealthStatus = 'OK' | 'REQUIRES_ATTENTION' | 'FAILURE';
+export type PipelineHealthStatus = "OK" | "REQUIRES_ATTENTION" | "FAILURE";
export type SelectionStaticPropertyUnion = AnyStaticProperty | OneOfStaticProperty;
export type SpDataStreamUnion = SpDataStream | SpDataSet;
-export type StaticPropertyType =
- 'AnyStaticProperty'
- | 'CollectionStaticProperty'
- | 'ColorPickerStaticProperty'
- | 'DomainStaticProperty'
- | 'FreeTextStaticProperty'
- | 'FileStaticProperty'
- | 'MappingPropertyUnary'
- | 'MappingPropertyNary'
- | 'MatchingStaticProperty'
- | 'OneOfStaticProperty'
- | 'RuntimeResolvableAnyStaticProperty'
- | 'RuntimeResolvableOneOfStaticProperty'
- | 'StaticPropertyGroup'
- | 'StaticPropertyAlternatives'
- | 'StaticPropertyAlternative'
- | 'SecretStaticProperty'
- | 'CodeInputStaticProperty';
-
-export type StaticPropertyUnion =
- AnyStaticProperty
- | CodeInputStaticProperty
- | CollectionStaticProperty
- | ColorPickerStaticProperty
- | DomainStaticProperty
- | FileStaticProperty
- | FreeTextStaticProperty
- | MappingPropertyUnary
- | MappingPropertyNary
- | MatchingStaticProperty
- | OneOfStaticProperty
- | RuntimeResolvableAnyStaticProperty
- | RuntimeResolvableOneOfStaticProperty
- | SecretStaticProperty
- | StaticPropertyAlternative
- | StaticPropertyAlternatives
- | StaticPropertyGroup;
-
-export type StreamTransformationRuleDescriptionUnion =
- EventRateTransformationRuleDescription
- | RemoveDuplicatesTransformationRuleDescription;
+export type StaticPropertyType = "AnyStaticProperty" | "CollectionStaticProperty" | "ColorPickerStaticProperty" | "DomainStaticProperty" | "FreeTextStaticProperty" | "FileStaticProperty" | "MappingPropertyUnary" | "MappingPropertyNary" | "MatchingStaticProperty" | "OneOfStaticProperty" | "RuntimeResolvableAnyStaticProperty" | "RuntimeResolvableOneOfStaticProperty" | "StaticPropertyGroup" | "StaticPropertyAlternatives" | "StaticPropertyAlternative" | "SecretStaticProperty" | "CodeInputSta [...]
+
+export type StaticPropertyUnion = AnyStaticProperty | CodeInputStaticProperty | CollectionStaticProperty | ColorPickerStaticProperty | DomainStaticProperty | FileStaticProperty | FreeTextStaticProperty | MappingPropertyUnary | MappingPropertyNary | MatchingStaticProperty | OneOfStaticProperty | RuntimeResolvableAnyStaticProperty | RuntimeResolvableOneOfStaticProperty | SecretStaticProperty | StaticPropertyAlternative | StaticPropertyAlternatives | StaticPropertyGroup;
+
+export type StreamTransformationRuleDescriptionUnion = EventRateTransformationRuleDescription | RemoveDuplicatesTransformationRuleDescription;
export type TopicDefinitionUnion = SimpleTopicDefinition | WildcardTopicDefinition;
-export type TransformationRuleDescriptionUnion =
- AddTimestampRuleDescription
- | AddValueTransformationRuleDescription
- | TimestampTranfsformationRuleDescription
- | UnitTransformRuleDescription
- | EventRateTransformationRuleDescription
- | RemoveDuplicatesTransformationRuleDescription
- | CreateNestedRuleDescription
- | DeleteRuleDescription
- | RenameRuleDescription
- | MoveRuleDescription
- | CorrectionValueTransformationRuleDescription;
+export type TransformationRuleDescriptionUnion = AddTimestampRuleDescription | AddValueTransformationRuleDescription | TimestampTranfsformationRuleDescription | UnitTransformRuleDescription | EventRateTransformationRuleDescription | RemoveDuplicatesTransformationRuleDescription | CreateNestedRuleDescription | DeleteRuleDescription | RenameRuleDescription | MoveRuleDescription | CorrectionValueTransformationRuleDescription;
export type TransportProtocolUnion = JmsTransportProtocol | KafkaTransportProtocol | MqttTransportProtocol;
export type ValueSpecificationUnion = QuantitativeValue | Enumeration;
-export type ValueTransformationRuleDescriptionUnion =
- AddTimestampRuleDescription
- | AddValueTransformationRuleDescription
- | TimestampTranfsformationRuleDescription
- | UnitTransformRuleDescription
- | CorrectionValueTransformationRuleDescription;
+export type ValueTransformationRuleDescriptionUnion = AddTimestampRuleDescription | AddValueTransformationRuleDescription | TimestampTranfsformationRuleDescription | UnitTransformRuleDescription | CorrectionValueTransformationRuleDescription;
function __getCopyArrayFn<T>(itemCopyFn: (item: T) => T): (array: T[]) => T[] {
- return (array: T[]) => __copyArray(array, itemCopyFn);
+ return (array: T[]) => __copyArray(array, itemCopyFn);
}
function __copyArray<T>(array: T[], itemCopyFn: (item: T) => T): T[] {
- return array && array.map(item => item && itemCopyFn(item));
+ return array && array.map(item => item && itemCopyFn(item));
}
function __getCopyObjectFn<T>(itemCopyFn: (item: T) => T): (object: { [index: string]: T }) => { [index: string]: T } {
- return (object: { [index: string]: T }) => __copyObject(object, itemCopyFn);
+ return (object: { [index: string]: T }) => __copyObject(object, itemCopyFn);
}
function __copyObject<T>(object: { [index: string]: T }, itemCopyFn: (item: T) => T): { [index: string]: T } {
- if (!object) {
- return object;
- }
- const result: any = {};
- for (const key in object) {
- if (object.hasOwnProperty(key)) {
- const value = object[key];
- result[key] = value && itemCopyFn(value);
+ if (!object) {
+ return object;
+ }
+ const result: any = {};
+ for (const key in object) {
+ if (object.hasOwnProperty(key)) {
+ const value = object[key];
+ result[key] = value && itemCopyFn(value);
+ }
}
- }
- return result;
+ return result;
}
function __identity<T>(): (value: T) => T {
- return value => value;
+ return value => value;
}