public final class MinAggregator<I,R extends Comparable> extends AbstractAggregator<I,R,R> implements IdentifiedDataSerializable
attributePath
Constructor and Description |
---|
MinAggregator() |
MinAggregator(String attributePath) |
Modifier and Type | Method and Description |
---|---|
void |
accumulateExtracted(I entry,
R value)
Accumulates a single extracted value.
|
R |
aggregate()
Returns the result of the aggregation.
|
void |
combine(Aggregator aggregator)
Incorporates the intermediary result of the given aggregator to this instance of the aggregator.
|
int |
getFactoryId()
Returns DataSerializableFactory factory ID for this class.
|
int |
getId()
Returns type identifier for this class.
|
void |
readData(ObjectDataInput in)
Reads fields from the input stream
|
void |
writeData(ObjectDataOutput out)
Writes object fields to output stream
|
accumulate
onAccumulationFinished, onCombinationFinished
public MinAggregator()
public MinAggregator(String attributePath)
public void accumulateExtracted(I entry, R value)
AbstractAggregator
accumulateExtracted
in class AbstractAggregator<I,R extends Comparable,R extends Comparable>
entry
- The entry containing the value.value
- If attributePath is not null the methods accumulates the value extracted from the attributePath.
If attributePath is null and the input object is a Map.Entry the method accumulates Map.Entry.getValue().public void combine(Aggregator aggregator)
Aggregator
combine
in class Aggregator<I,R extends Comparable>
aggregator
- aggregator providing intermediary results to be combined into the results of this aggregator.
The given aggregator has to be of the same class as the one that the method is being called on.public R aggregate()
Aggregator
aggregate
in class Aggregator<I,R extends Comparable>
public int getFactoryId()
IdentifiedDataSerializable
getFactoryId
in interface IdentifiedDataSerializable
public int getId()
IdentifiedDataSerializable
getId
in interface IdentifiedDataSerializable
public void writeData(ObjectDataOutput out) throws IOException
DataSerializable
writeData
in interface DataSerializable
out
- outputIOException
- if an I/O error occurs. In particular,
an IOException
may be thrown if the
output stream has been closed.public void readData(ObjectDataInput in) throws IOException
DataSerializable
readData
in interface DataSerializable
in
- inputIOException
- if an I/O error occurs. In particular,
an IOException
may be thrown if the
input stream has been closed.Copyright © 2022 Hazelcast, Inc.. All Rights Reserved.