Skip to main content

IdentityExtractor

Trait IdentityExtractor 

Source
pub trait IdentityExtractor: Send + Sync {
    // Required methods
    fn descriptor(&self) -> IdentityExtractorDescriptor;
    fn extract(&self, artifact_bytes: &[u8]) -> BinocResult<Vec<IdentityToken>>;
}
Expand description

Derives an ordered sequence of opaque IdentityTokens for an artifact — the atomic sub-units (e.g. table rows) used by partition (split/merge) detection.

Keyed by ArtifactFormat and dispatched like writers/compaction/annotators; a format with no registered extractor is simply not partition-capable. The extractor rides the format, so every producer of that format gains partition capability for free — the parsers do nothing.

Required Methods§

Source

fn descriptor(&self) -> IdentityExtractorDescriptor

Source

fn extract(&self, artifact_bytes: &[u8]) -> BinocResult<Vec<IdentityToken>>

Yield the ordered identity tokens for one artifact’s serialized bytes.

Implementors§