org.apache.solr.client.solrj

Class SolrRequest<T extends SolrResponse>

java.lang.Object

org.apache.solr.client.solrj.SolrRequest<T>

All Implemented Interfaces:

Serializable

Direct Known Subclasses:

AbstractSchemaRequest, AbstractUpdateRequest, CollectionAdminRequest, ConfigSetAdminRequest, CoreAdminRequest, DelegationTokenRequest, DirectXmlRequest, DocumentAnalysisRequest, FieldAnalysisRequest, GenericSolrRequest, HealthCheckRequest, LukeRequest, QueryRequest, SolrPing, V2Request

public abstract class SolrRequest<T extends SolrResponse>
extends Object
implements Serializable

Since:

solr 1.3

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SolrRequest.METHOD

Field Summary

Fields

Modifier and Type	Field and Description
static Set<String>	SUPPORTED_METHODS
protected boolean	useBinaryV2
protected boolean	usev2

Constructor Summary

Constructors

Constructor and Description
SolrRequest(SolrRequest.METHOD m, String path)

Method Summary

Modifier and Type	Method and Description
void	addHeader(String key, String value)
protected abstract T	createResponse(SolrClient client) Create a new SolrResponse to hold the response from the server
String	getBasePath()
String	getBasicAuthPassword()
String	getBasicAuthUser()
String	getCollection()
Collection<ContentStream>	getContentStreams() Deprecated. Please use getContentWriter(String) instead.
RequestWriter.ContentWriter	getContentWriter(String expectedType) If a request object wants to do a push write, implement this method.
Map<String,String>	getHeaders()
SolrRequest.METHOD	getMethod()
abstract SolrParams	getParams()
String	getPath()
Set<String>	getQueryParams() Parameter keys that are sent via the query string
ResponseParser	getResponseParser()
StreamingResponseCallback	getStreamingResponseCallback()
Principal	getUserPrincipal()
T	process(SolrClient client) Send this request to a SolrClient and return the response
T	process(SolrClient client, String collection) Send this request to a SolrClient and return the response
void	setBasePath(String path)
SolrRequest	setBasicAuthCredentials(String user, String password)
void	setMethod(SolrRequest.METHOD method)
void	setPath(String path)
void	setQueryParams(Set<String> queryParams)
void	setResponseParser(ResponseParser responseParser) Optionally specify how the Response should be parsed.
void	setStreamingResponseCallback(StreamingResponseCallback callback)
SolrRequest	setUseBinaryV2(boolean flag) If set to true use javabin instead of json (default)
void	setUserPrincipal(Principal userPrincipal)
SolrRequest	setUseV2(boolean flag) If set to true, every request that implements V2RequestSupport will be converted to a V2 API call

Methods inherited from class java.lang.Object

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

Field Detail

SUPPORTED_METHODS

public static final Set<String> SUPPORTED_METHODS

usev2

protected boolean usev2

useBinaryV2

protected boolean useBinaryV2

Constructor Detail

SolrRequest

public SolrRequest(SolrRequest.METHOD m,
                   String path)

Method Detail

setUserPrincipal

public void setUserPrincipal(Principal userPrincipal)

getUserPrincipal

public Principal getUserPrincipal()

setUseV2

public SolrRequest setUseV2(boolean flag)

If set to true, every request that implements V2RequestSupport will be converted to a V2 API call

setUseBinaryV2

public SolrRequest setUseBinaryV2(boolean flag)

If set to true use javabin instead of json (default)

setBasicAuthCredentials

public SolrRequest setBasicAuthCredentials(String user,
                                           String password)

getBasicAuthUser

public String getBasicAuthUser()

getBasicAuthPassword

public String getBasicAuthPassword()

getMethod

public SolrRequest.METHOD getMethod()

setMethod

public void setMethod(SolrRequest.METHOD method)

getPath

public String getPath()

setPath

public void setPath(String path)

getResponseParser

public ResponseParser getResponseParser()

Returns:

The ResponseParser

setResponseParser

public void setResponseParser(ResponseParser responseParser)

Optionally specify how the Response should be parsed. Not all server implementations require a ResponseParser to be specified.

Parameters:

responseParser - The ResponseParser

getStreamingResponseCallback

public StreamingResponseCallback getStreamingResponseCallback()

setStreamingResponseCallback

public void setStreamingResponseCallback(StreamingResponseCallback callback)

getQueryParams

public Set<String> getQueryParams()

Parameter keys that are sent via the query string

setQueryParams

public void setQueryParams(Set<String> queryParams)

getParams

public abstract SolrParams getParams()

getContentStreams

@Deprecated
public Collection<ContentStream> getContentStreams()
                                                        throws IOException

Deprecated. Please use getContentWriter(String) instead.

Throws:

IOException

getContentWriter

public RequestWriter.ContentWriter getContentWriter(String expectedType)

If a request object wants to do a push write, implement this method.

Parameters:

expectedType - This is the type that the RequestWriter would like to get. But, it is OK to send any format

createResponse

protected abstract T createResponse(SolrClient client)

Create a new SolrResponse to hold the response from the server

Parameters:

client - the SolrClient the request will be sent to

process

public final T process(SolrClient client,
                       String collection)
                throws SolrServerException,
                       IOException

Send this request to a SolrClient and return the response

Parameters:

client - the SolrClient to communicate with

collection - the collection to execute the request against

Returns:

the response

Throws:

SolrServerException - if there is an error on the Solr server

IOException - if there is a communication error

process

public final T process(SolrClient client)
                throws SolrServerException,
                       IOException

Send this request to a SolrClient and return the response

Parameters:

client - the SolrClient to communicate with

Returns:

the response

Throws:

SolrServerException - if there is an error on the Solr server

IOException - if there is a communication error

getCollection

public String getCollection()

setBasePath

public void setBasePath(String path)

getBasePath

public String getBasePath()

addHeader

public void addHeader(String key,
                      String value)

getHeaders

public Map<String,String> getHeaders()