Class ResultSetFutureCall<V>
- java.lang.Object
-
- zipkin2.Call<V>
-
- zipkin2.Call.Base<V>
-
- zipkin2.storage.cassandra.internal.call.ResultSetFutureCall<V>
-
- All Implemented Interfaces:
java.lang.Cloneable
,Call.Mapper<com.datastax.driver.core.ResultSet,V>
public abstract class ResultSetFutureCall<V> extends Call.Base<V> implements Call.Mapper<com.datastax.driver.core.ResultSet,V>
Future call pattern that takes advantage of special 'get' hooks onResultSetFuture
.
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class zipkin2.Call
Call.Base<V extends java.lang.Object>, Call.ErrorHandler<V extends java.lang.Object>, Call.FlatMapper<V1 extends java.lang.Object,V2 extends java.lang.Object>, Call.Mapper<V1 extends java.lang.Object,V2 extends java.lang.Object>
-
-
Constructor Summary
Constructors Constructor Description ResultSetFutureCall()
-
Method Summary
All Methods Static Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description protected void
doCancel()
protected void
doEnqueue(Callback<V> callback)
protected V
doExecute()
protected boolean
doIsCanceled()
static boolean
isOverCapacity(java.lang.Throwable e)
protected abstract com.google.common.util.concurrent.ListenableFuture<com.datastax.driver.core.ResultSet>
newFuture()
Defers I/O untilCall.Base.enqueue(Callback)
orCall.Base.execute()
are called.-
Methods inherited from class zipkin2.Call.Base
cancel, enqueue, execute, isCanceled
-
Methods inherited from class zipkin2.Call
clone, create, emptyList, flatMap, handleError, map, propagateIfFatal
-
Methods inherited from class java.lang.Object
equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface zipkin2.Call.Mapper
map
-
-
-
-
Method Detail
-
newFuture
protected abstract com.google.common.util.concurrent.ListenableFuture<com.datastax.driver.core.ResultSet> newFuture()
Defers I/O untilCall.Base.enqueue(Callback)
orCall.Base.execute()
are called.
-
doIsCanceled
protected final boolean doIsCanceled()
- Overrides:
doIsCanceled
in classCall.Base<V>
-
isOverCapacity
public static boolean isOverCapacity(java.lang.Throwable e)
-
-