|
20 | 20 | package org.neo4j.gds.compat._523; |
21 | 21 |
|
22 | 22 | import org.neo4j.collection.RawIterator; |
23 | | -import org.neo4j.configuration.Config; |
24 | 23 | import org.neo4j.dbms.api.DatabaseNotFoundException; |
25 | 24 | import org.neo4j.exceptions.KernelException; |
26 | 25 | import org.neo4j.gds.annotation.SuppressForbidden; |
27 | 26 | import org.neo4j.gds.compat.CompatCallableProcedure; |
28 | 27 | import org.neo4j.gds.compat.Neo4jProxyApi; |
29 | | -import org.neo4j.gds.compat.batchimport.BatchImporter; |
30 | | -import org.neo4j.gds.compat.batchimport.ImportConfig; |
31 | | -import org.neo4j.gds.compat.batchimport.Monitor; |
32 | | -import org.neo4j.gds.compat.batchimport.input.Collector; |
33 | | -import org.neo4j.gds.compat.batchimport.input.Estimates; |
34 | | -import org.neo4j.gds.compat.batchimport.input.ReadableGroups; |
35 | 28 | import org.neo4j.internal.kernel.api.exceptions.ProcedureException; |
36 | 29 | import org.neo4j.internal.kernel.api.procs.ProcedureSignature; |
37 | | -import org.neo4j.io.fs.FileSystemAbstraction; |
38 | | -import org.neo4j.io.layout.DatabaseLayout; |
39 | 30 | import org.neo4j.kernel.api.ResourceMonitor; |
40 | 31 | import org.neo4j.kernel.api.exceptions.Status; |
41 | 32 | import org.neo4j.kernel.api.procedure.CallableProcedure; |
42 | 33 | import org.neo4j.kernel.api.procedure.Context; |
43 | 34 | import org.neo4j.kernel.impl.query.QueryExecutionKernelException; |
44 | | -import org.neo4j.logging.internal.LogService; |
45 | | -import org.neo4j.scheduler.JobScheduler; |
46 | 35 | import org.neo4j.values.AnyValue; |
47 | 36 | import org.neo4j.values.SequenceValue; |
48 | 37 |
|
49 | | -import java.io.OutputStream; |
50 | | - |
51 | 38 | import static org.neo4j.internal.helpers.collection.Iterators.asRawIterator; |
52 | 39 |
|
53 | 40 | public final class Neo4jProxyImpl implements Neo4jProxyApi { |
54 | 41 |
|
55 | | - @Override |
56 | | - public BatchImporter instantiateBatchImporter( |
57 | | - DatabaseLayout dbLayout, |
58 | | - FileSystemAbstraction fileSystem, |
59 | | - ImportConfig config, |
60 | | - Monitor monitor, |
61 | | - LogService logService, |
62 | | - Config dbConfig, |
63 | | - JobScheduler jobScheduler, |
64 | | - Collector badCollector |
65 | | - ) { |
66 | | - return BatchImporterCompat.instantiateBatchImporter( |
67 | | - dbLayout, |
68 | | - fileSystem, |
69 | | - config, |
70 | | - monitor, |
71 | | - logService, |
72 | | - dbConfig, |
73 | | - jobScheduler, |
74 | | - badCollector |
75 | | - ); |
76 | | - } |
77 | | - |
78 | | - @Override |
79 | | - public ReadableGroups newGroups() { |
80 | | - return BatchImporterCompat.newGroups(); |
81 | | - } |
82 | | - |
83 | | - @Override |
84 | | - public ReadableGroups newInitializedGroups() { |
85 | | - return BatchImporterCompat.newInitializedGroups(); |
86 | | - } |
87 | | - |
88 | | - @Override |
89 | | - public Collector emptyCollector() { |
90 | | - return BatchImporterCompat.emptyCollector(); |
91 | | - } |
92 | | - |
93 | | - @Override |
94 | | - public Collector badCollector(OutputStream outputStream, int batchSize) { |
95 | | - return BatchImporterCompat.badCollector(outputStream, batchSize); |
96 | | - } |
97 | | - |
98 | | - @Override |
99 | | - public Estimates knownEstimates( |
100 | | - long numberOfNodes, |
101 | | - long numberOfRelationships, |
102 | | - long numberOfNodeProperties, |
103 | | - long numberOfRelationshipProperties, |
104 | | - long sizeOfNodeProperties, |
105 | | - long sizeOfRelationshipProperties, |
106 | | - long numberOfNodeLabels |
107 | | - ) { |
108 | | - return BatchImporterCompat.knownEstimates( |
109 | | - numberOfNodes, |
110 | | - numberOfRelationships, |
111 | | - numberOfNodeProperties, |
112 | | - numberOfRelationshipProperties, |
113 | | - sizeOfNodeProperties, |
114 | | - sizeOfRelationshipProperties, |
115 | | - numberOfNodeLabels |
116 | | - ); |
117 | | - } |
118 | | - |
119 | 42 | @Override |
120 | 43 | public void rethrowUnlessDuplicateRegistration(ProcedureException e) throws KernelException { |
121 | 44 | if (e.status() == Status.Procedure.ProcedureRegistrationFailed && e.getMessage().contains("already in use")) { |
|
0 commit comments