Class DoubleSumBufferAggregator
java.lang.Object
org.apache.druid.query.aggregation.SimpleDoubleBufferAggregator
org.apache.druid.query.aggregation.DoubleSumBufferAggregator
- All Implemented Interfaces:
BufferAggregator,HotLoopCallee
-
Method Summary
Modifier and TypeMethodDescriptionvoidaggregate(ByteBuffer buf, int position, double value) voidinit(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 byAggregatorFactory.getMaxIntermediateSizeWithNulls()in the correspondingAggregatorFactoryvoidputFirst(ByteBuffer buf, int position, double value) Faster equivalent to aggregator.init(buf, position); aggregator.aggregate(buf, position, value);Methods inherited from class org.apache.druid.query.aggregation.SimpleDoubleBufferAggregator
aggregate, close, get, getDouble, getFloat, getLong, getSelector, inspectRuntimeShapeMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface org.apache.druid.query.aggregation.BufferAggregator
isNull, relocate
-
Method Details
-
init
Description copied from interface:BufferAggregatorInitializes 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 byAggregatorFactory.getMaxIntermediateSizeWithNulls()in the correspondingAggregatorFactory- Parameters:
buf- byte buffer to initializeposition- offset within the byte buffer for initialization
-
putFirst
Description copied from class:SimpleDoubleBufferAggregatorFaster equivalent to aggregator.init(buf, position); aggregator.aggregate(buf, position, value);- Specified by:
putFirstin classSimpleDoubleBufferAggregator
-
aggregate
- Specified by:
aggregatein classSimpleDoubleBufferAggregator
-