int |
IncrementalIndex.add(io.druid.data.input.InputRow row)
Adds a new row.
|
protected Integer |
OnheapIncrementalIndex.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) |
protected Integer |
OffheapIncrementalIndex.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) |
protected abstract Integer |
IncrementalIndex.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) |