io.druid.server

Class AsyncQueryForwardingServlet

java.lang.Object

javax.servlet.GenericServlet

javax.servlet.http.HttpServlet

org.eclipse.jetty.proxy.ProxyServlet

org.eclipse.jetty.proxy.AsyncProxyServlet

io.druid.server.AsyncQueryForwardingServlet

All Implemented Interfaces:

Serializable, javax.servlet.Servlet, javax.servlet.ServletConfig

public class AsyncQueryForwardingServlet
extends org.eclipse.jetty.proxy.AsyncProxyServlet

This class does async query processing and should be merged with QueryResource at some point

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.eclipse.jetty.proxy.AsyncProxyServlet

org.eclipse.jetty.proxy.AsyncProxyServlet.StreamReader, org.eclipse.jetty.proxy.AsyncProxyServlet.StreamWriter, org.eclipse.jetty.proxy.AsyncProxyServlet.Transparent

Nested classes/interfaces inherited from class org.eclipse.jetty.proxy.ProxyServlet

org.eclipse.jetty.proxy.ProxyServlet.ProxyInputStreamContentProvider, org.eclipse.jetty.proxy.ProxyServlet.ProxyResponseListener, org.eclipse.jetty.proxy.ProxyServlet.TransparentDelegate

Field Summary

Fields inherited from class org.eclipse.jetty.proxy.ProxyServlet

_log

Constructor Summary

Constructors

Constructor and Description
AsyncQueryForwardingServlet(com.fasterxml.jackson.databind.ObjectMapper jsonMapper, com.fasterxml.jackson.databind.ObjectMapper smileMapper, QueryHostFinder hostFinder, com.google.inject.Provider<org.eclipse.jetty.client.HttpClient> httpClientProvider, DruidHttpClientConfig httpClientConfig, com.metamx.emitter.service.ServiceEmitter emitter, RequestLogger requestLogger)

Method Summary

Methods

Modifier and Type	Method and Description
protected org.eclipse.jetty.client.HttpClient	createHttpClient()
protected void	customizeProxyRequest(org.eclipse.jetty.client.api.Request proxyRequest, javax.servlet.http.HttpServletRequest request)
protected org.eclipse.jetty.client.HttpClient	newHttpClient()
protected org.eclipse.jetty.client.api.Response.Listener	newProxyResponseListener(javax.servlet.http.HttpServletRequest request, javax.servlet.http.HttpServletResponse response)
protected URI	rewriteURI(javax.servlet.http.HttpServletRequest request)
protected void	service(javax.servlet.http.HttpServletRequest request, javax.servlet.http.HttpServletResponse response)

Methods inherited from class org.eclipse.jetty.proxy.AsyncProxyServlet

newReadListener, newWriteListener, onResponseContent, proxyRequestContent

Methods inherited from class org.eclipse.jetty.proxy.ProxyServlet

addViaHeader, addXForwardedHeaders, createLogger, destroy, filterResponseHeader, getBlackListHosts, getHttpClient, getRequestId, getTimeout, getViaHost, getWhiteListHosts, init, onClientRequestFailure, onResponseFailure, onResponseHeaders, onResponseSuccess, onRewriteFailed, setTimeout, validateDestination, viaHost

Methods inherited from class javax.servlet.http.HttpServlet

doDelete, doGet, doHead, doOptions, doPost, doPut, doTrace, getLastModified, service

Methods inherited from class javax.servlet.GenericServlet

getInitParameter, getInitParameterNames, getServletConfig, getServletContext, getServletInfo, getServletName, init, log, log

Methods inherited from class java.lang.Object

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

Constructor Detail

AsyncQueryForwardingServlet

public AsyncQueryForwardingServlet(com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
                           com.fasterxml.jackson.databind.ObjectMapper smileMapper,
                           QueryHostFinder hostFinder,
                           com.google.inject.Provider<org.eclipse.jetty.client.HttpClient> httpClientProvider,
                           DruidHttpClientConfig httpClientConfig,
                           com.metamx.emitter.service.ServiceEmitter emitter,
                           RequestLogger requestLogger)

Method Detail

service

protected void service(javax.servlet.http.HttpServletRequest request,
           javax.servlet.http.HttpServletResponse response)
                throws javax.servlet.ServletException,
                       IOException

Overrides:

service in class org.eclipse.jetty.proxy.ProxyServlet

Throws:

javax.servlet.ServletException

IOException

customizeProxyRequest

protected void customizeProxyRequest(org.eclipse.jetty.client.api.Request proxyRequest,
                         javax.servlet.http.HttpServletRequest request)

Overrides:

customizeProxyRequest in class org.eclipse.jetty.proxy.ProxyServlet

newProxyResponseListener

protected org.eclipse.jetty.client.api.Response.Listener newProxyResponseListener(javax.servlet.http.HttpServletRequest request,
                                                                      javax.servlet.http.HttpServletResponse response)

Overrides:

newProxyResponseListener in class org.eclipse.jetty.proxy.ProxyServlet

rewriteURI

protected URI rewriteURI(javax.servlet.http.HttpServletRequest request)

Overrides:

rewriteURI in class org.eclipse.jetty.proxy.ProxyServlet

newHttpClient

protected org.eclipse.jetty.client.HttpClient newHttpClient()

Overrides:

newHttpClient in class org.eclipse.jetty.proxy.ProxyServlet

createHttpClient

protected org.eclipse.jetty.client.HttpClient createHttpClient()
                                                        throws javax.servlet.ServletException

Overrides:

createHttpClient in class org.eclipse.jetty.proxy.ProxyServlet

Throws:

javax.servlet.ServletException