Skip to content

Commit 332d7fd

Browse files
authored
fix: update RocksdbClient to use getDeclaredConstructor for options instantiation (#749)
1 parent f9b9852 commit 332d7fd

2 files changed

Lines changed: 6 additions & 6 deletions

File tree

  • geaflow/geaflow-plugins/geaflow-store

geaflow/geaflow-plugins/geaflow-store/geaflow-store-rocksdb/src/main/java/org/apache/geaflow/store/rocksdb/RocksdbClient.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -88,7 +88,7 @@ private void initRocksDbOptions() {
8888
if (this.rocksDBOptions == null || this.rocksDBOptions.isClosed()) {
8989
LOGGER.info("rocksdb optionClass {}", optionClass);
9090
try {
91-
this.rocksDBOptions = (IRocksDBOptions) Class.forName(optionClass).newInstance();
91+
this.rocksDBOptions = (IRocksDBOptions) Class.forName(optionClass).getDeclaredConstructor().newInstance();
9292
this.rocksDBOptions.init(config);
9393
} catch (Throwable e) {
9494
LOGGER.error("{} not found", optionClass);

geaflow/geaflow-plugins/geaflow-store/geaflow-store-vector/src/main/java/org/apache/geaflow/store/lucene/GraphVectorIndex.java

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -23,15 +23,15 @@
2323
import org.apache.lucene.analysis.standard.StandardAnalyzer;
2424
import org.apache.lucene.document.Document;
2525
import org.apache.lucene.document.Field;
26-
import org.apache.lucene.document.KnnVectorField;
26+
import org.apache.lucene.document.KnnFloatVectorField;
2727
import org.apache.lucene.document.StoredField;
2828
import org.apache.lucene.document.TextField;
2929
import org.apache.lucene.index.DirectoryReader;
3030
import org.apache.lucene.index.IndexReader;
3131
import org.apache.lucene.index.IndexWriter;
3232
import org.apache.lucene.index.IndexWriterConfig;
3333
import org.apache.lucene.search.IndexSearcher;
34-
import org.apache.lucene.search.KnnVectorQuery;
34+
import org.apache.lucene.search.KnnFloatVectorQuery;
3535
import org.apache.lucene.search.TopDocs;
3636
import org.apache.lucene.store.ByteBuffersDirectory;
3737
import org.apache.lucene.store.Directory;
@@ -107,7 +107,7 @@ public void addVectorIndex(boolean isVertex, K key, String fieldName, float[] ve
107107
}
108108

109109
// Add vector field
110-
doc.add(new KnnVectorField(fieldName, vector));
110+
doc.add(new KnnFloatVectorField(fieldName, vector));
111111

112112
// Add document to index
113113
writer.addDocument(doc);
@@ -140,12 +140,12 @@ public K searchVectorIndex(boolean isVertex, String fieldName, float[] vector, i
140140
IndexSearcher searcher = new IndexSearcher(reader);
141141

142142
// Create KNN vector query
143-
KnnVectorQuery knnQuery = new KnnVectorQuery(fieldName, vector, topK);
143+
KnnFloatVectorQuery knnQuery = new KnnFloatVectorQuery(fieldName, vector, topK);
144144

145145
// Execute search
146146
TopDocs topDocs = searcher.search(knnQuery, topK);
147147

148-
Document firstDoc = searcher.doc(topDocs.scoreDocs[0].doc);
148+
Document firstDoc = searcher.storedFields().document(topDocs.scoreDocs[0].doc);
149149

150150
K result;
151151
if (keyClass == String.class) {

0 commit comments

Comments
 (0)