io.druid.segment.loading

Class LocalDataSegmentPusher

java.lang.Object

io.druid.segment.loading.LocalDataSegmentPusher

All Implemented Interfaces:

DataSegmentPusher

public class LocalDataSegmentPusher
extends Object
implements DataSegmentPusher

Field Summary

Fields inherited from interface io.druid.segment.loading.DataSegmentPusher

JOINER

Constructor Summary

Constructors

Constructor and Description
LocalDataSegmentPusher(LocalDataSegmentPusherConfig config, com.fasterxml.jackson.databind.ObjectMapper jsonMapper)

Method Summary

Modifier and Type	Method and Description
String	getPathForHadoop()
String	getPathForHadoop(String dataSource) Deprecated.
Map<String,Object>	makeLoadSpec(URI finalIndexZipFilePath)
DataSegment	push(File dataSegmentFile, DataSegment segment)

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.druid.segment.loading.DataSegmentPusher

getAllowedPropertyPrefixesForHadoop, getDefaultStorageDir, getStorageDir, makeIndexPathName

Constructor Detail

LocalDataSegmentPusher

@Inject
public LocalDataSegmentPusher(LocalDataSegmentPusherConfig config,
                                      com.fasterxml.jackson.databind.ObjectMapper jsonMapper)

Method Detail

getPathForHadoop

public String getPathForHadoop()

Specified by:

getPathForHadoop in interface DataSegmentPusher

getPathForHadoop

@Deprecated
public String getPathForHadoop(String dataSource)

Deprecated.

Specified by:

getPathForHadoop in interface DataSegmentPusher

push

public DataSegment push(File dataSegmentFile,
                        DataSegment segment)
                 throws IOException

Specified by:

push in interface DataSegmentPusher

Throws:

IOException

makeLoadSpec

public Map<String,Object> makeLoadSpec(URI finalIndexZipFilePath)

Specified by:

makeLoadSpec in interface DataSegmentPusher