Uses of Class
io.druid.timeline.DataSegment

Packages that use DataSegment

Package	Description
io.druid.benchmark.datagen
io.druid.client
io.druid.client.indexing
io.druid.client.selector
io.druid.indexer
io.druid.indexer.hadoop
io.druid.indexer.path
io.druid.indexer.updater
io.druid.indexing.appenderator
io.druid.indexing.common
io.druid.indexing.common.actions
io.druid.indexing.common.task
io.druid.indexing.hadoop
io.druid.indexing.overlord
io.druid.metadata
io.druid.segment.loading
io.druid.segment.realtime
io.druid.segment.realtime.appenderator
io.druid.segment.realtime.plumber
io.druid.server
io.druid.server.coordination
io.druid.server.coordinator
io.druid.server.coordinator.cost
io.druid.server.coordinator.rules
io.druid.storage.azure
io.druid.storage.cassandra
io.druid.storage.cloudfiles
io.druid.storage.google
io.druid.storage.hdfs
io.druid.storage.s3
io.druid.timeline

Uses of DataSegment in io.druid.benchmark.datagen

Methods in io.druid.benchmark.datagen with parameters of type DataSegment

Modifier and Type	Method and Description
QueryableIndex	SegmentGenerator.generate(DataSegment dataSegment, BenchmarkSchemaInfo schemaInfo, Granularity granularity, int numRows)

Uses of DataSegment in io.druid.client

Methods in io.druid.client that return DataSegment

Modifier and Type	Method and Description
DataSegment	SegmentLoadInfo.getSegment()
DataSegment	ImmutableSegmentLoadInfo.getSegment()
DataSegment	ImmutableDruidServer.getSegment(String segmentName)
DataSegment	ImmutableDruidDataSource.getSegment(String segmentIdentifier)
DataSegment	DruidServer.getSegment(String segmentName)
DataSegment	DruidDataSource.getSegment(String identifier)

Methods in io.druid.client that return types with arguments of type DataSegment

Modifier and Type	Method and Description
Map<String,DataSegment>	ImmutableDruidServer.getSegments()
Collection<DataSegment>	ImmutableDruidDataSource.getSegments()
Map<String,DataSegment>	DruidServer.getSegments()
Collection<DataSegment>	DruidDataSource.getSegments()

Methods in io.druid.client with parameters of type DataSegment

Modifier and Type	Method and Description
DruidServer	DruidServer.addDataSegment(DataSegment segment)
protected DruidServer	SingleServerInventoryView.addInnerInventory(DruidServer container, String inventoryKey, DataSegment inventory) Deprecated.
DruidDataSource	DruidDataSource.addSegment(DataSegment dataSegment)
protected void	AbstractCuratorServerInventoryView.addSingleInventory(DruidServer container, DataSegment inventory)
boolean	InventoryView.isSegmentLoadedByServer(String serverKey, DataSegment segment)
boolean	HttpServerInventoryView.isSegmentLoadedByServer(String serverKey, DataSegment segment)
boolean	CoordinatorServerView.isSegmentLoadedByServer(String serverKey, DataSegment segment)
boolean	AbstractCuratorServerInventoryView.isSegmentLoadedByServer(String serverKey, DataSegment segment)
ServerView.CallbackAction	TimelineServerView.TimelineCallback.segmentAdded(DruidServerMetadata server, DataSegment segment) Called when a segment on a particular server has been added to the timeline.
ServerView.CallbackAction	ServerView.SegmentCallback.segmentAdded(DruidServerMetadata server, DataSegment segment) Called when a segment is added to a server.
ServerView.CallbackAction	ServerView.BaseSegmentCallback.segmentAdded(DruidServerMetadata server, DataSegment segment)
ServerView.CallbackAction	TimelineServerView.TimelineCallback.segmentRemoved(DataSegment segment) Called when a segment has been removed from all servers and is no longer present in the timeline.
ServerView.CallbackAction	ServerView.SegmentCallback.segmentRemoved(DruidServerMetadata server, DataSegment segment) Called when a segment is removed from a server.
ServerView.CallbackAction	ServerView.BaseSegmentCallback.segmentRemoved(DruidServerMetadata server, DataSegment segment)
protected DruidServer	SingleServerInventoryView.updateInnerInventory(DruidServer container, String inventoryKey, DataSegment inventory) Deprecated.

Method parameters in io.druid.client with type arguments of type DataSegment

Modifier and Type	Method and Description
protected DruidServer	BatchServerInventoryView.addInnerInventory(DruidServer container, String inventoryKey, Set<DataSegment> inventory) Deprecated.
void	SingleServerInventoryView.registerSegmentCallback(Executor exec, ServerView.SegmentCallback callback, com.google.common.base.Predicate<Pair<DruidServerMetadata,DataSegment>> filter) Deprecated.
void	HttpServerInventoryView.registerSegmentCallback(Executor exec, ServerView.SegmentCallback callback, com.google.common.base.Predicate<Pair<DruidServerMetadata,DataSegment>> filter)
void	FilteredServerInventoryView.registerSegmentCallback(Executor exec, ServerView.SegmentCallback callback, com.google.common.base.Predicate<Pair<DruidServerMetadata,DataSegment>> filter)
void	BatchServerInventoryView.registerSegmentCallback(Executor exec, ServerView.SegmentCallback callback, com.google.common.base.Predicate<Pair<DruidServerMetadata,DataSegment>> filter) Deprecated.
protected DruidServer	BatchServerInventoryView.updateInnerInventory(DruidServer container, String inventoryKey, Set<DataSegment> inventory) Deprecated.

Constructors in io.druid.client with parameters of type DataSegment

Constructor and Description
ImmutableSegmentLoadInfo(DataSegment segment, Set<DruidServerMetadata> servers)
SegmentLoadInfo(DataSegment segment)

Constructor parameters in io.druid.client with type arguments of type DataSegment

