T - The type of data being processed.public abstract class MinCollector<T extends ReductionData> extends ReductionDataCollector<T>
Supported types are:
| Modifier and Type | Class and Description |
|---|---|
static class |
MinCollector.DoubleMinCollector |
static class |
MinCollector.FloatMinCollector |
static class |
MinCollector.IntMinCollector |
static class |
MinCollector.LongMinCollector |
static class |
MinCollector.StringMinCollector |
| Modifier and Type | Field and Description |
|---|---|
static String |
name |
collectionTargets, ioData, lastingTargets| Modifier | Constructor and Description |
|---|---|
protected |
MinCollector(AnalyticsValueStream param) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
exists()
Returns true if any of the values being reduce exist, and false if none of them do.
|
String |
getExpressionStr()
The unique expression string of the reduction data collector, given all inputs and parameters.
|
String |
getName()
Get the name of the reduction data collector.
|
void |
setData(ReductionData data)
Finalize the reduction with the collected data stored in the parameter.
|
void |
setMergedData(ReductionData data)
Finalize the reduction with the merged data stored in the parameter.
|
addCollectTarget, addLastingCollectTarget, apply, clearLastingCollectTargets, collect, collectAndApply, dataIO, newData, newDataIO, newDataTarget, submitReservationspublic static final String name
protected MinCollector(AnalyticsValueStream param)
public boolean exists()
public void setMergedData(ReductionData data)
ReductionDataCollectorReductionFunctions that use this
data collector act like regular AnalyticsValue classes that
can be accessed through their get<value-type> methods.
(FOR CLOUD)setMergedData in class ReductionDataCollector<T extends ReductionData>data - the merged data to compute a reduction forpublic void setData(ReductionData data)
ReductionDataCollectorReductionFunctions that use this
data collector act like regular AnalyticsValue classes that
can be accessed through their get<value-type> methods.
(FOR SINGLE-SHARD)setData in class ReductionDataCollector<T extends ReductionData>data - the collected data to compute a reduction forpublic String getName()
ReductionDataCollectorgetName in class ReductionDataCollector<T extends ReductionData>public String getExpressionStr()
ReductionDataCollectorReductionDataCollector syncing. Since the string should be unique,
only one of expression is kept.getExpressionStr in class ReductionDataCollector<T extends ReductionData>Copyright © 2000-2017 Apache Software Foundation. All Rights Reserved.