io.druid.storage.hdfs

Class HdfsDataSegmentPusher

java.lang.Object

io.druid.storage.hdfs.HdfsDataSegmentPusher

All Implemented Interfaces:

DataSegmentPusher

public class HdfsDataSegmentPusher
extends Object
implements DataSegmentPusher

Constructor Summary

Constructors

Constructor and Description
HdfsDataSegmentPusher(HdfsDataSegmentPusherConfig config, org.apache.hadoop.conf.Configuration hadoopConfig, com.fasterxml.jackson.databind.ObjectMapper jsonMapper)

Method Summary

Modifier and Type	Method and Description
String	getPathForHadoop()
String	getPathForHadoop(String dataSource) Deprecated.
DataSegment	push(File inDir, DataSegment segment)

Methods inherited from class java.lang.Object

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

Constructor Detail

HdfsDataSegmentPusher

@Inject
public HdfsDataSegmentPusher(HdfsDataSegmentPusherConfig config,
                                     org.apache.hadoop.conf.Configuration hadoopConfig,
                                     com.fasterxml.jackson.databind.ObjectMapper jsonMapper)
                              throws IOException

Throws:

IOException

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

push

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

Specified by:

push in interface DataSegmentPusher

Throws:

IOException