You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampipes.apache.org by eb...@apache.org on 2021/06/11 18:43:42 UTC

[incubator-streampipes] 28/29: [STREAMPIPES-349] Add DataLakeResourceV4 to StreamPipesResourceConfig

This is an automated email from the ASF dual-hosted git repository.

ebi pushed a commit to branch STREAMPIPES-349
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes.git

commit d9e9d7980d448f4d4cc1ef5df8abc071478f3029
Author: Daniel Ebi <eb...@fzi.de>
AuthorDate: Fri Jun 11 20:16:46 2021 +0200

    [STREAMPIPES-349] Add DataLakeResourceV4 to StreamPipesResourceConfig
---
 .../backend/StreamPipesResourceConfig.java         | 156 +++++++++++----------
 1 file changed, 79 insertions(+), 77 deletions(-)

diff --git a/streampipes-backend/src/main/java/org/apache/streampipes/backend/StreamPipesResourceConfig.java b/streampipes-backend/src/main/java/org/apache/streampipes/backend/StreamPipesResourceConfig.java
index 2261149..1e66b44 100644
--- a/streampipes-backend/src/main/java/org/apache/streampipes/backend/StreamPipesResourceConfig.java
+++ b/streampipes-backend/src/main/java/org/apache/streampipes/backend/StreamPipesResourceConfig.java
@@ -20,6 +20,8 @@ package org.apache.streampipes.backend;
 
 import io.swagger.v3.jaxrs2.integration.resources.OpenApiResource;
 import org.apache.streampipes.connect.container.master.rest.*;
+import org.apache.streampipes.ps.DataLakeResourceV3;
+import org.apache.streampipes.ps.DataLakeResourceV4;
 import org.apache.streampipes.ps.PipelineElementTemplateResource;
 import org.apache.streampipes.rest.impl.*;
 import org.apache.streampipes.rest.impl.dashboard.Dashboard;
@@ -27,7 +29,6 @@ import org.apache.streampipes.rest.impl.dashboard.DashboardWidget;
 import org.apache.streampipes.rest.impl.dashboard.VisualizablePipeline;
 import org.apache.streampipes.rest.impl.datalake.DataLakeDashboardResource;
 import org.apache.streampipes.rest.impl.datalake.DataLakeNoUserResourceV3;
-import org.apache.streampipes.ps.DataLakeResourceV3;
 import org.apache.streampipes.rest.impl.datalake.DataLakeWidgetResource;
 import org.apache.streampipes.rest.impl.nouser.FileServingResource;
 import org.apache.streampipes.rest.impl.nouser.PipelineElementImportNoUser;
