| Package | Description | 
|---|---|
| io.druid.segment.incremental | |
| io.druid.segment.realtime.appenderator | |
| io.druid.segment.realtime.plumber | 
| Modifier and Type | Method and Description | 
|---|---|
int | 
IncrementalIndex.add(InputRow row)
Adds a new row. 
 | 
int | 
IncrementalIndex.add(InputRow row,
   boolean skipMaxRowsInMemoryCheck)  | 
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,
          boolean skipMaxRowsInMemoryCheck)  | 
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,
          boolean skipMaxRowsInMemoryCheck)  | 
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,
          boolean skipMaxRowsInMemoryCheck)  | 
| Modifier and Type | Method and Description | 
|---|---|
int | 
AppenderatorPlumber.add(InputRow row,
   com.google.common.base.Supplier<Committer> committerSupplier)  | 
default Appenderator.AppenderatorAddResult | 
Appenderator.add(SegmentIdentifier identifier,
   InputRow row,
   com.google.common.base.Supplier<Committer> committerSupplier)
Same as  
Appenderator.add(SegmentIdentifier, InputRow, Supplier, boolean), with allowIncrementalPersists set to true | 
Appenderator.AppenderatorAddResult | 
AppenderatorImpl.add(SegmentIdentifier identifier,
   InputRow row,
   com.google.common.base.Supplier<Committer> committerSupplier,
   boolean allowIncrementalPersists)  | 
Appenderator.AppenderatorAddResult | 
Appenderator.add(SegmentIdentifier identifier,
   InputRow row,
   com.google.common.base.Supplier<Committer> committerSupplier,
   boolean allowIncrementalPersists)
Add a row. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
int | 
Sink.add(InputRow row,
   boolean skipMaxRowsInMemoryCheck)  | 
int | 
RealtimePlumber.add(InputRow row,
   com.google.common.base.Supplier<Committer> committerSupplier)  | 
int | 
Plumber.add(InputRow row,
   com.google.common.base.Supplier<Committer> committerSupplier)  | 
Copyright © 2011–2018. All rights reserved.