Struct dataflow::source::DecodeResult [−][src]
pub struct DecodeResult {
pub key: Option<Result<Row, DecodeError>>,
pub value: Option<Result<Row, DecodeError>>,
pub position: Option<i64>,
pub upstream_time_millis: Option<i64>,
pub partition: PartitionId,
pub metadata: Row,
}
Expand description
The output of the decoding operator
Fields
key: Option<Result<Row, DecodeError>>
The decoded key
value: Option<Result<Row, DecodeError>>
The decoded value
position: Option<i64>
The index of the decoded value in the stream
upstream_time_millis: Option<i64>
The time the record was created in the upstream systsem, as milliseconds since the epoch
partition: PartitionId
The partition this record came from
metadata: Row
If this is a Kafka stream, the appropriate metadata
Trait Implementations
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
__D: Deserializer<'de>,
Deserialize this value from the given Serde deserializer. Read more
This method tests for self
and other
values to be equal, and is used
by ==
. Read more
This method tests for !=
.
Auto Trait Implementations
impl RefUnwindSafe for DecodeResult
impl Send for DecodeResult
impl Sync for DecodeResult
impl Unpin for DecodeResult
impl UnwindSafe for DecodeResult
Blanket Implementations
Mutably borrows from an owned value. Read more
Compare self to key
and return true
if they are equal.
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more