Uses of Class
org.apache.druid.metadata.ReplaceTaskLock

Packages that use ReplaceTaskLock

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

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

Method parameters in org.apache.druid.indexing.overlord with type arguments of type ReplaceTaskLock

Modifier and Type	Method	Description
SegmentPublishResult	IndexerMetadataStorageCoordinator.commitAppendSegments(Set<DataSegment> appendSegments, Map<DataSegment,ReplaceTaskLock> appendSegmentToReplaceLock, String taskAllocatorId, SegmentSchemaMapping segmentSchemaMapping)	Commits segments and corresponding schema created by an APPEND task.
SegmentPublishResult	IndexerMetadataStorageCoordinator.commitAppendSegmentsAndMetadata(Set<DataSegment> appendSegments, Map<DataSegment,ReplaceTaskLock> appendSegmentToReplaceLock, String supervisorId, DataSourceMetadata startMetadata, DataSourceMetadata endMetadata, String taskAllocatorId, SegmentSchemaMapping segmentSchemaMapping)	Commits segments created by an APPEND task.
int	IndexerMetadataStorageCoordinator.insertIntoUpgradeSegmentsTable(Map<DataSegment,ReplaceTaskLock> segmentToReplaceLock)	Inserts entries into the upgrade_segments table for segments that need to be upgraded to a new version when a REPLACE task finishes using IndexerMetadataStorageCoordinator.commitReplaceSegments(java.util.Set<org.apache.druid.timeline.DataSegment>, java.util.Set<org.apache.druid.metadata.ReplaceTaskLock>, org.apache.druid.segment.SegmentSchemaMapping).

Uses of ReplaceTaskLock in org.apache.druid.metadata

Method parameters in org.apache.druid.metadata with type arguments of type ReplaceTaskLock

Modifier and Type	Method	Description
SegmentPublishResult	IndexerSQLMetadataStorageCoordinator.commitAppendSegments(Set<DataSegment> appendSegments, Map<DataSegment,ReplaceTaskLock> appendSegmentToReplaceLock, String taskAllocatorId, SegmentSchemaMapping segmentSchemaMapping)
SegmentPublishResult	IndexerSQLMetadataStorageCoordinator.commitAppendSegmentsAndMetadata(Set<DataSegment> appendSegments, Map<DataSegment,ReplaceTaskLock> appendSegmentToReplaceLock, String supervisorId, DataSourceMetadata startMetadata, DataSourceMetadata endMetadata, String taskAllocatorId, SegmentSchemaMapping segmentSchemaMapping)
int	IndexerSQLMetadataStorageCoordinator.insertIntoUpgradeSegmentsTable(Map<DataSegment,ReplaceTaskLock> segmentToReplaceLock)