Constructor and Description
BatchServerInventoryView(ZkPathsConfig zkPaths, org.apache.curator.framework.CuratorFramework curator, com.fasterxml.jackson.databind.ObjectMapper jsonMapper, com.google.common.base.Predicate<Pair<DruidServerMetadata,DataSegment>> defaultFilter) Deprecated.
HttpServerInventoryView(com.fasterxml.jackson.databind.ObjectMapper smileMapper, HttpClient httpClient, DruidNodeDiscoveryProvider druidNodeDiscoveryProvider, com.google.common.base.Predicate<Pair<DruidServerMetadata,DataSegment>> defaultFilter, HttpServerInventoryViewConfig config)
ImmutableDruidDataSource(String name, com.google.common.collect.ImmutableMap<String,String> properties, com.google.common.collect.ImmutableMap<String,DataSegment> idToSegments)
ImmutableDruidServer(DruidServerMetadata metadata, long currSize, com.google.common.collect.ImmutableMap<String,ImmutableDruidDataSource> dataSources, com.google.common.collect.ImmutableMap<String,DataSegment> segments)
SingleServerInventoryView(ZkPathsConfig zkPaths, org.apache.curator.framework.CuratorFramework curator, com.fasterxml.jackson.databind.ObjectMapper jsonMapper, com.google.common.base.Predicate<Pair<DruidServerMetadata,DataSegment>> defaultFilter) Deprecated.

Uses of DataSegment in io.druid.client.indexing

Methods in io.druid.client.indexing that return DataSegment

Modifier and Type	Method and Description
DataSegment	ClientConversionQuery.getSegment()

Methods in io.druid.client.indexing that return types with arguments of type DataSegment

Modifier and Type	Method and Description
List<DataSegment>	ClientMergeQuery.getSegments()
List<DataSegment>	ClientAppendQuery.getSegments()

Methods in io.druid.client.indexing with parameters of type DataSegment

Modifier and Type	Method and Description
void	IndexingServiceClient.upgradeSegment(DataSegment dataSegment)

Method parameters in io.druid.client.indexing with type arguments of type DataSegment

Modifier and Type	Method and Description
void	IndexingServiceClient.mergeSegments(List<DataSegment> segments)

Constructors in io.druid.client.indexing with parameters of type DataSegment

Constructor and Description
ClientConversionQuery(DataSegment segment)

Constructor parameters in io.druid.client.indexing with type arguments of type DataSegment

Constructor and Description
ClientAppendQuery(String dataSource, List<DataSegment> segments)
ClientMergeQuery(String dataSource, List<DataSegment> segments, List<AggregatorFactory> aggregators)

Uses of DataSegment in io.druid.client.selector

Methods in io.druid.client.selector that return DataSegment

Modifier and Type	Method and Description
DataSegment	ServerSelector.getSegment()

Methods in io.druid.client.selector with parameters of type DataSegment

Modifier and Type	Method and Description
void	ServerSelector.addServerAndUpdateSegment(QueryableDruidServer server, DataSegment segment)
QueryableDruidServer	TierSelectorStrategy.pick(it.unimi.dsi.fastutil.ints.Int2ObjectRBTreeMap<Set<QueryableDruidServer>> prioritizedServers, DataSegment segment)
QueryableDruidServer	AbstractTierSelectorStrategy.pick(it.unimi.dsi.fastutil.ints.Int2ObjectRBTreeMap<Set<QueryableDruidServer>> prioritizedServers, DataSegment segment)
List<QueryableDruidServer>	TierSelectorStrategy.pick(it.unimi.dsi.fastutil.ints.Int2ObjectRBTreeMap<Set<QueryableDruidServer>> prioritizedServers, DataSegment segment, int numServersToPick)
List<QueryableDruidServer>	AbstractTierSelectorStrategy.pick(it.unimi.dsi.fastutil.ints.Int2ObjectRBTreeMap<Set<QueryableDruidServer>> prioritizedServers, DataSegment segment, int numServersToPick)
QueryableDruidServer	ServerSelectorStrategy.pick(Set<QueryableDruidServer> servers, DataSegment segment)
QueryableDruidServer	RandomServerSelectorStrategy.pick(Set<QueryableDruidServer> servers, DataSegment segment)
QueryableDruidServer	ConnectionCountServerSelectorStrategy.pick(Set<QueryableDruidServer> servers, DataSegment segment)
List<QueryableDruidServer>	ServerSelectorStrategy.pick(Set<QueryableDruidServer> servers, DataSegment segment, int numServersToPick)
List<QueryableDruidServer>	RandomServerSelectorStrategy.pick(Set<QueryableDruidServer> servers, DataSegment segment, int numServersToPick)
List<QueryableDruidServer>	ConnectionCountServerSelectorStrategy.pick(Set<QueryableDruidServer> servers, DataSegment segment, int numServersToPick)

Constructors in io.druid.client.selector with parameters of type DataSegment

Constructor and Description
ServerSelector(DataSegment segment, TierSelectorStrategy strategy)

Uses of DataSegment in io.druid.indexer

Methods in io.druid.indexer that return DataSegment

Modifier and Type	Method and Description
static DataSegment	JobHelper.serializeOutIndex(DataSegment segmentTemplate, org.apache.hadoop.conf.Configuration configuration, org.apache.hadoop.util.Progressable progressable, File mergedBase, org.apache.hadoop.fs.Path finalIndexZipFilePath, org.apache.hadoop.fs.Path finalDescriptorPath, org.apache.hadoop.fs.Path tmpPath, DataSegmentPusher dataSegmentPusher)

Methods in io.druid.indexer that return types with arguments of type DataSegment

Modifier and Type	Method and Description
List<DataSegment>	HadoopDruidIndexerJob.getPublishedSegments()
static List<DataSegment>	IndexGeneratorJob.getPublishedSegments(HadoopDruidIndexerConfig config)

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

Modifier and Type	Method and Description
static URI	JobHelper.getURIFromSegment(DataSegment dataSegment)
org.apache.hadoop.fs.Path	HadoopDruidIndexerConfig.makeDescriptorInfoPath(DataSegment segment)
static org.apache.hadoop.fs.Path	JobHelper.makeFileNamePath(org.apache.hadoop.fs.Path basePath, org.apache.hadoop.fs.FileSystem fs, DataSegment segmentTemplate, String baseFileName, DataSegmentPusher dataSegmentPusher)
static org.apache.hadoop.fs.Path	JobHelper.makeTmpPath(org.apache.hadoop.fs.Path basePath, org.apache.hadoop.fs.FileSystem fs, DataSegment segmentTemplate, org.apache.hadoop.mapreduce.TaskAttemptID taskAttemptID, DataSegmentPusher dataSegmentPusher)
static DataSegment	JobHelper.serializeOutIndex(DataSegment segmentTemplate, org.apache.hadoop.conf.Configuration configuration, org.apache.hadoop.util.Progressable progressable, File mergedBase, org.apache.hadoop.fs.Path finalIndexZipFilePath, org.apache.hadoop.fs.Path finalDescriptorPath, org.apache.hadoop.fs.Path tmpPath, DataSegmentPusher dataSegmentPusher)
static void	JobHelper.writeSegmentDescriptor(org.apache.hadoop.fs.FileSystem outputFS, DataSegment segment, org.apache.hadoop.fs.Path descriptorPath, org.apache.hadoop.util.Progressable progressable)

