io.druid.segment

Class IndexMerger

java.lang.Object

io.druid.segment.IndexMerger

public class IndexMerger
extends Object

Constructor Summary

Constructors

Constructor and Description
IndexMerger()

Method Summary

Methods

Modifier and Type	Method and Description
static File	append(List<IndexableAdapter> indexes, File outDir)
static File	append(List<IndexableAdapter> indexes, File outDir, ProgressIndicator progress)
static void	createIndexDrdFile(byte versionId, File inDir, GenericIndexed<String> availableDimensions, GenericIndexed<String> availableMetrics, org.joda.time.Interval dataInterval)
static File	merge(List<IndexableAdapter> indexes, AggregatorFactory[] metricAggs, File outDir)
static File	merge(List<IndexableAdapter> indexes, AggregatorFactory[] metricAggs, File outDir, ProgressIndicator progress)
static File	mergeQueryableIndex(List<QueryableIndex> indexes, AggregatorFactory[] metricAggs, File outDir)
static File	mergeQueryableIndex(List<QueryableIndex> indexes, AggregatorFactory[] metricAggs, File outDir, ProgressIndicator progress)
static File	persist(IncrementalIndex index, File outDir)
static File	persist(IncrementalIndex index, org.joda.time.Interval dataInterval, File outDir) This is *not* thread-safe and havok will ensue if this is called and writes are still occurring on the IncrementalIndex object.
static File	persist(IncrementalIndex index, org.joda.time.Interval dataInterval, File outDir, ProgressIndicator progress)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

IndexMerger

public IndexMerger()

Method Detail

persist

public static File persist(IncrementalIndex index,
           File outDir)
                    throws IOException

Throws:

IOException

persist

public static File persist(IncrementalIndex index,
           org.joda.time.Interval dataInterval,
           File outDir)
                    throws IOException

This is *not* thread-safe and havok will ensue if this is called and writes are still occurring on the IncrementalIndex object.

Parameters:

index - the IncrementalIndex to persist

dataInterval - the Interval that the data represents

outDir - the directory to persist the data to

Returns:

the index output directory

Throws:

IOException - if an IO error occurs persisting the index

persist

public static File persist(IncrementalIndex index,
           org.joda.time.Interval dataInterval,
           File outDir,
           ProgressIndicator progress)
                    throws IOException

Throws:

IOException

mergeQueryableIndex

public static File mergeQueryableIndex(List<QueryableIndex> indexes,
                       AggregatorFactory[] metricAggs,
                       File outDir)
                                throws IOException

Throws:

IOException

mergeQueryableIndex

public static File mergeQueryableIndex(List<QueryableIndex> indexes,
                       AggregatorFactory[] metricAggs,
                       File outDir,
                       ProgressIndicator progress)
                                throws IOException

Throws:

IOException

merge

public static File merge(List<IndexableAdapter> indexes,
         AggregatorFactory[] metricAggs,
         File outDir)
                  throws IOException

Throws:

IOException

merge

public static File merge(List<IndexableAdapter> indexes,
         AggregatorFactory[] metricAggs,
         File outDir,
         ProgressIndicator progress)
                  throws IOException

Throws:

IOException

append

public static File append(List<IndexableAdapter> indexes,
          File outDir)
                   throws IOException

Throws:

IOException

append

public static File append(List<IndexableAdapter> indexes,
          File outDir,
          ProgressIndicator progress)
                   throws IOException

Throws:

IOException

createIndexDrdFile

public static void createIndexDrdFile(byte versionId,
                      File inDir,
                      GenericIndexed<String> availableDimensions,
                      GenericIndexed<String> availableMetrics,
                      org.joda.time.Interval dataInterval)
                               throws IOException

Throws:

IOException