io.druid.segment.loading

Class SegmentLoaderLocalCacheManager

java.lang.Object

io.druid.segment.loading.SegmentLoaderLocalCacheManager

All Implemented Interfaces:

SegmentLoader

public class SegmentLoaderLocalCacheManager
extends Object
implements SegmentLoader

Constructor Summary

Constructors

Constructor and Description
SegmentLoaderLocalCacheManager(IndexIO indexIO, SegmentLoaderConfig config, com.fasterxml.jackson.databind.ObjectMapper mapper)

Method Summary

Modifier and Type	Method and Description
void	cleanup(DataSegment segment)
void	cleanupCacheFiles(File baseFile, File cacheFile)
io.druid.segment.loading.StorageLocation	findStorageLocationIfLoaded(DataSegment segment)
Segment	getSegment(DataSegment segment)
File	getSegmentFiles(DataSegment segment)
List<io.druid.segment.loading.StorageLocation>	getSortedList(List<io.druid.segment.loading.StorageLocation> locs)
boolean	isSegmentLoaded(DataSegment segment)
SegmentLoaderLocalCacheManager	withConfig(SegmentLoaderConfig config)

Methods inherited from class java.lang.Object

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

Constructor Detail

SegmentLoaderLocalCacheManager

@Inject
public SegmentLoaderLocalCacheManager(IndexIO indexIO,
                                              SegmentLoaderConfig config,
                                              com.fasterxml.jackson.databind.ObjectMapper mapper)

Method Detail

withConfig

public SegmentLoaderLocalCacheManager withConfig(SegmentLoaderConfig config)

isSegmentLoaded

public boolean isSegmentLoaded(DataSegment segment)

Specified by:

isSegmentLoaded in interface SegmentLoader

findStorageLocationIfLoaded

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

getSegment

public Segment getSegment(DataSegment segment)
                   throws SegmentLoadingException

Specified by:

getSegment in interface SegmentLoader

Throws:

SegmentLoadingException

getSegmentFiles

public File getSegmentFiles(DataSegment segment)
                     throws SegmentLoadingException

Specified by:

getSegmentFiles in interface SegmentLoader

Throws:

SegmentLoadingException

cleanup

public void cleanup(DataSegment segment)
             throws SegmentLoadingException

Specified by:

cleanup in interface SegmentLoader

Throws:

SegmentLoadingException

cleanupCacheFiles

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

Throws:

IOException

getSortedList

public List<io.druid.segment.loading.StorageLocation> getSortedList(List<io.druid.segment.loading.StorageLocation> locs)