io.druid.segment.loading

Interface DataSegmentPusher

All Known Implementing Classes:

AzureDataSegmentPusher, CassandraDataSegmentPusher, CloudFilesDataSegmentPusher, GoogleDataSegmentPusher, HdfsDataSegmentPusher, LocalDataSegmentPusher, S3DataSegmentPusher

public interface DataSegmentPusher

Field Summary

Fields

Modifier and Type	Field and Description
static com.google.common.base.Joiner	JOINER

Method Summary

Modifier and Type	Method and Description
default List<String>	getAllowedPropertyPrefixesForHadoop() Property prefixes that should be added to the "allowedHadoopPrefix" config for passing down to Hadoop jobs.
static String	getDefaultStorageDir(DataSegment segment)
String	getPathForHadoop()
String	getPathForHadoop(String dataSource) Deprecated.
default String	getStorageDir(DataSegment dataSegment)
default String	makeIndexPathName(DataSegment dataSegment, String indexName)
Map<String,Object>	makeLoadSpec(URI finalIndexZipFilePath)
DataSegment	push(File file, DataSegment segment)

Field Detail

JOINER

static final com.google.common.base.Joiner JOINER

Method Detail

getPathForHadoop

@Deprecated
String getPathForHadoop(String dataSource)

Deprecated.

getPathForHadoop

String getPathForHadoop()

push

DataSegment push(File file,
                 DataSegment segment)
          throws IOException

Throws:

IOException

makeLoadSpec

Map<String,Object> makeLoadSpec(URI finalIndexZipFilePath)

getStorageDir

default String getStorageDir(DataSegment dataSegment)

makeIndexPathName

default String makeIndexPathName(DataSegment dataSegment,
                                 String indexName)

getAllowedPropertyPrefixesForHadoop

default List<String> getAllowedPropertyPrefixesForHadoop()

Property prefixes that should be added to the "allowedHadoopPrefix" config for passing down to Hadoop jobs. These should be property prefixes like "druid.xxx", which means to include "druid.xxx" and "druid.xxx.*".

getDefaultStorageDir

static String getDefaultStorageDir(DataSegment segment)