Class EsqlResponseListener
java.lang.Object
org.elasticsearch.rest.action.RestActionListener<EsqlQueryResponse>
org.elasticsearch.rest.action.RestChunkedToXContentListener<EsqlQueryResponse>
org.elasticsearch.rest.action.RestRefCountedChunkedToXContentListener<EsqlQueryResponse>
org.elasticsearch.xpack.esql.action.EsqlResponseListener
- All Implemented Interfaces:
ActionListener<EsqlQueryResponse>
public final class EsqlResponseListener
extends RestRefCountedChunkedToXContentListener<EsqlQueryResponse>
Listens for a single
EsqlQueryResponse, builds a corresponding RestResponse and sends it.-
Constructor Summary
ConstructorsConstructorDescriptionEsqlResponseListener(RestChannel channel, RestRequest getRequest) Async query GET API does not have an EsqlQueryRequest.EsqlResponseListener(RestChannel channel, RestRequest restRequest, EsqlQueryRequest esqlRequest) To correctly time the execution of a request, aEsqlResponseListenermust be constructed immediately before execution begins. -
Method Summary
Modifier and TypeMethodDescriptionprotected voidprocessResponse(EsqlQueryResponse esqlQueryResponse) Log internal server errors all the time and log queries if debug is enabled.Methods inherited from class org.elasticsearch.rest.action.RestRefCountedChunkedToXContentListener
releasableFromResponseMethods inherited from class org.elasticsearch.rest.action.RestChunkedToXContentListener
getRestStatusMethods inherited from class org.elasticsearch.rest.action.RestActionListener
ensureOpen, onFailure, onResponseMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface org.elasticsearch.action.ActionListener
delegateFailure, delegateFailureAndWrap, delegateFailureIgnoreResponseAndWrap, delegateResponse, map, safeMap
-
Constructor Details
-
EsqlResponseListener
public EsqlResponseListener(RestChannel channel, RestRequest restRequest, EsqlQueryRequest esqlRequest) To correctly time the execution of a request, aEsqlResponseListenermust be constructed immediately before execution begins. -
EsqlResponseListener
Async query GET API does not have an EsqlQueryRequest.
-
-
Method Details
-
processResponse
- Overrides:
processResponsein classRestChunkedToXContentListener<EsqlQueryResponse>- Throws:
IOException
-
wrapWithLogging
Log internal server errors all the time and log queries if debug is enabled.
-