io.druid.storage.google

Class GoogleDataSegmentPusher

java.lang.Object

io.druid.storage.google.GoogleDataSegmentPusher

All Implemented Interfaces:

DataSegmentPusher

public class GoogleDataSegmentPusher
extends Object
implements DataSegmentPusher

Constructor Summary

Constructors

Constructor and Description
GoogleDataSegmentPusher(GoogleStorage storage, GoogleAccountConfig config, com.fasterxml.jackson.databind.ObjectMapper jsonMapper)

Method Summary

Modifier and Type	Method and Description
String	buildPath(String path)
File	createDescriptorFile(com.fasterxml.jackson.databind.ObjectMapper jsonMapper, DataSegment segment)
String	getPathForHadoop()
String	getPathForHadoop(String dataSource) Deprecated.
void	insert(File file, String contentType, String path)
DataSegment	push(File indexFilesDir, DataSegment segment)

Methods inherited from class java.lang.Object

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

Constructor Detail

GoogleDataSegmentPusher

@Inject
public GoogleDataSegmentPusher(GoogleStorage storage,
                                       GoogleAccountConfig 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

createDescriptorFile

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

Throws:

IOException

insert

public void insert(File file,
                   String contentType,
                   String path)
            throws IOException

Throws:

IOException

push

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

Specified by:

push in interface DataSegmentPusher

Throws:

IOException

buildPath

public String buildPath(String path)