io.druid.storage.cassandra

Class CassandraDataSegmentPuller

java.lang.Object

io.druid.storage.cassandra.CassandraStorage

io.druid.storage.cassandra.CassandraDataSegmentPuller

All Implemented Interfaces:

DataSegmentPuller

public class CassandraDataSegmentPuller
extends CassandraStorage
implements DataSegmentPuller

Cassandra Segment Puller

Constructor Summary

Constructors

Constructor and Description
CassandraDataSegmentPuller(CassandraDataSegmentConfig config)

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 key, File outDir)

Methods inherited from class java.lang.Object

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

Constructor Detail

CassandraDataSegmentPuller

@Inject
public CassandraDataSegmentPuller(CassandraDataSegmentConfig config)

Method Detail

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

getSegmentFiles

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

Throws:

SegmentLoadingException