io.druid.storage.azure

Class AzureDataSegmentPusher

java.lang.Object

io.druid.storage.azure.AzureDataSegmentPusher

All Implemented Interfaces:

io.druid.segment.loading.DataSegmentPusher

public class AzureDataSegmentPusher
extends Object
implements io.druid.segment.loading.DataSegmentPusher

Constructor Summary

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
File	createCompressedSegmentDataFile(File indexFilesDir)
File	createSegmentDescriptorFile(com.fasterxml.jackson.databind.ObjectMapper jsonMapper, io.druid.timeline.DataSegment segment)
Map<String,String>	getAzurePaths(io.druid.timeline.DataSegment segment)
String	getPathForHadoop(String dataSource)
io.druid.timeline.DataSegment	push(File indexFilesDir, io.druid.timeline.DataSegment segment)
io.druid.timeline.DataSegment	uploadDataSegment(io.druid.timeline.DataSegment segment, int version, 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

public String getPathForHadoop(String dataSource)

Specified by:

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

createCompressedSegmentDataFile

public File createCompressedSegmentDataFile(File indexFilesDir)
                                     throws IOException

Throws:

IOException

createSegmentDescriptorFile

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

Throws:

IOException

getAzurePaths

public Map<String,String> getAzurePaths(io.druid.timeline.DataSegment segment)

uploadDataSegment

public io.druid.timeline.DataSegment uploadDataSegment(io.druid.timeline.DataSegment segment,
                                              int version,
                                              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 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