reifydb_sub_flow::operator::window::aggregation

Struct Aggregation

pub struct Aggregation {
    pub node: FlowNodeId,
    pub parent: OperatorCell,
    pub compiled_group_by: Vec<CompiledExpr>,
    pub group_names: Vec<String>,
    pub aggregate_output_names: Vec<String>,
    pub slot_kinds: Option<Vec<SlotKind>>,
    pub slot_inputs: Vec<SlotInput>,
    pub compiled_slot_args: Vec<CompiledExpr>,
    pub compiled_outputs: Vec<CompiledExpr>,
    pub routines: Routines,
    pub runtime_context: RuntimeContext,
}

Fields§

§node: FlowNodeId§parent: OperatorCell§compiled_group_by: Vec<CompiledExpr>§group_names: Vec<String>§aggregate_output_names: Vec<String>§slot_kinds: Option<Vec<SlotKind>>§slot_inputs: Vec<SlotInput>§compiled_slot_args: Vec<CompiledExpr>§compiled_outputs: Vec<CompiledExpr>§routines: Routines§runtime_context: RuntimeContext

Struct Aggregation Copy item path

Fields§

Implementations§

impl Aggregation

pub fn new( node: FlowNodeId, parent: OperatorCell, group_by: Vec<Expression>, aggregations: Vec<Expression>, routines: Routines, runtime_context: RuntimeContext, context: AggregateContext, ) -> Self

pub fn create_window_key( &self, group_hash: Hash128, window_id: u64, ) -> EncodedKey

pub fn compute_groups( &self, columns: &Columns, ) -> Result<Vec<(Hash128, Vec<Value>)>>

pub fn evaluate_slot_inputs( &self, columns: &Columns, ) -> Result<Vec<ColumnWithName>>

pub fn build_contribution( &self, columns: &Columns, slot_cols: &[ColumnWithName], row_idx: usize, ) -> Vec<Option<Value>>

pub fn compute_outputs(&self, slot_values: &[Value]) -> Result<Vec<Value>>

pub fn build_engine_row( &self, group_values: &[Value], slot_values: &[Value], row_number: RowNumber, ts_nanos: u64, ) -> Result<Row>

pub fn current_timestamp(&self) -> u64

Auto Trait Implementations§

impl !RefUnwindSafe for Aggregation

impl !UnwindSafe for Aggregation

impl Freeze for Aggregation

impl Send for Aggregation

impl Sync for Aggregation

impl Unpin for Aggregation

impl UnsafeUnpin for Aggregation

Blanket Implementations§

impl<T> Any for Twhere T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<T> Borrow<T> for Twhere T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for Twhere T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DTwhere ST: ?Sized, DT: ?Sized,

impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DTwhere ST: ?Sized, DT: ?Sized,

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> GetSetFdFlags for T

fn get_fd_flags(&self) -> Result<FdFlags, Error>where T: AsFilelike,

fn new_set_fd_flags(&self, fd_flags: FdFlags) -> Result<SetFdFlags<T>, Error>where T: AsFilelike,

fn set_fd_flags(&mut self, set_fd_flags: SetFdFlags<T>) -> Result<(), Error>where T: Sized + AsFilelike,

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

fn in_current_span(self) -> Instrumented<Self>

impl<T, U> Into<U> for Twhere U: From<T>,

fn into(self) -> U

impl<T> IntoEither for T

fn into_either(self, into_left: bool) -> Either<Self, Self>

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>where F: FnOnce(&Self) -> bool,

impl<T> IntoRequest<T> for T

fn into_request(self) -> Request<T>

impl<L> LayerExt<L> for L

fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>where L: Layer<S>,

impl<T> Pointable for T

const ALIGN: usize

type Init = T

unsafe fn init(init: <T as Pointable>::Init) -> usize

unsafe fn deref<'a>(ptr: usize) -> &'a T

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

unsafe fn drop(ptr: usize)

impl<T> Pointee for T

type Pointer = u32

fn debug( pointer: <T as Pointee>::Pointer, f: &mut Formatter<'_>, ) -> Result<(), Error>

impl<T> Read<Exclusive, BecauseExclusive> for Twhere T: ?Sized,

impl<T> Same for T

type Output = T

impl<T, U> TryFrom<U> for Twhere U: Into<T>,

type Error = Infallible

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

impl<T, U> TryInto<U> for Twhere U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

impl<V, T> VZip<V> for Twhere V: MultiLane<T>,

fn vzip(self) -> V

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>where S: Into<Dispatch>,

fn with_current_subscriber(self) -> WithDispatch<Self>

Struct Aggregation

impl<T> Any for T
where T: 'static + ?Sized,

impl<T> Borrow<T> for T
where T: ?Sized,

impl<T> BorrowMut<T> for T
where T: ?Sized,

impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
where ST: ?Sized, DT: ?Sized,

impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
where ST: ?Sized, DT: ?Sized,

fn get_fd_flags(&self) -> Result<FdFlags, Error>
where T: AsFilelike,

fn new_set_fd_flags(&self, fd_flags: FdFlags) -> Result<SetFdFlags<T>, Error>
where T: AsFilelike,

fn set_fd_flags(&mut self, set_fd_flags: SetFdFlags<T>) -> Result<(), Error>
where T: Sized + AsFilelike,

impl<T, U> Into<U> for T
where U: From<T>,

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>
where L: Layer<S>,

impl<T> Read<Exclusive, BecauseExclusive> for T
where T: ?Sized,

impl<T, U> TryFrom<U> for T
where U: Into<T>,

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,