pub struct TakeOperator { /* private fields */ }Implementations§
Source§impl TakeOperator
impl TakeOperator
pub fn new(parent: OperatorCell, node: FlowNodeId, limit: usize) -> Self
Trait Implementations§
Source§impl Operator for TakeOperator
impl Operator for TakeOperator
fn id(&self) -> FlowNodeId
fn capabilities(&self) -> &[OperatorCapability]
fn apply(&self, txn: &mut FlowTransaction, change: Change) -> Result<Change>
fn tick( &self, _txn: &mut FlowTransaction, _tick: Tick, ) -> Result<Option<Change>>
fn ticks(&self) -> Option<Duration>
Source§impl RawStatefulOperator for TakeOperator
impl RawStatefulOperator for TakeOperator
fn state_get( &self, txn: &mut FlowTransaction, key: &EncodedKey, ) -> Result<Option<EncodedRow>>
fn state_set( &self, txn: &mut FlowTransaction, key: &EncodedKey, value: EncodedRow, ) -> Result<()>
fn state_remove( &self, txn: &mut FlowTransaction, key: &EncodedKey, ) -> Result<()>
fn state_drop(&self, txn: &mut FlowTransaction, key: &EncodedKey) -> Result<()>
fn state_scan_all( &self, txn: &mut FlowTransaction, ) -> Result<Vec<(EncodedKey, EncodedRow)>>
fn state_range<'a>( &self, txn: &'a mut FlowTransaction, range: EncodedKeyRange, ) -> StateIterator<'a> ⓘ
fn state_clear(&self, txn: &mut FlowTransaction) -> Result<()>
fn internal_state_get( &self, txn: &mut FlowTransaction, key: &EncodedKey, ) -> Result<Option<EncodedRow>>
fn internal_state_set( &self, txn: &mut FlowTransaction, key: &EncodedKey, value: EncodedRow, ) -> Result<()>
fn internal_state_remove( &self, txn: &mut FlowTransaction, key: &EncodedKey, ) -> Result<()>
fn internal_state_drop( &self, txn: &mut FlowTransaction, key: &EncodedKey, ) -> Result<()>
Source§impl SingleStateful for TakeOperator
impl SingleStateful for TakeOperator
fn layout(&self) -> RowShape
fn key(&self) -> EncodedKey
fn create_state(&self) -> EncodedRow
fn load_state(&self, txn: &mut FlowTransaction) -> Result<EncodedRow>
fn save_state(&self, txn: &mut FlowTransaction, row: EncodedRow) -> Result<()>
fn update_state<F>(&self, txn: &mut FlowTransaction, f: F) -> Result<EncodedRow>
fn clear_state(&self, txn: &mut FlowTransaction) -> Result<()>
Auto Trait Implementations§
impl !RefUnwindSafe for TakeOperator
impl !UnwindSafe for TakeOperator
impl Freeze for TakeOperator
impl Send for TakeOperator
impl Sync for TakeOperator
impl Unpin for TakeOperator
impl UnsafeUnpin for TakeOperator
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
Source§impl<T> GetSetFdFlags for T
impl<T> GetSetFdFlags for T
Source§fn get_fd_flags(&self) -> Result<FdFlags, Error>where
T: AsFilelike,
fn get_fd_flags(&self) -> Result<FdFlags, Error>where
T: AsFilelike,
Query the “status” flags for the
self file descriptor.Source§fn new_set_fd_flags(&self, fd_flags: FdFlags) -> Result<SetFdFlags<T>, Error>where
T: AsFilelike,
fn new_set_fd_flags(&self, fd_flags: FdFlags) -> Result<SetFdFlags<T>, Error>where
T: AsFilelike,
Source§fn set_fd_flags(&mut self, set_fd_flags: SetFdFlags<T>) -> Result<(), Error>where
T: Sized + AsFilelike,
fn set_fd_flags(&mut self, set_fd_flags: SetFdFlags<T>) -> Result<(), Error>where
T: Sized + AsFilelike,
Set the “status” flags for the
self file descriptor. Read moreSource§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request