protected org.apache.druid.segment.incremental.IncrementalIndex.AddToFactsResult |
OnheapIncrementalIndex.addToFacts(AggregatorFactory[] metrics,
boolean deserializeComplexMetrics,
boolean reportParseExceptions,
InputRow row,
AtomicInteger numEntries,
AtomicLong sizeInBytes,
IncrementalIndexRow key,
ThreadLocal<InputRow> rowContainer,
com.google.common.base.Supplier<InputRow> rowSupplier,
boolean skipMaxRowsInMemoryCheck) |
protected org.apache.druid.segment.incremental.IncrementalIndex.AddToFactsResult |
OffheapIncrementalIndex.addToFacts(AggregatorFactory[] metrics,
boolean deserializeComplexMetrics,
boolean reportParseExceptions,
InputRow row,
AtomicInteger numEntries,
AtomicLong sizeInBytes,
IncrementalIndexRow key,
ThreadLocal<InputRow> rowContainer,
com.google.common.base.Supplier<InputRow> rowSupplier,
boolean skipMaxRowsInMemoryCheck) |
protected abstract org.apache.druid.segment.incremental.IncrementalIndex.AddToFactsResult |
IncrementalIndex.addToFacts(AggregatorFactory[] metrics,
boolean deserializeComplexMetrics,
boolean reportParseExceptions,
InputRow row,
AtomicInteger numEntries,
AtomicLong sizeInBytes,
IncrementalIndexRow key,
ThreadLocal<InputRow> rowContainer,
com.google.common.base.Supplier<InputRow> rowSupplier,
boolean skipMaxRowsInMemoryCheck) |
void |
IncrementalIndexRowHolder.set(IncrementalIndexRow currEntry) |