Struct rlink::core::function::Context [−][src]
pub struct Context { pub application_id: String, pub application_properties: Properties, pub operator_id: OperatorId, pub task_id: TaskId, pub checkpoint_id: CheckpointId, pub completed_checkpoint_id: Option<CheckpointId>, pub checkpoint_handle: Option<CheckpointHandle>, pub input_schema: FnSchema, pub output_schema: FnSchema, // some fields omitted }
Fields
application_id: String
application_properties: Properties
operator_id: OperatorId
task_id: TaskId
checkpoint_id: CheckpointId
completed_checkpoint_id: Option<CheckpointId>
checkpoint_handle: Option<CheckpointHandle>
input_schema: FnSchema
output_schema: FnSchema
Implementations
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
Auto Trait Implementations
impl RefUnwindSafe for Context
impl UnwindSafe for Context
Blanket Implementations
Mutably borrows from an owned value. Read more
pub fn clone_any_send(&self) -> Box<dyn CloneAny + Send + 'static, Global> where
T: Send,
pub fn clone_any_sync(&self) -> Box<dyn CloneAny + Sync + 'static, Global> where
T: Sync,
Instruments this type with the provided Span
, returning an
Instrumented
wrapper. Read more
type Output = T
type Output = T
Should always be Self