| Package | Description |
|---|---|
| org.apache.druid.segment.realtime.appenderator |
| Modifier and Type | Method and Description |
|---|---|
AppenderatorDriverAddResult |
BatchAppenderatorDriver.add(org.apache.druid.data.input.InputRow row,
String sequenceName)
Add a row.
|
AppenderatorDriverAddResult |
StreamAppenderatorDriver.add(org.apache.druid.data.input.InputRow row,
String sequenceName,
com.google.common.base.Supplier<org.apache.druid.data.input.Committer> committerSupplier) |
AppenderatorDriverAddResult |
StreamAppenderatorDriver.add(org.apache.druid.data.input.InputRow row,
String sequenceName,
com.google.common.base.Supplier<org.apache.druid.data.input.Committer> committerSupplier,
boolean skipSegmentLineageCheck,
boolean allowIncrementalPersists)
Add a row.
|
protected AppenderatorDriverAddResult |
BaseAppenderatorDriver.append(org.apache.druid.data.input.InputRow row,
String sequenceName,
com.google.common.base.Supplier<org.apache.druid.data.input.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,
ParseException parseException) |
Copyright © 2011–2018 The Apache Software Foundation. All rights reserved.