Struct SourceTransformRequest 

pub struct SourceTransformRequest {
    pub keys: Vec<String>,
    pub value: Vec<u8>,
    pub watermark: DateTime<Utc>,
    pub eventtime: DateTime<Utc>,
    pub headers: HashMap<String, String>,
    pub user_metadata: UserMetadata,
    pub system_metadata: SystemMetadata,
}

Incoming request to the Source Transformer.

Fields

keys: Vec<String>

keys are the keys in the (key, value) terminology of map/reduce paradigm.

value: Vec<u8>

value is the value in (key, value) terminology of map/reduce paradigm.

watermark: DateTime<Utc>

watermark represented by time is a guarantee that we will not see an element older than this time.

eventtime: DateTime<Utc>

event_time is the time of the element as seen at source or aligned after a reduce operation.

headers: HashMap<String, String>

Headers for the message.

user_metadata: UserMetadata

User metadata for the message.

system_metadata: SystemMetadata

System metadata for the message.

Trait Implementations

impl From<Request> for SourceTransformRequest

fn from(request: Request) -> Self

Converts to this type from the input type.