io.druid.server

Class QueryResource

java.lang.Object

io.druid.server.QueryResource

All Implemented Interfaces:

QueryCountStatsProvider

Direct Known Subclasses:

BrokerQueryResource

public class QueryResource
extends Object
implements QueryCountStatsProvider

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	QueryResource.ResponseContext

Field Summary

Fields

Modifier and Type	Field and Description
protected static String	APPLICATION_SMILE Deprecated.
protected AuthConfig	authConfig
protected ServerConfig	config
protected com.metamx.emitter.service.ServiceEmitter	emitter
static String	HDR_ETAG
static String	HDR_IF_NONE_MATCH
protected com.fasterxml.jackson.databind.ObjectMapper	jsonMapper
protected static com.metamx.emitter.EmittingLogger	log
protected QueryManager	queryManager
protected RequestLogger	requestLogger
protected static int	RESPONSE_CTX_HEADER_LEN_LIMIT
protected com.fasterxml.jackson.databind.ObjectMapper	smileMapper
protected QuerySegmentWalker	texasRanger
protected QueryToolChestWarehouse	warehouse

Constructor Summary

Constructors

Constructor and Description
QueryResource(QueryToolChestWarehouse warehouse, ServerConfig config, com.fasterxml.jackson.databind.ObjectMapper jsonMapper, com.fasterxml.jackson.databind.ObjectMapper smileMapper, QuerySegmentWalker texasRanger, com.metamx.emitter.service.ServiceEmitter emitter, RequestLogger requestLogger, QueryManager queryManager, AuthConfig authConfig)

Method Summary

Modifier and Type	Method and Description
protected QueryResource.ResponseContext	createContext(String requestType, boolean pretty)
javax.ws.rs.core.Response	doPost(InputStream in, String pretty, javax.servlet.http.HttpServletRequest req)
long	getFailedQueryCount()
long	getInterruptedQueryCount()
javax.ws.rs.core.Response	getServer(String queryId, javax.servlet.http.HttpServletRequest req)
long	getSuccessfulQueryCount()

Methods inherited from class java.lang.Object

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

Field Detail

log

protected static final com.metamx.emitter.EmittingLogger log

APPLICATION_SMILE

@Deprecated
protected static final String APPLICATION_SMILE

Deprecated.

See Also:

Constant Field Values

RESPONSE_CTX_HEADER_LEN_LIMIT

protected static final int RESPONSE_CTX_HEADER_LEN_LIMIT

See Also:

Constant Field Values

HDR_IF_NONE_MATCH

public static final String HDR_IF_NONE_MATCH

See Also:

Constant Field Values

HDR_ETAG

public static final String HDR_ETAG

See Also:

Constant Field Values

warehouse

protected final QueryToolChestWarehouse warehouse

config

protected final ServerConfig config

jsonMapper

protected final com.fasterxml.jackson.databind.ObjectMapper jsonMapper

smileMapper

protected final com.fasterxml.jackson.databind.ObjectMapper smileMapper

texasRanger

protected final QuerySegmentWalker texasRanger

emitter

protected final com.metamx.emitter.service.ServiceEmitter emitter

requestLogger

protected final RequestLogger requestLogger

queryManager

protected final QueryManager queryManager

authConfig

protected final AuthConfig authConfig

Constructor Detail

QueryResource

@Inject
public QueryResource(QueryToolChestWarehouse warehouse,
                             ServerConfig config,
                             com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
                             com.fasterxml.jackson.databind.ObjectMapper smileMapper,
                             QuerySegmentWalker texasRanger,
                             com.metamx.emitter.service.ServiceEmitter emitter,
                             RequestLogger requestLogger,
                             QueryManager queryManager,
                             AuthConfig authConfig)

Method Detail

getServer

public javax.ws.rs.core.Response getServer(String queryId,
                                           @Context
                                           javax.servlet.http.HttpServletRequest req)

doPost

public javax.ws.rs.core.Response doPost(InputStream in,
                                        String pretty,
                                        @Context
                                        javax.servlet.http.HttpServletRequest req)
                                 throws IOException

Throws:

IOException

createContext

protected QueryResource.ResponseContext createContext(String requestType,
                                                      boolean pretty)

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