You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampipes.apache.org by ri...@apache.org on 2023/01/08 16:56:49 UTC
[streampipes] 01/03: Remove unused classes (#1058)
This is an automated email from the ASF dual-hosted git repository.
riemer pushed a commit to branch SP-1058
in repository https://gitbox.apache.org/repos/asf/streampipes.git
commit dbdac1ad24ef873531d8605b3896df0205463f82
Author: Dominik Riemer <do...@gmail.com>
AuthorDate: Sat Jan 7 23:18:41 2023 +0100
Remove unused classes (#1058)
---
.../api/declarer/EventStreamDeclarer.java | 25 ------
.../declarer/SemanticEventProducerDeclarer.java | 28 -------
.../apache/streampipes/model/base/Namespaces.java | 25 ------
.../model/graph/DataSourceDescription.java | 93 ----------------------
.../runtime/HeartbeatMessageGenerator.java | 38 ---------
.../runtime/RuntimeVerificationResult.java | 23 ------
.../verification/runtime/RuntimeVerifier.java | 23 ------
.../verification/runtime/SourceSchemaVerifier.java | 41 ----------
.../verification/structure/GeneralSecVerifier.java | 23 ------
.../verification/structure/GeneralSepVerifier.java | 23 ------
.../structure/GeneralSepaVerifier.java | 23 ------
.../structure/StreamRequirementVerifier.java | 23 ------
.../verification/structure/StreamVerifier.java | 41 ----------
.../streampipes/sdk/builder/DataSourceBuilder.java | 50 ------------
14 files changed, 479 deletions(-)
diff --git a/streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/declarer/EventStreamDeclarer.java b/streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/declarer/EventStreamDeclarer.java
deleted file mode 100644
index 4eb79f810..000000000
--- a/streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/declarer/EventStreamDeclarer.java
+++ /dev/null
@@ -1,25 +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.extensions.api.declarer;
-
-@Deprecated
-public interface EventStreamDeclarer extends DataStreamDeclarer {
-
-
-}
diff --git a/streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/declarer/SemanticEventProducerDeclarer.java b/streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/declarer/SemanticEventProducerDeclarer.java
deleted file mode 100644
index c21db7506..000000000
--- a/streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/declarer/SemanticEventProducerDeclarer.java
+++ /dev/null
@@ -1,28 +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.extensions.api.declarer;
-
-import org.apache.streampipes.model.graph.DataSourceDescription;
-
-import java.util.List;
-
-@Deprecated
-public interface SemanticEventProducerDeclarer extends Declarer<DataSourceDescription> {
- List<DataStreamDeclarer> getEventStreams();
-}
diff --git a/streampipes-model/src/main/java/org/apache/streampipes/model/base/Namespaces.java b/streampipes-model/src/main/java/org/apache/streampipes/model/base/Namespaces.java
deleted file mode 100644
index 23c57a7ad..000000000
--- a/streampipes-model/src/main/java/org/apache/streampipes/model/base/Namespaces.java
+++ /dev/null
@@ -1,25 +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.base;
-
-public class Namespaces {
-
- public static final String SO = org.apache.streampipes.vocabulary.SO.NS;
-
-}
diff --git a/streampipes-model/src/main/java/org/apache/streampipes/model/graph/DataSourceDescription.java b/streampipes-model/src/main/java/org/apache/streampipes/model/graph/DataSourceDescription.java
deleted file mode 100644
index a22e5f9e5..000000000
--- a/streampipes-model/src/main/java/org/apache/streampipes/model/graph/DataSourceDescription.java
+++ /dev/null
@@ -1,93 +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.graph;
-
-import org.apache.streampipes.model.SpDataStream;
-import org.apache.streampipes.model.base.NamedStreamPipesEntity;
-import org.apache.streampipes.model.shared.annotation.TsModel;
-import org.apache.streampipes.model.util.Cloner;
-
-import java.util.ArrayList;
-import java.util.Arrays;
-import java.util.List;
-
-/**
- * class that represents Semantic Event Producers.
- */
-
-
-/**
- * @deprecated As of release 0.90.0, replaced by {@link DataSourceDescription}
- */
-@TsModel
-@Deprecated(since = "0.90.0", forRemoval = true)
-public class DataSourceDescription extends NamedStreamPipesEntity {
-
- private static final long serialVersionUID = 5607030219013954697L;
-
- private List<SpDataStream> spDataStreams;
-
- private String correspondingSourceId;
-
- public DataSourceDescription() {
- super();
- spDataStreams = new ArrayList<>();
- }
-
- public DataSourceDescription(DataSourceDescription other) {
- super(other);
- this.spDataStreams = new Cloner().seq(other.getSpDataStreams());
- this.spDataStreams.forEach(e -> e.setCategory(Arrays.asList(this.getElementId())));
- }
-
- public DataSourceDescription(String uri, String name, String description, String iconUrl,
- List<SpDataStream> spDataStreams) {
- super(uri, name, description, iconUrl);
- this.spDataStreams = spDataStreams;
- this.setAppId(uri);
- }
-
- public DataSourceDescription(String uri, String name2, String description2, String iconUrl) {
- this(uri, name2, description2, iconUrl, new ArrayList<>());
- }
-
- public DataSourceDescription(String uri, String name, String description) {
- this(uri, name, description, "", new ArrayList<>());
- }
-
- public List<SpDataStream> getSpDataStreams() {
- return spDataStreams;
- }
-
- public void setSpDataStreams(List<SpDataStream> spDataStreams) {
- this.spDataStreams = spDataStreams;
- }
-
- public void addEventStream(SpDataStream spDataStream) {
- spDataStreams.add(spDataStream);
- }
-
- public String getCorrespondingSourceId() {
- return correspondingSourceId;
- }
-
- public void setCorrespondingSourceId(String correspondingSourceId) {
- this.correspondingSourceId = correspondingSourceId;
- }
-}
diff --git a/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/verification/runtime/HeartbeatMessageGenerator.java b/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/verification/runtime/HeartbeatMessageGenerator.java
deleted file mode 100644
index 6e87231f9..000000000
--- a/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/verification/runtime/HeartbeatMessageGenerator.java
+++ /dev/null
@@ -1,38 +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.manager.verification.runtime;
-
-import org.apache.streampipes.model.graph.DataProcessorDescription;
-
-public class HeartbeatMessageGenerator {
-
- private DataProcessorDescription description;
-
- public HeartbeatMessageGenerator(DataProcessorDescription description) {
- this.description = description;
- }
-
- public DataProcessorDescription getDescription() {
- return description;
- }
-
- public void setDescription(DataProcessorDescription description) {
- this.description = description;
- }
-}
diff --git a/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/verification/runtime/RuntimeVerificationResult.java b/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/verification/runtime/RuntimeVerificationResult.java
deleted file mode 100644
index d0edcae05..000000000
--- a/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/verification/runtime/RuntimeVerificationResult.java
+++ /dev/null
@@ -1,23 +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.manager.verification.runtime;
-
-public class RuntimeVerificationResult {
-
-}
diff --git a/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/verification/runtime/RuntimeVerifier.java b/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/verification/runtime/RuntimeVerifier.java
deleted file mode 100644
index 164c196a7..000000000
--- a/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/verification/runtime/RuntimeVerifier.java
+++ /dev/null
@@ -1,23 +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.manager.verification.runtime;
-
-public class RuntimeVerifier {
-
-}
diff --git a/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/verification/runtime/SourceSchemaVerifier.java b/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/verification/runtime/SourceSchemaVerifier.java
deleted file mode 100644
index faf01b4cf..000000000
--- a/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/verification/runtime/SourceSchemaVerifier.java
+++ /dev/null
@@ -1,41 +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.manager.verification.runtime;
-
-import org.apache.streampipes.manager.verification.messages.VerificationResult;
-import org.apache.streampipes.manager.verification.structure.Verifier;
-import org.apache.streampipes.model.graph.DataSourceDescription;
-
-import java.util.List;
-
-public class SourceSchemaVerifier implements Verifier {
-
- private DataSourceDescription sep;
-
- public SourceSchemaVerifier(DataSourceDescription sep) {
- this.sep = sep;
- }
-
- @Override
- public List<VerificationResult> validate() {
- // TODO Auto-generated method stub
- return null;
- }
-
-}
diff --git a/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/verification/structure/GeneralSecVerifier.java b/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/verification/structure/GeneralSecVerifier.java
deleted file mode 100644
index 7373d0457..000000000
--- a/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/verification/structure/GeneralSecVerifier.java
+++ /dev/null
@@ -1,23 +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.manager.verification.structure;
-
-public class GeneralSecVerifier {
-
-}
diff --git a/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/verification/structure/GeneralSepVerifier.java b/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/verification/structure/GeneralSepVerifier.java
deleted file mode 100644
index 2bc6c2a12..000000000
--- a/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/verification/structure/GeneralSepVerifier.java
+++ /dev/null
@@ -1,23 +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.manager.verification.structure;
-
-public class GeneralSepVerifier {
-
-}
diff --git a/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/verification/structure/GeneralSepaVerifier.java b/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/verification/structure/GeneralSepaVerifier.java
deleted file mode 100644
index eb6ef2fdf..000000000
--- a/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/verification/structure/GeneralSepaVerifier.java
+++ /dev/null
@@ -1,23 +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.manager.verification.structure;
-
-public class GeneralSepaVerifier {
-
-}
diff --git a/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/verification/structure/StreamRequirementVerifier.java b/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/verification/structure/StreamRequirementVerifier.java
deleted file mode 100644
index f6c79f60e..000000000
--- a/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/verification/structure/StreamRequirementVerifier.java
+++ /dev/null
@@ -1,23 +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.manager.verification.structure;
-
-public class StreamRequirementVerifier {
-
-}
diff --git a/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/verification/structure/StreamVerifier.java b/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/verification/structure/StreamVerifier.java
deleted file mode 100644
index ef6ca89e6..000000000
--- a/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/verification/structure/StreamVerifier.java
+++ /dev/null
@@ -1,41 +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.manager.verification.structure;
-
-import org.apache.streampipes.manager.verification.messages.VerificationResult;
-import org.apache.streampipes.model.SpDataStream;
-
-import java.util.List;
-
-public class StreamVerifier extends AbstractVerifier {
-
- SpDataStream stream;
-
- public StreamVerifier(SpDataStream stream) {
- this.stream = stream;
- }
-
- @Override
- public List<VerificationResult> validate() {
-
-
- return validationResults;
- }
-
-}
diff --git a/streampipes-sdk/src/main/java/org/apache/streampipes/sdk/builder/DataSourceBuilder.java b/streampipes-sdk/src/main/java/org/apache/streampipes/sdk/builder/DataSourceBuilder.java
deleted file mode 100644
index 12537762b..000000000
--- a/streampipes-sdk/src/main/java/org/apache/streampipes/sdk/builder/DataSourceBuilder.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.sdk.builder;
-
-import org.apache.streampipes.model.graph.DataSourceDescription;
-
-public class DataSourceBuilder extends AbstractPipelineElementBuilder<DataSourceBuilder, DataSourceDescription> {
-
- /**
- * Creates a new data source using the builder pattern.
- *
- * @param id A unique identifier of the new element, e.g., com.mycompany.source.mynewdatasource
- * @param label A human-readable name of the element.
- * Will later be shown as the element name in the StreamPipes UI.
- * @param description A human-readable description of the element.
- */
- protected DataSourceBuilder(String id, String label, String description) {
- super(id, label, description, new DataSourceDescription());
- }
-
- public static DataSourceBuilder create(String id, String label, String description) {
- return new DataSourceBuilder(id, label, description);
- }
-
- @Override
- protected DataSourceBuilder me() {
- return this;
- }
-
- @Override
- protected void prepareBuild() {
-
- }
-}