Method parameters in io.druid.indexer with type arguments of type DataSegment

Modifier and Type	Method and Description
void	MetadataStorageUpdaterJobHandler.publishSegments(String tableName, List<DataSegment> segments, com.fasterxml.jackson.databind.ObjectMapper mapper)
void	SQLMetadataStorageUpdaterJobHandler.publishSegments(String tableName, List<DataSegment> segments, com.fasterxml.jackson.databind.ObjectMapper mapper)

Uses of DataSegment in io.druid.indexer.hadoop

Methods in io.druid.indexer.hadoop that return DataSegment

Modifier and Type	Method and Description
DataSegment	WindowedDataSegment.getSegment()

Methods in io.druid.indexer.hadoop that return types with arguments of type DataSegment

Modifier and Type	Method and Description
List<DataSegment>	DatasourceIngestionSpec.getSegments()

Methods in io.druid.indexer.hadoop with parameters of type DataSegment

Modifier and Type	Method and Description
static WindowedDataSegment	WindowedDataSegment.of(DataSegment segment)

Constructors in io.druid.indexer.hadoop with parameters of type DataSegment

Constructor and Description
WindowedDataSegment(DataSegment segment, org.joda.time.Interval interval)

Constructor parameters in io.druid.indexer.hadoop with type arguments of type DataSegment

Constructor and Description
DatasourceIngestionSpec(String dataSource, org.joda.time.Interval interval, List<org.joda.time.Interval> intervals, List<DataSegment> segments, DimFilter filter, List<String> dimensions, List<String> metrics, boolean ignoreWhenNoSegments, TransformSpec transformSpec)

Uses of DataSegment in io.druid.indexer.path

Methods in io.druid.indexer.path that return types with arguments of type DataSegment

Modifier and Type	Method and Description
List<DataSegment>	UsedSegmentLister.getUsedSegmentsForIntervals(String dataSource, List<org.joda.time.Interval> intervals) Get all segments which may include any data in the interval and are flagged as used.
List<DataSegment>	MetadataStoreBasedUsedSegmentLister.getUsedSegmentsForIntervals(String dataSource, List<org.joda.time.Interval> intervals)

Uses of DataSegment in io.druid.indexer.updater

Methods in io.druid.indexer.updater that return types with arguments of type DataSegment

Modifier and Type	Method and Description
List<DataSegment>	HadoopDruidConverterConfig.getSegments()
List<DataSegment>	HadoopConverterJob.run()

Method parameters in io.druid.indexer.updater with type arguments of type DataSegment

Modifier and Type	Method and Description
static void	HadoopConverterJob.converterConfigIntoConfiguration(HadoopDruidConverterConfig priorConfig, List<DataSegment> segments, org.apache.hadoop.conf.Configuration configuration)

Constructor parameters in io.druid.indexer.updater with type arguments of type DataSegment

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)

Uses of DataSegment in io.druid.indexing.appenderator

Methods in io.druid.indexing.appenderator that return types with arguments of type DataSegment

Modifier and Type	Method and Description
Set<DataSegment>	ActionBasedUsedSegmentChecker.findUsedSegments(Set<SegmentIdentifier> identifiers)

Uses of DataSegment in io.druid.indexing.common

Methods in io.druid.indexing.common that return types with arguments of type DataSegment

Modifier and Type	Method and Description
Map<DataSegment,File>	TaskToolbox.fetchSegments(List<DataSegment> segments)

Method parameters in io.druid.indexing.common with type arguments of type DataSegment

Modifier and Type	Method and Description
Map<DataSegment,File>	TaskToolbox.fetchSegments(List<DataSegment> segments)
void	TaskToolbox.publishSegments(Iterable<DataSegment> segments)

Uses of DataSegment in io.druid.indexing.common.actions

Methods in io.druid.indexing.common.actions that return types with arguments of type DataSegment

Modifier and Type	Method and Description
com.fasterxml.jackson.core.type.TypeReference<List<DataSegment>>	SegmentListUsedAction.getReturnTypeReference()
com.fasterxml.jackson.core.type.TypeReference<List<DataSegment>>	SegmentListUnusedAction.getReturnTypeReference()
com.fasterxml.jackson.core.type.TypeReference<Set<DataSegment>>	SegmentInsertAction.getReturnTypeReference()
Set<DataSegment>	SegmentTransactionalInsertAction.getSegments()
Set<DataSegment>	SegmentNukeAction.getSegments()
Set<DataSegment>	SegmentMetadataUpdateAction.getSegments()
Set<DataSegment>	SegmentInsertAction.getSegments()
List<DataSegment>	SegmentListUsedAction.perform(Task task, TaskActionToolbox toolbox)
List<DataSegment>	SegmentListUnusedAction.perform(Task task, TaskActionToolbox toolbox)
Set<DataSegment>	SegmentInsertAction.perform(Task task, TaskActionToolbox toolbox) Behaves similarly to IndexerMetadataStorageCoordinator.announceHistoricalSegments(java.util.Set<io.druid.timeline.DataSegment>), with startMetadata and endMetadata both null.

Constructor parameters in io.druid.indexing.common.actions with type arguments of type DataSegment

Constructor and Description
SegmentInsertAction(Set<DataSegment> segments)
SegmentMetadataUpdateAction(Set<DataSegment> segments)
SegmentNukeAction(Set<DataSegment> segments)
SegmentTransactionalInsertAction(Set<DataSegment> segments)
SegmentTransactionalInsertAction(Set<DataSegment> segments, DataSourceMetadata startMetadata, DataSourceMetadata endMetadata)

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

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

Modifier and Type	Method and Description
DataSegment	HadoopConverterTask.getSegment()
DataSegment	ConvertSegmentTask.getSegment()
DataSegment	ConvertSegmentTask.SubTask.getSegment()

Methods in io.druid.indexing.common.task that return types with arguments of type DataSegment

Modifier and Type	Method and Description
List<DataSegment>	MergeTaskBase.getSegments()
List<DataSegment>	HadoopConverterTask.ConverterSubTask.getSegments()
List<DataSegment>	CompactionTask.getSegments()

Methods in io.druid.indexing.common.task with parameters of type DataSegment

