Uses of Class
io.druid.segment.indexing.DataSchema

Packages that use DataSchema

Package	Description
io.druid.indexer
io.druid.indexing.appenderator
io.druid.indexing.common.index
io.druid.indexing.common.task
io.druid.indexing.kafka
io.druid.indexing.kafka.supervisor
io.druid.segment.indexing
io.druid.segment.realtime
io.druid.segment.realtime.appenderator
io.druid.segment.realtime.plumber

Uses of DataSchema in io.druid.indexer

Methods in io.druid.indexer that return DataSchema

Modifier and Type	Method and Description
DataSchema	HadoopIngestionSpec.getDataSchema()

Methods in io.druid.indexer with parameters of type DataSchema

Modifier and Type	Method and Description
HadoopIngestionSpec	HadoopIngestionSpec.withDataSchema(DataSchema schema)

Constructors in io.druid.indexer with parameters of type DataSchema

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

Uses of DataSchema in io.druid.indexing.appenderator

Constructors in io.druid.indexing.appenderator with parameters of type DataSchema

Constructor and Description
ActionBasedSegmentAllocator(TaskActionClient taskActionClient, DataSchema dataSchema)

Uses of DataSchema in io.druid.indexing.common.index

Methods in io.druid.indexing.common.index with parameters of type DataSchema

Modifier and Type	Method and Description
Plumber	YeOldePlumberSchool.findPlumber(DataSchema schema, RealtimeTuningConfig config, FireDepartmentMetrics metrics)

Uses of DataSchema in io.druid.indexing.common.task

Methods in io.druid.indexing.common.task that return DataSchema

Modifier and Type	Method and Description
DataSchema	IndexTask.IndexIngestionSpec.getDataSchema()

Constructors in io.druid.indexing.common.task with parameters of type DataSchema

Constructor and Description
IndexIngestionSpec(DataSchema dataSchema, IndexTask.IndexIOConfig ioConfig, IndexTask.IndexTuningConfig tuningConfig)

Uses of DataSchema in io.druid.indexing.kafka

Methods in io.druid.indexing.kafka that return DataSchema

Modifier and Type	Method and Description
DataSchema	KafkaIndexTask.getDataSchema()

Constructors in io.druid.indexing.kafka with parameters of type DataSchema

Constructor and Description
KafkaIndexTask(String id, TaskResource taskResource, DataSchema dataSchema, KafkaTuningConfig tuningConfig, KafkaIOConfig ioConfig, Map<String,Object> context, ChatHandlerProvider chatHandlerProvider, AuthorizerMapper authorizerMapper)

Uses of DataSchema in io.druid.indexing.kafka.supervisor

Methods in io.druid.indexing.kafka.supervisor that return DataSchema

Modifier and Type	Method and Description
DataSchema	KafkaSupervisorSpec.getDataSchema()

Constructors in io.druid.indexing.kafka.supervisor with parameters of type DataSchema

Constructor and Description

KafkaSupervisorSpec(DataSchema dataSchema, KafkaSupervisorTuningConfig tuningConfig, KafkaSupervisorIOConfig ioConfig, Map<String,Object> context, TaskStorage taskStorage, TaskMaster taskMaster, IndexerMetadataStorageCoordinator indexerMetadataStorageCoordinator, KafkaIndexTaskClientFactory kafkaIndexTaskClientFactory, com.fasterxml.jackson.databind.ObjectMapper mapper, ServiceEmitter emitter, DruidMonitorSchedulerConfig monitorSchedulerConfig)

Uses of DataSchema in io.druid.segment.indexing

Methods in io.druid.segment.indexing that return DataSchema

Modifier and Type	Method and Description
DataSchema	IngestionSpec.getDataSchema()
DataSchema	DataSchema.withGranularitySpec(GranularitySpec granularitySpec)
DataSchema	DataSchema.withTransformSpec(TransformSpec transformSpec)

Constructors in io.druid.segment.indexing with parameters of type DataSchema

Constructor and Description
IngestionSpec(DataSchema dataSchema, IOConfigType ioConfig, TuningConfigType tuningConfig)

Uses of DataSchema in io.druid.segment.realtime

Methods in io.druid.segment.realtime that return DataSchema

Modifier and Type	Method and Description
DataSchema	FireDepartment.getDataSchema() Provides the data schema for the feed that this FireDepartment is in charge of.

Constructors in io.druid.segment.realtime with parameters of type DataSchema

Constructor and Description
FireDepartment(DataSchema dataSchema, RealtimeIOConfig ioConfig, RealtimeTuningConfig tuningConfig)

Uses of DataSchema in io.druid.segment.realtime.appenderator

Methods in io.druid.segment.realtime.appenderator that return DataSchema

Modifier and Type	Method and Description
DataSchema	AppenderatorPlumber.getSchema()

Methods in io.druid.segment.realtime.appenderator with parameters of type DataSchema

