public class TimestampAggregator extends Object implements Aggregator
Constructor and Description |
---|
TimestampAggregator(String name,
BaseObjectColumnValueSelector selector,
TimestampSpec timestampSpec,
Comparator<Long> comparator,
Long initValue) |
Modifier and Type | Method and Description |
---|---|
void |
aggregate() |
Aggregator |
clone() |
void |
close() |
Object |
get() |
double |
getDouble()
The default implementation casts
Aggregator.getFloat() to double. |
float |
getFloat() |
long |
getLong() |
public TimestampAggregator(String name, BaseObjectColumnValueSelector selector, TimestampSpec timestampSpec, Comparator<Long> comparator, Long initValue)
public void aggregate()
aggregate
in interface Aggregator
public Object get()
get
in interface Aggregator
public float getFloat()
getFloat
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 long getLong()
getLong
in interface Aggregator
public void close()
close
in interface Aggregator
close
in interface Closeable
close
in interface AutoCloseable
public Aggregator clone()
Copyright © 2011–2018. All rights reserved.