THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block |
---|
@Evolving public class QueryResult<R> { // wraps a successful result public static <R> QueryResult<R> forResult(R result); // wraps a failure result public static <R> QueryResult<R> forFailure(FailureReason failureReason, String failureMessage); // returns a failed query result because the store didn't know how to handle the query. public static <R> QueryResult<R> forUnknownQueryType(Query<R> query, StateStore store); // returns a failed query result because the partition wasn't caught up to the desired bound. public static <R> QueryResult<R> notUpToBound(Position currentPosition, Position bound); // Used by state stores that need to delegate to another store to run a query and then // translate the results. Does not change the execution info or any other metadata. public <NewR> QueryResult<NewR> swapResult(NewR newTypedResult); // If requested, stores should record // helpful information, such as their own class, how they executed the query, // and the time they took. public void addExecutionInfo(String executionInfo); // records the point in the store's history that executed the query. public void setPosition(Position position); public boolean isSuccess(); public boolean isFailure(); public List<String> getExecutionInfo(); public Position getPosition(); public FailureReason getFailureReason(); public String getFailuregetFailureMessage(); public getResult(); } |
FailureReason
An enum classifying failures for individual partitions' failures
...