Modifier and Type	Method and Description
Appenderator	DefaultRealtimeAppenderatorFactory.build(DataSchema schema, RealtimeTuningConfig config, FireDepartmentMetrics metrics)
Appenderator	DefaultOfflineAppenderatorFactory.build(DataSchema schema, RealtimeTuningConfig config, FireDepartmentMetrics metrics)
Appenderator	AppenderatorFactory.build(DataSchema schema, RealtimeTuningConfig config, FireDepartmentMetrics metrics)
static Appenderator	Appenderators.createOffline(DataSchema schema, AppenderatorConfig config, FireDepartmentMetrics metrics, DataSegmentPusher dataSegmentPusher, com.fasterxml.jackson.databind.ObjectMapper objectMapper, IndexIO indexIO, IndexMerger indexMerger)
static Appenderator	Appenderators.createRealtime(DataSchema schema, AppenderatorConfig config, FireDepartmentMetrics metrics, DataSegmentPusher dataSegmentPusher, com.fasterxml.jackson.databind.ObjectMapper objectMapper, IndexIO indexIO, IndexMerger indexMerger, QueryRunnerFactoryConglomerate conglomerate, DataSegmentAnnouncer segmentAnnouncer, ServiceEmitter emitter, ExecutorService queryExecutorService, Cache cache, CacheConfig cacheConfig)
Plumber	AppenderatorPlumberSchool.findPlumber(DataSchema schema, RealtimeTuningConfig config, FireDepartmentMetrics metrics)

Constructors in io.druid.segment.realtime.appenderator with parameters of type DataSchema

Constructor and Description
AppenderatorImpl(DataSchema schema, AppenderatorConfig tuningConfig, FireDepartmentMetrics metrics, DataSegmentPusher dataSegmentPusher, com.fasterxml.jackson.databind.ObjectMapper objectMapper, QueryRunnerFactoryConglomerate conglomerate, DataSegmentAnnouncer segmentAnnouncer, ServiceEmitter emitter, ExecutorService queryExecutorService, IndexIO indexIO, IndexMerger indexMerger, Cache cache, CacheConfig cacheConfig)
AppenderatorPlumber(DataSchema schema, RealtimeTuningConfig config, FireDepartmentMetrics metrics, DataSegmentAnnouncer segmentAnnouncer, SegmentPublisher segmentPublisher, SegmentHandoffNotifier handoffNotifier, Appenderator appenderator)

Uses of DataSchema in io.druid.segment.realtime.plumber

Methods in io.druid.segment.realtime.plumber that return DataSchema

Modifier and Type	Method and Description
DataSchema	RealtimePlumber.getSchema()

Methods in io.druid.segment.realtime.plumber with parameters of type DataSchema

Modifier and Type	Method and Description
protected File	RealtimePlumber.computeBaseDir(DataSchema schema)
protected File	RealtimePlumber.computeCorruptedFileDumpDir(File persistDir, DataSchema schema)
protected File	RealtimePlumber.computePersistDir(DataSchema schema, org.joda.time.Interval interval)
Plumber	RealtimePlumberSchool.findPlumber(DataSchema schema, RealtimeTuningConfig config, FireDepartmentMetrics metrics)
Plumber	PlumberSchool.findPlumber(DataSchema schema, RealtimeTuningConfig config, FireDepartmentMetrics metrics) Creates a Plumber
Plumber	FlushingPlumberSchool.findPlumber(DataSchema schema, RealtimeTuningConfig config, FireDepartmentMetrics metrics)
protected int	RealtimePlumber.persistHydrant(FireHydrant indexToPersist, DataSchema schema, org.joda.time.Interval interval, Map<String,Object> metadataElems) Persists the given hydrant and returns the number of rows persisted

Constructors in io.druid.segment.realtime.plumber with parameters of type DataSchema

Constructor and Description
FlushingPlumber(org.joda.time.Duration flushDuration, DataSchema schema, RealtimeTuningConfig config, FireDepartmentMetrics metrics, ServiceEmitter emitter, QueryRunnerFactoryConglomerate conglomerate, DataSegmentAnnouncer segmentAnnouncer, ExecutorService queryExecutorService, IndexMerger indexMerger, IndexIO indexIO, Cache cache, CacheConfig cacheConfig, com.fasterxml.jackson.databind.ObjectMapper objectMapper)
RealtimePlumber(DataSchema schema, RealtimeTuningConfig config, FireDepartmentMetrics metrics, ServiceEmitter emitter, QueryRunnerFactoryConglomerate conglomerate, DataSegmentAnnouncer segmentAnnouncer, ExecutorService queryExecutorService, DataSegmentPusher dataSegmentPusher, SegmentPublisher segmentPublisher, SegmentHandoffNotifier handoffNotifier, IndexMerger indexMerger, IndexIO indexIO, Cache cache, CacheConfig cacheConfig, com.fasterxml.jackson.databind.ObjectMapper objectMapper)
Sink(org.joda.time.Interval interval, DataSchema schema, ShardSpec shardSpec, String version, int maxRowsInMemory, boolean reportParseExceptions)
Sink(org.joda.time.Interval interval, DataSchema schema, ShardSpec shardSpec, String version, int maxRowsInMemory, boolean reportParseExceptions, List<FireHydrant> hydrants)