| Package | Description |
|---|---|
| io.druid.segment.incremental |
| Modifier and Type | Method and Description |
|---|---|
IncrementalIndex.TimeAndDims |
IncrementalIndexStorageAdapter.EntryHolder.getKey() |
IncrementalIndex.TimeAndDims |
IncrementalIndex.FactsEntry.getKey() |
| Modifier and Type | Method and Description |
|---|---|
protected Comparator<IncrementalIndex.TimeAndDims> |
IncrementalIndex.dimsComparator() |
Map.Entry<IncrementalIndex.TimeAndDims,Integer> |
IncrementalIndexStorageAdapter.EntryHolder.get() |
| Modifier and Type | Method and Description |
|---|---|
protected Integer |
OnheapIncrementalIndex.addToFacts(AggregatorFactory[] metrics,
boolean deserializeComplexMetrics,
boolean reportParseExceptions,
InputRow row,
AtomicInteger numEntries,
IncrementalIndex.TimeAndDims key,
ThreadLocal<InputRow> rowContainer,
com.google.common.base.Supplier<InputRow> rowSupplier) |
protected Integer |
OffheapIncrementalIndex.addToFacts(AggregatorFactory[] metrics,
boolean deserializeComplexMetrics,
boolean reportParseExceptions,
InputRow row,
AtomicInteger numEntries,
IncrementalIndex.TimeAndDims key,
ThreadLocal<InputRow> rowContainer,
com.google.common.base.Supplier<InputRow> rowSupplier) |
protected abstract Integer |
IncrementalIndex.addToFacts(AggregatorFactory[] metrics,
boolean deserializeComplexMetrics,
boolean reportParseExceptions,
InputRow row,
AtomicInteger numEntries,
IncrementalIndex.TimeAndDims key,
ThreadLocal<InputRow> rowContainer,
com.google.common.base.Supplier<InputRow> rowSupplier) |
| Modifier and Type | Method and Description |
|---|---|
void |
IncrementalIndexStorageAdapter.EntryHolder.set(Map.Entry<IncrementalIndex.TimeAndDims,Integer> currEntry) |
| Constructor and Description |
|---|
FactsEntry(IncrementalIndex.TimeAndDims key,
Integer value) |
Copyright © 2011–2017. All rights reserved.