org.apache.druid.sql

Class HttpStatement

java.lang.Object

org.apache.druid.sql.AbstractStatement

org.apache.druid.sql.DirectStatement

org.apache.druid.sql.HttpStatement

All Implemented Interfaces:

Closeable, AutoCloseable, SqlLifecycleManager.Cancelable

public class HttpStatement
extends DirectStatement

SQL statement lifecycle for the HTTP endpoint. The request thread creates the object and calls DirectStatement.execute(). The response thread reads results and inspects the statement contents to emit logs and metrics. The object is transferred between threads, with no overlapping access.

The key extension of an HTTP statement is the use of the HTTP request for authorization.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.druid.sql.DirectStatement

DirectStatement.ResultSet

Field Summary

Fields inherited from class org.apache.druid.sql.DirectStatement

prepareResult, resultSet

Fields inherited from class org.apache.druid.sql.AbstractStatement

cancellationResourceActions, fullResourceActions, plannerContext, queryPlus, reporter, sqlToolbox

Constructor Summary

Constructors

Constructor and Description
HttpStatement(SqlToolbox lifecycleToolbox, SqlQuery sqlQuery, javax.servlet.http.HttpServletRequest req)

Method Summary

Modifier and Type	Method and Description
protected Function<Set<ResourceAction>,Access>	authorizer() Resource authorizer based on the authentication result provided earlier.

Methods inherited from class org.apache.druid.sql.DirectStatement

cancel, close, closeWithError, createPlan, createResultSet, execute, plan, prepareResult

Methods inherited from class org.apache.druid.sql.AbstractStatement

allResources, authorize, closeQuietly, query, reporter, resources, sqlQueryId, validate

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.druid.sql.SqlLifecycleManager.Cancelable

resources

Constructor Detail

HttpStatement

public HttpStatement(SqlToolbox lifecycleToolbox,
                     SqlQuery sqlQuery,
                     javax.servlet.http.HttpServletRequest req)

Method Detail

authorizer

protected Function<Set<ResourceAction>,Access> authorizer()

Description copied from class: AbstractStatement

Resource authorizer based on the authentication result provided earlier.

Overrides:

authorizer in class AbstractStatement