public class FloatLastAggregator extends Object implements Aggregator
| Modifier and Type | Field and Description |
|---|---|
protected long |
lastTime |
protected float |
lastValue |
| Constructor and Description |
|---|
FloatLastAggregator(BaseLongColumnValueSelector timeSelector,
BaseFloatColumnValueSelector valueSelector) |
| Modifier and Type | Method and Description |
|---|---|
void |
aggregate() |
void |
close() |
Object |
get() |
double |
getDouble()
The default implementation casts
Aggregator.getFloat() to double. |
float |
getFloat() |
long |
getLong() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitisNullpublic FloatLastAggregator(BaseLongColumnValueSelector timeSelector, BaseFloatColumnValueSelector valueSelector)
public void aggregate()
aggregate in interface Aggregatorpublic Object get()
get in interface Aggregatorpublic float getFloat()
getFloat in interface Aggregatorpublic long getLong()
getLong in interface Aggregatorpublic double getDouble()
AggregatorAggregator.getFloat() to double.
This default method is added to enable smooth backward compatibility, please re-implement it if your aggregators
work with numeric double columns.getDouble in interface Aggregatorpublic void close()
close in interface Closeableclose in interface AutoCloseableclose in interface AggregatorCopyright © 2011–2019 The Apache Software Foundation. All rights reserved.