Package | Description |
---|---|
io.druid.indexer | |
io.druid.query.groupby | |
io.druid.segment | |
io.druid.segment.incremental | |
io.druid.segment.realtime |
Modifier and Type | Method and Description |
---|---|
protected File |
LegacyIndexGeneratorJob.LegacyIndexGeneratorReducer.persist(IncrementalIndex index,
org.joda.time.Interval interval,
File file,
ProgressIndicator progressIndicator) |
protected File |
IndexGeneratorJob.IndexGeneratorReducer.persist(IncrementalIndex index,
org.joda.time.Interval interval,
File file,
ProgressIndicator progressIndicator) |
Modifier and Type | Method and Description |
---|---|
static <T> com.metamx.common.Pair<IncrementalIndex,com.metamx.common.guava.Accumulator<IncrementalIndex,T>> |
GroupByQueryHelper.createIndexAccumulatorPair(GroupByQuery query,
GroupByQueryConfig config,
StupidPool<ByteBuffer> bufferPool) |
static <T> com.metamx.common.Pair<IncrementalIndex,com.metamx.common.guava.Accumulator<IncrementalIndex,T>> |
GroupByQueryHelper.createIndexAccumulatorPair(GroupByQuery query,
GroupByQueryConfig config,
StupidPool<ByteBuffer> bufferPool) |
Modifier and Type | Method and Description |
---|---|
static File |
IndexMerger.persist(IncrementalIndex index,
File outDir,
IndexSpec indexSpec) |
static File |
IndexMaker.persist(IncrementalIndex index,
File outDir,
IndexSpec indexSpec) |
static File |
IndexMerger.persist(IncrementalIndex index,
org.joda.time.Interval dataInterval,
File outDir,
IndexSpec indexSpec)
This is *not* thread-safe and havok will ensue if this is called and writes are still occurring
on the IncrementalIndex object.
|
static File |
IndexMaker.persist(IncrementalIndex index,
org.joda.time.Interval dataInterval,
File outDir,
IndexSpec indexSpec)
This is *not* thread-safe and havok will ensue if this is called and writes are still occurring
on the IncrementalIndex object.
|
static File |
IndexMerger.persist(IncrementalIndex index,
org.joda.time.Interval dataInterval,
File outDir,
IndexSpec indexSpec,
ProgressIndicator progress) |
static File |
IndexMaker.persist(IncrementalIndex index,
org.joda.time.Interval dataInterval,
File outDir,
IndexSpec indexSpec,
ProgressIndicator progress) |
Constructor and Description |
---|
IncrementalIndexSegment(IncrementalIndex index,
String segmentIdentifier) |
Modifier and Type | Class and Description |
---|---|
class |
OffheapIncrementalIndex |
class |
OnheapIncrementalIndex |
Constructor and Description |
---|
IncrementalIndexAdapter(org.joda.time.Interval dataInterval,
IncrementalIndex<?> index,
com.metamx.collections.bitmap.BitmapFactory bitmapFactory) |
IncrementalIndexStorageAdapter(IncrementalIndex index) |
Modifier and Type | Method and Description |
---|---|
IncrementalIndex |
FireHydrant.getIndex() |
Constructor and Description |
---|
FireHydrant(IncrementalIndex index,
int count,
String segmentIdentifier) |
Copyright © 2011–2015. All rights reserved.