public class OnheapIncrementalIndex extends IncrementalIndex<Aggregator>
IncrementalIndex.DimensionDesc, IncrementalIndex.MetricDesc
Modifier and Type | Field and Description |
---|---|
protected int |
maxRowCount |
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) |
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) |
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
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
forEach, spliterator
public OnheapIncrementalIndex(IncrementalIndexSchema incrementalIndexSchema, boolean deserializeComplexMetrics, boolean reportParseExceptions, int maxRowCount)
public OnheapIncrementalIndex(long minTimestamp, QueryGranularity gran, AggregatorFactory[] metrics, boolean deserializeComplexMetrics, boolean reportParseExceptions, int maxRowCount)
public OnheapIncrementalIndex(long minTimestamp, QueryGranularity gran, AggregatorFactory[] metrics, int maxRowCount)
public OnheapIncrementalIndex(IncrementalIndexSchema incrementalIndexSchema, boolean reportParseExceptions, int maxRowCount)
public ConcurrentNavigableMap<io.druid.segment.incremental.IncrementalIndex.TimeAndDims,Integer> getFacts()
getFacts
in class IncrementalIndex<Aggregator>
protected io.druid.segment.incremental.IncrementalIndex.DimDim makeDimDim(String dimension, Object lock)
makeDimDim
in class IncrementalIndex<Aggregator>
protected Aggregator[] initAggs(AggregatorFactory[] metrics, com.google.common.base.Supplier<io.druid.data.input.InputRow> rowSupplier, boolean deserializeComplexMetrics)
initAggs
in class IncrementalIndex<Aggregator>
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
addToFacts
in class IncrementalIndex<Aggregator>
IndexSizeExceededException
protected Aggregator[] concurrentGet(int offset)
protected void concurrentSet(int offset, Aggregator[] value)
protected void concurrentRemove(int offset)
public boolean canAppendRow()
canAppendRow
in class IncrementalIndex<Aggregator>
public String getOutOfRowsReason()
getOutOfRowsReason
in class IncrementalIndex<Aggregator>
protected Aggregator[] getAggsForRow(int rowOffset)
getAggsForRow
in class IncrementalIndex<Aggregator>
protected Object getAggVal(Aggregator agg, int rowOffset, int aggPosition)
getAggVal
in class IncrementalIndex<Aggregator>
public float getMetricFloatValue(int rowOffset, int aggOffset)
getMetricFloatValue
in class IncrementalIndex<Aggregator>
public long getMetricLongValue(int rowOffset, int aggOffset)
getMetricLongValue
in class IncrementalIndex<Aggregator>
public Object getMetricObjectValue(int rowOffset, int aggOffset)
getMetricObjectValue
in class IncrementalIndex<Aggregator>
public void close()
close
in interface Closeable
close
in interface AutoCloseable
close
in class IncrementalIndex<Aggregator>
Copyright © 2011–2016. All rights reserved.