io.druid.storage.azure

Class AzureDataSegmentPusher

java.lang.Object

io.druid.storage.azure.AzureDataSegmentPusher

All Implemented Interfaces:

DataSegmentPusher

public class AzureDataSegmentPusher
extends Object
implements DataSegmentPusher

Field Summary

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

JOINER

Constructor Summary

Constructors

Constructor and Description
AzureDataSegmentPusher(AzureStorage azureStorage, AzureAccountConfig config, com.fasterxml.jackson.databind.ObjectMapper jsonMapper)

Method Summary

Modifier and Type	Method and Description
File	createSegmentDescriptorFile(com.fasterxml.jackson.databind.ObjectMapper jsonMapper, DataSegment segment)
List<String>	getAllowedPropertyPrefixesForHadoop() Property prefixes that should be added to the "allowedHadoopPrefix" config for passing down to Hadoop jobs.
Map<String,String>	getAzurePaths(DataSegment segment)
String	getPathForHadoop()
String	getPathForHadoop(String dataSource) Deprecated.
Map<String,Object>	makeLoadSpec(URI uri)
DataSegment	push(File indexFilesDir, DataSegment segment)
DataSegment	uploadDataSegment(DataSegment segment, int version, long size, File compressedSegmentData, File descriptorFile, Map<String,String> azurePaths)

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

getDefaultStorageDir, getStorageDir, makeIndexPathName

Constructor Detail

AzureDataSegmentPusher

@Inject
public AzureDataSegmentPusher(AzureStorage azureStorage,
                                      AzureAccountConfig config,
                                      com.fasterxml.jackson.databind.ObjectMapper jsonMapper)

Method Detail

getPathForHadoop

@Deprecated
public String getPathForHadoop(String dataSource)

Deprecated.

Specified by:

getPathForHadoop in interface DataSegmentPusher

getPathForHadoop

public String getPathForHadoop()

Specified by:

getPathForHadoop in interface DataSegmentPusher

getAllowedPropertyPrefixesForHadoop

public List<String> getAllowedPropertyPrefixesForHadoop()

Description copied from interface: DataSegmentPusher

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.*".

Specified by:

getAllowedPropertyPrefixesForHadoop in interface DataSegmentPusher

createSegmentDescriptorFile

public File createSegmentDescriptorFile(com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
                                        DataSegment segment)
                                 throws IOException

Throws:

IOException

getAzurePaths

public Map<String,String> getAzurePaths(DataSegment segment)

uploadDataSegment

public DataSegment uploadDataSegment(DataSegment segment,
                                     int version,
                                     long size,
                                     File compressedSegmentData,
                                     File descriptorFile,
                                     Map<String,String> azurePaths)
                              throws com.microsoft.azure.storage.StorageException,
                                     IOException,
                                     URISyntaxException

Throws:

com.microsoft.azure.storage.StorageException

IOException

URISyntaxException

push

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

Specified by:

push in interface DataSegmentPusher

Throws:

IOException

makeLoadSpec

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

Specified by:

makeLoadSpec in interface DataSegmentPusher