@@ -47,86 +48,87 @@ import javax.ws.rs.ApplicationPath;
 @ApplicationPath("/api")
 public class StreamPipesResourceConfig extends ResourceConfig {
 
-  public StreamPipesResourceConfig() {
-    register(Authentication.class);
-    register(AssetDashboard.class);
-    register(AutoComplete.class);
-    register(CategoryResource.class);
-    register(ConsulConfig.class);
-    register(ContainerProvidedOptions.class);
-    register(Couchdb.class);
-    register(DashboardWidget.class);
-    register(Dashboard.class);
-    register(DataLakeResourceV3.class);
-    register(DataLakeNoUserResourceV3.class);
-    register(DataStream.class);
-    register(Deployment.class);
-    register(FileServingResource.class);
-    register(InternalPipelineTemplates.class);
-    register(LabelResource.class);
-    register(MeasurementUnitResource.class);
-    register(Notification.class);
-    register(OntologyContext.class);
-    register(OntologyKnowledge.class);
-    register(OntologyMeasurementUnit.class);
-    register(OntologyPipelineElement.class);
-    register(PipelineCache.class);
-    register(PipelineCategory.class);
-    register(PipelineElementAsset.class);
-    register(PipelineElementCategory.class);
-    register(PipelineElementFile.class);
-    register(PipelineElementImportNoUser.class);
-    register(PipelineElementImport.class);
-    register(PipelineElementRuntimeInfo.class);
-    register(PipelineMonitoring.class);
-    register(PipelineNoUserResource.class);
-    register(PipelineTemplate.class);
-    register(PipelineResource.class);
-    register(RdfEndpoint.class);
-    register(SemanticEventConsumer.class);
-    register(SemanticEventProcessingAgent.class);
-    register(SemanticEventProducer.class);
-    register(Setup.class);
-    register(User.class);
-    register(Version.class);
-    register(PipelineElementAsset.class);
-    register(DataLakeDashboardResource.class);
-    register(DataLakeWidgetResource.class);
-    register(DataLakeResourceV3.class);
-    register(DataLakeNoUserResourceV3.class);
-    register(PipelineElementFile.class);
-    register(FileServingResource.class);
-    register(DashboardWidget.class);
-    register(Dashboard.class);
-    register(VirtualSensor.class);
-    register(Visualization.class);
-    register(VisualizablePipeline.class);
+    public StreamPipesResourceConfig() {
+        register(Authentication.class);
+        register(AssetDashboard.class);
+        register(AutoComplete.class);
+        register(CategoryResource.class);
+        register(ConsulConfig.class);
+        register(ContainerProvidedOptions.class);
+        register(Couchdb.class);
+        register(DashboardWidget.class);
+        register(Dashboard.class);
+        register(DataLakeResourceV3.class);
+        register(DataLakeNoUserResourceV3.class);
+        register(DataStream.class);
+        register(Deployment.class);
+        register(FileServingResource.class);
+        register(InternalPipelineTemplates.class);
+        register(LabelResource.class);
+        register(MeasurementUnitResource.class);
+        register(Notification.class);
+        register(OntologyContext.class);
+        register(OntologyKnowledge.class);
+        register(OntologyMeasurementUnit.class);
+        register(OntologyPipelineElement.class);
+        register(PipelineCache.class);
+        register(PipelineCategory.class);
+        register(PipelineElementAsset.class);
+        register(PipelineElementCategory.class);
+        register(PipelineElementFile.class);
+        register(PipelineElementImportNoUser.class);
+        register(PipelineElementImport.class);
+        register(PipelineElementRuntimeInfo.class);
+        register(PipelineMonitoring.class);
+        register(PipelineNoUserResource.class);
+        register(PipelineTemplate.class);
+        register(PipelineResource.class);
+        register(RdfEndpoint.class);
+        register(SemanticEventConsumer.class);
+        register(SemanticEventProcessingAgent.class);
+        register(SemanticEventProducer.class);
+        register(Setup.class);
+        register(User.class);
+        register(Version.class);
+        register(PipelineElementAsset.class);
+        register(DataLakeDashboardResource.class);
+        register(DataLakeWidgetResource.class);
+        register(DataLakeResourceV3.class);
+        register(DataLakeNoUserResourceV3.class);
+        register(PipelineElementFile.class);
+        register(FileServingResource.class);
+        register(DashboardWidget.class);
+        register(Dashboard.class);
+        register(VirtualSensor.class);
+        register(Visualization.class);
+        register(VisualizablePipeline.class);
+
+        // Serializers
+        register(GsonWithIdProvider.class);
+        register(GsonWithoutIdProvider.class);
+        register(GsonClientModelProvider.class);
+        register(JsonLdProvider.class);
+        register(JacksonSerializationProvider.class);
+        register(MultiPartFeature.class);
 
-    // Serializers
-    register(GsonWithIdProvider.class);
-    register(GsonWithoutIdProvider.class);
-    register(GsonClientModelProvider.class);
-    register(JsonLdProvider.class);
-    register(JacksonSerializationProvider.class);
-    register(MultiPartFeature.class);
-    
-    // Platform Services
-    register(PipelineElementTemplateResource.class);
+        // Platform Services
+        register(PipelineElementTemplateResource.class);
+        register(DataLakeResourceV4.class);
 
-    register(OpenApiResource.class);
+        register(OpenApiResource.class);
 
 
-    // Connect Master
-    register(WelcomePageMaster.class);
-    register(AdapterResource.class);
-    register(AdapterTemplateResource.class);
-    register(DescriptionResource.class);
-    register(SourcesResource.class);
-    register(GuessResource.class);
+        // Connect Master
+        register(WelcomePageMaster.class);
+        register(AdapterResource.class);
+        register(AdapterTemplateResource.class);
+        register(DescriptionResource.class);
+        register(SourcesResource.class);
+        register(GuessResource.class);
 //    register(MultiPartFeature.class);
-    register(UnitResource.class);
-    register(WorkerAdministrationResource.class);
-    register(RuntimeResolvableResource.class);
-  }
+        register(UnitResource.class);
+        register(WorkerAdministrationResource.class);
+        register(RuntimeResolvableResource.class);
+    }
 
 }