io.druid.server

Class AsyncQueryForwardingServlet

java.lang.Object

javax.servlet.GenericServlet

javax.servlet.http.HttpServlet

org.eclipse.jetty.proxy.AbstractProxyServlet

org.eclipse.jetty.proxy.ProxyServlet

org.eclipse.jetty.proxy.AsyncProxyServlet

io.druid.server.AsyncQueryForwardingServlet

All Implemented Interfaces:

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

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

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

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

org.eclipse.jetty.proxy.AbstractProxyServlet.TransparentDelegate

Field Summary

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

_log, CLIENT_REQUEST_ATTRIBUTE, HOP_HEADERS

Constructor Summary

Constructors

Constructor and Description

AsyncQueryForwardingServlet(QueryToolChestWarehouse warehouse, 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

Modifier and Type	Method and Description
protected org.eclipse.jetty.client.HttpClient	createHttpClient()
void	destroy()
long	getFailedQueryCount()
long	getInterruptedQueryCount()
long	getSuccessfulQueryCount()
void	init()
protected static URI	makeURI(String host, String requestURI, String rawQueryString)
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 String	rewriteTarget(javax.servlet.http.HttpServletRequest request)
protected URI	rewriteURI(javax.servlet.http.HttpServletRequest request, String host)
protected void	sendProxyRequest(javax.servlet.http.HttpServletRequest clientRequest, javax.servlet.http.HttpServletResponse proxyResponse, org.eclipse.jetty.client.api.Request proxyRequest)
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

onContinue

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

addProxyHeaders, addViaHeader, addXForwardedHeaders, copyRequestHeaders, createLogger, expects100Continue, filterServerResponseHeader, findConnectionHeaders, getBlackListHosts, getHostHeader, getHttpClient, getRequestId, getTimeout, getViaHost, getWhiteListHosts, hasContent, onClientRequestFailure, onProxyResponseFailure, onProxyResponseSuccess, onProxyRewriteFailed, onServerResponseHeaders, sendProxyResponseError, setTimeout, validateDestination

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

@Inject
public AsyncQueryForwardingServlet(QueryToolChestWarehouse warehouse,
                                           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

init

public void init()
          throws javax.servlet.ServletException

Overrides:

init in class org.eclipse.jetty.proxy.AbstractProxyServlet

Throws:

javax.servlet.ServletException

destroy

public void destroy()

Specified by:

destroy in interface javax.servlet.Servlet

Overrides:

destroy in class org.eclipse.jetty.proxy.AbstractProxyServlet

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

sendProxyRequest

protected void sendProxyRequest(javax.servlet.http.HttpServletRequest clientRequest,
                                javax.servlet.http.HttpServletResponse proxyResponse,
                                org.eclipse.jetty.client.api.Request proxyRequest)

Overrides:

sendProxyRequest in class org.eclipse.jetty.proxy.AbstractProxyServlet

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

rewriteTarget

protected String rewriteTarget(javax.servlet.http.HttpServletRequest request)

Overrides:

rewriteTarget in class org.eclipse.jetty.proxy.AbstractProxyServlet

rewriteURI

protected URI rewriteURI(javax.servlet.http.HttpServletRequest request,
                         String host)

makeURI

protected static URI makeURI(String host,
                             String requestURI,
                             String rawQueryString)

newHttpClient

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

Overrides:

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

createHttpClient

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

Overrides:

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

Throws:

javax.servlet.ServletException

getSuccessfulQueryCount

public long getSuccessfulQueryCount()

Specified by:

getSuccessfulQueryCount in interface QueryCountStatsProvider

getFailedQueryCount

public long getFailedQueryCount()

Specified by:

getFailedQueryCount in interface QueryCountStatsProvider

getInterruptedQueryCount

public long getInterruptedQueryCount()

Specified by:

getInterruptedQueryCount in interface QueryCountStatsProvider