Package org.apache.druid.segment.incremental

Class OnheapIncrementalIndex

java.lang.Object

org.apache.druid.segment.incremental.IncrementalIndex

org.apache.druid.segment.incremental.OnheapIncrementalIndex

All Implemented Interfaces:

Closeable, AutoCloseable, Iterable<Row>, Expr.InputBindingInspector, ColumnInspector, IncrementalIndexRowSelector

public class OnheapIncrementalIndex
extends IncrementalIndex

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	OnheapIncrementalIndex.Builder
static class	OnheapIncrementalIndex.Spec

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

IncrementalIndex.AddToFactsResult, IncrementalIndex.DimensionDesc, IncrementalIndex.InputRowHolder, IncrementalIndex.MetricDesc

Field Summary

Fields

Modifier and Type	Field	Description
protected final long	maxBytesInMemory
protected final int	maxRowCount

Fields inherited from class org.apache.druid.segment.incremental.IncrementalIndex

inputRowHolder, preserveExistingMetrics, timePosition

Method Summary

Modifier and Type	Method	Description
protected IncrementalIndex.AddToFactsResult	addToFacts(IncrementalIndexRow key, IncrementalIndex.InputRowHolder inputRowHolder)
boolean	canAppendRow()
void	close()	Clear out maps to allow GC NOTE: This is NOT thread-safe with add...
FactsHolder	getFacts()	Get the FactsHolder containing all of the IncrementalIndexRow backing this selector
int	getLastRowIndex()	Highest value IncrementalIndexRow.getRowIndex() available in this selector.
Metadata	getMetadata()
double	getMetricDoubleValue(int rowOffset, int aggOffset)
float	getMetricFloatValue(int rowOffset, int aggOffset)
long	getMetricLongValue(int rowOffset, int aggOffset)
Object	getMetricObjectValue(int rowOffset, int aggOffset)
String	getOutOfRowsReason()
IncrementalIndexRowSelector	getProjection(String name)
QueryableProjection<IncrementalIndexRowSelector>	getProjection(CursorBuildSpec buildSpec)
protected void	initAggs(AggregatorFactory[] metrics, IncrementalIndex.InputRowHolder inputRowHolder)
boolean	isNull(int rowOffset, int aggOffset)
Iterable<Row>	iterableWithPostAggregations(List<PostAggregator> postAggs, boolean descending)

Methods inherited from class org.apache.druid.segment.incremental.IncrementalIndex

add, dimsComparator, formatRow, getBytesInMemory, getColumnCapabilities, getColumnFormat, getColumnFormats, getColumnNames, getCombinedParseException, getDimension, getDimensionNames, getDimensionOrder, getDimensions, getDimensionsSpec, getInterval, getMaxIngestedEventTime, getMaxTime, getMetric, getMetricAggs, getMetricNames, getMinTime, getOrdering, getTimePosition, isEmpty, isRollup, iterator, loadDimensionIterable, makeColumnSelectorFactory, makeColumnSelectorFactory, makeDefaultCapabilitiesFromValueType, makeMetricColumnValueSelector, numRows

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.druid.segment.ColumnInspector

getType

Methods inherited from interface org.apache.druid.math.expr.Expr.InputBindingInspector

areNumeric, areNumeric, areSameTypes, areSameTypes, areScalar, areScalar, canVectorize, canVectorize

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Field Details

maxRowCount

protected final int maxRowCount

maxBytesInMemory

protected final long maxBytesInMemory

Method Details

getFacts

public FactsHolder getFacts()

Description copied from interface: IncrementalIndexRowSelector

Get the FactsHolder containing all of the IncrementalIndexRow backing this selector

getMetadata

public Metadata getMetadata()

Overrides:

getMetadata in class IncrementalIndex

initAggs

protected void initAggs(AggregatorFactory[] metrics,
 IncrementalIndex.InputRowHolder inputRowHolder)

Specified by:

initAggs in class IncrementalIndex

addToFacts

protected IncrementalIndex.AddToFactsResult addToFacts(IncrementalIndexRow key,
 IncrementalIndex.InputRowHolder inputRowHolder)

Specified by:

addToFacts in class IncrementalIndex

getLastRowIndex

public int getLastRowIndex()

Description copied from interface: IncrementalIndexRowSelector

Highest value IncrementalIndexRow.getRowIndex() available in this selector. Note that these values do not reflect the position of the row in the FactsHolder, rather just the order in which they were processed

getProjection

@Nullable
public QueryableProjection<IncrementalIndexRowSelector> getProjection(CursorBuildSpec buildSpec)

Specified by:

getProjection in class IncrementalIndex

getProjection

public IncrementalIndexRowSelector getProjection(String name)

Specified by:

getProjection in class IncrementalIndex

canAppendRow

public boolean canAppendRow()

Specified by:

canAppendRow in class IncrementalIndex

getOutOfRowsReason

public String getOutOfRowsReason()

Specified by:

getOutOfRowsReason in class IncrementalIndex

getMetricFloatValue

public float getMetricFloatValue(int rowOffset,
 int aggOffset)

Parameters:

rowOffset - row to get float aggregator value

aggOffset - position of the aggregator in the aggregators array of the data schema

Returns:

float value of the metric

getMetricLongValue

public long getMetricLongValue(int rowOffset,
 int aggOffset)

Parameters:

rowOffset - row to get long aggregator value

aggOffset - position of the aggregator in the aggregators array of the data schema

Returns:

long value of the aggregator for this row

getMetricDoubleValue

public double getMetricDoubleValue(int rowOffset,
 int aggOffset)

Parameters:

rowOffset - row to get double aggregator value

aggOffset - position of the aggregator in the aggregators array of the data schema

Returns:

double value of the aggregator for this row

getMetricObjectValue

public Object getMetricObjectValue(int rowOffset,
 int aggOffset)

Parameters:

rowOffset - row to get long aggregator value

aggOffset - position of the aggregator in the aggregators array of the data schema

Returns:

long value of the aggregator for this row

isNull

public boolean isNull(int rowOffset,
 int aggOffset)

Parameters:

rowOffset - row to check for a aggregator value

aggOffset - position of the aggregator in the aggregators array of the data schema

Returns:

is the value null for this row?

iterableWithPostAggregations

public Iterable<Row> iterableWithPostAggregations(@Nullable
 List<PostAggregator> postAggs,
 boolean descending)

Specified by:

iterableWithPostAggregations in class IncrementalIndex

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 AutoCloseable

Specified by:

close in interface Closeable

Overrides:

close in class IncrementalIndex