io.druid.query.aggregation

Class LongSumBufferAggregator

java.lang.Object

io.druid.query.aggregation.LongBufferAggregator

io.druid.query.aggregation.LongSumBufferAggregator

All Implemented Interfaces:

BufferAggregator, HotLoopCallee

public class LongSumBufferAggregator
extends LongBufferAggregator

Field Summary

Fields inherited from class io.druid.query.aggregation.LongBufferAggregator

selector

Method Summary

Modifier and Type	Method and Description
void	aggregate(ByteBuffer buf, int position) Aggregates metric values into the given aggregate byte representation Implementations of this method must read in the aggregate value from the buffer at the given position, aggregate the next element of data and write the updated aggregate value back into the buffer.
void	init(ByteBuffer buf, int position) Initializes the buffer location Implementations of this method must initialize the byte buffer at the given position Implementations must not change the position, limit or mark of the given buffer This method must not exceed the number of bytes returned by AggregatorFactory.getMaxIntermediateSize() in the corresponding AggregatorFactory

Methods inherited from class io.druid.query.aggregation.LongBufferAggregator

close, get, getDouble, getFloat, getLong, inspectRuntimeShape

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.druid.query.aggregation.BufferAggregator

relocate

Method Detail

init

public void init(ByteBuffer buf,
                 int position)

Description copied from interface: BufferAggregator

Initializes the buffer location Implementations of this method must initialize the byte buffer at the given position Implementations must not change the position, limit or mark of the given buffer This method must not exceed the number of bytes returned by AggregatorFactory.getMaxIntermediateSize() in the corresponding AggregatorFactory

Parameters:

buf - byte buffer to initialize

position - offset within the byte buffer for initialization

aggregate

public void aggregate(ByteBuffer buf,
                      int position)

Description copied from interface: BufferAggregator

Aggregates metric values into the given aggregate byte representation Implementations of this method must read in the aggregate value from the buffer at the given position, aggregate the next element of data and write the updated aggregate value back into the buffer. Implementations must not change the position, limit or mark of the given buffer

Parameters:

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

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