io.druid.segment

Class IndexMaker

java.lang.Object

io.druid.segment.IndexMaker

public class IndexMaker
extends Object

Constructor Summary

Constructors

Constructor and Description
IndexMaker()

Method Summary

Methods

Modifier and Type	Method and Description
static File	append(List<IndexableAdapter> adapters, File outDir, IndexSpec indexSpec)
static File	append(List<IndexableAdapter> adapters, File outDir, ProgressIndicator progress, IndexSpec indexSpec)
static File	convert(File inDir, File outDir, IndexSpec indexSpec)
static File	convert(File inDir, File outDir, IndexSpec indexSpec, ProgressIndicator progress)
static File	merge(List<IndexableAdapter> adapters, AggregatorFactory[] metricAggs, File outDir, IndexSpec indexSpec)
static File	merge(List<IndexableAdapter> adapters, 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

IndexMaker

public IndexMaker()

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

Throws:

IOException

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> adapters,
         AggregatorFactory[] metricAggs,
         File outDir,
         IndexSpec indexSpec)
                  throws IOException

Throws:

IOException

merge

public static File merge(List<IndexableAdapter> adapters,
         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> adapters,
          File outDir,
          IndexSpec indexSpec)
                   throws IOException

Throws:

IOException

append

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

Throws:

IOException