Uses of Interface
org.apache.druid.indexing.overlord.DataSourceMetadata

Packages that use DataSourceMetadata

Package	Description
org.apache.druid.indexing.overlord
org.apache.druid.indexing.overlord.supervisor
org.apache.druid.metadata

Uses of DataSourceMetadata in org.apache.druid.indexing.overlord

Classes in org.apache.druid.indexing.overlord that implement DataSourceMetadata

Modifier and Type	Class and Description
class	ObjectMetadata

Methods in org.apache.druid.indexing.overlord that return DataSourceMetadata

Modifier and Type	Method and Description
DataSourceMetadata	IndexerMetadataStorageCoordinator.getDataSourceMetadata(String dataSource) Read dataSource metadata.
DataSourceMetadata	DataSourceMetadata.minus(DataSourceMetadata other) Returns a copy of this instance with "other" subtracted.
DataSourceMetadata	ObjectMetadata.minus(DataSourceMetadata other)
DataSourceMetadata	DataSourceMetadata.plus(DataSourceMetadata other) Returns a copy of this instance with "other" merged in.
DataSourceMetadata	ObjectMetadata.plus(DataSourceMetadata other)

Methods in org.apache.druid.indexing.overlord with parameters of type DataSourceMetadata

Modifier and Type	Method and Description
SegmentPublishResult	IndexerMetadataStorageCoordinator.announceHistoricalSegments(Set<org.apache.druid.timeline.DataSegment> segments, DataSourceMetadata startMetadata, DataSourceMetadata endMetadata) Attempts to insert a set of segments to the metadata storage.
boolean	IndexerMetadataStorageCoordinator.insertDataSourceMetadata(String dataSource, DataSourceMetadata dataSourceMetadata) Insert dataSourceMetadata entry for 'dataSource'.
boolean	DataSourceMetadata.matches(DataSourceMetadata other) Returns true if any information present in this instance matches analogous information from "other" and so they are conflict-free.
boolean	ObjectMetadata.matches(DataSourceMetadata other)
DataSourceMetadata	DataSourceMetadata.minus(DataSourceMetadata other) Returns a copy of this instance with "other" subtracted.
DataSourceMetadata	ObjectMetadata.minus(DataSourceMetadata other)
DataSourceMetadata	DataSourceMetadata.plus(DataSourceMetadata other) Returns a copy of this instance with "other" merged in.
DataSourceMetadata	ObjectMetadata.plus(DataSourceMetadata other)
boolean	IndexerMetadataStorageCoordinator.resetDataSourceMetadata(String dataSource, DataSourceMetadata dataSourceMetadata) Resets dataSourceMetadata entry for 'dataSource' to the one supplied.

Uses of DataSourceMetadata in org.apache.druid.indexing.overlord.supervisor

Methods in org.apache.druid.indexing.overlord.supervisor with parameters of type DataSourceMetadata

Modifier and Type	Method and Description
void	Supervisor.checkpoint(Integer taskGroupId, String baseSequenceName, DataSourceMetadata previousCheckPoint, DataSourceMetadata currentCheckPoint) The definition of checkpoint is not very strict as currently it does not affect data or control path.
void	Supervisor.reset(DataSourceMetadata dataSourceMetadata)

Uses of DataSourceMetadata in org.apache.druid.metadata

Methods in org.apache.druid.metadata that return DataSourceMetadata

Modifier and Type	Method and Description
DataSourceMetadata	IndexerSQLMetadataStorageCoordinator.getDataSourceMetadata(String dataSource) Read dataSource metadata.

Methods in org.apache.druid.metadata with parameters of type DataSourceMetadata

Modifier and Type	Method and Description
SegmentPublishResult	IndexerSQLMetadataStorageCoordinator.announceHistoricalSegments(Set<org.apache.druid.timeline.DataSegment> segments, DataSourceMetadata startMetadata, DataSourceMetadata endMetadata) Attempts to insert a set of segments to the metadata storage.
boolean	IndexerSQLMetadataStorageCoordinator.insertDataSourceMetadata(String dataSource, DataSourceMetadata metadata)
boolean	IndexerSQLMetadataStorageCoordinator.resetDataSourceMetadata(String dataSource, DataSourceMetadata dataSourceMetadata)
protected org.apache.druid.metadata.IndexerSQLMetadataStorageCoordinator.DataSourceMetadataUpdateResult	IndexerSQLMetadataStorageCoordinator.updateDataSourceMetadataWithHandle(org.skife.jdbi.v2.Handle handle, String dataSource, DataSourceMetadata startMetadata, DataSourceMetadata endMetadata) Compare-and-swap dataSource metadata in a transaction.