Struct rlink::core::runtime::TaskDescriptor [−][src]
pub struct TaskDescriptor { pub task_id: TaskId, pub operators: Vec<OperatorDescriptor>, pub input_split: InputSplit, pub daemon: bool, pub thread_id: String, pub terminated: bool, }
Fields
task_id: TaskId
operators: Vec<OperatorDescriptor>
input_split: InputSplit
daemon: bool
thread_id: String
terminated: bool
mark the task is Terminated
status
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 TaskDescriptor
impl Send for TaskDescriptor
impl Sync for TaskDescriptor
impl Unpin for TaskDescriptor
impl UnwindSafe for TaskDescriptor
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