Struct dataflow::source::SourceData [−][src]
pub(crate) struct SourceData {
pub(crate) value: Option<Result<Row, DataflowError>>,
pub(crate) position: Option<i64>,
pub(crate) upstream_time_millis: Option<i64>,
}
Expand description
The data that we send from Upsert to the decode process
Fields
value: Option<Result<Row, DataflowError>>
The actual value
position: Option<i64>
The source’s reported position for this record
e.g. kafka offset or file location
upstream_time_millis: Option<i64>
The time that the upstream source believes that the message was created
Currently only applies to Kafka
Trait Implementations
Returns the “default value” for a type. Read more
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 SourceData
impl Send for SourceData
impl Sync for SourceData
impl Unpin for SourceData
impl UnwindSafe for SourceData
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