Package org.apache.solr.filestore

Class DistribFileStore

java.lang.Object

org.apache.solr.filestore.DistribFileStore

All Implemented Interfaces:

FileStore

@NotThreadSafe
public class DistribFileStore
extends Object
implements FileStore

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.solr.filestore.FileStore

FileStore.FileDetails, FileStore.FileEntry, FileStore.FileType

Constructor Summary

Constructors

Constructor	Description
DistribFileStore(CoreContainer coreContainer)

Method Summary

Modifier and Type	Method	Description
static FileStore.FileType	_getFileType(Path file)
static void	_persistToFile(Path solrHome, String path, ByteBuffer data, ByteBuffer meta)	Internal API
void	delete(String path)	Delete a file cluster-wide
void	deleteLocal(String path)	Delete file from local file system
static void	deleteZKFileEntry(org.apache.solr.common.cloud.SolrZkClient client, String path)
boolean	fetch(String path, String from)	Fetch a resource from another node internal API
void	get(String path, Consumer<FileStore.FileEntry> consumer, boolean fetchMissing)	Read file content from a given path.
static Path	getFileStoreDirPath(Path solrHome)
Map<String,byte[]>	getKeys()	Get all the keys in the package store.
Path	getRealPath(String path)	get the real path on filesystem
FileStore.FileType	getType(String path, boolean fetchMissing)	The type of the resource
static boolean	isMetaDataFile(String file)
List<FileStore.FileDetails>	list(String path, Predicate<String> predicate)
void	put(FileStore.FileEntry entry)	Store a file into the filestore.
void	refresh(String path)	Refresh the files in a path.
void	syncToAllNodes(String path)	Sync a local file to all nodes.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

DistribFileStore

public DistribFileStore(CoreContainer coreContainer)

Method Details

getRealPath

public Path getRealPath(String path)

Description copied from interface: FileStore

get the real path on filesystem

Specified by:

getRealPath in interface FileStore

put

public void put(FileStore.FileEntry entry)
         throws IOException

Description copied from interface: FileStore

Store a file into the filestore. This should ensure that it is replicated across all nodes in the cluster

Specified by:

put in interface FileStore

Throws:

IOException

fetch

public boolean fetch(String path,
 String from)

Description copied from interface: FileStore

Fetch a resource from another node internal API

Specified by:

fetch in interface FileStore

get

public void get(String path,
 Consumer<FileStore.FileEntry> consumer,
 boolean fetchMissing)
         throws IOException

Description copied from interface: FileStore

Read file content from a given path.

TODO: Is fetchMissing actually used? I don't see it being used, but the IDE doesn't flag it not being used!

Specified by:

get in interface FileStore

Throws:

IOException

syncToAllNodes

public void syncToAllNodes(String path)
                    throws IOException

Description copied from interface: FileStore

Sync a local file to all nodes. All the nodes are asked to pull the file from this node

Specified by:

syncToAllNodes in interface FileStore

Throws:

IOException

list

public List<FileStore.FileDetails> list(String path,
 Predicate<String> predicate)

Specified by:

list in interface FileStore

delete

public void delete(String path)

Description copied from interface: FileStore

Delete a file cluster-wide

Specified by:

delete in interface FileStore

deleteLocal

public void deleteLocal(String path)

Description copied from interface: FileStore

Delete file from local file system

Specified by:

deleteLocal in interface FileStore

refresh

public void refresh(String path)

Description copied from interface: FileStore

Refresh the files in a path. Maybe this node does not have all files?

Specified by:

refresh in interface FileStore

Parameters:

path - the path to be refreshed.

getType

public FileStore.FileType getType(String path,
 boolean fetchMissing)

Description copied from interface: FileStore

The type of the resource

Specified by:

getType in interface FileStore

_getFileType

public static FileStore.FileType _getFileType(Path file)

isMetaDataFile

public static boolean isMetaDataFile(String file)

getFileStoreDirPath

public static Path getFileStoreDirPath(Path solrHome)

_persistToFile

public static void _persistToFile(Path solrHome,
 String path,
 ByteBuffer data,
 ByteBuffer meta)
                           throws IOException

Internal API

Throws:

IOException

getKeys

public Map<String,byte[]> getKeys()
                           throws IOException

Description copied from interface: FileStore

Get all the keys in the package store. The data is a .DER file content

Specified by:

getKeys in interface FileStore

Throws:

IOException

deleteZKFileEntry

public static void deleteZKFileEntry(org.apache.solr.common.cloud.SolrZkClient client,
 String path)