io.druid.storage.cassandra

Class CassandraDataSegmentPuller

java.lang.Object

io.druid.storage.cassandra.CassandraStorage

io.druid.storage.cassandra.CassandraDataSegmentPuller

All Implemented Interfaces:

io.druid.segment.loading.DataSegmentPuller

public class CassandraDataSegmentPuller
extends CassandraStorage
implements io.druid.segment.loading.DataSegmentPuller

Cassandra Segment Puller

Constructor Summary

Constructors

Constructor and Description
CassandraDataSegmentPuller(CassandraDataSegmentConfig config)

Method Summary

Methods

Modifier and Type	Method and Description
void	getSegmentFiles(io.druid.timeline.DataSegment segment, File outDir)
com.metamx.common.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(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

getSegmentFiles

public com.metamx.common.FileUtils.FileCopyResult getSegmentFiles(String key,
                                                         File outDir)
                                                           throws io.druid.segment.loading.SegmentLoadingException

Throws:

io.druid.segment.loading.SegmentLoadingException