io.druid.indexer.updater

Class HadoopDruidConverterConfig

java.lang.Object

io.druid.indexer.updater.HadoopDruidConverterConfig

public class HadoopDruidConverterConfig
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static String	CONFIG_PROPERTY
static com.fasterxml.jackson.databind.ObjectMapper	jsonMapper

Constructor Summary

Constructors

Constructor and Description
HadoopDruidConverterConfig(String dataSource, org.joda.time.Interval interval, IndexSpec indexSpec, List<io.druid.timeline.DataSegment> segments, Boolean validate, URI distributedSuccessCache, Map<String,String> hadoopProperties, String jobPriority, String segmentOutputPath)

Method Summary

Methods

Modifier and Type	Method and Description
static HadoopDruidConverterConfig	fromFile(File file)
static HadoopDruidConverterConfig	fromMap(Map<String,Object> map)
static HadoopDruidConverterConfig	fromString(String string)
String	getDataSource()
URI	getDistributedSuccessCache()
Map<String,String>	getHadoopProperties()
IndexSpec	getIndexSpec()
org.joda.time.Interval	getInterval()
String	getJobPriority()
String	getSegmentOutputPath()
List<io.druid.timeline.DataSegment>	getSegments()
boolean	isValidate()

Methods inherited from class java.lang.Object

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

Field Detail

CONFIG_PROPERTY

public static final String CONFIG_PROPERTY

See Also:

Constant Field Values

jsonMapper

public static final com.fasterxml.jackson.databind.ObjectMapper jsonMapper

Constructor Detail

HadoopDruidConverterConfig

public HadoopDruidConverterConfig(String dataSource,
                          org.joda.time.Interval interval,
                          IndexSpec indexSpec,
                          List<io.druid.timeline.DataSegment> segments,
                          Boolean validate,
                          URI distributedSuccessCache,
                          Map<String,String> hadoopProperties,
                          String jobPriority,
                          String segmentOutputPath)

Method Detail

fromString

public static HadoopDruidConverterConfig fromString(String string)
                                             throws IOException

Throws:

IOException

fromFile

public static HadoopDruidConverterConfig fromFile(File file)
                                           throws IOException

Throws:

IOException

fromMap

public static HadoopDruidConverterConfig fromMap(Map<String,Object> map)

isValidate

public boolean isValidate()

getDataSource

public String getDataSource()

getInterval

public org.joda.time.Interval getInterval()

getIndexSpec

public IndexSpec getIndexSpec()

getSegments

public List<io.druid.timeline.DataSegment> getSegments()

getDistributedSuccessCache

public URI getDistributedSuccessCache()

getHadoopProperties

public Map<String,String> getHadoopProperties()

getJobPriority

public String getJobPriority()

getSegmentOutputPath

public String getSegmentOutputPath()