Modifier and Type	Method and Description
static ConvertSegmentTask	ConvertSegmentTask.create(DataSegment segment, IndexSpec indexSpec, boolean force, boolean validate, SegmentWriteOutMediumFactory segmentWriteOutMediumFactory, Map<String,Object> context) Create a task to update the segment specified to the most recent binary version with the specified indexSpec
void	RealtimeIndexTask.TaskActionSegmentPublisher.publishSegment(DataSegment segment)

Method parameters in io.druid.indexing.common.task with type arguments of type DataSegment

Modifier and Type	Method and Description
protected Iterable<Task>	HadoopConverterTask.generateSubTasks(String groupId, Iterable<DataSegment> segments, IndexSpec indexSpec, boolean force, boolean validate, Map<String,Object> context)
protected Iterable<Task>	ConvertSegmentTask.generateSubTasks(String groupId, Iterable<DataSegment> segments, IndexSpec indexSpec, boolean force, boolean validate, Map<String,Object> context)
protected abstract File	MergeTaskBase.merge(TaskToolbox taskToolbox, Map<DataSegment,File> segments, File outDir)
File	MergeTask.merge(TaskToolbox toolbox, Map<DataSegment,File> segments, File outDir)
File	AppendTask.merge(TaskToolbox toolbox, Map<DataSegment,File> segments, File outDir)
protected void	SameIntervalMergeTask.SubTask.verifyInputSegments(List<DataSegment> segments)
protected void	MergeTaskBase.verifyInputSegments(List<DataSegment> segments)

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

Constructor and Description
ConvertSegmentBackwardsCompatibleTask(String id, String dataSource, org.joda.time.Interval interval, DataSegment segment, IndexSpec indexSpec, Boolean force, Boolean validate, SegmentWriteOutMediumFactory segmentWriteOutMediumFactory) Deprecated.
SubTask(String groupId, DataSegment segment, IndexSpec indexSpec, Boolean force, Boolean validate, SegmentWriteOutMediumFactory segmentWriteOutMediumFactory) Deprecated.
SubTask(String groupId, DataSegment segment, IndexSpec indexSpec, Boolean force, Boolean validate, SegmentWriteOutMediumFactory segmentWriteOutMediumFactory, Map<String,Object> context)

Constructor parameters in io.druid.indexing.common.task with type arguments of type DataSegment

Constructor and Description
AppendTask(String id, String dataSource, List<DataSegment> segments, List<AggregatorFactory> aggregators, IndexSpec indexSpec, Boolean buildV9Directly, SegmentWriteOutMediumFactory segmentWriteOutMediumFactory, Map<String,Object> context)
CompactionTask(String id, TaskResource taskResource, String dataSource, org.joda.time.Interval interval, List<DataSegment> segments, DimensionsSpec dimensionsSpec, IndexTask.IndexTuningConfig tuningConfig, Map<String,Object> context, com.fasterxml.jackson.databind.ObjectMapper jsonMapper)
ConverterSubTask(List<DataSegment> segments, HadoopConverterTask parent, Map<String,Object> context)
MergeTask(String id, String dataSource, List<DataSegment> segments, List<AggregatorFactory> aggregators, Boolean rollup, IndexSpec indexSpec, Boolean buildV9Directly, SegmentWriteOutMediumFactory segmentWriteOutMediumFactory, Map<String,Object> context)
MergeTaskBase(String id, String dataSource, List<DataSegment> segments, SegmentWriteOutMediumFactory segmentWriteOutMediumFactory, Map<String,Object> context)

Uses of DataSegment in io.druid.indexing.hadoop

Methods in io.druid.indexing.hadoop that return types with arguments of type DataSegment

Modifier and Type	Method and Description
List<DataSegment>	OverlordActionBasedUsedSegmentLister.getUsedSegmentsForIntervals(String dataSource, List<org.joda.time.Interval> intervals)

Uses of DataSegment in io.druid.indexing.overlord

Methods in io.druid.indexing.overlord that return types with arguments of type DataSegment

Modifier and Type	Method and Description
Set<DataSegment>	IndexerMetadataStorageCoordinator.announceHistoricalSegments(Set<DataSegment> segments) Attempts to insert a set of segments to the metadata storage.
Set<DataSegment>	TaskStorageQueryAdapter.getInsertedSegments(String taskid) Returns all segments created by this task.
Set<DataSegment>	SegmentPublishResult.getSegments()
List<DataSegment>	IndexerMetadataStorageCoordinator.getUnusedSegmentsForInterval(String dataSource, org.joda.time.Interval interval) Get all segments which include ONLY data within the given interval and are not flagged as used.
List<DataSegment>	IndexerMetadataStorageCoordinator.getUsedSegmentsForInterval(String dataSource, org.joda.time.Interval interval) Get all segments which may include any data in the interval and are flagged as used.
List<DataSegment>	IndexerMetadataStorageCoordinator.getUsedSegmentsForIntervals(String dataSource, List<org.joda.time.Interval> intervals) Get all segments which may include any data in the interval and are flagged as used.

Method parameters in io.druid.indexing.overlord with type arguments of type DataSegment

Modifier and Type	Method and Description
Set<DataSegment>	IndexerMetadataStorageCoordinator.announceHistoricalSegments(Set<DataSegment> segments) Attempts to insert a set of segments to the metadata storage.
SegmentPublishResult	IndexerMetadataStorageCoordinator.announceHistoricalSegments(Set<DataSegment> segments, DataSourceMetadata startMetadata, DataSourceMetadata endMetadata) Attempts to insert a set of segments to the metadata storage.
void	IndexerMetadataStorageCoordinator.deleteSegments(Set<DataSegment> segments)
void	IndexerMetadataStorageCoordinator.updateSegmentMetadata(Set<DataSegment> segments)

Constructor parameters in io.druid.indexing.overlord with type arguments of type DataSegment

Constructor and Description
SegmentPublishResult(Set<DataSegment> segments, boolean success)

Uses of DataSegment in io.druid.metadata

Methods in io.druid.metadata that return types with arguments of type DataSegment

Modifier and Type	Method and Description
Set<DataSegment>	IndexerSQLMetadataStorageCoordinator.announceHistoricalSegments(Set<DataSegment> segments) Attempts to insert a set of segments to the database.
List<DataSegment>	IndexerSQLMetadataStorageCoordinator.getUnusedSegmentsForInterval(String dataSource, org.joda.time.Interval interval)
List<DataSegment>	IndexerSQLMetadataStorageCoordinator.getUsedSegmentsForInterval(String dataSource, org.joda.time.Interval interval)
List<DataSegment>	IndexerSQLMetadataStorageCoordinator.getUsedSegmentsForIntervals(String dataSource, List<org.joda.time.Interval> intervals)

