public interface ReductionFunction extends AnalyticsValue
AnalyticsValue.AbstractAnalyticsValueAnalyticsValueStream.AbstractAnalyticsValueStream, 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, getObjectconvertToConstant, createExpressionString, determineMappingPhase, getExpressionStr, getExpressionType, getName, streamObjectsvoid synchronizeDataCollectors(UnaryOperator<ReductionDataCollector<?>> sync)
sync - a function that takes in a ReductionDataCollector and returns a shared versionCopyright © 2000-2020 Apache Software Foundation. All Rights Reserved.