io.druid.segment.loading

Class LocalDataSegmentPuller

java.lang.Object

io.druid.segment.loading.LocalDataSegmentPuller

All Implemented Interfaces:

io.druid.segment.loading.DataSegmentPuller, io.druid.segment.loading.URIDataPuller

Direct Known Subclasses:

LocalFileTimestampVersionFinder

public class LocalDataSegmentPuller
extends Object
implements io.druid.segment.loading.DataSegmentPuller, io.druid.segment.loading.URIDataPuller

Field Summary

Fields

Modifier and Type	Field and Description
static int	DEFAULT_RETRY_COUNT

Constructor Summary

Constructors

Constructor and Description
LocalDataSegmentPuller()

Method Summary

Methods

Modifier and Type	Method and Description
static FileObject	buildFileObject(URI uri)
InputStream	getInputStream(URI uri)
void	getSegmentFiles(io.druid.timeline.DataSegment segment, File dir)
com.metamx.common.FileUtils.FileCopyResult	getSegmentFiles(File sourceFile, File dir)
String	getVersion(URI uri) Returns the "version" (aka last modified timestamp) of the URI of interest
com.google.common.base.Predicate<Throwable>	shouldRetryPredicate()

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_RETRY_COUNT

public static final int DEFAULT_RETRY_COUNT

See Also:

Constant Field Values

Constructor Detail

LocalDataSegmentPuller

public LocalDataSegmentPuller()

Method Detail

buildFileObject

public static FileObject buildFileObject(URI uri)

getSegmentFiles

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

Specified by:

getSegmentFiles in interface io.druid.segment.loading.DataSegmentPuller

Throws:

io.druid.segment.loading.SegmentLoadingException

getSegmentFiles

public com.metamx.common.FileUtils.FileCopyResult getSegmentFiles(File sourceFile,
                                                         File dir)
                                                           throws io.druid.segment.loading.SegmentLoadingException

Throws:

io.druid.segment.loading.SegmentLoadingException

getInputStream

public InputStream getInputStream(URI uri)
                           throws IOException

Specified by:

getInputStream in interface io.druid.segment.loading.URIDataPuller

Throws:

IOException

getVersion

public String getVersion(URI uri)

Returns the "version" (aka last modified timestamp) of the URI of interest

Specified by:

getVersion in interface io.druid.segment.loading.URIDataPuller

Parameters:

uri - The URI to check the last modified timestamp

Returns:

The last modified timestamp in ms of the URI in String format

shouldRetryPredicate

public com.google.common.base.Predicate<Throwable> shouldRetryPredicate()

Specified by:

shouldRetryPredicate in interface io.druid.segment.loading.URIDataPuller