pub struct DistributedAggregationCollector { /* private fields */ }
Expand description
Collector for distributed aggregations.
The collector collects all aggregations by the underlying aggregation request.
Purpose
AggregationCollector returns IntermediateAggregationResults
and not the final
AggregationResults
, so that results from differenct indices can be merged and then converted
into the final AggregationResults
via the into()
method.
Implementations
sourceimpl DistributedAggregationCollector
impl DistributedAggregationCollector
sourcepub fn from_aggs(agg: Aggregations) -> Self
pub fn from_aggs(agg: Aggregations) -> Self
Create collector from aggregation request.
Trait Implementations
sourceimpl Collector for DistributedAggregationCollector
impl Collector for DistributedAggregationCollector
type Fruit = IntermediateAggregationResults
type Fruit = IntermediateAggregationResults
Fruit
is the type for the result of our collection.
e.g. usize
for the Count
collector. Read more
type Child = AggregationSegmentCollector
type Child = AggregationSegmentCollector
Type of the SegmentCollector
associated to this collector.
sourcefn for_segment(
&self,
_segment_local_id: SegmentOrdinal,
reader: &SegmentReader
) -> Result<Self::Child>
fn for_segment(
&self,
_segment_local_id: SegmentOrdinal,
reader: &SegmentReader
) -> Result<Self::Child>
set_segment
is called before beginning to enumerate
on this segment. Read more
sourcefn requires_scoring(&self) -> bool
fn requires_scoring(&self) -> bool
Returns true iff the collector requires to compute scores for documents.
sourcefn merge_fruits(
&self,
segment_fruits: Vec<<Self::Child as SegmentCollector>::Fruit>
) -> Result<Self::Fruit>
fn merge_fruits(
&self,
segment_fruits: Vec<<Self::Child as SegmentCollector>::Fruit>
) -> Result<Self::Fruit>
Combines the fruit associated to the collection of each segments into one fruit. Read more
sourcefn collect_segment(
&self,
weight: &dyn Weight,
segment_ord: u32,
reader: &SegmentReader
) -> Result<<Self::Child as SegmentCollector>::Fruit>
fn collect_segment(
&self,
weight: &dyn Weight,
segment_ord: u32,
reader: &SegmentReader
) -> Result<<Self::Child as SegmentCollector>::Fruit>
Created a segment collector and
Auto Trait Implementations
impl RefUnwindSafe for DistributedAggregationCollector
impl Send for DistributedAggregationCollector
impl Sync for DistributedAggregationCollector
impl Unpin for DistributedAggregationCollector
impl UnwindSafe for DistributedAggregationCollector
Blanket Implementations
sourceimpl<T> BorrowMut<T> for T where
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
sourceimpl<T> Downcast for T where
T: Any,
impl<T> Downcast for T where
T: Any,
sourcefn into_any(self: Box<T, Global>) -> Box<dyn Any + 'static, Global>
fn into_any(self: Box<T, Global>) -> Box<dyn Any + 'static, Global>
Convert Box<dyn Trait>
(where Trait: Downcast
) to Box<dyn Any>
. Box<dyn Any>
can
then be further downcast
into Box<ConcreteType>
where ConcreteType
implements Trait
. Read more
sourcefn into_any_rc(self: Rc<T>) -> Rc<dyn Any + 'static>
fn into_any_rc(self: Rc<T>) -> Rc<dyn Any + 'static>
Convert Rc<Trait>
(where Trait: Downcast
) to Rc<Any>
. Rc<Any>
can then be
further downcast
into Rc<ConcreteType>
where ConcreteType
implements Trait
. Read more
sourcefn as_any(&self) -> &(dyn Any + 'static)
fn as_any(&self) -> &(dyn Any + 'static)
Convert &Trait
(where Trait: Downcast
) to &Any
. This is needed since Rust cannot
generate &Any
’s vtable from &Trait
’s. Read more
sourcefn as_any_mut(&mut self) -> &mut (dyn Any + 'static)
fn as_any_mut(&mut self) -> &mut (dyn Any + 'static)
Convert &mut Trait
(where Trait: Downcast
) to &Any
. This is needed since Rust cannot
generate &mut Any
’s vtable from &mut Trait
’s. Read more