| Package | Description | 
|---|---|
| io.druid.query.groupby | |
| io.druid.segment | |
| io.druid.segment.incremental | |
| io.druid.segment.realtime | 
| Modifier and Type | Method and Description | 
|---|---|
static IncrementalIndex | 
GroupByQueryHelper.makeIncrementalIndex(GroupByQuery query,
                    GroupByQueryConfig config,
                    NonBlockingPool<ByteBuffer> bufferPool,
                    Sequence<Row> rows,
                    boolean combine)  | 
| Modifier and Type | Method and Description | 
|---|---|
static <T> Pair<IncrementalIndex,Accumulator<IncrementalIndex,T>> | 
GroupByQueryHelper.createIndexAccumulatorPair(GroupByQuery query,
                          GroupByQueryConfig config,
                          NonBlockingPool<ByteBuffer> bufferPool,
                          boolean combine)  | 
static <T> Pair<IncrementalIndex,Accumulator<IncrementalIndex,T>> | 
GroupByQueryHelper.createIndexAccumulatorPair(GroupByQuery query,
                          GroupByQueryConfig config,
                          NonBlockingPool<ByteBuffer> bufferPool,
                          boolean combine)  | 
| Modifier and Type | Method and Description | 
|---|---|
static Sequence<Row> | 
GroupByQueryHelper.postAggregate(GroupByQuery query,
             IncrementalIndex index)  | 
| Modifier and Type | Method and Description | 
|---|---|
File | 
IndexMergerV9.persist(IncrementalIndex index,
       File outDir,
       IndexSpec indexSpec,
       SegmentWriteOutMediumFactory segmentWriteOutMediumFactory)  | 
File | 
IndexMerger.persist(IncrementalIndex index,
       File outDir,
       IndexSpec indexSpec,
       SegmentWriteOutMediumFactory segmentWriteOutMediumFactory)  | 
File | 
IndexMergerV9.persist(IncrementalIndex index,
       org.joda.time.Interval dataInterval,
       File outDir,
       IndexSpec indexSpec,
       ProgressIndicator progress,
       SegmentWriteOutMediumFactory segmentWriteOutMediumFactory)  | 
File | 
IndexMerger.persist(IncrementalIndex index,
       org.joda.time.Interval dataInterval,
       File outDir,
       IndexSpec indexSpec,
       ProgressIndicator progress,
       SegmentWriteOutMediumFactory segmentWriteOutMediumFactory)  | 
File | 
IndexMergerV9.persist(IncrementalIndex index,
       org.joda.time.Interval dataInterval,
       File outDir,
       IndexSpec indexSpec,
       SegmentWriteOutMediumFactory segmentWriteOutMediumFactory)  | 
File | 
IndexMerger.persist(IncrementalIndex index,
       org.joda.time.Interval dataInterval,
       File outDir,
       IndexSpec indexSpec,
       SegmentWriteOutMediumFactory segmentWriteOutMediumFactory)
This is *not* thread-safe and havok will ensue if this is called and writes are still occurring
 on the IncrementalIndex object. 
 | 
| Constructor and Description | 
|---|
IncrementalIndexSegment(IncrementalIndex index,
                       String segmentIdentifier)  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
OffheapIncrementalIndex  | 
class  | 
OnheapIncrementalIndex  | 
| Modifier and Type | Method and Description | 
|---|---|
IncrementalIndex | 
IncrementalIndex.Builder.buildOffheap(NonBlockingPool<ByteBuffer> bufferPool)  | 
IncrementalIndex | 
IncrementalIndex.Builder.buildOnheap()  | 
| Constructor and Description | 
|---|
IncrementalIndexAdapter(org.joda.time.Interval dataInterval,
                       IncrementalIndex<?> index,
                       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–2018. All rights reserved.