"Fossies" - the Fresh Open Source Software Archive  

Source code changes of the file "solr/core/src/java/org/apache/solr/filestore/PackageStore.java" between
solr-8.4.0-src.tgz and solr-8.4.1-src.tgz

About: Solr is the search platform from the Apache Lucene project. Its major features include full-text search, hit highlighting, faceted search, caching, replication, and a web admin interface.

PackageStore.java  (solr-8.4.0-src.tgz):PackageStore.java  (solr-8.4.1-src.tgz)
skipping to change at line 26 skipping to change at line 26
*/ */
package org.apache.solr.filestore; package org.apache.solr.filestore;
import java.io.IOException; import java.io.IOException;
import java.io.InputStream; import java.io.InputStream;
import java.nio.ByteBuffer; import java.nio.ByteBuffer;
import java.nio.file.Path; import java.nio.file.Path;
import java.util.Date; import java.util.Date;
import java.util.List; import java.util.List;
import java.util.Map;
import java.util.function.Consumer; import java.util.function.Consumer;
import java.util.function.Predicate; import java.util.function.Predicate;
import org.apache.solr.common.MapWriter; import org.apache.solr.common.MapWriter;
import org.apache.solr.filestore.PackageStoreAPI.MetaData; import org.apache.solr.filestore.PackageStoreAPI.MetaData;
import org.apache.zookeeper.server.ByteBufferInputStream; import org.apache.zookeeper.server.ByteBufferInputStream;
/** /**
* The interface to be implemented by any package store provider * The interface to be implemented by any package store provider
* * @lucene.experimental * * @lucene.experimental
skipping to change at line 58 skipping to change at line 59
void get(String path, Consumer<FileEntry> filecontent, boolean getMissing) thr ows IOException; void get(String path, Consumer<FileEntry> filecontent, boolean getMissing) thr ows IOException;
/** /**
* Fetch a resource from another node * Fetch a resource from another node
* internal API * internal API
*/ */
boolean fetch(String path, String from); boolean fetch(String path, String from);
List<FileDetails> list(String path, Predicate<String> predicate); List<FileDetails> list(String path, Predicate<String> predicate);
/** Sync a local file to all nodes. All the nodes are asked to pull the file f
rom this node
*/
void syncToAllNodes(String path) throws IOException;
/** /**
* get the real path on filesystem * get the real path on filesystem
*/ */
Path getRealpath(String path); Path getRealpath(String path);
/** /**
* The type of the resource * The type of the resource
*/ */
FileType getType(String path, boolean fetchMissing); FileType getType(String path, boolean fetchMissing);
/**Get all the keys in the package store. The data is a .DER file content
*/
Map<String,byte[]> getKeys() throws IOException;
/**Refresh the files in a path. May be this node does not have all files
* @param path the path to be refreshed.
*/
void refresh(String path);
public class FileEntry { public class FileEntry {
final ByteBuffer buf; final ByteBuffer buf;
final MetaData meta; final MetaData meta;
final String path; final String path;
FileEntry(ByteBuffer buf, MetaData meta, String path) { FileEntry(ByteBuffer buf, MetaData meta, String path) {
this.buf = buf; this.buf = buf;
this.meta = meta; this.meta = meta;
this.path = path; this.path = path;
} }
 End of changes. 3 change blocks. 
0 lines changed or deleted 15 lines changed or added

Home  |  About  |  Features  |  All  |  Newest  |  Dox  |  Diffs  |  RSS Feeds  |  Screenshots  |  Comments  |  Imprint  |  Privacy  |  HTTP(S)