summer

Type Members

1. class ApproxHHTracker extends AnyRef

   

2. class AsyncListMMapSum[Key, Value] extends AsyncSummer[(Key, Value), Map[Key, Value]] with WithFlushConditions[(Key, Value), Map[Key, Value]]

   

3. class AsyncListSum[Key, Value] extends AsyncSummer[(Key, Value), Map[Key, Value]] with WithFlushConditions[(Key, Value), Map[Key, Value]]

   

4. class AsyncMapSum[Key, Value] extends AsyncSummer[(Key, Value), Map[Key, Value]] with WithFlushConditions[(Key, Value), Map[Key, Value]]

   

5. trait AsyncSummer[T, +M <: Iterable[T]] extends AnyRef

   

6. trait AsyncSummerProxy[T, +M <: Iterable[T]] extends AsyncSummer[T, M]

   

7. case class BufferSize(v: Int) extends Product with Serializable

   

8. final case class Compact(flag: Boolean) extends AnyVal with Product with Serializable

   

9. final case class CompactionSize(toInt: Int) extends AnyVal with Product with Serializable

   

10. class CustomSummingQueue[V] extends StatefulSummer[V]

    

11. case class FlushFrequency(v: Duration) extends Product with Serializable

    

12. class HeavyHittersCachingSummer[K, V] extends AsyncSummer[(K, V), Iterable[(K, V)]] with WithFlushConditions[(K, V), Iterable[(K, V)]]

    

13. case class HeavyHittersPercent(toFloat: Float) extends Product with Serializable

    

14. trait Incrementor extends AnyRef

    

15. case class MemoryFlushPercent(v: Float) extends Product with Serializable

    

16. class NullSummer[Key, Value] extends AsyncSummer[(Key, Value), Map[Key, Value]]

    

17. case class RollOverFrequency(toLong: Long) extends Product with Serializable

    

18. case class SyncSummingQueue[Key, Value](bufferSize: BufferSize, flushFrequency: FlushFrequency, softMemoryFlush: MemoryFlushPercent, memoryIncr: Incrementor, timeoutIncr: Incrementor, sizeIncr: Incrementor, insertOps: Incrementor, tuplesIn: Incrementor, tuplesOut: Incrementor)(implicit semigroup: Semigroup[Value]) extends AsyncSummer[(Key, Value), Map[Key, Value]] with WithFlushConditions[(Key, Value), Map[Key, Value]] with Product with Serializable

    

19. case class UpdateFrequency(toInt: Int) extends Product with Serializable

    

20. trait WithFlushConditions[T, M <: Iterable[T]] extends AsyncSummer[T, M]