Methods in io.druid.metadata with parameters of type DataSegment

Modifier and Type	Method and Description
void	SQLMetadataSegmentPublisher.publishSegment(DataSegment segment)

Method parameters in io.druid.metadata with type arguments of type DataSegment

Modifier and Type	Method and Description
Set<DataSegment>	IndexerSQLMetadataStorageCoordinator.announceHistoricalSegments(Set<DataSegment> segments) Attempts to insert a set of segments to the database.
SegmentPublishResult	IndexerSQLMetadataStorageCoordinator.announceHistoricalSegments(Set<DataSegment> segments, DataSourceMetadata startMetadata, DataSourceMetadata endMetadata) Attempts to insert a set of segments to the metadata storage.
void	IndexerSQLMetadataStorageCoordinator.deleteSegments(Set<DataSegment> segments)
void	IndexerSQLMetadataStorageCoordinator.updateSegmentMetadata(Set<DataSegment> segments)

Uses of DataSegment in io.druid.segment.loading

Methods in io.druid.segment.loading that return DataSegment

Modifier and Type	Method and Description
DataSegment	DataSegmentArchiver.archive(DataSegment segment) Perform an archive task on the segment and return the resulting segment or null if there was no action needed.
DataSegment	OmniDataSegmentArchiver.archive(DataSegment segment)
DataSegment	DataSegmentMover.move(DataSegment segment, Map<String,Object> targetLoadSpec)
DataSegment	OmniDataSegmentMover.move(DataSegment segment, Map<String,Object> targetLoadSpec)
DataSegment	DataSegmentPusher.push(File file, DataSegment segment, boolean replaceExisting) Pushes index files and segment descriptor to deep storage.
DataSegment	LocalDataSegmentPusher.push(File dataSegmentFile, DataSegment segment, boolean replaceExisting)
DataSegment	DataSegmentArchiver.restore(DataSegment segment) Perform the restore from an archived segment and return the resulting segment or null if there was no action
DataSegment	OmniDataSegmentArchiver.restore(DataSegment segment)

Methods in io.druid.segment.loading that return types with arguments of type DataSegment

Modifier and Type	Method and Description
Set<DataSegment>	DataSegmentFinder.findSegments(String workingDirPath, boolean updateDescriptor) This method should first recursively look for descriptor.json (partitionNum_descriptor.json for HDFS data storage) underneath workingDirPath and then verify that index.zip (partitionNum_index.zip for HDFS data storage) exists in the same folder.
Set<DataSegment>	LocalDataSegmentFinder.findSegments(String workingDirPath, boolean updateDescriptor)

Methods in io.druid.segment.loading with parameters of type DataSegment

Modifier and Type	Method and Description
DataSegment	DataSegmentArchiver.archive(DataSegment segment) Perform an archive task on the segment and return the resulting segment or null if there was no action needed.
DataSegment	OmniDataSegmentArchiver.archive(DataSegment segment)
void	SegmentLoaderLocalCacheManager.cleanup(DataSegment segment)
void	SegmentLoader.cleanup(DataSegment segment)
Segment	SegmentizerFactory.factorize(DataSegment segment, File parentDir)
Segment	MMappedQueryableSegmentizerFactory.factorize(DataSegment dataSegment, File parentDir)
io.druid.segment.loading.StorageLocation	SegmentLoaderLocalCacheManager.findStorageLocationIfLoaded(DataSegment segment)
static String	DataSegmentPusher.getDefaultStorageDir(DataSegment segment)
Segment	SegmentLoaderLocalCacheManager.getSegment(DataSegment segment)
Segment	SegmentLoader.getSegment(DataSegment segment)
File	SegmentLoaderLocalCacheManager.getSegmentFiles(DataSegment segment)
File	SegmentLoader.getSegmentFiles(DataSegment segment)
void	DataSegmentPuller.getSegmentFiles(DataSegment segment, File dir) Pull down segment files for the given DataSegment and put them in the given directory.
void	LocalDataSegmentPuller.getSegmentFiles(DataSegment segment, File dir)
default String	DataSegmentPusher.getStorageDir(DataSegment dataSegment)
boolean	SegmentLoaderLocalCacheManager.isSegmentLoaded(DataSegment segment)
boolean	SegmentLoader.isSegmentLoaded(DataSegment segment)
void	DataSegmentKiller.kill(DataSegment segments)
void	OmniDataSegmentKiller.kill(DataSegment segment)
void	LocalDataSegmentKiller.kill(DataSegment segment)
default String	DataSegmentPusher.makeIndexPathName(DataSegment dataSegment, String indexName)
DataSegment	DataSegmentMover.move(DataSegment segment, Map<String,Object> targetLoadSpec)
DataSegment	OmniDataSegmentMover.move(DataSegment segment, Map<String,Object> targetLoadSpec)
DataSegment	DataSegmentPusher.push(File file, DataSegment segment, boolean replaceExisting) Pushes index files and segment descriptor to deep storage.
DataSegment	LocalDataSegmentPusher.push(File dataSegmentFile, DataSegment segment, boolean replaceExisting)
DataSegment	DataSegmentArchiver.restore(DataSegment segment) Perform the restore from an archived segment and return the resulting segment or null if there was no action
DataSegment	OmniDataSegmentArchiver.restore(DataSegment segment)

Uses of DataSegment in io.druid.segment.realtime

Methods in io.druid.segment.realtime with parameters of type DataSegment

Modifier and Type	Method and Description
void	SegmentPublisher.publishSegment(DataSegment segment)
void	NoopSegmentPublisher.publishSegment(DataSegment segment)

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

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

Modifier and Type	Method and Description
DataSegment	SegmentWithState.getDataSegment()

Methods in io.druid.segment.realtime.appenderator that return types with arguments of type DataSegment

Modifier and Type	Method and Description
Set<DataSegment>	UsedSegmentChecker.findUsedSegments(Set<SegmentIdentifier> identifiers) For any identifiers that exist and are actually used, returns the corresponding DataSegment objects.
List<DataSegment>	SegmentsAndMetadata.getSegments()

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

Modifier and Type	Method and Description
static SegmentIdentifier	SegmentIdentifier.fromDataSegment(DataSegment segment)
void	SegmentWithState.pushAndDrop(DataSegment dataSegment) Change the segment state to SegmentWithState.SegmentState.PUSHED_AND_DROPPED.

Method parameters in io.druid.segment.realtime.appenderator with type arguments of type DataSegment

