public interface ReductionFunction extends AnalyticsValue
AnalyticsValue.AbstractAnalyticsValue
AnalyticsValueStream.ExpressionType
Modifier and Type | Method and Description |
---|---|
void |
synchronizeDataCollectors(UnaryOperator<ReductionDataCollector<?>> sync)
Syncs the data collectors with shared versions across the entire Analytics Request
so that as little data as possible is sent across shards.
|
exists, getObject
createExpressionString, determineMappingPhase, getExpressionStr, getExpressionType, getName, streamObjects
void synchronizeDataCollectors(UnaryOperator<ReductionDataCollector<?>> sync)
sync
- a function that takes in a ReductionDataCollector
and returns a shared versionCopyright © 2000-2017 Apache Software Foundation. All Rights Reserved.