@SolrThreadSafe public class HttpSolrCall extends Object
Modifier and Type | Field and Description |
---|---|
protected SolrDispatchFilter.Action |
action |
protected List<String> |
collectionsList |
protected SolrConfig |
config |
protected SolrCore |
core |
protected CoreContainer |
cores |
protected String |
coreUrl |
protected SolrRequestHandler |
handler |
static String |
INTERNAL_REQUEST_COUNT |
protected Map<String,Integer> |
invalidStates |
protected String |
origCorename |
static String |
ORIGINAL_USER_PRINCIPAL_HEADER |
protected String |
path |
protected SolrParams |
queryParams |
static Random |
random |
protected javax.servlet.http.HttpServletRequest |
req |
protected AuthorizationContext.RequestType |
requestType |
protected javax.servlet.http.HttpServletResponse |
response |
protected boolean |
retry |
protected SolrDispatchFilter |
solrDispatchFilter |
protected SolrQueryRequest |
solrReq |
Constructor and Description |
---|
HttpSolrCall(SolrDispatchFilter solrDispatchFilter,
CoreContainer cores,
javax.servlet.http.HttpServletRequest request,
javax.servlet.http.HttpServletResponse response,
boolean retry) |
Modifier and Type | Method and Description |
---|---|
protected Object |
_getHandler() |
protected void |
addCollectionParamIfNeeded(List<String> collections)
Sets the "collection" parameter on the request to the list of alias-resolved collections for this request.
|
protected void |
autoCreateSystemColl(String corename) |
SolrDispatchFilter.Action |
call()
This method processes the request.
|
protected void |
execute(SolrQueryResponse rsp) |
protected void |
extractHandlerFromURLPath(SolrRequestParsers parser)
Extract handler from the URL path if not set.
|
protected void |
extractRemotePath(String collectionName,
String origCorename) |
protected Aliases |
getAliases() |
List<String> |
getCollectionsList()
The collection(s) referenced in this request.
|
List<CommandOperation> |
getCommands(boolean validateInput) |
SolrCore |
getCore() |
protected SolrCore |
getCoreByCollection(String collectionName,
boolean isPreferLeader) |
String |
getPath() |
SolrParams |
getQueryParams() |
protected String |
getRemoteCoreUrl(String collectionName,
String origCorename) |
javax.servlet.http.HttpServletRequest |
getReq() |
AuthorizationContext.RequestType |
getRequestType() |
protected QueryResponseWriter |
getResponseWriter()
Returns
QueryResponseWriter to be used. |
protected ValidatingJsonMap |
getSpec() |
protected Map<String,JsonSchemaValidator> |
getValidators() |
protected void |
handleAdmin(SolrQueryResponse solrResp) |
protected void |
init() |
protected List<String> |
resolveCollectionListOrAlias(String collectionStr)
Resolves the parameter as a potential comma delimited list of collections, and resolves aliases too.
|
protected void |
sendError(int code,
String message) |
protected void |
sendError(Throwable ex) |
public static final String ORIGINAL_USER_PRINCIPAL_HEADER
public static final String INTERNAL_REQUEST_COUNT
public static final Random random
protected final SolrDispatchFilter solrDispatchFilter
protected final CoreContainer cores
protected final javax.servlet.http.HttpServletRequest req
protected final javax.servlet.http.HttpServletResponse response
protected final boolean retry
protected SolrCore core
protected SolrQueryRequest solrReq
protected SolrRequestHandler handler
protected final SolrParams queryParams
protected String path
protected SolrDispatchFilter.Action action
protected String coreUrl
protected SolrConfig config
protected String origCorename
protected AuthorizationContext.RequestType requestType
public HttpSolrCall(SolrDispatchFilter solrDispatchFilter, CoreContainer cores, javax.servlet.http.HttpServletRequest request, javax.servlet.http.HttpServletResponse response, boolean retry)
public AuthorizationContext.RequestType getRequestType()
public String getPath()
public javax.servlet.http.HttpServletRequest getReq()
public SolrCore getCore()
public SolrParams getQueryParams()
protected Aliases getAliases()
public List<String> getCollectionsList()
init()
. Not null.protected void autoCreateSystemColl(String corename) throws Exception
Exception
protected List<String> resolveCollectionListOrAlias(String collectionStr)
getCollectionsList()
protected void extractHandlerFromURLPath(SolrRequestParsers parser) throws Exception
Exception
protected void extractRemotePath(String collectionName, String origCorename) throws UnsupportedEncodingException, org.apache.zookeeper.KeeperException, InterruptedException, SolrException
UnsupportedEncodingException
org.apache.zookeeper.KeeperException
InterruptedException
SolrException
public SolrDispatchFilter.Action call() throws IOException
IOException
protected void sendError(Throwable ex) throws IOException
IOException
protected void sendError(int code, String message) throws IOException
IOException
protected void execute(SolrQueryResponse rsp)
protected QueryResponseWriter getResponseWriter()
QueryResponseWriter
to be used.
When CommonParams.WT
not specified in the request or specified value doesn't have
corresponding QueryResponseWriter
then, returns the default query response writer
Note: This method must not return nullprotected void handleAdmin(SolrQueryResponse solrResp)
protected void addCollectionParamIfNeeded(List<String> collections)
HttpShardHandler
processes this param.getCollectionsList()
protected SolrCore getCoreByCollection(String collectionName, boolean isPreferLeader)
protected String getRemoteCoreUrl(String collectionName, String origCorename) throws SolrException
SolrException
protected Object _getHandler()
public List<CommandOperation> getCommands(boolean validateInput)
protected ValidatingJsonMap getSpec()
protected Map<String,JsonSchemaValidator> getValidators()
Copyright © 2000-2021 Apache Software Foundation. All Rights Reserved.