Module org.elasticsearch.xcore
Class StoredAsyncResponse<R extends Writeable>
java.lang.Object
org.elasticsearch.transport.TransportMessage
org.elasticsearch.transport.TransportResponse
org.elasticsearch.action.ActionResponse
org.elasticsearch.xpack.core.async.StoredAsyncResponse<R>
- All Implemented Interfaces:
Writeable,org.elasticsearch.core.RefCounted,org.elasticsearch.xcontent.ToXContent,org.elasticsearch.xcontent.ToXContentObject,AsyncResponse<StoredAsyncResponse<R>>
public class StoredAsyncResponse<R extends Writeable>
extends ActionResponse
implements AsyncResponse<StoredAsyncResponse<R>>, org.elasticsearch.xcontent.ToXContentObject
Internal class for temporary storage of eql search results
-
Nested Class Summary
Nested classes/interfaces inherited from class org.elasticsearch.action.ActionResponse
ActionResponse.EmptyNested classes/interfaces inherited from interface org.elasticsearch.xcontent.ToXContent
org.elasticsearch.xcontent.ToXContent.DelegatingMapParams, org.elasticsearch.xcontent.ToXContent.MapParams, org.elasticsearch.xcontent.ToXContent.ParamsNested classes/interfaces inherited from interface org.elasticsearch.common.io.stream.Writeable
Writeable.Reader<V>, Writeable.Writer<V> -
Field Summary
Fields inherited from interface org.elasticsearch.core.RefCounted
ALWAYS_REFERENCEDFields inherited from interface org.elasticsearch.xcontent.ToXContent
EMPTY, EMPTY_PARAMS -
Constructor Summary
ConstructorsConstructorDescriptionStoredAsyncResponse(Exception exception, long expirationTimeMillis) StoredAsyncResponse(Writeable.Reader<R> reader, StreamInput input) StoredAsyncResponse(R response, long expirationTimeMillis) -
Method Summary
Modifier and TypeMethodDescriptionbooleanlongWhen this response will expire as a timestamp in milliseconds since epoch.inthashCode()org.elasticsearch.xcontent.XContentBuildertoXContent(org.elasticsearch.xcontent.XContentBuilder builder, org.elasticsearch.xcontent.ToXContent.Params params) withExpirationTime(long expirationTime) Returns a copy of this object with a new expiration timevoidwriteTo(StreamOutput out) Methods inherited from class org.elasticsearch.transport.TransportMessage
decRef, hasReferences, incRef, tryIncRefMethods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface org.elasticsearch.xpack.core.async.AsyncResponse
convertToFailureMethods inherited from interface org.elasticsearch.core.RefCounted
decRef, hasReferences, incRef, mustIncRef, tryIncRefMethods inherited from interface org.elasticsearch.xcontent.ToXContentObject
isFragment
-
Constructor Details
-
StoredAsyncResponse
-
StoredAsyncResponse
-
StoredAsyncResponse
- Throws:
IOException
-
-
Method Details
-
getExpirationTime
public long getExpirationTime()Description copied from interface:AsyncResponseWhen this response will expire as a timestamp in milliseconds since epoch.- Specified by:
getExpirationTimein interfaceAsyncResponse<R extends Writeable>
-
withExpirationTime
Description copied from interface:AsyncResponseReturns a copy of this object with a new expiration time- Specified by:
withExpirationTimein interfaceAsyncResponse<R extends Writeable>
-
writeTo
- Specified by:
writeToin interfaceWriteable- Throws:
IOException
-
getResponse
-
getException
-
equals
-
hashCode
public int hashCode() -
toXContent
public org.elasticsearch.xcontent.XContentBuilder toXContent(org.elasticsearch.xcontent.XContentBuilder builder, org.elasticsearch.xcontent.ToXContent.Params params) throws IOException - Specified by:
toXContentin interfaceorg.elasticsearch.xcontent.ToXContent- Throws:
IOException
-