Package | Description |
---|---|
io.druid.segment.realtime.appenderator |
Modifier and Type | Method and Description |
---|---|
AppenderatorDriverAddResult |
BatchAppenderatorDriver.add(InputRow row,
String sequenceName)
Add a row.
|
AppenderatorDriverAddResult |
StreamAppenderatorDriver.add(InputRow row,
String sequenceName,
com.google.common.base.Supplier<Committer> committerSupplier,
boolean skipSegmentLineageCheck,
boolean allowIncrementalPersists)
Add a row.
|
protected AppenderatorDriverAddResult |
BaseAppenderatorDriver.append(InputRow row,
String sequenceName,
com.google.common.base.Supplier<Committer> committerSupplier,
boolean skipSegmentLineageCheck,
boolean allowIncrementalPersists)
Add a row.
|
static AppenderatorDriverAddResult |
AppenderatorDriverAddResult.fail() |
static AppenderatorDriverAddResult |
AppenderatorDriverAddResult.ok(SegmentIdentifier segmentIdentifier,
int numRowsInSegment,
long totalNumRowsInAppenderator,
boolean isPersistRequired) |
Copyright © 2011–2018. All rights reserved.