Package org.apache.druid.segment.metadata

Class NoopIndexingStateCache

java.lang.Object

org.apache.druid.segment.metadata.IndexingStateCache

org.apache.druid.segment.metadata.NoopIndexingStateCache

public class NoopIndexingStateCache
extends IndexingStateCache

No-op implementation of IndexingStateCache

Constructor Summary

Constructors

Constructor	Description
NoopIndexingStateCache()

Method Summary

Modifier and Type	Method	Description
void	clear()	Clears the cache.
Map<String,Integer>	getAndResetStats()
Optional<CompactionState>	getIndexingStateByFingerprint(String fingerprint)	Retrieves an indexing state by its fingerprint.
Map<String,CompactionState>	getPublishedIndexingStateMap()	Gets the full cached map (immutable copy).
boolean	isEnabled()
void	resetIndexingStatesForPublishedSegments(Map<String,CompactionState> fingerprintToStateMap)	Resets the cache with indexing states polled from the metadata store.

Methods inherited from class org.apache.druid.segment.metadata.IndexingStateCache

addIndexingState

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

NoopIndexingStateCache

public NoopIndexingStateCache()

Method Details

isEnabled

public boolean isEnabled()

Overrides:

isEnabled in class IndexingStateCache

resetIndexingStatesForPublishedSegments

public void resetIndexingStatesForPublishedSegments(Map<String,CompactionState> fingerprintToStateMap)

Description copied from class: IndexingStateCache

Resets the cache with indexing states polled from the metadata store. Called after each successful poll in HeapMemorySegmentMetadataCache.

Overrides:

resetIndexingStatesForPublishedSegments in class IndexingStateCache

Parameters:

fingerprintToStateMap - Complete fp:state map of all active indexing state fingerprints

getIndexingStateByFingerprint

public Optional<CompactionState> getIndexingStateByFingerprint(String fingerprint)

Description copied from class: IndexingStateCache

Retrieves an indexing state by its fingerprint. This is the indexing method for reading indexing states.

Overrides:

getIndexingStateByFingerprint in class IndexingStateCache

Parameters:

fingerprint - The fingerprint to look up

Returns:

The cached indexing state, or Optional.empty() if not cached

getPublishedIndexingStateMap

public Map<String,CompactionState> getPublishedIndexingStateMap()

Description copied from class: IndexingStateCache

Gets the full cached map (immutable copy). Used by HeapMemorySegmentMetadataCache for delta sync calculations.

Overrides:

getPublishedIndexingStateMap in class IndexingStateCache

clear

public void clear()

Description copied from class: IndexingStateCache

Clears the cache. Called when node stops being leader.

Overrides:

clear in class IndexingStateCache

getAndResetStats

public Map<String,Integer> getAndResetStats()

Overrides:

getAndResetStats in class IndexingStateCache

Returns:

Summary stats for metric emission