Modifier and Type	Method and Description
boolean	TransactionalSegmentPublisher.publishSegments(Set<DataSegment> segments, Object commitMetadata) Publish segments, along with some commit metadata, in a single transaction.

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

Constructor and Description
SegmentWithState(SegmentIdentifier segmentIdentifier, SegmentWithState.SegmentState state, DataSegment dataSegment)

Constructor parameters in io.druid.segment.realtime.appenderator with type arguments of type DataSegment

Constructor and Description
SegmentsAndMetadata(List<DataSegment> segments, Object commitMetadata)

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

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

Modifier and Type	Method and Description
DataSegment	Sink.getSegment()

Uses of DataSegment in io.druid.server

Methods in io.druid.server with parameters of type DataSegment

Modifier and Type	Method and Description
void	SegmentManager.dropSegment(DataSegment segment)
boolean	SegmentManager.isSegmentCached(DataSegment segment)
boolean	SegmentManager.loadSegment(DataSegment segment) Load a single segment.

Uses of DataSegment in io.druid.server.coordination

Methods in io.druid.server.coordination that return DataSegment

Modifier and Type	Method and Description
DataSegment	SegmentChangeRequestLoad.getSegment()
DataSegment	SegmentChangeRequestDrop.getSegment()

Methods in io.druid.server.coordination that return types with arguments of type DataSegment

Modifier and Type	Method and Description
Collection<DataSegment>	SegmentLoadDropHandler.getPendingDeleteSnapshot()

Methods in io.druid.server.coordination with parameters of type DataSegment

Modifier and Type	Method and Description
void	SegmentLoadDropHandler.addSegment(DataSegment segment, DataSegmentChangeCallback callback)
void	DataSegmentChangeHandler.addSegment(DataSegment segment, DataSegmentChangeCallback callback)
void	DataSegmentAnnouncer.announceSegment(DataSegment segment)
void	BatchDataSegmentAnnouncer.announceSegment(DataSegment segment)
void	SegmentLoadDropHandler.removeSegment(DataSegment segment, DataSegmentChangeCallback callback)
void	DataSegmentChangeHandler.removeSegment(DataSegment segment, DataSegmentChangeCallback callback)
void	DataSegmentAnnouncer.unannounceSegment(DataSegment segment)
void	BatchDataSegmentAnnouncer.unannounceSegment(DataSegment segment)

Method parameters in io.druid.server.coordination with type arguments of type DataSegment

Modifier and Type	Method and Description
void	DataSegmentAnnouncer.announceSegments(Iterable<DataSegment> segments)
void	BatchDataSegmentAnnouncer.announceSegments(Iterable<DataSegment> segments)
void	DataSegmentAnnouncer.unannounceSegments(Iterable<DataSegment> segments)
void	BatchDataSegmentAnnouncer.unannounceSegments(Iterable<DataSegment> segments)

Constructors in io.druid.server.coordination with parameters of type DataSegment

Constructor and Description
SegmentChangeRequestDrop(DataSegment segment)
SegmentChangeRequestLoad(DataSegment segment)

Uses of DataSegment in io.druid.server.coordinator

Fields in io.druid.server.coordinator with type parameters of type DataSegment

Modifier and Type	Field and Description
static Comparator<DataSegment>	DruidCoordinator.SEGMENT_COMPARATOR

Methods in io.druid.server.coordinator that return DataSegment

Modifier and Type	Method and Description
DataSegment	BalancerSegmentHolder.getSegment()

Methods in io.druid.server.coordinator that return types with arguments of type DataSegment

Modifier and Type	Method and Description
Set<DataSegment>	DruidCoordinatorRuntimeParams.getAvailableSegments()
Set<DataSegment>	DruidCoordinator.getOrderedAvailableDataSegments()
abstract Set<DataSegment>	LoadQueuePeon.getSegmentsMarkedToDrop() Deprecated.
Set<DataSegment>	HttpLoadQueuePeon.getSegmentsMarkedToDrop()
Set<DataSegment>	CuratorLoadQueuePeon.getSegmentsMarkedToDrop() Deprecated.
abstract Set<DataSegment>	LoadQueuePeon.getSegmentsToDrop() Deprecated.
Set<DataSegment>	HttpLoadQueuePeon.getSegmentsToDrop()
Set<DataSegment>	CuratorLoadQueuePeon.getSegmentsToDrop() Deprecated.
abstract Set<DataSegment>	LoadQueuePeon.getSegmentsToLoad() Deprecated.
Set<DataSegment>	HttpLoadQueuePeon.getSegmentsToLoad()
Set<DataSegment>	CuratorLoadQueuePeon.getSegmentsToLoad() Deprecated.

Methods in io.druid.server.coordinator with parameters of type DataSegment

