Package org.apache.druid.segment.metadata

Class DefaultIndexingStateFingerprintMapper

java.lang.Object

org.apache.druid.segment.metadata.DefaultIndexingStateFingerprintMapper

All Implemented Interfaces:

IndexingStateFingerprintMapper

public class DefaultIndexingStateFingerprintMapper
extends Object
implements IndexingStateFingerprintMapper

Default implementation of IndexingStateFingerprintMapper that delegates to IndexingStateStorage for fingerprint generation and IndexingStateCache for state lookups.

Constructor Summary

Constructors

Constructor	Description
DefaultIndexingStateFingerprintMapper(IndexingStateCache indexingStateCache, com.fasterxml.jackson.databind.ObjectMapper jsonMapper)

Method Summary

Modifier and Type	Method	Description
String	generateFingerprint(String dataSource, CompactionState indexingState)	Generates a deterministic fingerprint for the given indexing state and datasource.
Optional<CompactionState>	getStateForFingerprint(String fingerprint)	Retrieves a compaction state by its fingerprint.

Methods inherited from class java.lang.Object

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

Constructor Details

DefaultIndexingStateFingerprintMapper

public DefaultIndexingStateFingerprintMapper(IndexingStateCache indexingStateCache,
 com.fasterxml.jackson.databind.ObjectMapper jsonMapper)

Method Details

generateFingerprint

public String generateFingerprint(String dataSource,
 CompactionState indexingState)

Description copied from interface: IndexingStateFingerprintMapper

Generates a deterministic fingerprint for the given indexing state and datasource.

The fingerprint is a SHA-256 hash of the datasource name and serialized indexing state that is globally unique in the segment space.

Specified by:

generateFingerprint in interface IndexingStateFingerprintMapper

Parameters:

dataSource - The datasource name

indexingState - The compaction configuration to fingerprint

Returns:

A hex-encoded SHA-256 fingerprint string

getStateForFingerprint

public Optional<CompactionState> getStateForFingerprint(String fingerprint)

Description copied from interface: IndexingStateFingerprintMapper

Retrieves a compaction state by its fingerprint.

Specified by:

getStateForFingerprint in interface IndexingStateFingerprintMapper

Parameters:

fingerprint - The fingerprint to look up

Returns:

The compaction state, or Optional.empty() if not found