Make code compile :)

AtomGraph · Oct 22, 2023 · 4f30f58 · 4f30f58
1 parent 72f40c7
commit 4f30f58
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 9 deletions.
diff --git a/src/main/java/com/atomgraph/linkeddatahub/Application.java b/src/main/java/com/atomgraph/linkeddatahub/Application.java
@@ -1281,7 +1281,7 @@ public Map<Integer, Resource> getLengthMap(Map<URI, Resource> apps)
      */
     public void submitImport(CSVImport csvImport, com.atomgraph.linkeddatahub.apps.model.Application app, Service service, Service adminService, String baseURI, LinkedDataClient ldc)
     {
-        new ImportExecutor(importThreadPool).start(service, adminService, baseURI, ldc, service.getGraphStoreClient(), csvImport);
+        new ImportExecutor(importThreadPool).start(service, adminService, baseURI, ldc, csvImport);
     }
 
     /**
@@ -1296,7 +1296,7 @@ public void submitImport(CSVImport csvImport, com.atomgraph.linkeddatahub.apps.m
      */
     public void submitImport(RDFImport rdfImport, com.atomgraph.linkeddatahub.apps.model.Application app, Service service, Service adminService, String baseURI, LinkedDataClient ldc)
     {
-        new ImportExecutor(importThreadPool).start(service, adminService, baseURI, ldc, service.getGraphStoreClient(), rdfImport);
+        new ImportExecutor(importThreadPool).start(service, adminService, baseURI, ldc, rdfImport);
     }
 
     /**

diff --git a/src/main/java/com/atomgraph/linkeddatahub/imports/ImportExecutor.java b/src/main/java/com/atomgraph/linkeddatahub/imports/ImportExecutor.java
@@ -102,14 +102,13 @@ public ImportExecutor(ExecutorService execService)
     /**
      * Executes CSV import.
      * 
-     * @param csvImport CSV import resource
      * @param service application's SPARQL service
      * @param adminService admin application's SPARQL service
      * @param appBaseURI application's base URI
      * @param ldc Linked Data client
-     * @param graphStoreClient GSP client
+     * @param csvImport CSV import resource
      */
-    public void start(Service service, Service adminService, String appBaseURI, LinkedDataClient ldc, LinkedDataClient graphStoreClient, CSVImport csvImport)
+    public void start(Service service, Service adminService, String appBaseURI, LinkedDataClient ldc, CSVImport csvImport)
     {
         if (csvImport == null) throw new IllegalArgumentException("CSVImport cannot be null");
         if (log.isDebugEnabled()) log.debug("Submitting new import to thread pool: {}", csvImport.toString());
@@ -134,15 +133,14 @@ public void start(Service service, Service adminService, String appBaseURI, Link
     /**
      * Executes RDF import.
      * 
-     * @param rdfImport RDF import resource
      * @param service application's SPARQL service
      * @param adminService admin application's SPARQL service
      * @param appBaseURI application's base URI
      * @param ldc Linked Data client
-     * @param graphStoreClient GSP client
+     * @param rdfImport RDF import resource
      */
 
-    public void start(Service service, Service adminService, String appBaseURI, LinkedDataClient ldc, LinkedDataClient graphStoreClient, RDFImport rdfImport)
+    public void start(Service service, Service adminService, String appBaseURI, LinkedDataClient ldc, RDFImport rdfImport)
     {
         if (rdfImport == null) throw new IllegalArgumentException("RDFImport cannot be null");
         if (log.isDebugEnabled()) log.debug("Submitting new import to thread pool: {}", rdfImport.toString());
@@ -165,7 +163,7 @@ public void start(Service service, Service adminService, String appBaseURI, Link
         Supplier<Response> fileSupplier = new ClientResponseSupplier(ldc, RDF_MEDIA_TYPES, URI.create(rdfImport.getFile().getURI()));
         // skip validation because it will be done during final POST anyway
         CompletableFuture.supplyAsync(fileSupplier, getExecutorService()).thenApplyAsync(getStreamRDFOutputWriter(service, adminService,
-                graphStoreClient, queryBaseURI, query, rdfImport), getExecutorService()).
+                ldc, queryBaseURI, query, rdfImport), getExecutorService()).
             thenAcceptAsync(success(service, rdfImport, provImport), getExecutorService()).
             exceptionally(failure(service, rdfImport, provImport));
     }