Modifier and Type	Method and Description
protected Pair<Double,ServerHolder>	CostBalancerStrategy.chooseBestServer(DataSegment proposalSegment, Iterable<ServerHolder> serverHolders, boolean includeCurrentServer) For assignment, we want to move to the lowest cost server that isn't already serving the segment.
protected double	DiskNormalizedCostBalancerStrategy.computeCost(DataSegment proposalSegment, ServerHolder server, boolean includeCurrentServer) Averages the cost obtained from CostBalancerStrategy.
protected double	CostBalancerStrategy.computeCost(DataSegment proposalSegment, ServerHolder server, boolean includeCurrentServer)
protected double	CachingCostBalancerStrategy.computeCost(DataSegment proposalSegment, ServerHolder server, boolean includeCurrentServer)
static double	CostBalancerStrategy.computeJointSegmentsCost(DataSegment segmentA, DataSegment segmentB) This defines the unnormalized cost function between two segments.
abstract void	LoadQueuePeon.dropSegment(DataSegment segment, LoadPeonCallback callback) Deprecated.
void	HttpLoadQueuePeon.dropSegment(DataSegment segment, LoadPeonCallback callback)
void	CuratorLoadQueuePeon.dropSegment(DataSegment segment, LoadPeonCallback callback) Deprecated.
ServerHolder	RandomBalancerStrategy.findNewSegmentHomeBalancer(DataSegment proposalSegment, List<ServerHolder> serverHolders)
ServerHolder	CostBalancerStrategy.findNewSegmentHomeBalancer(DataSegment proposalSegment, List<ServerHolder> serverHolders)
ServerHolder	BalancerStrategy.findNewSegmentHomeBalancer(DataSegment proposalSegment, List<ServerHolder> serverHolders)
ServerHolder	RandomBalancerStrategy.findNewSegmentHomeReplicator(DataSegment proposalSegment, List<ServerHolder> serverHolders)
ServerHolder	CostBalancerStrategy.findNewSegmentHomeReplicator(DataSegment proposalSegment, List<ServerHolder> serverHolders)
ServerHolder	BalancerStrategy.findNewSegmentHomeReplicator(DataSegment proposalSegment, List<ServerHolder> serverHolders)
boolean	ServerHolder.isLoadingSegment(DataSegment segment)
boolean	ServerHolder.isServingSegment(DataSegment segment)
abstract void	LoadQueuePeon.loadSegment(DataSegment segment, LoadPeonCallback callback) Deprecated.
void	HttpLoadQueuePeon.loadSegment(DataSegment segment, LoadPeonCallback callback)
void	CuratorLoadQueuePeon.loadSegment(DataSegment segment, LoadPeonCallback callback) Deprecated.
abstract void	LoadQueuePeon.markSegmentToDrop(DataSegment segmentToLoad) Deprecated.
void	HttpLoadQueuePeon.markSegmentToDrop(DataSegment dataSegment)
void	CuratorLoadQueuePeon.markSegmentToDrop(DataSegment dataSegment) Deprecated.
void	DruidCoordinator.moveSegment(ImmutableDruidServer fromServer, ImmutableDruidServer toServer, DataSegment segment, LoadPeonCallback callback)
void	DruidCoordinator.removeSegment(DataSegment segment)
abstract void	LoadQueuePeon.unmarkSegmentToDrop(DataSegment segmentToLoad) Deprecated.
void	HttpLoadQueuePeon.unmarkSegmentToDrop(DataSegment dataSegment)
void	CuratorLoadQueuePeon.unmarkSegmentToDrop(DataSegment dataSegment) Deprecated.

Method parameters in io.druid.server.coordinator with type arguments of type DataSegment

Modifier and Type	Method and Description
DruidCoordinatorRuntimeParams.Builder	DruidCoordinatorRuntimeParams.Builder.withAvailableSegments(Collection<DataSegment> availableSegmentsCollection)

Constructors in io.druid.server.coordinator with parameters of type DataSegment

Constructor and Description
BalancerSegmentHolder(ImmutableDruidServer fromServer, DataSegment segment)

Uses of DataSegment in io.druid.server.coordinator.cost

Methods in io.druid.server.coordinator.cost with parameters of type DataSegment

Modifier and Type	Method and Description
ServerCostCache.Builder	ServerCostCache.Builder.addSegment(DataSegment dataSegment)
SegmentsCostCache.Builder	SegmentsCostCache.Builder.addSegment(DataSegment segment)
void	ClusterCostCache.Builder.addSegment(String serverName, DataSegment dataSegment)
double	ClusterCostCache.computeCost(String serverName, DataSegment dataSegment)
double	SegmentsCostCache.cost(DataSegment segment)
ServerCostCache.Builder	ServerCostCache.Builder.removeSegment(DataSegment dataSegment)
SegmentsCostCache.Builder	SegmentsCostCache.Builder.removeSegment(DataSegment segment)
void	ClusterCostCache.Builder.removeSegment(String serverName, DataSegment dataSegment)

Method parameters in io.druid.server.coordinator.cost with type arguments of type DataSegment

Modifier and Type	Method and Description
static ClusterCostCache.Builder	ClusterCostCache.builder(Map<String,Set<DataSegment>> segmentsByServerName)

Uses of DataSegment in io.druid.server.coordinator.rules

Methods in io.druid.server.coordinator.rules with parameters of type DataSegment

Modifier and Type	Method and Description
boolean	Rule.appliesTo(DataSegment segment, org.joda.time.DateTime referenceTimestamp)
boolean	PeriodLoadRule.appliesTo(DataSegment segment, org.joda.time.DateTime referenceTimestamp)
boolean	PeriodDropRule.appliesTo(DataSegment segment, org.joda.time.DateTime referenceTimestamp)
boolean	PeriodBroadcastDistributionRule.appliesTo(DataSegment segment, org.joda.time.DateTime referenceTimestamp)
boolean	IntervalLoadRule.appliesTo(DataSegment segment, org.joda.time.DateTime referenceTimestamp)
boolean	IntervalDropRule.appliesTo(DataSegment segment, org.joda.time.DateTime referenceTimestamp)
boolean	IntervalBroadcastDistributionRule.appliesTo(DataSegment segment, org.joda.time.DateTime referenceTimestamp)
boolean	ForeverLoadRule.appliesTo(DataSegment segment, org.joda.time.DateTime referenceTimestamp)
boolean	ForeverDropRule.appliesTo(DataSegment segment, org.joda.time.DateTime referenceTimestamp)
boolean	ForeverBroadcastDistributionRule.appliesTo(DataSegment segment, org.joda.time.DateTime referenceTimestamp)
CoordinatorStats	Rule.run(DruidCoordinator coordinator, DruidCoordinatorRuntimeParams params, DataSegment segment)
CoordinatorStats	LoadRule.run(DruidCoordinator coordinator, DruidCoordinatorRuntimeParams params, DataSegment segment)
CoordinatorStats	DropRule.run(DruidCoordinator coordinator, DruidCoordinatorRuntimeParams params, DataSegment segment)
CoordinatorStats	BroadcastDistributionRule.run(DruidCoordinator coordinator, DruidCoordinatorRuntimeParams params, DataSegment segment)

Uses of DataSegment in io.druid.storage.azure

Methods in io.druid.storage.azure that return DataSegment

Modifier and Type	Method and Description
DataSegment	AzureDataSegmentPusher.push(File indexFilesDir, DataSegment segment, boolean replaceExisting)
DataSegment	AzureDataSegmentPusher.uploadDataSegment(DataSegment segment, int version, long size, File compressedSegmentData, File descriptorFile, Map<String,String> azurePaths, boolean replaceExisting)

Methods in io.druid.storage.azure with parameters of type DataSegment

Modifier and Type	Method and Description
File	AzureDataSegmentPusher.createSegmentDescriptorFile(com.fasterxml.jackson.databind.ObjectMapper jsonMapper, DataSegment segment)
Map<String,String>	AzureDataSegmentPusher.getAzurePaths(DataSegment segment)
void	AzureDataSegmentPuller.getSegmentFiles(DataSegment segment, File outDir)
void	AzureDataSegmentKiller.kill(DataSegment segment)
DataSegment	AzureDataSegmentPusher.push(File indexFilesDir, DataSegment segment, boolean replaceExisting)
DataSegment	AzureDataSegmentPusher.uploadDataSegment(DataSegment segment, int version, long size, File compressedSegmentData, File descriptorFile, Map<String,String> azurePaths, boolean replaceExisting)

