Uses of Interface
io.druid.indexing.overlord.DataSourceMetadata

Packages that use DataSourceMetadata

Package	Description
io.druid.indexing.common.actions
io.druid.indexing.kafka
io.druid.indexing.kafka.supervisor
io.druid.indexing.overlord
io.druid.indexing.overlord.supervisor
io.druid.metadata

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

Methods in io.druid.indexing.common.actions that return DataSourceMetadata

Modifier and Type	Method and Description
DataSourceMetadata	CheckPointDataSourceMetadataAction.getCurrentCheckPoint()
DataSourceMetadata	SegmentTransactionalInsertAction.getEndMetadata()
DataSourceMetadata	CheckPointDataSourceMetadataAction.getPreviousCheckPoint()
DataSourceMetadata	ResetDataSourceMetadataAction.getResetMetadata()
DataSourceMetadata	SegmentTransactionalInsertAction.getStartMetadata()

Constructors in io.druid.indexing.common.actions with parameters of type DataSourceMetadata

Constructor and Description
CheckPointDataSourceMetadataAction(String supervisorId, String sequenceName, DataSourceMetadata previousCheckPoint, DataSourceMetadata currentCheckPoint)
ResetDataSourceMetadataAction(String dataSource, DataSourceMetadata resetMetadata)
SegmentTransactionalInsertAction(Set<DataSegment> segments, DataSourceMetadata startMetadata, DataSourceMetadata endMetadata)

Uses of DataSourceMetadata in io.druid.indexing.kafka

Classes in io.druid.indexing.kafka that implement DataSourceMetadata

Modifier and Type	Class and Description
class	KafkaDataSourceMetadata

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

Modifier and Type	Method and Description
DataSourceMetadata	KafkaDataSourceMetadata.minus(DataSourceMetadata other)
DataSourceMetadata	KafkaDataSourceMetadata.plus(DataSourceMetadata other)

Methods in io.druid.indexing.kafka with parameters of type DataSourceMetadata

Modifier and Type	Method and Description
boolean	KafkaDataSourceMetadata.matches(DataSourceMetadata other)
DataSourceMetadata	KafkaDataSourceMetadata.minus(DataSourceMetadata other)
DataSourceMetadata	KafkaDataSourceMetadata.plus(DataSourceMetadata other)

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

Methods in io.druid.indexing.kafka.supervisor with parameters of type DataSourceMetadata

Modifier and Type	Method and Description
void	KafkaSupervisor.checkpoint(String sequenceName, DataSourceMetadata previousCheckpoint, DataSourceMetadata currentCheckpoint)
void	KafkaSupervisor.reset(DataSourceMetadata dataSourceMetadata)

Uses of DataSourceMetadata in io.druid.indexing.overlord

Classes in io.druid.indexing.overlord that implement DataSourceMetadata

Modifier and Type	Class and Description
class	ObjectMetadata

Methods in io.druid.indexing.overlord that return DataSourceMetadata

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

Methods in io.druid.indexing.overlord with parameters of type DataSourceMetadata

Modifier and Type	Method and Description
SegmentPublishResult	IndexerMetadataStorageCoordinator.announceHistoricalSegments(Set<DataSegment> segments, DataSourceMetadata startMetadata, DataSourceMetadata endMetadata) Attempts to insert a set of segments to the metadata storage.
boolean	ObjectMetadata.matches(DataSourceMetadata other)
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.
DataSourceMetadata	ObjectMetadata.minus(DataSourceMetadata other)
DataSourceMetadata	DataSourceMetadata.minus(DataSourceMetadata other) Returns a copy of this instance with "other" subtracted.
DataSourceMetadata	ObjectMetadata.plus(DataSourceMetadata other)
DataSourceMetadata	DataSourceMetadata.plus(DataSourceMetadata other) Returns a copy of this instance with "other" merged in.
boolean	IndexerMetadataStorageCoordinator.resetDataSourceMetadata(String dataSource, DataSourceMetadata dataSourceMetadata) Resets dataSourceMetadata entry for 'dataSource' to the one supplied.

Uses of DataSourceMetadata in io.druid.indexing.overlord.supervisor

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

Modifier and Type	Method and Description
void	Supervisor.checkpoint(String sequenceName, DataSourceMetadata previousCheckPoint, DataSourceMetadata currentCheckPoint) The definition of checkpoint is not very strict as currently it does not affect data or control path.
boolean	SupervisorManager.checkPointDataSourceMetadata(String supervisorId, String sequenceName, DataSourceMetadata previousDataSourceMetadata, DataSourceMetadata currentDataSourceMetadata)
void	Supervisor.reset(DataSourceMetadata dataSourceMetadata)
boolean	SupervisorManager.resetSupervisor(String id, DataSourceMetadata dataSourceMetadata)

Uses of DataSourceMetadata in io.druid.metadata

Methods in io.druid.metadata that return DataSourceMetadata

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

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

Modifier and Type	Method and Description
SegmentPublishResult	IndexerSQLMetadataStorageCoordinator.announceHistoricalSegments(Set<DataSegment> segments, DataSourceMetadata startMetadata, DataSourceMetadata endMetadata) Attempts to insert a set of segments to the metadata storage.
boolean	IndexerSQLMetadataStorageCoordinator.resetDataSourceMetadata(String dataSource, DataSourceMetadata dataSourceMetadata)
protected io.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.