io.druid.storage.azure

Class AzureDataSegmentPuller

java.lang.Object

io.druid.storage.azure.AzureDataSegmentPuller

All Implemented Interfaces:

DataSegmentPuller

public class AzureDataSegmentPuller
extends Object
implements DataSegmentPuller

Constructor Summary

Constructors

Constructor and Description
AzureDataSegmentPuller(AzureStorage azureStorage)

Method Summary

Modifier and Type	Method and Description
void	getSegmentFiles(DataSegment segment, File outDir) Pull down segment files for the given DataSegment and put them in the given directory.
FileUtils.FileCopyResult	getSegmentFiles(String containerName, String blobPath, File outDir)
void	prepareOutDir(File outDir)

Methods inherited from class java.lang.Object

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

Constructor Detail

AzureDataSegmentPuller

@Inject
public AzureDataSegmentPuller(AzureStorage azureStorage)

Method Detail

getSegmentFiles

public FileUtils.FileCopyResult getSegmentFiles(String containerName,
                                                String blobPath,
                                                File outDir)
                                         throws SegmentLoadingException

Throws:

SegmentLoadingException

getSegmentFiles

public void getSegmentFiles(DataSegment segment,
                            File outDir)
                     throws SegmentLoadingException

Description copied from interface: DataSegmentPuller

Pull down segment files for the given DataSegment and put them in the given directory.

Specified by:

getSegmentFiles in interface DataSegmentPuller

Parameters:

segment - The segment to pull down files for

outDir - The directory to store the files in

Throws:

SegmentLoadingException - if there are any errors

prepareOutDir

public void prepareOutDir(File outDir)
                   throws ISE

Throws:

ISE