io.druid.segment.incremental

Class IncrementalIndex

java.lang.Object

io.druid.segment.incremental.IncrementalIndex

All Implemented Interfaces:

Iterable<io.druid.data.input.Row>

public class IncrementalIndex
extends Object
implements Iterable<io.druid.data.input.Row>

Constructor Summary

Constructors

Constructor and Description
IncrementalIndex(IncrementalIndexSchema incrementalIndexSchema)
IncrementalIndex(long minTimestamp, QueryGranularity gran, AggregatorFactory[] metrics)

Method Summary

Methods

Modifier and Type	Method and Description
int	add(io.druid.data.input.InputRow row)
int	add(io.druid.data.input.InputRow row, boolean deserializeComplexMetrics) Adds a new row.
List<String>	getDimensions()
QueryGranularity	getGranularity()
org.joda.time.Interval	getInterval()
org.joda.time.DateTime	getMaxTime()
long	getMaxTimeMillis()
AggregatorFactory[]	getMetricAggs()
String	getMetricType(String metric)
org.joda.time.DateTime	getMinTime()
long	getMinTimeMillis()
long	getMinTimestamp()
SpatialDimensionRowFormatter	getSpatialDimensionRowFormatter()
List<io.druid.data.input.impl.SpatialDimensionSchema>	getSpatialDimensions()
boolean	isEmpty()
Iterable<io.druid.data.input.Row>	iterableWithPostAggregations(List<PostAggregator> postAggs)
Iterator<io.druid.data.input.Row>	iterator()
int	size()

Methods inherited from class java.lang.Object

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

Constructor Detail

IncrementalIndex

public IncrementalIndex(IncrementalIndexSchema incrementalIndexSchema)

IncrementalIndex

public IncrementalIndex(long minTimestamp,
                QueryGranularity gran,
                AggregatorFactory[] metrics)

Method Detail

add

public int add(io.druid.data.input.InputRow row)

add

public int add(io.druid.data.input.InputRow row,
      boolean deserializeComplexMetrics)

Adds a new row. The row might correspond with another row that already exists, in which case this will update that row instead of inserting a new one. Calls to add() are thread safe. Setting deserializeComplexMetrics to false is necessary for intermediate aggregation such as groupBy that should not deserialize input columns using ComplexMetricSerde for aggregators that return complex metrics.

Parameters:

row - the row of data to add

deserializeComplexMetrics - flag whether or not to call ComplexMetricExtractor.extractValue() on the input value for aggregators that return metrics other than float.

Returns:

the number of rows in the data set after adding the InputRow

isEmpty

public boolean isEmpty()

size

public int size()

getMinTimeMillis

public long getMinTimeMillis()

getMaxTimeMillis

public long getMaxTimeMillis()

getMetricAggs

public AggregatorFactory[] getMetricAggs()

getDimensions

public List<String> getDimensions()

getSpatialDimensions

public List<io.druid.data.input.impl.SpatialDimensionSchema> getSpatialDimensions()

getSpatialDimensionRowFormatter

public SpatialDimensionRowFormatter getSpatialDimensionRowFormatter()

getMetricType

public String getMetricType(String metric)

getMinTimestamp

public long getMinTimestamp()

getGranularity

public QueryGranularity getGranularity()

getInterval

public org.joda.time.Interval getInterval()

getMinTime

public org.joda.time.DateTime getMinTime()

getMaxTime

public org.joda.time.DateTime getMaxTime()

iterator

public Iterator<io.druid.data.input.Row> iterator()

Specified by:

iterator in interface Iterable<io.druid.data.input.Row>

iterableWithPostAggregations

public Iterable<io.druid.data.input.Row> iterableWithPostAggregations(List<PostAggregator> postAggs)