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, IndexSpec indexSpec)
static File	append(List<IndexableAdapter> indexes, File outDir, IndexSpec indexSpec, ProgressIndicator progress)
static File	convert(File inDir, File outDir, IndexSpec indexSpec)
static File	convert(File inDir, File outDir, IndexSpec indexSpec, ProgressIndicator progress)
static void	createIndexDrdFile(byte versionId, File inDir, GenericIndexed<String> availableDimensions, GenericIndexed<String> availableMetrics, org.joda.time.Interval dataInterval, BitmapSerdeFactory bitmapSerdeFactory)
static File	merge(List<IndexableAdapter> indexes, AggregatorFactory[] metricAggs, File outDir, IndexSpec indexSpec)
static File	merge(List<IndexableAdapter> indexes, AggregatorFactory[] metricAggs, File outDir, IndexSpec indexSpec, ProgressIndicator progress)
static File	mergeQueryableIndex(List<QueryableIndex> indexes, AggregatorFactory[] metricAggs, File outDir, IndexSpec indexSpec)
static File	mergeQueryableIndex(List<QueryableIndex> indexes, AggregatorFactory[] metricAggs, File outDir, IndexSpec indexSpec, ProgressIndicator progress)
static File	persist(IncrementalIndex index, File outDir, IndexSpec indexSpec)
static File	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	persist(IncrementalIndex index, org.joda.time.Interval dataInterval, File outDir, IndexSpec indexSpec, 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,
           IndexSpec indexSpec)
                    throws IOException

Throws:

IOException

persist

public static File persist(IncrementalIndex index,
           org.joda.time.Interval dataInterval,
           File outDir,
           IndexSpec indexSpec)
                    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,
           IndexSpec indexSpec,
           ProgressIndicator progress)
                    throws IOException

Throws:

IOException

mergeQueryableIndex

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

Throws:

IOException

mergeQueryableIndex

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

Throws:

IOException

merge

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

Throws:

IOException

merge

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

Throws:

IOException

convert

public static File convert(File inDir,
           File outDir,
           IndexSpec indexSpec)
                    throws IOException

Throws:

IOException

convert

public static File convert(File inDir,
           File outDir,
           IndexSpec indexSpec,
           ProgressIndicator progress)
                    throws IOException

Throws:

IOException

append

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

Throws:

IOException

append

public static File append(List<IndexableAdapter> indexes,
          File outDir,
          IndexSpec indexSpec,
          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,
                      BitmapSerdeFactory bitmapSerdeFactory)
                               throws IOException

Throws:

IOException