Skip to content

Commit

Permalink
restored reader creation
Browse files Browse the repository at this point in the history
  • Loading branch information
vga91 committed Feb 17, 2025
1 parent f06d573 commit 9449084
Showing 1 changed file with 4 additions and 5 deletions.
9 changes: 4 additions & 5 deletions extended/src/main/java/apoc/metrics/Metrics.java
Original file line number Diff line number Diff line change
Expand Up @@ -5,10 +5,7 @@
import apoc.load.CSVResult;
import apoc.load.LoadCsv;
import apoc.load.util.LoadCsvConfig;
import apoc.util.CompressionAlgo;
import apoc.util.ExtendedFileUtils;
import apoc.util.FileUtils;
import apoc.util.Util;
import apoc.util.*;
import org.neo4j.graphdb.security.URLAccessChecker;
import org.neo4j.logging.Log;
import org.neo4j.procedure.*;
Expand Down Expand Up @@ -190,7 +187,9 @@ public Stream<GenericMetric> loadCsvForMetric(String metricName, Map<String,Obje
String url = file.getAbsolutePath();
CountingReader reader = null;
try {
reader = FileUtils.readerFor(url, CompressionAlgo.NONE.name(), urlAccessChecker);
reader = FileUtils.getStreamConnection(SupportedProtocols.file, url, null, null, urlAccessChecker)
.toCountingInputStream(CompressionAlgo.NONE.name())
.asReader();
return new LoadCsv()
.streamCsv(url, new LoadCsvConfig(config), reader)
.filter(Metrics.duplicatedHeaderRows)
Expand Down

0 comments on commit 9449084

Please sign in to comment.