io.druid.segment.incremental

Class OnheapIncrementalIndex

java.lang.Object

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

io.druid.segment.incremental.OnheapIncrementalIndex

All Implemented Interfaces:

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

public class OnheapIncrementalIndex
extends IncrementalIndex<Aggregator>

Nested Class Summary

Nested classes/interfaces inherited from class io.druid.segment.incremental.IncrementalIndex

IncrementalIndex.DimensionDesc, IncrementalIndex.MetricDesc

Field Summary

Fields

Modifier and Type	Field and Description
protected int	maxRowCount

Constructor Summary

Constructors

Constructor and Description
OnheapIncrementalIndex(IncrementalIndexSchema incrementalIndexSchema, boolean deserializeComplexMetrics, boolean reportParseExceptions, int maxRowCount)
OnheapIncrementalIndex(IncrementalIndexSchema incrementalIndexSchema, boolean reportParseExceptions, int maxRowCount)
OnheapIncrementalIndex(long minTimestamp, QueryGranularity gran, AggregatorFactory[] metrics, boolean deserializeComplexMetrics, boolean reportParseExceptions, int maxRowCount)
OnheapIncrementalIndex(long minTimestamp, QueryGranularity gran, AggregatorFactory[] metrics, int maxRowCount)

Method Summary

Modifier and Type	Method and Description
protected Integer	addToFacts(AggregatorFactory[] metrics, boolean deserializeComplexMetrics, boolean reportParseExceptions, 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() Clear out maps to allow GC NOTE: This is NOT thread-safe with add...
protected Aggregator[]	concurrentGet(int offset)
protected void	concurrentRemove(int offset)
protected void	concurrentSet(int offset, Aggregator[] value)
protected Aggregator[]	getAggsForRow(int rowOffset)
protected Object	getAggVal(Aggregator 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 Aggregator[]	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, Object lock)

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

add, dimsComparator, formatRow, getAggs, getCapabilities, getDimension, getDimensionNames, getDimensionOrder, getDimensions, getDimensionValues, getInterval, getMaxIngestedEventTime, getMaxTime, getMetadata, getMetricAggs, getMetricIndex, getMetricNames, getMetrics, getMetricType, getMinTime, getSubMap, isEmpty, iterableWithPostAggregations, iterator, loadDimensionIterable, makeColumnSelectorFactory, size

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Field Detail

maxRowCount

protected final int maxRowCount

Constructor Detail

OnheapIncrementalIndex

public OnheapIncrementalIndex(IncrementalIndexSchema incrementalIndexSchema,
                              boolean deserializeComplexMetrics,
                              boolean reportParseExceptions,
                              int maxRowCount)

OnheapIncrementalIndex

public OnheapIncrementalIndex(long minTimestamp,
                              QueryGranularity gran,
                              AggregatorFactory[] metrics,
                              boolean deserializeComplexMetrics,
                              boolean reportParseExceptions,
                              int maxRowCount)

OnheapIncrementalIndex

public OnheapIncrementalIndex(long minTimestamp,
                              QueryGranularity gran,
                              AggregatorFactory[] metrics,
                              int maxRowCount)

OnheapIncrementalIndex

public OnheapIncrementalIndex(IncrementalIndexSchema incrementalIndexSchema,
                              boolean reportParseExceptions,
                              int maxRowCount)

Method Detail

getFacts

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

Specified by:

getFacts in class IncrementalIndex<Aggregator>

makeDimDim

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

Specified by:

makeDimDim in class IncrementalIndex<Aggregator>

initAggs

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

Specified by:

initAggs in class IncrementalIndex<Aggregator>

addToFacts

protected Integer addToFacts(AggregatorFactory[] metrics,
                             boolean deserializeComplexMetrics,
                             boolean reportParseExceptions,
                             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<Aggregator>

Throws:

IndexSizeExceededException

concurrentGet

protected Aggregator[] concurrentGet(int offset)

concurrentSet

protected void concurrentSet(int offset,
                             Aggregator[] value)

concurrentRemove

protected void concurrentRemove(int offset)

canAppendRow

public boolean canAppendRow()

Specified by:

canAppendRow in class IncrementalIndex<Aggregator>

getOutOfRowsReason

public String getOutOfRowsReason()

Specified by:

getOutOfRowsReason in class IncrementalIndex<Aggregator>

getAggsForRow

protected Aggregator[] getAggsForRow(int rowOffset)

Specified by:

getAggsForRow in class IncrementalIndex<Aggregator>

getAggVal

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

Specified by:

getAggVal in class IncrementalIndex<Aggregator>

getMetricFloatValue

public float getMetricFloatValue(int rowOffset,
                                 int aggOffset)

Specified by:

getMetricFloatValue in class IncrementalIndex<Aggregator>

getMetricLongValue

public long getMetricLongValue(int rowOffset,
                               int aggOffset)

Specified by:

getMetricLongValue in class IncrementalIndex<Aggregator>

getMetricObjectValue

public Object getMetricObjectValue(int rowOffset,
                                   int aggOffset)

Specified by:

getMetricObjectValue in class IncrementalIndex<Aggregator>

close

public void close()

Clear out maps to allow GC NOTE: This is NOT thread-safe with add... so make sure all the adding is DONE before closing

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Overrides:

close in class IncrementalIndex<Aggregator>