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§
fn descriptor(&self) -> IdentityExtractorDescriptor
Sourcefn extract(&self, artifact_bytes: &[u8]) -> BinocResult<Vec<IdentityToken>>
fn extract(&self, artifact_bytes: &[u8]) -> BinocResult<Vec<IdentityToken>>
Yield the ordered identity tokens for one artifact’s serialized bytes.