public class LongLastAggregator extends Object implements Aggregator
Modifier and Type | Field and Description |
---|---|
protected long |
lastTime |
protected long |
lastValue |
Constructor and Description |
---|
LongLastAggregator(BaseLongColumnValueSelector timeSelector,
BaseLongColumnValueSelector 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() |
public LongLastAggregator(BaseLongColumnValueSelector timeSelector, BaseLongColumnValueSelector valueSelector)
public void aggregate()
aggregate
in interface Aggregator
public double getDouble()
Aggregator
Aggregator.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 Aggregator
public Object get()
get
in interface Aggregator
public float getFloat()
getFloat
in interface Aggregator
public long getLong()
getLong
in interface Aggregator
public void close()
close
in interface Aggregator
close
in interface Closeable
close
in interface AutoCloseable
Copyright © 2011–2018. All rights reserved.