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

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)
Map<String,String>	getAzurePaths(DataSegment segment)
String	getPathForHadoop()
String	getPathForHadoop(String dataSource) Deprecated.
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

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

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