Struct ValueToKey 

pub struct ValueToKey { /* private fields */ }

Extract key fields from the value.

Useful for creating a message key from specific value fields. Stores the key in the “after” data as “__key” field.

Implementations

impl ValueToKey

pub fn new(fields: Vec<String>) -> Self

Create a new ValueToKey with specified fields.

pub fn with_fields<I, S>(fields: I) -> Self

where I: IntoIterator<Item = S>, S: Into<String>,

Create from field names.

pub fn extract_key(&self, event: &CdcEvent) -> Option<Value>

Extract key from event.

Trait Implementations

impl Clone for ValueToKey

fn clone(&self) -> ValueToKey

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ValueToKey

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Smt for ValueToKey

fn apply(&self, event: CdcEvent) -> Option<CdcEvent>

Transform a CDC event. Returns None to drop the event.

fn name(&self) -> &'static str

Get the transform name.