io.druid.storage.cassandra

Class CassandraDataSegmentPusher

java.lang.Object

io.druid.storage.cassandra.CassandraStorage

io.druid.storage.cassandra.CassandraDataSegmentPusher

All Implemented Interfaces:

io.druid.segment.loading.DataSegmentPusher

public class CassandraDataSegmentPusher
extends CassandraStorage
implements io.druid.segment.loading.DataSegmentPusher

Cassandra Segment Pusher

Author:

boneill42

Constructor Summary

Constructors

Constructor and Description
CassandraDataSegmentPusher(CassandraDataSegmentConfig config, com.fasterxml.jackson.databind.ObjectMapper jsonMapper)

Method Summary

Methods

Modifier and Type	Method and Description
String	getPathForHadoop(String dataSource)
io.druid.timeline.DataSegment	push(File indexFilesDir, io.druid.timeline.DataSegment segment)

Methods inherited from class java.lang.Object

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

Constructor Detail

CassandraDataSegmentPusher

@Inject
public CassandraDataSegmentPusher(CassandraDataSegmentConfig config,
                                 com.fasterxml.jackson.databind.ObjectMapper jsonMapper)

Method Detail

getPathForHadoop

public String getPathForHadoop(String dataSource)

Specified by:

getPathForHadoop in interface io.druid.segment.loading.DataSegmentPusher

push

public io.druid.timeline.DataSegment push(File indexFilesDir,
                                 io.druid.timeline.DataSegment segment)
                                   throws IOException

Specified by:

push in interface io.druid.segment.loading.DataSegmentPusher

Throws:

IOException