io.druid.segment.incremental

Class OffheapIncrementalIndex

java.lang.Object

io.druid.segment.incremental.IncrementalIndex<BufferAggregator>

io.druid.segment.incremental.OffheapIncrementalIndex

All Implemented Interfaces:

Closeable, AutoCloseable, Iterable<io.druid.data.input.Row>

public class OffheapIncrementalIndex
extends IncrementalIndex<BufferAggregator>

Field Summary

Fields inherited from class io.druid.segment.incremental.IncrementalIndex

dimensions

Constructor Summary

Constructors

Constructor and Description
OffheapIncrementalIndex(IncrementalIndexSchema incrementalIndexSchema, StupidPool<ByteBuffer> bufferPool, boolean deserializeComplexMetrics, int maxTotalBufferSize)
OffheapIncrementalIndex(long minTimestamp, QueryGranularity gran, AggregatorFactory[] metrics, StupidPool<ByteBuffer> bufferPool, boolean deserializeComplexMetrics, int maxTotalBufferSize)

Method Summary

Methods

Modifier and Type	Method and Description
protected Integer	addToFacts(AggregatorFactory[] metrics, boolean deserializeComplexMetrics, io.druid.data.input.InputRow row, AtomicInteger numEntries, io.druid.segment.incremental.IncrementalIndex.TimeAndDims key, ThreadLocal<io.druid.data.input.InputRow> rowContainer, com.google.common.base.Supplier<io.druid.data.input.InputRow> rowSupplier)
boolean	canAppendRow()
void	close()
protected BufferAggregator[]	getAggsForRow(int rowOffset)
protected Object	getAggVal(BufferAggregator agg, int rowOffset, int aggPosition)
ConcurrentNavigableMap<io.druid.segment.incremental.IncrementalIndex.TimeAndDims,Integer>	getFacts()
float	getMetricFloatValue(int rowOffset, int aggOffset)
long	getMetricLongValue(int rowOffset, int aggOffset)
Object	getMetricObjectValue(int rowOffset, int aggOffset)
String	getOutOfRowsReason()
protected BufferAggregator[]	initAggs(AggregatorFactory[] metrics, com.google.common.base.Supplier<io.druid.data.input.InputRow> rowSupplier, boolean deserializeComplexMetrics)
protected io.druid.segment.incremental.IncrementalIndex.DimDim	makeDimDim(String dimension)

Methods inherited from class io.druid.segment.incremental.IncrementalIndex

add, formatRow, getAggs, getCapabilities, getDimension, getDimensionIndex, getDimensions, getDimValues, getInterval, getMaxIngestedEventTime, getMaxTime, getMetricAggs, getMetricIndex, getMetricNames, getMetricType, getMinTime, getSubMap, isEmpty, iterableWithPostAggregations, iterator, makeColumnSelectorFactory, size, updateMaxIngestedTime

Methods inherited from class java.lang.Object

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

Constructor Detail

OffheapIncrementalIndex

public OffheapIncrementalIndex(IncrementalIndexSchema incrementalIndexSchema,
                       StupidPool<ByteBuffer> bufferPool,
                       boolean deserializeComplexMetrics,
                       int maxTotalBufferSize)

OffheapIncrementalIndex

public OffheapIncrementalIndex(long minTimestamp,
                       QueryGranularity gran,
                       AggregatorFactory[] metrics,
                       StupidPool<ByteBuffer> bufferPool,
                       boolean deserializeComplexMetrics,
                       int maxTotalBufferSize)

Method Detail

getFacts

public ConcurrentNavigableMap<io.druid.segment.incremental.IncrementalIndex.TimeAndDims,Integer> getFacts()

Specified by:

getFacts in class IncrementalIndex<BufferAggregator>

makeDimDim

protected io.druid.segment.incremental.IncrementalIndex.DimDim makeDimDim(String dimension)

Specified by:

makeDimDim in class IncrementalIndex<BufferAggregator>

initAggs

protected BufferAggregator[] initAggs(AggregatorFactory[] metrics,
                          com.google.common.base.Supplier<io.druid.data.input.InputRow> rowSupplier,
                          boolean deserializeComplexMetrics)

Specified by:

initAggs in class IncrementalIndex<BufferAggregator>

addToFacts

protected Integer addToFacts(AggregatorFactory[] metrics,
                 boolean deserializeComplexMetrics,
                 io.druid.data.input.InputRow row,
                 AtomicInteger numEntries,
                 io.druid.segment.incremental.IncrementalIndex.TimeAndDims key,
                 ThreadLocal<io.druid.data.input.InputRow> rowContainer,
                 com.google.common.base.Supplier<io.druid.data.input.InputRow> rowSupplier)
                      throws IndexSizeExceededException

Specified by:

addToFacts in class IncrementalIndex<BufferAggregator>

Throws:

IndexSizeExceededException

canAppendRow

public boolean canAppendRow()

Specified by:

canAppendRow in class IncrementalIndex<BufferAggregator>

getOutOfRowsReason

public String getOutOfRowsReason()

Specified by:

getOutOfRowsReason in class IncrementalIndex<BufferAggregator>

getAggsForRow

protected BufferAggregator[] getAggsForRow(int rowOffset)

Specified by:

getAggsForRow in class IncrementalIndex<BufferAggregator>

getAggVal

protected Object getAggVal(BufferAggregator agg,
               int rowOffset,
               int aggPosition)

Specified by:

getAggVal in class IncrementalIndex<BufferAggregator>

getMetricFloatValue

public float getMetricFloatValue(int rowOffset,
                        int aggOffset)

Specified by:

getMetricFloatValue in class IncrementalIndex<BufferAggregator>

getMetricLongValue

public long getMetricLongValue(int rowOffset,
                      int aggOffset)

Specified by:

getMetricLongValue in class IncrementalIndex<BufferAggregator>

getMetricObjectValue

public Object getMetricObjectValue(int rowOffset,
                          int aggOffset)

Specified by:

getMetricObjectValue in class IncrementalIndex<BufferAggregator>

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Overrides:

close in class IncrementalIndex<BufferAggregator>