io.druid.storage.s3

Class S3DataSegmentPuller

java.lang.Object

io.druid.storage.s3.S3DataSegmentPuller

All Implemented Interfaces:

io.druid.segment.loading.DataSegmentPuller

public class S3DataSegmentPuller
extends Object
implements io.druid.segment.loading.DataSegmentPuller

Constructor Summary

Constructors

Constructor and Description
S3DataSegmentPuller(org.jets3t.service.impl.rest.httpclient.RestS3Service s3Client)

Method Summary

Methods

Modifier and Type	Method and Description
long	getLastModified(io.druid.timeline.DataSegment segment)
void	getSegmentFiles(io.druid.timeline.DataSegment segment, File outDir)

Methods inherited from class java.lang.Object

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

Constructor Detail

S3DataSegmentPuller

@Inject
public S3DataSegmentPuller(org.jets3t.service.impl.rest.httpclient.RestS3Service s3Client)

Method Detail

getSegmentFiles

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

Specified by:

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

Throws:

io.druid.segment.loading.SegmentLoadingException

getLastModified

public long getLastModified(io.druid.timeline.DataSegment segment)
                     throws io.druid.segment.loading.SegmentLoadingException

Specified by:

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

Throws:

io.druid.segment.loading.SegmentLoadingException