io.druid.segment.loading

Class OmniSegmentLoader

java.lang.Object

io.druid.segment.loading.OmniSegmentLoader

All Implemented Interfaces:

SegmentLoader

public class OmniSegmentLoader
extends Object
implements SegmentLoader

Constructor Summary

Constructors

Constructor and Description
OmniSegmentLoader(Map<String,io.druid.segment.loading.DataSegmentPuller> pullers, QueryableIndexFactory factory, SegmentLoaderConfig config)

Method Summary

Methods

Modifier and Type	Method and Description
void	cleanup(io.druid.timeline.DataSegment segment)
void	cleanupCacheFiles(File baseFile, File cacheFile)
io.druid.segment.loading.StorageLocation	findStorageLocationIfLoaded(io.druid.timeline.DataSegment segment)
Segment	getSegment(io.druid.timeline.DataSegment segment)
File	getSegmentFiles(io.druid.timeline.DataSegment segment)
boolean	isSegmentLoaded(io.druid.timeline.DataSegment segment)
OmniSegmentLoader	withConfig(SegmentLoaderConfig config)

Methods inherited from class java.lang.Object

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

Constructor Detail

OmniSegmentLoader

@Inject
public OmniSegmentLoader(Map<String,io.druid.segment.loading.DataSegmentPuller> pullers,
                        QueryableIndexFactory factory,
                        SegmentLoaderConfig config)

Method Detail

withConfig

public OmniSegmentLoader withConfig(SegmentLoaderConfig config)

isSegmentLoaded

public boolean isSegmentLoaded(io.druid.timeline.DataSegment segment)

Specified by:

isSegmentLoaded in interface SegmentLoader

findStorageLocationIfLoaded

public io.druid.segment.loading.StorageLocation findStorageLocationIfLoaded(io.druid.timeline.DataSegment segment)

getSegment

public Segment getSegment(io.druid.timeline.DataSegment segment)
                   throws io.druid.segment.loading.SegmentLoadingException

Specified by:

getSegment in interface SegmentLoader

Throws:

io.druid.segment.loading.SegmentLoadingException

getSegmentFiles

public File getSegmentFiles(io.druid.timeline.DataSegment segment)
                     throws io.druid.segment.loading.SegmentLoadingException

Specified by:

getSegmentFiles in interface SegmentLoader

Throws:

io.druid.segment.loading.SegmentLoadingException

cleanup

public void cleanup(io.druid.timeline.DataSegment segment)
             throws io.druid.segment.loading.SegmentLoadingException

Specified by:

cleanup in interface SegmentLoader

Throws:

io.druid.segment.loading.SegmentLoadingException

cleanupCacheFiles

public void cleanupCacheFiles(File baseFile,
                     File cacheFile)
                       throws IOException

Throws:

IOException