Package org.apache.solr.filestore

Class ClusterFileStore

java.lang.Object

org.apache.solr.api.JerseyResource

org.apache.solr.filestore.ClusterFileStore

All Implemented Interfaces:

ClusterFileStoreApis

public class ClusterFileStore
extends JerseyResource
implements ClusterFileStoreApis

Field Summary

Fields

Modifier and Type	Field	Description
static final String	FILESTORE_DIRECTORY
static final String	KEYS_DIR
static final String	TRUSTED_DIR

Fields inherited from class org.apache.solr.api.JerseyResource

containerRequestContext

Constructor Summary

Constructors

Constructor	Description
ClusterFileStore(CoreContainer coreContainer, DistribFileStore fileStore, SolrQueryRequest req, SolrQueryResponse rsp)

Method Summary

Modifier and Type	Method	Description
static FileStoreAPI.MetaData	_createJsonMetaData(byte[] buf, List<String> signatures)	Creates a JSON string with the metadata.
static void	attachFileToResponse(String path, FileStore fileStore, SolrQueryRequest req, SolrQueryResponse rsp)
SolrJerseyResponse	deleteFile(String filePath, Boolean localDelete)
SolrJerseyResponse	fetchFile(String path, String getFrom)
SolrJerseyResponse	getFile(String path)
FileStoreDirectoryListingResponse	getMetadata(String path)
static FileStoreDirectoryListingResponse	getMetadata(FileStore.FileType type, String path, FileStore fileStore)
static void	pullFileFromNode(CoreContainer coreContainer, FileStore fileStore, String path, String getFrom)
SolrJerseyResponse	syncFile(String path)
static void	syncToAllNodes(FileStore fileStore, String path)
UploadToFileStoreResponse	uploadFile(String filePath, List<String> sig, InputStream requestBody)
static void	validateName(String path, boolean failForTrusted)

Methods inherited from class org.apache.solr.api.JerseyResource

ensureRequiredParameterProvided, ensureRequiredRequestBodyProvided, instantiateJerseyResponse, instantiateJerseyResponse

Methods inherited from class java.lang.Object

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

Field Details

FILESTORE_DIRECTORY

public static final String FILESTORE_DIRECTORY

See Also:

• Constant Field Values

TRUSTED_DIR

public static final String TRUSTED_DIR

See Also:

• Constant Field Values

KEYS_DIR

public static final String KEYS_DIR

See Also:

• Constant Field Values

Constructor Details

ClusterFileStore

@Inject
public ClusterFileStore(CoreContainer coreContainer,
 DistribFileStore fileStore,
 SolrQueryRequest req,
 SolrQueryResponse rsp)

Method Details

uploadFile

public UploadToFileStoreResponse uploadFile(String filePath,
 List<String> sig,
 InputStream requestBody)

Specified by:

uploadFile in interface ClusterFileStoreApis

getFile

public SolrJerseyResponse getFile(String path)

Specified by:

getFile in interface ClusterFileStoreApis

getMetadata

public FileStoreDirectoryListingResponse getMetadata(String path)

Specified by:

getMetadata in interface ClusterFileStoreApis

attachFileToResponse

public static void attachFileToResponse(String path,
 FileStore fileStore,
 SolrQueryRequest req,
 SolrQueryResponse rsp)

getMetadata

public static FileStoreDirectoryListingResponse getMetadata(FileStore.FileType type,
 String path,
 FileStore fileStore)

deleteFile

public SolrJerseyResponse deleteFile(String filePath,
 Boolean localDelete)

Specified by:

deleteFile in interface ClusterFileStoreApis

fetchFile

public SolrJerseyResponse fetchFile(String path,
 String getFrom)

Specified by:

fetchFile in interface ClusterFileStoreApis

syncFile

public SolrJerseyResponse syncFile(String path)

Specified by:

syncFile in interface ClusterFileStoreApis

syncToAllNodes

public static void syncToAllNodes(FileStore fileStore,
 String path)

pullFileFromNode

public static void pullFileFromNode(CoreContainer coreContainer,
 FileStore fileStore,
 String path,
 String getFrom)

_createJsonMetaData

public static FileStoreAPI.MetaData _createJsonMetaData(byte[] buf,
 List<String> signatures)
                                                 throws IOException

Creates a JSON string with the metadata.

Throws:

IOException

NOTE: This API is for internal purposes only and might change in incompatible ways in the next release.

validateName

public static void validateName(String path,
 boolean failForTrusted)