Package org.apache.storm.daemon.drpc
Class OutstandingRequest
- java.lang.Object
-
- org.apache.storm.daemon.drpc.OutstandingRequest
-
- Direct Known Subclasses:
BlockingOutstandingRequest
public abstract class OutstandingRequest extends Object
-
-
Constructor Summary
Constructors Constructor Description OutstandingRequest(String function, DRPCRequest req)
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description abstract void
fail(DRPCExecutionException e)
void
fetched()
String
getFunction()
DRPCRequest
getRequest()
boolean
isTimedOut(long timeoutMs)
abstract void
returnResult(String result)
boolean
wasFetched()
-
-
-
Constructor Detail
-
OutstandingRequest
public OutstandingRequest(String function, DRPCRequest req)
-
-
Method Detail
-
getRequest
public DRPCRequest getRequest()
-
fetched
public void fetched()
-
wasFetched
public boolean wasFetched()
-
getFunction
public String getFunction()
-
isTimedOut
public boolean isTimedOut(long timeoutMs)
-
returnResult
public abstract void returnResult(String result)
-
fail
public abstract void fail(DRPCExecutionException e)
-
-