Module org.elasticsearch.compute

Package org.elasticsearch.compute.operator.exchange

Class BatchExchangeStatusResponse

java.lang.Object

org.elasticsearch.transport.TransportMessage

org.elasticsearch.transport.TransportResponse

org.elasticsearch.compute.operator.exchange.BatchExchangeStatusResponse

All Implemented Interfaces:

Writeable, org.elasticsearch.core.RefCounted

public final class BatchExchangeStatusResponse
extends TransportResponse

Response sent from server to client indicating batch exchange completion status. A null failure means success; a non-null failure means the server encountered an error.

Nested Class Summary

Nested 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_REFERENCED

Constructor Summary

Constructors

Constructor	Description
BatchExchangeStatusResponse()	Create a success response.
BatchExchangeStatusResponse(Exception failure)	Create a failure response.
BatchExchangeStatusResponse(StreamInput in)

Method Summary

Modifier and Type	Method	Description
Exception	getFailure()
boolean	isSuccess()
void	writeTo(StreamOutput out)

Methods inherited from class org.elasticsearch.transport.TransportMessage

decRef, hasReferences, incRef, tryIncRef

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.elasticsearch.core.RefCounted

mustIncRef

Constructor Details

BatchExchangeStatusResponse

public BatchExchangeStatusResponse()

Create a success response.

BatchExchangeStatusResponse

public BatchExchangeStatusResponse(Exception failure)

Create a failure response.

BatchExchangeStatusResponse

public BatchExchangeStatusResponse(StreamInput in)
                            throws IOException

Throws:

IOException

Method Details

writeTo

public void writeTo(StreamOutput out)
             throws IOException

Throws:

IOException

isSuccess

public boolean isSuccess()

getFailure

public Exception getFailure()