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.
|
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 |
---|---|
int |
AppenderatorPlumber.add(InputRow row,
com.google.common.base.Supplier<Committer> committerSupplier) |
int |
AppenderatorImpl.add(SegmentIdentifier identifier,
InputRow row,
com.google.common.base.Supplier<Committer> committerSupplier) |
int |
Appenderator.add(SegmentIdentifier identifier,
InputRow row,
com.google.common.base.Supplier<Committer> committerSupplier)
Add a row.
|
Modifier and Type | Method and Description |
---|---|
int |
Sink.add(InputRow row) |
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–2017. All rights reserved.