Package zipkin2.storage.cassandra.internal.call

Class IntersectKeySets

java.lang.Object

zipkin2.Call<V>

zipkin2.Call.Base<O>

zipkin2.internal.AggregateCall<java.util.Map<java.lang.String,java.lang.Long>,java.util.Set<java.lang.String>>

zipkin2.storage.cassandra.internal.call.IntersectKeySets

All Implemented Interfaces:

java.lang.Cloneable

public final class IntersectKeySets
extends zipkin2.internal.AggregateCall<java.util.Map<java.lang.String,java.lang.Long>,java.util.Set<java.lang.String>>

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
IntersectKeySets(java.util.List<Call<java.util.Map<java.lang.String,java.lang.Long>>> calls)

Method Summary

Modifier and Type	Method	Description
protected void	append(java.util.Map<java.lang.String,java.lang.Long> input, java.util.Set<java.lang.String> output)
IntersectKeySets	clone()
protected boolean	isEmpty(java.util.Set<java.lang.String> output)
protected java.util.Set<java.lang.String>	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

IntersectKeySets

public IntersectKeySets(java.util.List<Call<java.util.Map<java.lang.String,java.lang.Long>>> calls)

Method Detail

newOutput

protected java.util.Set<java.lang.String> newOutput()

Specified by:

newOutput in class zipkin2.internal.AggregateCall<java.util.Map<java.lang.String,java.lang.Long>,java.util.Set<java.lang.String>>

append

protected void append(java.util.Map<java.lang.String,java.lang.Long> input,
                      java.util.Set<java.lang.String> output)

Specified by:

append in class zipkin2.internal.AggregateCall<java.util.Map<java.lang.String,java.lang.Long>,java.util.Set<java.lang.String>>

isEmpty

protected boolean isEmpty(java.util.Set<java.lang.String> output)

Specified by:

isEmpty in class zipkin2.internal.AggregateCall<java.util.Map<java.lang.String,java.lang.Long>,java.util.Set<java.lang.String>>

clone

public IntersectKeySets clone()

Specified by:

clone in class Call.Base<java.util.Set<java.lang.String>>