Package zipkin2.storage.cassandra.internal.call

Class IntersectMaps<K,V>

java.lang.Object

zipkin2.Call<V>

zipkin2.Call.Base<O>

zipkin2.internal.AggregateCall<java.util.Map<K,V>,java.util.Map<K,V>>

zipkin2.storage.cassandra.internal.call.IntersectMaps<K,V>

All Implemented Interfaces:

java.lang.Cloneable

public final class IntersectMaps<K,V>
extends zipkin2.internal.AggregateCall<java.util.Map<K,V>,java.util.Map<K,V>>

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
IntersectMaps(java.util.List<Call<java.util.Map<K,V>>> calls)

Method Summary

Modifier and Type	Method	Description
protected void	append(java.util.Map<K,V> input, java.util.Map<K,V> output)
IntersectMaps<K,V>	clone()
protected boolean	isEmpty(java.util.Map<K,V> output)
protected java.util.Map<K,V>	newOutput()

Methods inherited from class zipkin2.internal.AggregateCall

cloneCalls, doCancel, doEnqueue, doExecute, finish, newVoidCall, toString

Methods inherited from class zipkin2.Call.Base

cancel, doIsCanceled, enqueue, execute, isCanceled

Methods inherited from class zipkin2.Call

create, emptyList, flatMap, handleError, map, propagateIfFatal

Methods inherited from class java.lang.Object

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

Constructor Detail

IntersectMaps

public IntersectMaps(java.util.List<Call<java.util.Map<K,V>>> calls)

Method Detail

newOutput

protected java.util.Map<K,V> newOutput()

Specified by:

newOutput in class zipkin2.internal.AggregateCall<java.util.Map<K,V>,java.util.Map<K,V>>

append

protected void append(java.util.Map<K,V> input,
                      java.util.Map<K,V> output)

Specified by:

append in class zipkin2.internal.AggregateCall<java.util.Map<K,V>,java.util.Map<K,V>>

isEmpty

protected boolean isEmpty(java.util.Map<K,V> output)

Specified by:

isEmpty in class zipkin2.internal.AggregateCall<java.util.Map<K,V>,java.util.Map<K,V>>

clone

public IntersectMaps<K,V> clone()

Specified by:

clone in class Call.Base<java.util.Map<K,V>>