com.yahoo.bullet.rest.query

Class HTTPQueryHandler

java.lang.Object

com.yahoo.bullet.rest.query.QueryHandler

com.yahoo.bullet.rest.query.HTTPQueryHandler

public class HTTPQueryHandler
extends QueryHandler

Query handler that implements results for HTTP - one result per query. In other words, a single send(PubSubMessage) or fail(QueryError) call is supported. Use getResult() to get a CompletableFuture that resolves to the single result or error.

Field Summary

Fields inherited from class com.yahoo.bullet.rest.query.QueryHandler

complete

Constructor Summary

Constructors

Constructor and Description
HTTPQueryHandler()

Method Summary

Modifier and Type	Method and Description
void	fail(QueryError cause) Fail the query.
CompletableFuture<String>	getResult() Get the single eventual result sent to this handler.
void	send(com.yahoo.bullet.pubsub.PubSubMessage message) Send a PubSubMessage to the query handler.

Methods inherited from class com.yahoo.bullet.rest.query.QueryHandler

acknowledge, complete, fail

Methods inherited from class java.lang.Object

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

Constructor Detail

HTTPQueryHandler

public HTTPQueryHandler()

Method Detail

send

public void send(com.yahoo.bullet.pubsub.PubSubMessage message)

Description copied from class: QueryHandler

Send a PubSubMessage to the query handler.

Specified by:

send in class QueryHandler

Parameters:

message - The PubSubMessage containing a response.

fail

public void fail(QueryError cause)

Description copied from class: QueryHandler

Fail the query.

Specified by:

fail in class QueryHandler

Parameters:

cause - is the QueryError that caused the fail to be invoked.

getResult

public CompletableFuture<String> getResult()

Get the single eventual result sent to this handler.

Returns:

The CompletableFuture of the single result that will eventually (but not guaranteed) to be added.