Package org.apache.druid.query.aggregation

Class ObjectColumnFloatBufferAggregatorWrapper

java.lang.Object

org.apache.druid.query.aggregation.DelegatingBufferAggregator

org.apache.druid.query.aggregation.ObjectColumnFloatBufferAggregatorWrapper

All Implemented Interfaces:

BufferAggregator, HotLoopCallee

public class ObjectColumnFloatBufferAggregatorWrapper
extends DelegatingBufferAggregator

This class can be used to wrap Float BufferAggregator that consume float type columns to handle Object type.

Field Summary

Fields inherited from class org.apache.druid.query.aggregation.DelegatingBufferAggregator

delegate

Constructor Summary

Constructors

Constructor	Description
ObjectColumnFloatBufferAggregatorWrapper(BaseObjectColumnValueSelector selector, Function<BaseFloatColumnValueSelector,BufferAggregator> delegateBuilder, float nullValue)

Method Summary

Modifier and Type	Method	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.

Methods inherited from class org.apache.druid.query.aggregation.DelegatingBufferAggregator

close, get, getDouble, getFloat, getLong, init, inspectRuntimeShape, isNull, relocate

Methods inherited from class java.lang.Object

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

Constructor Details

ObjectColumnFloatBufferAggregatorWrapper

public ObjectColumnFloatBufferAggregatorWrapper(BaseObjectColumnValueSelector selector,
 Function<BaseFloatColumnValueSelector,BufferAggregator> delegateBuilder,
 float nullValue)

Method Details

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

Specified by:

aggregate in interface BufferAggregator

Overrides:

aggregate in class DelegatingBufferAggregator

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