Uses of DataSegment in io.druid.storage.cassandra

Methods in io.druid.storage.cassandra that return DataSegment

Modifier and Type	Method and Description
DataSegment	CassandraDataSegmentPusher.push(File indexFilesDir, DataSegment segment, boolean replaceExisting)

Methods in io.druid.storage.cassandra with parameters of type DataSegment

Modifier and Type	Method and Description
void	CassandraDataSegmentPuller.getSegmentFiles(DataSegment segment, File outDir)
DataSegment	CassandraDataSegmentPusher.push(File indexFilesDir, DataSegment segment, boolean replaceExisting)

Uses of DataSegment in io.druid.storage.cloudfiles

Methods in io.druid.storage.cloudfiles that return DataSegment

Modifier and Type	Method and Description
DataSegment	CloudFilesDataSegmentPusher.push(File indexFilesDir, DataSegment inSegment, boolean replaceExisting)

Methods in io.druid.storage.cloudfiles with parameters of type DataSegment

Modifier and Type	Method and Description
void	CloudFilesDataSegmentPuller.getSegmentFiles(DataSegment segment, File outDir)
DataSegment	CloudFilesDataSegmentPusher.push(File indexFilesDir, DataSegment inSegment, boolean replaceExisting)

Uses of DataSegment in io.druid.storage.google

Methods in io.druid.storage.google that return DataSegment

Modifier and Type	Method and Description
DataSegment	GoogleDataSegmentPusher.push(File indexFilesDir, DataSegment segment, boolean replaceExisting)

Methods in io.druid.storage.google with parameters of type DataSegment

Modifier and Type	Method and Description
File	GoogleDataSegmentPusher.createDescriptorFile(com.fasterxml.jackson.databind.ObjectMapper jsonMapper, DataSegment segment)
void	GoogleDataSegmentPuller.getSegmentFiles(DataSegment segment, File outDir)
void	GoogleDataSegmentKiller.kill(DataSegment segment)
DataSegment	GoogleDataSegmentPusher.push(File indexFilesDir, DataSegment segment, boolean replaceExisting)

Uses of DataSegment in io.druid.storage.hdfs

Methods in io.druid.storage.hdfs that return DataSegment

Modifier and Type	Method and Description
DataSegment	HdfsDataSegmentPusher.push(File inDir, DataSegment segment, boolean replaceExisting)

Methods in io.druid.storage.hdfs that return types with arguments of type DataSegment

Modifier and Type	Method and Description
Set<DataSegment>	HdfsDataSegmentFinder.findSegments(String workingDirPathStr, boolean updateDescriptor)

Methods in io.druid.storage.hdfs with parameters of type DataSegment

Modifier and Type	Method and Description
void	HdfsDataSegmentPuller.getSegmentFiles(DataSegment segment, File dir)
String	HdfsDataSegmentPusher.getStorageDir(DataSegment segment) Due to https://issues.apache.org/jira/browse/HDFS-13 ":" are not allowed in path names.
void	HdfsDataSegmentKiller.kill(DataSegment segment)
String	HdfsDataSegmentPusher.makeIndexPathName(DataSegment dataSegment, String indexName)
DataSegment	HdfsDataSegmentPusher.push(File inDir, DataSegment segment, boolean replaceExisting)

Uses of DataSegment in io.druid.storage.s3

Methods in io.druid.storage.s3 that return DataSegment

Modifier and Type	Method and Description
DataSegment	S3DataSegmentArchiver.archive(DataSegment segment)
DataSegment	S3DataSegmentMover.move(DataSegment segment, Map<String,Object> targetLoadSpec)
DataSegment	S3DataSegmentPusher.push(File indexFilesDir, DataSegment inSegment, boolean replaceExisting)
DataSegment	S3DataSegmentArchiver.restore(DataSegment segment)

Methods in io.druid.storage.s3 that return types with arguments of type DataSegment

Modifier and Type	Method and Description
Set<DataSegment>	S3DataSegmentFinder.findSegments(String workingDirPath, boolean updateDescriptor)

Methods in io.druid.storage.s3 with parameters of type DataSegment

Modifier and Type	Method and Description
DataSegment	S3DataSegmentArchiver.archive(DataSegment segment)
void	S3DataSegmentPuller.getSegmentFiles(DataSegment segment, File outDir)
void	S3DataSegmentKiller.kill(DataSegment segment)
DataSegment	S3DataSegmentMover.move(DataSegment segment, Map<String,Object> targetLoadSpec)
DataSegment	S3DataSegmentPusher.push(File indexFilesDir, DataSegment inSegment, boolean replaceExisting)
DataSegment	S3DataSegmentArchiver.restore(DataSegment segment)

Constructors in io.druid.storage.s3 with parameters of type DataSegment

Constructor and Description
S3Coords(DataSegment segment)

Uses of DataSegment in io.druid.timeline

Methods in io.druid.timeline that return DataSegment

Modifier and Type	Method and Description
DataSegment	DataSegment.Builder.build()
DataSegment	DataSegment.withBinaryVersion(int binaryVersion)
DataSegment	DataSegment.withDimensions(List<String> dimensions)
DataSegment	DataSegment.withLoadSpec(Map<String,Object> loadSpec)
DataSegment	DataSegment.withMetrics(List<String> metrics)
DataSegment	DataSegment.withSize(long size)
DataSegment	DataSegment.withVersion(String version)

Methods in io.druid.timeline that return types with arguments of type DataSegment

Modifier and Type	Method and Description
static Comparator<DataSegment>	DataSegment.bucketMonthComparator()
static VersionedIntervalTimeline<String,DataSegment>	VersionedIntervalTimeline.forSegments(Iterable<DataSegment> segments)

Methods in io.druid.timeline with parameters of type DataSegment

Modifier and Type	Method and Description
static DataSegment.Builder	DataSegment.builder(DataSegment segment)
int	DataSegment.compareTo(DataSegment dataSegment)

Method parameters in io.druid.timeline with type arguments of type DataSegment

Modifier and Type	Method and Description
static VersionedIntervalTimeline<String,DataSegment>	VersionedIntervalTimeline.forSegments(Iterable<DataSegment> segments)

Constructors in io.druid.timeline with parameters of type DataSegment

Constructor and Description
Builder(DataSegment segment)