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 DataSegmentPusher	DATA_SEGMENT_PUSHER
static IndexIO	INDEX_IO
static IndexMerger	INDEX_MERGER
static com.fasterxml.jackson.databind.ObjectMapper	jsonMapper

Constructor Summary

Constructors

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

Method Summary

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<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

INDEX_IO

public static final IndexIO INDEX_IO

INDEX_MERGER

public static final IndexMerger INDEX_MERGER

DATA_SEGMENT_PUSHER

public static final DataSegmentPusher DATA_SEGMENT_PUSHER

Constructor Detail

HadoopDruidConverterConfig

public HadoopDruidConverterConfig(String dataSource,
                                  org.joda.time.Interval interval,
                                  IndexSpec indexSpec,
                                  List<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<DataSegment> getSegments()

getDistributedSuccessCache

public URI getDistributedSuccessCache()

getHadoopProperties

public Map<String,String> getHadoopProperties()

getJobPriority

public String getJobPriority()

getSegmentOutputPath

public String getSegmentOutputPath()