Package org.apache.druid.java.util.common.guava
package org.apache.druid.java.util.common.guava
-
ClassDescriptionAccumulator<AccumulatedType,
InType> BaseSequence<T,IterType extends Iterator<T>> BaseSequence.IteratorMaker<T,IterType extends Iterator<T>> DelegatingYieldingAccumulator<OutType,T> Wraps an underlying sequence and allows us to force it to explode at various points.FilteringAccumulator<OutType,T> FilteringYieldingAccumulator<OutType,T> LazySequence<T>MappedSequence<T,Out> MappingAccumulator<OutType,InType, MappedType> MappingYieldingAccumulator<OutType,InType, MappedType> Iterator that merges a collection of sorted iterators using a comparator.Used to perform an n-way merge on n ordered sequencesArtisanal, locally-sourced, hand-crafted, gluten and GMO free, bespoke, free-range, organic, small-batch parallel merge combining sequence.ListenableFuturethat allowsParallelMergeCombiningSequenceto be registered withQueryWatcher.registerQueryFuture(org.apache.druid.query.Query<?>, com.google.common.util.concurrent.ListenableFuture<?>)to participate in query cancellation or anything else that has a need to watch the activity on the merge pool.Token used to stop internal parallel processing across all tasks in the merge pool.Metrics for the execution of aParallelMergeCombiningSequenceon theForkJoinPoolSequence<T>A Sequence represents an iterable sequence of elements.Simple Sequence based on an Iterable, created usingSequences.simple(java.lang.Iterable<T>).A Sequence that skips the first few elements.TopNSequence<T>Simultaneously sorts and limits its input.Yielder<T>A Yielder is an object that tries to act like the yield() command/continuations in other languages.YieldingAccumulator<AccumulatedType,InType> A YieldingAccumulator is used along with a Yielder in order to replicate continuations in Java.A Sequence that is based entirely on the Yielder implementation.