io.druid.indexer

Class HadoopIngestionSpec

java.lang.Object

io.druid.segment.indexing.IngestionSpec<HadoopIOConfig,HadoopTuningConfig>

io.druid.indexer.HadoopIngestionSpec

public class HadoopIngestionSpec
extends IngestionSpec<HadoopIOConfig,HadoopTuningConfig>

Constructor Summary

Constructors

Constructor and Description
HadoopIngestionSpec(DataSchema dataSchema, HadoopIOConfig ioConfig, HadoopTuningConfig tuningConfig)

Method Summary

Methods

Modifier and Type	Method and Description
DataSchema	getDataSchema()
HadoopIOConfig	getIOConfig()
HadoopTuningConfig	getTuningConfig()
static HadoopIngestionSpec	updateSegmentListIfDatasourcePathSpecIsUsed(HadoopIngestionSpec spec, com.fasterxml.jackson.databind.ObjectMapper jsonMapper, UsedSegmentLister segmentLister)
HadoopIngestionSpec	withDataSchema(DataSchema schema)
HadoopIngestionSpec	withIOConfig(HadoopIOConfig config)
HadoopIngestionSpec	withTuningConfig(HadoopTuningConfig config)

Methods inherited from class java.lang.Object

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

Constructor Detail

HadoopIngestionSpec

public HadoopIngestionSpec(DataSchema dataSchema,
                   HadoopIOConfig ioConfig,
                   HadoopTuningConfig tuningConfig)

Method Detail

getDataSchema

public DataSchema getDataSchema()

Overrides:

getDataSchema in class IngestionSpec<HadoopIOConfig,HadoopTuningConfig>

getIOConfig

public HadoopIOConfig getIOConfig()

Overrides:

getIOConfig in class IngestionSpec<HadoopIOConfig,HadoopTuningConfig>

getTuningConfig

public HadoopTuningConfig getTuningConfig()

Overrides:

getTuningConfig in class IngestionSpec<HadoopIOConfig,HadoopTuningConfig>

withDataSchema

public HadoopIngestionSpec withDataSchema(DataSchema schema)

withIOConfig

public HadoopIngestionSpec withIOConfig(HadoopIOConfig config)

withTuningConfig

public HadoopIngestionSpec withTuningConfig(HadoopTuningConfig config)

updateSegmentListIfDatasourcePathSpecIsUsed

public static HadoopIngestionSpec updateSegmentListIfDatasourcePathSpecIsUsed(HadoopIngestionSpec spec,
                                                              com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
                                                              UsedSegmentLister segmentLister)
                                                                       throws IOException

Throws:

IOException