Package org.apache.druid.query.aggregation.firstlast.last

Class LongLastBufferAggregator

java.lang.Object

org.apache.druid.query.aggregation.firstlast.last.NumericLastBufferAggregator

org.apache.druid.query.aggregation.firstlast.last.LongLastBufferAggregator

All Implemented Interfaces:

BufferAggregator, HotLoopCallee

public class LongLastBufferAggregator
extends NumericLastBufferAggregator

Constructor Summary

Constructors

Constructor	Description
LongLastBufferAggregator(BaseLongColumnValueSelector timeSelector, ColumnValueSelector valueSelector, boolean needsFoldCheck)

Method Summary

Modifier and Type	Method	Description
Object	get(ByteBuffer buf, int position)	Returns the intermediate object representation of the given aggregate.
double	getDouble(ByteBuffer buf, int position)	Returns the double representation of the given aggregate byte array Converts the given byte buffer representation into the intermediate aggregate value.
float	getFloat(ByteBuffer buf, int position)	Returns the float representation of the given aggregate byte array Converts the given byte buffer representation into the intermediate aggregate value.
long	getLong(ByteBuffer buf, int position)	Returns the long representation of the given aggregate byte array Converts the given byte buffer representation into the intermediate aggregate value.

Methods inherited from class org.apache.druid.query.aggregation.firstlast.last.NumericLastBufferAggregator

aggregate, close, init, inspectRuntimeShape

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.druid.query.aggregation.BufferAggregator

isNull, relocate

Constructor Details

LongLastBufferAggregator

public LongLastBufferAggregator(BaseLongColumnValueSelector timeSelector,
 ColumnValueSelector valueSelector,
 boolean needsFoldCheck)

Method Details

get

public Object get(ByteBuffer buf,
 int position)

Description copied from interface: BufferAggregator

Returns the intermediate object representation of the given aggregate. Converts the given byte buffer representation into an intermediate aggregate Object Implementations must not change the position, limit or mark of the given buffer. The object returned must not have any references to the given buffer (i.e., make a copy), since the underlying buffer is a shared resource and may be given to another processing thread while the objects returned by this aggregator are still in use. If the corresponding AggregatorFactory.combine(Object, Object) method for this aggregator expects its inputs to be mutable, then the object returned by this method must be mutable.

Parameters:

buf - byte buffer storing the byte array representation of the aggregate

position - offset within the byte buffer at which the aggregate value is stored

Returns:

the Object representation of the aggregate

getFloat

public float getFloat(ByteBuffer buf,
 int position)

Description copied from interface: BufferAggregator

Returns the float representation of the given aggregate byte array Converts the given byte buffer representation into the intermediate aggregate value. Implementations must not change the position, limit or mark of the given buffer Implementations are only required to support this method if they are aggregations which have an AggregatorFactory.getIntermediateType() ()} of ValueType.FLOAT. If unimplemented, throwing an UnsupportedOperationException is common and recommended.

Parameters:

buf - byte buffer storing the byte array representation of the aggregate

position - offset within the byte buffer at which the aggregate value is stored

Returns:

the float representation of the aggregate

getDouble

public double getDouble(ByteBuffer buf,
 int position)

Description copied from interface: BufferAggregator

Returns the double representation of the given aggregate byte array Converts the given byte buffer representation into the intermediate aggregate value. Implementations must not change the position, limit or mark of the given buffer Implementations are only required to support this method if they are aggregations which have an AggregatorFactory.getIntermediateType() of of ValueType.DOUBLE. If unimplemented, throwing an UnsupportedOperationException is common and recommended. The default implementation casts BufferAggregator.getFloat(ByteBuffer, int) to double. This default method is added to enable smooth backward compatibility, please re-implement it if your aggregators work with numeric double columns.

Parameters:

buf - byte buffer storing the byte array representation of the aggregate

position - offset within the byte buffer at which the aggregate value is stored

Returns:

the double representation of the aggregate

getLong

public long getLong(ByteBuffer buf,
 int position)

Description copied from interface: BufferAggregator

Returns the long representation of the given aggregate byte array Converts the given byte buffer representation into the intermediate aggregate value. Implementations must not change the position, limit or mark of the given buffer Implementations are only required to support this method if they are aggregations which have an AggregatorFactory.getIntermediateType() of of ValueType.LONG. If unimplemented, throwing an UnsupportedOperationException is common and recommended.

Parameters:

buf - byte buffer storing the byte array representation of the aggregate

position - offset within the byte buffer at which the aggregate value is stored

Returns:

the long representation of the aggregate