public interface Plumber
Modifier and Type | Method and Description |
---|---|
int |
add(io.druid.data.input.InputRow row,
com.google.common.base.Supplier<io.druid.data.input.Committer> committerSupplier) |
void |
finishJob()
Perform any final processing and clean up after ourselves.
|
<T> QueryRunner<T> |
getQueryRunner(Query<T> query) |
void |
persist(io.druid.data.input.Committer committer)
Persist any in-memory indexed data to durable storage.
|
Object |
startJob()
Perform any initial setup.
|
Object startJob()
finishJob()
.int add(io.druid.data.input.InputRow row, com.google.common.base.Supplier<io.druid.data.input.Committer> committerSupplier) throws IndexSizeExceededException
row
- the row to insertcommitterSupplier
- supplier of a committer associated with all data that has been added, including this rowIndexSizeExceededException
<T> QueryRunner<T> getQueryRunner(Query<T> query)
void persist(io.druid.data.input.Committer committer)
committer
- committer to use after persisting datavoid finishJob()
Copyright © 2011–2016. All rights reserved.