Package zipkin2.storage.cassandra.internal.call

Class AccumulateAllResults<T>

java.lang.Object

zipkin2.storage.cassandra.internal.call.AccumulateAllResults<T>

All Implemented Interfaces:

Call.FlatMapper<com.datastax.driver.core.ResultSet,T>

Direct Known Subclasses:

AccumulateTraceIdTsUuid, DistinctSortedStrings

public abstract class AccumulateAllResults<T>
extends java.lang.Object
implements Call.FlatMapper<com.datastax.driver.core.ResultSet,T>

Constructor Summary

Constructors

Constructor	Description
AccumulateAllResults()

Method Summary

Modifier and Type	Method	Description
protected abstract java.util.function.BiConsumer<com.datastax.driver.core.Row,T>	accumulator()
protected java.util.function.Function<T,T>	finisher()	Customizes the aggregated result.
Call<T>	map(com.datastax.driver.core.ResultSet rs)
protected abstract java.util.function.Supplier<T>	supplier()

Methods inherited from class java.lang.Object

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

Constructor Detail

AccumulateAllResults

public AccumulateAllResults()

Method Detail

supplier

protected abstract java.util.function.Supplier<T> supplier()

accumulator

protected abstract java.util.function.BiConsumer<com.datastax.driver.core.Row,T> accumulator()

finisher

protected java.util.function.Function<T,T> finisher()

Customizes the aggregated result. For example, summarizing or making immutable.

map

public Call<T> map(com.datastax.driver.core.ResultSet rs)

Specified by:

map in interface Call.FlatMapper<com.datastax.driver.core.ResultSet,T>