pub struct Indexed<K: IndexDomain, V: ValueDomain>(/* private fields */);Trait Implementations§
Source§impl<I: IndexDomain, V: ValueDomain, O: OrderState> AlignableArity<Indexed<I, V>, Keyed<I>> for Multiple<O>
impl<I: IndexDomain, V: ValueDomain, O: OrderState> AlignableArity<Indexed<I, V>, Keyed<I>> for Multiple<O>
Source§impl<I: IndexDomain, V: ValueDomain, O: OrderState> BucketFailureArity<Indexed<I, V>> for Multiple<O>
impl<I: IndexDomain, V: ValueDomain, O: OrderState> BucketFailureArity<Indexed<I, V>> for Multiple<O>
fn bucket_failure<'payload, 'a>(
payload: &'payload QueryResult<Self::Container<'a, <Indexed<I, V> as ElementShape>::Element<'a>>>,
) -> Option<&'payload Failure>where
Indexed<I, V>: 'a,
Source§impl<I: IndexDomain, V: ValueDomain> BucketFailureArity<Indexed<I, V>> for Single
impl<I: IndexDomain, V: ValueDomain> BucketFailureArity<Indexed<I, V>> for Single
fn bucket_failure<'payload, 'a>(
payload: &'payload QueryResult<Self::Container<'a, <Indexed<I, V> as ElementShape>::Element<'a>>>,
) -> Option<&'payload Failure>where
Indexed<I, V>: 'a,
Source§impl<I: IndexDomain, V: ValueDomain> BucketFailureArity<Indexed<I, V>> for Definite
impl<I: IndexDomain, V: ValueDomain> BucketFailureArity<Indexed<I, V>> for Definite
fn bucket_failure<'payload, 'a>(
payload: &'payload QueryResult<Self::Container<'a, <Indexed<I, V> as ElementShape>::Element<'a>>>,
) -> Option<&'payload Failure>where
Indexed<I, V>: 'a,
Source§impl<I: IndexDomain, V: ValueDomain> CacheableShape for Indexed<I, V>
impl<I: IndexDomain, V: ValueDomain> CacheableShape for Indexed<I, V>
type CachedElement = (<I as IndexDomain>::Owned, Result<<V as ValueDomain>::Owned, Box<Failure>>)
fn into_cached_element(element: Self::Element<'_>) -> Self::CachedElement
fn from_cached_element(cached: &Self::CachedElement) -> Self::Element<'_>
Source§impl<E: EntityAttributes> ElementKernel<Indexed<E, Unit>> for HasAttributeOperation
impl<E: EntityAttributes> ElementKernel<Indexed<E, Unit>> for HasAttributeOperation
Source§impl<P, C, W, S> ElementKernel<Indexed<ExpandedIndex<P, C>, W>> for ExpandToOperation<S>
impl<P, C, W, S> ElementKernel<Indexed<ExpandedIndex<P, C>, W>> for ExpandToOperation<S>
type Emission = <S as ArgumentSource<Keyed<P>>>::Retention
type OutShape = Indexed<ExpandedIndex<P, C>, <S as SourceDomain>::ValueDomain>
fn pipeline<'a>( _graphrecord: &'a GraphRecord, prepared: Self::Prepared<'a>, ) -> QueryResult<ElementPipeline<'a, Indexed<ExpandedIndex<P, C>, W>, Self>>
fn estimate(&self, input: Estimate, stats: &Stats<'_>) -> Estimate
Source§impl ElementKernel<Indexed<GraphRecordAttribute, Unit>> for ViaEdgesOperation
impl ElementKernel<Indexed<GraphRecordAttribute, Unit>> for ViaEdgesOperation
type Emission = Expanding<Unordered>
type OutShape = Indexed<ExpandedIndex<GraphRecordAttribute, u32>, EntityReference<u32>>
fn pipeline<'a>( graphrecord: &'a GraphRecord, prepared: Self::Prepared<'a>, ) -> QueryResult<ElementPipeline<'a, Indexed<NodeIndex, Unit>, Self>>
fn estimate(&self, input: Estimate, stats: &Stats<'_>) -> Estimate
Source§impl ElementKernel<Indexed<GraphRecordAttribute, Unit>> for ViaNeighborsOperation
impl ElementKernel<Indexed<GraphRecordAttribute, Unit>> for ViaNeighborsOperation
type Emission = Expanding<Unordered>
type OutShape = Indexed<ExpandedIndex<GraphRecordAttribute, GraphRecordAttribute>, EntityReference<GraphRecordAttribute>>
fn pipeline<'a>( graphrecord: &'a GraphRecord, prepared: Self::Prepared<'a>, ) -> QueryResult<ElementPipeline<'a, Indexed<NodeIndex, Unit>, Self>>
fn estimate(&self, input: Estimate, stats: &Stats<'_>) -> Estimate
Source§impl<E: EntityDomain, I: IndexDomain> ElementKernel<Indexed<I, EntityReference<E>>> for IndexOperation
impl<E: EntityDomain, I: IndexDomain> ElementKernel<Indexed<I, EntityReference<E>>> for IndexOperation
type Emission = Preserving
type OutShape = Indexed<I, IndexValue<E>>
fn pipeline<'a>( _graphrecord: &'a GraphRecord, _prepared: Self::Prepared<'a>, ) -> QueryResult<ElementPipeline<'a, Indexed<I, EntityReference<E>>, Self>>
fn estimate(&self, input: Estimate, _stats: &Stats<'_>) -> Estimate
Source§impl<E: EntityAttributes, I: IndexDomain> ElementKernel<Indexed<I, EntityReference<E>>> for AttributeOperation
impl<E: EntityAttributes, I: IndexDomain> ElementKernel<Indexed<I, EntityReference<E>>> for AttributeOperation
type Emission = Preserving
type OutShape = Indexed<I, Scalar>
fn pipeline<'a>( graphrecord: &'a GraphRecord, prepared: Self::Prepared<'a>, ) -> QueryResult<ElementPipeline<'a, Indexed<I, EntityReference<E>>, Self>>
fn estimate(&self, input: Estimate, stats: &Stats<'_>) -> Estimate
Source§impl<E: EntityAttributes, I: IndexDomain> ElementKernel<Indexed<I, EntityReference<E>>> for AttributesOperation
impl<E: EntityAttributes, I: IndexDomain> ElementKernel<Indexed<I, EntityReference<E>>> for AttributesOperation
type Emission = Expanding<Unordered>
type OutShape = Indexed<ExpandedIndex<I, AttributeName>, AttributeName>
fn pipeline<'a>( graphrecord: &'a GraphRecord, _prepared: Self::Prepared<'a>, ) -> QueryResult<ElementPipeline<'a, Indexed<I, EntityReference<E>>, Self>>
fn estimate(&self, input: Estimate, stats: &Stats<'_>) -> Estimate
Source§impl<E: EntityAttributes, I: IndexDomain> ElementKernel<Indexed<I, EntityReference<E>>> for HasAttributeOperation
impl<E: EntityAttributes, I: IndexDomain> ElementKernel<Indexed<I, EntityReference<E>>> for HasAttributeOperation
type Emission = Preserving
type OutShape = Indexed<I, Mask>
fn pipeline<'a>( graphrecord: &'a GraphRecord, prepared: Self::Prepared<'a>, ) -> QueryResult<ElementPipeline<'a, Indexed<I, EntityReference<E>>, Self>>
fn estimate(&self, input: Estimate, stats: &Stats<'_>) -> Estimate
Source§impl<E: IndicesInGroup, I: IndexDomain> ElementKernel<Indexed<I, EntityReference<E>>> for InGroupOperation
impl<E: IndicesInGroup, I: IndexDomain> ElementKernel<Indexed<I, EntityReference<E>>> for InGroupOperation
type Emission = Preserving
type OutShape = Indexed<I, Mask>
fn pipeline<'a>( graphrecord: &'a GraphRecord, prepared: Self::Prepared<'a>, ) -> QueryResult<ElementPipeline<'a, Indexed<I, EntityReference<E>>, Self>>
fn estimate(&self, input: Estimate, _stats: &Stats<'_>) -> Estimate
Source§impl<I: IndexDomain> ElementKernel<Indexed<I, EntityReference<GraphRecordAttribute>>> for ViaEdgesOperation
impl<I: IndexDomain> ElementKernel<Indexed<I, EntityReference<GraphRecordAttribute>>> for ViaEdgesOperation
type Emission = Expanding<Unordered>
type OutShape = Indexed<ExpandedIndex<I, u32>, EntityReference<u32>>
fn pipeline<'a>( graphrecord: &'a GraphRecord, prepared: Self::Prepared<'a>, ) -> QueryResult<ElementPipeline<'a, Indexed<I, EntityReference<NodeIndex>>, Self>>
fn estimate(&self, input: Estimate, stats: &Stats<'_>) -> Estimate
Source§impl<I: IndexDomain> ElementKernel<Indexed<I, EntityReference<GraphRecordAttribute>>> for ViaNeighborsOperation
impl<I: IndexDomain> ElementKernel<Indexed<I, EntityReference<GraphRecordAttribute>>> for ViaNeighborsOperation
type Emission = Expanding<Unordered>
type OutShape = Indexed<ExpandedIndex<I, GraphRecordAttribute>, EntityReference<GraphRecordAttribute>>
fn pipeline<'a>( graphrecord: &'a GraphRecord, prepared: Self::Prepared<'a>, ) -> QueryResult<ElementPipeline<'a, Indexed<I, EntityReference<NodeIndex>>, Self>>
fn estimate(&self, input: Estimate, stats: &Stats<'_>) -> Estimate
Source§impl<I: IndexDomain> ElementKernel<Indexed<I, EntityReference<u32>>> for EndpointOperation
impl<I: IndexDomain> ElementKernel<Indexed<I, EntityReference<u32>>> for EndpointOperation
type Emission = Preserving
type OutShape = Indexed<I, EntityReference<GraphRecordAttribute>>
fn pipeline<'a>( graphrecord: &'a GraphRecord, prepared: Self::Prepared<'a>, ) -> QueryResult<ElementPipeline<'a, Indexed<I, EntityReference<EdgeIndex>>, Self>>
fn estimate(&self, input: Estimate, stats: &Stats<'_>) -> Estimate
Source§impl<I: IndexDomain> ElementKernel<Indexed<I, EntityReference<u32>>> for ViaNodesOperation
impl<I: IndexDomain> ElementKernel<Indexed<I, EntityReference<u32>>> for ViaNodesOperation
type Emission = Expanding<Ordered>
type OutShape = Indexed<ExpandedIndex<I, EdgeEndpointRole>, EntityReference<GraphRecordAttribute>>
fn pipeline<'a>( graphrecord: &'a GraphRecord, _prepared: Self::Prepared<'a>, ) -> QueryResult<ElementPipeline<'a, Indexed<I, EntityReference<EdgeIndex>>, Self>>
fn estimate(&self, input: Estimate, stats: &Stats<'_>) -> Estimate
Source§impl<I: IndexDomain> ElementKernel<Indexed<I, FailureKindValue>> for ErrorKindNameOperation
impl<I: IndexDomain> ElementKernel<Indexed<I, FailureKindValue>> for ErrorKindNameOperation
type Emission = Preserving
type OutShape = Indexed<I, Scalar>
fn pipeline<'a>( _graphrecord: &'a GraphRecord, _prepared: Self::Prepared<'a>, ) -> QueryResult<ElementPipeline<'a, Indexed<I, FailureKindValue>, Self>>
fn estimate(&self, input: Estimate, stats: &Stats<'_>) -> Estimate
Source§impl<I: IndexDomain> ElementKernel<Indexed<I, FailureValue>> for ErrorKindOperation
impl<I: IndexDomain> ElementKernel<Indexed<I, FailureValue>> for ErrorKindOperation
type Emission = Preserving
type OutShape = Indexed<I, FailureKindValue>
fn pipeline<'a>( _graphrecord: &'a GraphRecord, _prepared: Self::Prepared<'a>, ) -> QueryResult<ElementPipeline<'a, Indexed<I, FailureValue>, Self>>
fn estimate(&self, input: Estimate, stats: &Stats<'_>) -> Estimate
Source§impl<I: IndexDomain, D: Diagnostic> ElementKernel<Indexed<I, FailureValue>> for IsErrorKindOperation<D>
impl<I: IndexDomain, D: Diagnostic> ElementKernel<Indexed<I, FailureValue>> for IsErrorKindOperation<D>
type Emission = Preserving
type OutShape = Indexed<I, Mask>
fn pipeline<'a>( _graphrecord: &'a GraphRecord, _prepared: Self::Prepared<'a>, ) -> QueryResult<ElementPipeline<'a, Indexed<I, FailureValue>, Self>>
fn estimate(&self, input: Estimate, stats: &Stats<'_>) -> Estimate
Source§impl<I: IndexDomain, G: ErrorGroup> ElementKernel<Indexed<I, FailureValue>> for InErrorGroupOperation<G>
impl<I: IndexDomain, G: ErrorGroup> ElementKernel<Indexed<I, FailureValue>> for InErrorGroupOperation<G>
type Emission = Preserving
type OutShape = Indexed<I, Mask>
fn pipeline<'a>( _graphrecord: &'a GraphRecord, _prepared: Self::Prepared<'a>, ) -> QueryResult<ElementPipeline<'a, Indexed<I, FailureValue>, Self>>
fn estimate(&self, input: Estimate, stats: &Stats<'_>) -> Estimate
Source§impl<I: IndexDomain, C: Error + 'static> ElementKernel<Indexed<I, FailureValue>> for HasErrorCauseOperation<C>
impl<I: IndexDomain, C: Error + 'static> ElementKernel<Indexed<I, FailureValue>> for HasErrorCauseOperation<C>
type Emission = Preserving
type OutShape = Indexed<I, Mask>
fn pipeline<'a>( _graphrecord: &'a GraphRecord, _prepared: Self::Prepared<'a>, ) -> QueryResult<ElementPipeline<'a, Indexed<I, FailureValue>, Self>>
fn estimate(&self, input: Estimate, stats: &Stats<'_>) -> Estimate
Source§impl<E: EntityDomain, I: IndexDomain> ElementKernel<Indexed<I, IndexValue<E>>> for ResolveOperation
impl<E: EntityDomain, I: IndexDomain> ElementKernel<Indexed<I, IndexValue<E>>> for ResolveOperation
type Emission = Preserving
type OutShape = Indexed<I, EntityReference<E>>
fn pipeline<'a>( graphrecord: &'a GraphRecord, _prepared: Self::Prepared<'a>, ) -> QueryResult<ElementPipeline<'a, Indexed<I, IndexValue<E>>, Self>>
fn estimate(&self, input: Estimate, stats: &Stats<'_>) -> Estimate
Source§impl<I: IndexDomain, P: IndexDomain, C: IndexDomain> ElementKernel<Indexed<I, IndexValue<ExpandedIndex<P, C>>>> for ParentIndexOperation
impl<I: IndexDomain, P: IndexDomain, C: IndexDomain> ElementKernel<Indexed<I, IndexValue<ExpandedIndex<P, C>>>> for ParentIndexOperation
type Emission = Preserving
type OutShape = Indexed<I, IndexValue<P>>
fn pipeline<'a>( _graphrecord: &'a GraphRecord, _prepared: Self::Prepared<'a>, ) -> QueryResult<ElementPipeline<'a, Indexed<I, IndexValue<ExpandedIndex<P, C>>>, Self>>
fn estimate(&self, input: Estimate, stats: &Stats<'_>) -> Estimate
Source§impl<I: IndexDomain, P: IndexDomain, C: IndexDomain> ElementKernel<Indexed<I, IndexValue<ExpandedIndex<P, C>>>> for ChildIndexOperation
impl<I: IndexDomain, P: IndexDomain, C: IndexDomain> ElementKernel<Indexed<I, IndexValue<ExpandedIndex<P, C>>>> for ChildIndexOperation
type Emission = Preserving
type OutShape = Indexed<I, IndexValue<C>>
fn pipeline<'a>( _graphrecord: &'a GraphRecord, _prepared: Self::Prepared<'a>, ) -> QueryResult<ElementPipeline<'a, Indexed<I, IndexValue<ExpandedIndex<P, C>>>, Self>>
fn estimate(&self, input: Estimate, stats: &Stats<'_>) -> Estimate
Source§impl<I, M> ElementKernel<Indexed<I, Mask>> for AndOperation<M>
impl<I, M> ElementKernel<Indexed<I, Mask>> for AndOperation<M>
type Emission = <M as ArgumentSource<Keyed<I>, Mask>>::Retention
type OutShape = Indexed<I, Mask>
fn pipeline<'a>( _graphrecord: &'a GraphRecord, prepared: Self::Prepared<'a>, ) -> QueryResult<ElementPipeline<'a, Indexed<I, Mask>, Self>>
fn estimate(&self, input: Estimate, stats: &Stats<'_>) -> Estimate
Source§impl<I, M> ElementKernel<Indexed<I, Mask>> for ExclusiveOrOperation<M>
impl<I, M> ElementKernel<Indexed<I, Mask>> for ExclusiveOrOperation<M>
type Emission = <M as ArgumentSource<Keyed<I>, Mask>>::Retention
type OutShape = Indexed<I, Mask>
fn pipeline<'a>( _graphrecord: &'a GraphRecord, prepared: Self::Prepared<'a>, ) -> QueryResult<ElementPipeline<'a, Indexed<I, Mask>, Self>>
fn estimate(&self, input: Estimate, stats: &Stats<'_>) -> Estimate
Source§impl<I: IndexDomain> ElementKernel<Indexed<I, Mask>> for NotOperation
impl<I: IndexDomain> ElementKernel<Indexed<I, Mask>> for NotOperation
Source§impl<I, M> ElementKernel<Indexed<I, Mask>> for OrOperation<M>
impl<I, M> ElementKernel<Indexed<I, Mask>> for OrOperation<M>
type Emission = <M as ArgumentSource<Keyed<I>, Mask>>::Retention
type OutShape = Indexed<I, Mask>
fn pipeline<'a>( _graphrecord: &'a GraphRecord, prepared: Self::Prepared<'a>, ) -> QueryResult<ElementPipeline<'a, Indexed<I, Mask>, Self>>
fn estimate(&self, input: Estimate, stats: &Stats<'_>) -> Estimate
Source§impl<I, S, T> ElementKernel<Indexed<I, S>> for TransitionOperation<T>
impl<I, S, T> ElementKernel<Indexed<I, S>> for TransitionOperation<T>
Source§impl<I: EntityAttributes> ElementKernel<Indexed<I, Unit>> for AttributeOperation
impl<I: EntityAttributes> ElementKernel<Indexed<I, Unit>> for AttributeOperation
Source§impl<I: EntityAttributes> ElementKernel<Indexed<I, Unit>> for AttributesOperation
impl<I: EntityAttributes> ElementKernel<Indexed<I, Unit>> for AttributesOperation
type Emission = Expanding<Unordered>
type OutShape = Indexed<ExpandedIndex<I, AttributeName>, AttributeName>
fn pipeline<'a>( graphrecord: &'a GraphRecord, _prepared: Self::Prepared<'a>, ) -> QueryResult<ElementPipeline<'a, Indexed<I, Unit>, Self>>
fn estimate(&self, input: Estimate, stats: &Stats<'_>) -> Estimate
Source§impl<I: IndicesInGroup> ElementKernel<Indexed<I, Unit>> for InGroupOperation
impl<I: IndicesInGroup> ElementKernel<Indexed<I, Unit>> for InGroupOperation
Source§impl<I, V, A> ElementKernel<Indexed<I, V>> for AddOperation<A>
impl<I, V, A> ElementKernel<Indexed<I, V>> for AddOperation<A>
type Emission = <A as ArgumentSource<Keyed<I>, V>>::Retention
type OutShape = Indexed<I, V>
fn pipeline<'a>( _graphrecord: &'a GraphRecord, prepared: Self::Prepared<'a>, ) -> QueryResult<ElementPipeline<'a, Indexed<I, V>, Self>>
fn estimate(&self, input: Estimate, _stats: &Stats<'_>) -> Estimate
Source§impl<I, V, A> ElementKernel<Indexed<I, V>> for DivideOperation<A>
impl<I, V, A> ElementKernel<Indexed<I, V>> for DivideOperation<A>
type Emission = <A as ArgumentSource<Keyed<I>, V>>::Retention
type OutShape = Indexed<I, V>
fn pipeline<'a>( _graphrecord: &'a GraphRecord, prepared: Self::Prepared<'a>, ) -> QueryResult<ElementPipeline<'a, Indexed<I, V>, Self>>
fn estimate(&self, input: Estimate, _stats: &Stats<'_>) -> Estimate
Source§impl<I, V, A> ElementKernel<Indexed<I, V>> for ModuloOperation<A>
impl<I, V, A> ElementKernel<Indexed<I, V>> for ModuloOperation<A>
type Emission = <A as ArgumentSource<Keyed<I>, V>>::Retention
type OutShape = Indexed<I, V>
fn pipeline<'a>( _graphrecord: &'a GraphRecord, prepared: Self::Prepared<'a>, ) -> QueryResult<ElementPipeline<'a, Indexed<I, V>, Self>>
fn estimate(&self, input: Estimate, _stats: &Stats<'_>) -> Estimate
Source§impl<I, V, A> ElementKernel<Indexed<I, V>> for MultiplyOperation<A>
impl<I, V, A> ElementKernel<Indexed<I, V>> for MultiplyOperation<A>
type Emission = <A as ArgumentSource<Keyed<I>, V>>::Retention
type OutShape = Indexed<I, V>
fn pipeline<'a>( _graphrecord: &'a GraphRecord, prepared: Self::Prepared<'a>, ) -> QueryResult<ElementPipeline<'a, Indexed<I, V>, Self>>
fn estimate(&self, input: Estimate, _stats: &Stats<'_>) -> Estimate
Source§impl<I, V, A> ElementKernel<Indexed<I, V>> for PowerOperation<A>
impl<I, V, A> ElementKernel<Indexed<I, V>> for PowerOperation<A>
type Emission = <A as ArgumentSource<Keyed<I>, V>>::Retention
type OutShape = Indexed<I, V>
fn pipeline<'a>( _graphrecord: &'a GraphRecord, prepared: Self::Prepared<'a>, ) -> QueryResult<ElementPipeline<'a, Indexed<I, V>, Self>>
fn estimate(&self, input: Estimate, _stats: &Stats<'_>) -> Estimate
Source§impl<I, V, A> ElementKernel<Indexed<I, V>> for SubtractOperation<A>
impl<I, V, A> ElementKernel<Indexed<I, V>> for SubtractOperation<A>
type Emission = <A as ArgumentSource<Keyed<I>, V>>::Retention
type OutShape = Indexed<I, V>
fn pipeline<'a>( _graphrecord: &'a GraphRecord, prepared: Self::Prepared<'a>, ) -> QueryResult<ElementPipeline<'a, Indexed<I, V>, Self>>
fn estimate(&self, input: Estimate, _stats: &Stats<'_>) -> Estimate
Source§impl<I, V, A> ElementKernel<Indexed<I, V>> for EqualToOperation<A>
impl<I, V, A> ElementKernel<Indexed<I, V>> for EqualToOperation<A>
type Emission = <A as ArgumentSource<Keyed<I>, V>>::Retention
type OutShape = Indexed<I, Mask>
fn pipeline<'a>( _graphrecord: &'a GraphRecord, prepared: Self::Prepared<'a>, ) -> QueryResult<ElementPipeline<'a, Indexed<I, V>, Self>>
fn estimate(&self, input: Estimate, _stats: &Stats<'_>) -> Estimate
Source§impl<I, V, A> ElementKernel<Indexed<I, V>> for GreaterThanOperation<A>where
I: IndexDomain,
V: ValueOrdering,
A: ArgumentSource<Keyed<I>, V>,
V::Owned: Debug + Display + Send + Sync,
impl<I, V, A> ElementKernel<Indexed<I, V>> for GreaterThanOperation<A>where
I: IndexDomain,
V: ValueOrdering,
A: ArgumentSource<Keyed<I>, V>,
V::Owned: Debug + Display + Send + Sync,
type Emission = <A as ArgumentSource<Keyed<I>, V>>::Retention
type OutShape = Indexed<I, Mask>
fn pipeline<'a>( _graphrecord: &'a GraphRecord, prepared: Self::Prepared<'a>, ) -> QueryResult<ElementPipeline<'a, Indexed<I, V>, Self>>
fn estimate(&self, input: Estimate, _stats: &Stats<'_>) -> Estimate
Source§impl<I, V, A> ElementKernel<Indexed<I, V>> for GreaterThanOrEqualToOperation<A>where
I: IndexDomain,
V: ValueOrdering,
A: ArgumentSource<Keyed<I>, V>,
V::Owned: Debug + Display + Send + Sync,
impl<I, V, A> ElementKernel<Indexed<I, V>> for GreaterThanOrEqualToOperation<A>where
I: IndexDomain,
V: ValueOrdering,
A: ArgumentSource<Keyed<I>, V>,
V::Owned: Debug + Display + Send + Sync,
type Emission = <A as ArgumentSource<Keyed<I>, V>>::Retention
type OutShape = Indexed<I, Mask>
fn pipeline<'a>( _graphrecord: &'a GraphRecord, prepared: Self::Prepared<'a>, ) -> QueryResult<ElementPipeline<'a, Indexed<I, V>, Self>>
fn estimate(&self, input: Estimate, _stats: &Stats<'_>) -> Estimate
Source§impl<I, V, A> ElementKernel<Indexed<I, V>> for LessThanOperation<A>where
I: IndexDomain,
V: ValueOrdering,
A: ArgumentSource<Keyed<I>, V>,
V::Owned: Debug + Display + Send + Sync,
impl<I, V, A> ElementKernel<Indexed<I, V>> for LessThanOperation<A>where
I: IndexDomain,
V: ValueOrdering,
A: ArgumentSource<Keyed<I>, V>,
V::Owned: Debug + Display + Send + Sync,
type Emission = <A as ArgumentSource<Keyed<I>, V>>::Retention
type OutShape = Indexed<I, Mask>
fn pipeline<'a>( _graphrecord: &'a GraphRecord, prepared: Self::Prepared<'a>, ) -> QueryResult<ElementPipeline<'a, Indexed<I, V>, Self>>
fn estimate(&self, input: Estimate, _stats: &Stats<'_>) -> Estimate
Source§impl<I, V, A> ElementKernel<Indexed<I, V>> for LessThanOrEqualToOperation<A>where
I: IndexDomain,
V: ValueOrdering,
A: ArgumentSource<Keyed<I>, V>,
V::Owned: Debug + Display + Send + Sync,
impl<I, V, A> ElementKernel<Indexed<I, V>> for LessThanOrEqualToOperation<A>where
I: IndexDomain,
V: ValueOrdering,
A: ArgumentSource<Keyed<I>, V>,
V::Owned: Debug + Display + Send + Sync,
type Emission = <A as ArgumentSource<Keyed<I>, V>>::Retention
type OutShape = Indexed<I, Mask>
fn pipeline<'a>( _graphrecord: &'a GraphRecord, prepared: Self::Prepared<'a>, ) -> QueryResult<ElementPipeline<'a, Indexed<I, V>, Self>>
fn estimate(&self, input: Estimate, _stats: &Stats<'_>) -> Estimate
Source§impl<I, V, A> ElementKernel<Indexed<I, V>> for NotEqualToOperation<A>
impl<I, V, A> ElementKernel<Indexed<I, V>> for NotEqualToOperation<A>
type Emission = <A as ArgumentSource<Keyed<I>, V>>::Retention
type OutShape = Indexed<I, Mask>
fn pipeline<'a>( _graphrecord: &'a GraphRecord, prepared: Self::Prepared<'a>, ) -> QueryResult<ElementPipeline<'a, Indexed<I, V>, Self>>
fn estimate(&self, input: Estimate, _stats: &Stats<'_>) -> Estimate
Source§impl<I, V, T> ElementKernel<Indexed<I, V>> for CastOperation<T>
impl<I, V, T> ElementKernel<Indexed<I, V>> for CastOperation<T>
Source§impl<I: IndexDomain, V: BareValueDomain> ElementKernel<Indexed<I, V>> for DiscardIndexOperation
impl<I: IndexDomain, V: BareValueDomain> ElementKernel<Indexed<I, V>> for DiscardIndexOperation
Source§impl<I: IndexDomain, V: ValueDomain> ElementKernel<Indexed<I, V>> for DiscardValueOperation
impl<I: IndexDomain, V: ValueDomain> ElementKernel<Indexed<I, V>> for DiscardValueOperation
Source§impl<I: IndexDomain, V: ValueDomain> ElementKernel<Indexed<I, V>> for ErrorsOperation
impl<I: IndexDomain, V: ValueDomain> ElementKernel<Indexed<I, V>> for ErrorsOperation
Source§impl<I: IndexDomain, V: ValueDomain> ElementKernel<Indexed<I, V>> for Drop
impl<I: IndexDomain, V: ValueDomain> ElementKernel<Indexed<I, V>> for Drop
Source§impl<I: IndexDomain, V: ValueDomain, D: Diagnostic> ElementKernel<Indexed<I, V>> for DropErrorsOf<D>
impl<I: IndexDomain, V: ValueDomain, D: Diagnostic> ElementKernel<Indexed<I, V>> for DropErrorsOf<D>
Source§impl<I: IndexDomain, V: ValueDomain, G: ErrorGroup> ElementKernel<Indexed<I, V>> for DropErrorsIn<G>
impl<I: IndexDomain, V: ValueDomain, G: ErrorGroup> ElementKernel<Indexed<I, V>> for DropErrorsIn<G>
Source§impl<I: IndexDomain, V: ValueDomain, C: Error + 'static> ElementKernel<Indexed<I, V>> for DropErrorsWithCause<C>
impl<I: IndexDomain, V: ValueDomain, C: Error + 'static> ElementKernel<Indexed<I, V>> for DropErrorsWithCause<C>
Source§impl<I, V, R> ElementKernel<Indexed<I, V>> for Replace<R>
impl<I, V, R> ElementKernel<Indexed<I, V>> for Replace<R>
type Emission = <R as ArgumentSource<Keyed<I>, V>>::Retention
type OutShape = Indexed<I, V>
fn pipeline<'a>( _graphrecord: &'a GraphRecord, prepared: Self::Prepared<'a>, ) -> QueryResult<ElementPipeline<'a, Indexed<I, V>, Self>>
fn estimate(&self, input: Estimate, stats: &Stats<'_>) -> Estimate
Source§impl<I, V, D, R> ElementKernel<Indexed<I, V>> for ReplaceErrorsOf<D, R>
impl<I, V, D, R> ElementKernel<Indexed<I, V>> for ReplaceErrorsOf<D, R>
type Emission = <R as ArgumentSource<Keyed<I>, V>>::Retention
type OutShape = Indexed<I, V>
fn pipeline<'a>( _graphrecord: &'a GraphRecord, prepared: Self::Prepared<'a>, ) -> QueryResult<ElementPipeline<'a, Indexed<I, V>, Self>>
fn estimate(&self, input: Estimate, stats: &Stats<'_>) -> Estimate
Source§impl<I, V, G, R> ElementKernel<Indexed<I, V>> for ReplaceErrorsIn<G, R>
impl<I, V, G, R> ElementKernel<Indexed<I, V>> for ReplaceErrorsIn<G, R>
type Emission = <R as ArgumentSource<Keyed<I>, V>>::Retention
type OutShape = Indexed<I, V>
fn pipeline<'a>( _graphrecord: &'a GraphRecord, prepared: Self::Prepared<'a>, ) -> QueryResult<ElementPipeline<'a, Indexed<I, V>, Self>>
fn estimate(&self, input: Estimate, stats: &Stats<'_>) -> Estimate
Source§impl<I, V, C, R> ElementKernel<Indexed<I, V>> for ReplaceErrorsWithCause<C, R>
impl<I, V, C, R> ElementKernel<Indexed<I, V>> for ReplaceErrorsWithCause<C, R>
type Emission = <R as ArgumentSource<Keyed<I>, V>>::Retention
type OutShape = Indexed<I, V>
fn pipeline<'a>( _graphrecord: &'a GraphRecord, prepared: Self::Prepared<'a>, ) -> QueryResult<ElementPipeline<'a, Indexed<I, V>, Self>>
fn estimate(&self, input: Estimate, stats: &Stats<'_>) -> Estimate
Source§impl<I: IndexDomain, V: ValueScalarKindTest> ElementKernel<Indexed<I, V>> for IsBoolOperation
impl<I: IndexDomain, V: ValueScalarKindTest> ElementKernel<Indexed<I, V>> for IsBoolOperation
Source§impl<I: IndexDomain, V: ValueScalarKindTest> ElementKernel<Indexed<I, V>> for IsDateTimeOperation
impl<I: IndexDomain, V: ValueScalarKindTest> ElementKernel<Indexed<I, V>> for IsDateTimeOperation
Source§impl<I: IndexDomain, V: ValueScalarKindTest> ElementKernel<Indexed<I, V>> for IsDurationOperation
impl<I: IndexDomain, V: ValueScalarKindTest> ElementKernel<Indexed<I, V>> for IsDurationOperation
Source§impl<I: IndexDomain, V: ValueScalarKindTest> ElementKernel<Indexed<I, V>> for IsFloatOperation
impl<I: IndexDomain, V: ValueScalarKindTest> ElementKernel<Indexed<I, V>> for IsFloatOperation
Source§impl<I: IndexDomain, V: ValueKindTest> ElementKernel<Indexed<I, V>> for IsIntOperation
impl<I: IndexDomain, V: ValueKindTest> ElementKernel<Indexed<I, V>> for IsIntOperation
Source§impl<I: IndexDomain, V: ValueScalarKindTest> ElementKernel<Indexed<I, V>> for IsNullOperation
impl<I: IndexDomain, V: ValueScalarKindTest> ElementKernel<Indexed<I, V>> for IsNullOperation
Source§impl<I: IndexDomain, V: ValueKindTest> ElementKernel<Indexed<I, V>> for IsStringOperation
impl<I: IndexDomain, V: ValueKindTest> ElementKernel<Indexed<I, V>> for IsStringOperation
Source§impl<I, V, A> ElementKernel<Indexed<I, V>> for IsInOperation<A>
impl<I, V, A> ElementKernel<Indexed<I, V>> for IsInOperation<A>
Source§impl<I, V> ElementKernel<Indexed<I, V>> for AbsoluteOperationwhere
I: IndexDomain,
V: ValueAbsolute,
impl<I, V> ElementKernel<Indexed<I, V>> for AbsoluteOperationwhere
I: IndexDomain,
V: ValueAbsolute,
Source§impl<I, V> ElementKernel<Indexed<I, V>> for CeilOperationwhere
I: IndexDomain,
V: ValueCeil,
impl<I, V> ElementKernel<Indexed<I, V>> for CeilOperationwhere
I: IndexDomain,
V: ValueCeil,
Source§impl<I, V, L, U> ElementKernel<Indexed<I, V>> for ClipOperation<L, U>
impl<I, V, L, U> ElementKernel<Indexed<I, V>> for ClipOperation<L, U>
type Emission = <<L as ArgumentSource<Keyed<I>, V>>::Retention as Retention>::Then<<U as ArgumentSource<Keyed<I>, V>>::Retention>
type OutShape = Indexed<I, V>
fn pipeline<'a>( _graphrecord: &'a GraphRecord, prepared: Self::Prepared<'a>, ) -> QueryResult<ElementPipeline<'a, Indexed<I, V>, Self>>
fn estimate(&self, input: Estimate, _stats: &Stats<'_>) -> Estimate
Source§impl<I, V> ElementKernel<Indexed<I, V>> for CubeRootOperationwhere
I: IndexDomain,
V: ValueCubeRoot,
impl<I, V> ElementKernel<Indexed<I, V>> for CubeRootOperationwhere
I: IndexDomain,
V: ValueCubeRoot,
Source§impl<I, V> ElementKernel<Indexed<I, V>> for ExponentialOperationwhere
I: IndexDomain,
V: ValueExponential,
impl<I, V> ElementKernel<Indexed<I, V>> for ExponentialOperationwhere
I: IndexDomain,
V: ValueExponential,
Source§impl<I, V> ElementKernel<Indexed<I, V>> for FloorOperationwhere
I: IndexDomain,
V: ValueFloor,
impl<I, V> ElementKernel<Indexed<I, V>> for FloorOperationwhere
I: IndexDomain,
V: ValueFloor,
Source§impl<I, V> ElementKernel<Indexed<I, V>> for LogarithmOperationwhere
I: IndexDomain,
V: ValueLogarithm,
impl<I, V> ElementKernel<Indexed<I, V>> for LogarithmOperationwhere
I: IndexDomain,
V: ValueLogarithm,
Source§impl<I, V> ElementKernel<Indexed<I, V>> for NegateOperationwhere
I: IndexDomain,
V: ValueNegate,
impl<I, V> ElementKernel<Indexed<I, V>> for NegateOperationwhere
I: IndexDomain,
V: ValueNegate,
Source§impl<I, V> ElementKernel<Indexed<I, V>> for RoundOperationwhere
I: IndexDomain,
V: ValueRound,
impl<I, V> ElementKernel<Indexed<I, V>> for RoundOperationwhere
I: IndexDomain,
V: ValueRound,
Source§impl<I, V> ElementKernel<Indexed<I, V>> for SignOperationwhere
I: IndexDomain,
V: ValueSign,
impl<I, V> ElementKernel<Indexed<I, V>> for SignOperationwhere
I: IndexDomain,
V: ValueSign,
Source§impl<I, V> ElementKernel<Indexed<I, V>> for SquareRootOperationwhere
I: IndexDomain,
V: ValueSquareRoot,
impl<I, V> ElementKernel<Indexed<I, V>> for SquareRootOperationwhere
I: IndexDomain,
V: ValueSquareRoot,
Source§impl<I, V, A> ElementKernel<Indexed<I, V>> for ContainsOperation<A>
impl<I, V, A> ElementKernel<Indexed<I, V>> for ContainsOperation<A>
type Emission = <A as ArgumentSource<Keyed<I>>>::Retention
type OutShape = Indexed<I, Mask>
fn pipeline<'a>( _graphrecord: &'a GraphRecord, prepared: Self::Prepared<'a>, ) -> QueryResult<ElementPipeline<'a, Indexed<I, V>, Self>>
fn estimate(&self, input: Estimate, _stats: &Stats<'_>) -> Estimate
Source§impl<I, V, A> ElementKernel<Indexed<I, V>> for EndsWithOperation<A>
impl<I, V, A> ElementKernel<Indexed<I, V>> for EndsWithOperation<A>
type Emission = <A as ArgumentSource<Keyed<I>>>::Retention
type OutShape = Indexed<I, Mask>
fn pipeline<'a>( _graphrecord: &'a GraphRecord, prepared: Self::Prepared<'a>, ) -> QueryResult<ElementPipeline<'a, Indexed<I, V>, Self>>
fn estimate(&self, input: Estimate, _stats: &Stats<'_>) -> Estimate
Source§impl<I, V> ElementKernel<Indexed<I, V>> for LengthOperationwhere
I: IndexDomain,
V: StringValue,
impl<I, V> ElementKernel<Indexed<I, V>> for LengthOperationwhere
I: IndexDomain,
V: StringValue,
Source§impl<I, V> ElementKernel<Indexed<I, V>> for LowercaseOperationwhere
I: IndexDomain,
V: StringValue,
impl<I, V> ElementKernel<Indexed<I, V>> for LowercaseOperationwhere
I: IndexDomain,
V: StringValue,
Source§impl<I, V, A> ElementKernel<Indexed<I, V>> for MatchesOperation<A>
impl<I, V, A> ElementKernel<Indexed<I, V>> for MatchesOperation<A>
type Emission = <A as ArgumentSource<Keyed<I>>>::Retention
type OutShape = Indexed<I, Mask>
fn pipeline<'a>( _graphrecord: &'a GraphRecord, prepared: Self::Prepared<'a>, ) -> QueryResult<ElementPipeline<'a, Indexed<I, V>, Self>>
fn estimate(&self, input: Estimate, _stats: &Stats<'_>) -> Estimate
Source§impl<I, V, W, C> ElementKernel<Indexed<I, V>> for PadEndOperation<W, C>where
I: IndexDomain,
V: StringValue,
W: ArgumentSource<Keyed<I>>,
W::ValueDomain: IntValue,
C: ArgumentSource<Keyed<I>>,
C::ValueDomain: StringValue,
impl<I, V, W, C> ElementKernel<Indexed<I, V>> for PadEndOperation<W, C>where
I: IndexDomain,
V: StringValue,
W: ArgumentSource<Keyed<I>>,
W::ValueDomain: IntValue,
C: ArgumentSource<Keyed<I>>,
C::ValueDomain: StringValue,
type Emission = <<W as ArgumentSource<Keyed<I>>>::Retention as Retention>::Then<<C as ArgumentSource<Keyed<I>>>::Retention>
type OutShape = Indexed<I, V>
fn pipeline<'a>( _graphrecord: &'a GraphRecord, prepared: Self::Prepared<'a>, ) -> QueryResult<ElementPipeline<'a, Indexed<I, V>, Self>>
fn estimate(&self, input: Estimate, _stats: &Stats<'_>) -> Estimate
Source§impl<I, V, W, C> ElementKernel<Indexed<I, V>> for PadStartOperation<W, C>where
I: IndexDomain,
V: StringValue,
W: ArgumentSource<Keyed<I>>,
W::ValueDomain: IntValue,
C: ArgumentSource<Keyed<I>>,
C::ValueDomain: StringValue,
impl<I, V, W, C> ElementKernel<Indexed<I, V>> for PadStartOperation<W, C>where
I: IndexDomain,
V: StringValue,
W: ArgumentSource<Keyed<I>>,
W::ValueDomain: IntValue,
C: ArgumentSource<Keyed<I>>,
C::ValueDomain: StringValue,
type Emission = <<W as ArgumentSource<Keyed<I>>>::Retention as Retention>::Then<<C as ArgumentSource<Keyed<I>>>::Retention>
type OutShape = Indexed<I, V>
fn pipeline<'a>( _graphrecord: &'a GraphRecord, prepared: Self::Prepared<'a>, ) -> QueryResult<ElementPipeline<'a, Indexed<I, V>, Self>>
fn estimate(&self, input: Estimate, _stats: &Stats<'_>) -> Estimate
Source§impl<I, V, A, B> ElementKernel<Indexed<I, V>> for ReplaceOperation<A, B>where
I: IndexDomain,
V: StringValue,
A: ArgumentSource<Keyed<I>>,
A::ValueDomain: StringValue,
B: ArgumentSource<Keyed<I>>,
B::ValueDomain: StringValue,
impl<I, V, A, B> ElementKernel<Indexed<I, V>> for ReplaceOperation<A, B>where
I: IndexDomain,
V: StringValue,
A: ArgumentSource<Keyed<I>>,
A::ValueDomain: StringValue,
B: ArgumentSource<Keyed<I>>,
B::ValueDomain: StringValue,
type Emission = <<A as ArgumentSource<Keyed<I>>>::Retention as Retention>::Then<<B as ArgumentSource<Keyed<I>>>::Retention>
type OutShape = Indexed<I, V>
fn pipeline<'a>( _graphrecord: &'a GraphRecord, prepared: Self::Prepared<'a>, ) -> QueryResult<ElementPipeline<'a, Indexed<I, V>, Self>>
fn estimate(&self, input: Estimate, _stats: &Stats<'_>) -> Estimate
Source§impl<I, V, A, B> ElementKernel<Indexed<I, V>> for ReplaceAllOperation<A, B>where
I: IndexDomain,
V: StringValue,
A: ArgumentSource<Keyed<I>>,
A::ValueDomain: StringValue,
B: ArgumentSource<Keyed<I>>,
B::ValueDomain: StringValue,
impl<I, V, A, B> ElementKernel<Indexed<I, V>> for ReplaceAllOperation<A, B>where
I: IndexDomain,
V: StringValue,
A: ArgumentSource<Keyed<I>>,
A::ValueDomain: StringValue,
B: ArgumentSource<Keyed<I>>,
B::ValueDomain: StringValue,
type Emission = <<A as ArgumentSource<Keyed<I>>>::Retention as Retention>::Then<<B as ArgumentSource<Keyed<I>>>::Retention>
type OutShape = Indexed<I, V>
fn pipeline<'a>( _graphrecord: &'a GraphRecord, prepared: Self::Prepared<'a>, ) -> QueryResult<ElementPipeline<'a, Indexed<I, V>, Self>>
fn estimate(&self, input: Estimate, _stats: &Stats<'_>) -> Estimate
Source§impl<I, V> ElementKernel<Indexed<I, V>> for ReverseOperationwhere
I: IndexDomain,
V: StringValue,
impl<I, V> ElementKernel<Indexed<I, V>> for ReverseOperationwhere
I: IndexDomain,
V: StringValue,
Source§impl<I, V> ElementKernel<Indexed<I, V>> for SliceOperationwhere
I: IndexDomain,
V: StringValue,
impl<I, V> ElementKernel<Indexed<I, V>> for SliceOperationwhere
I: IndexDomain,
V: StringValue,
Source§impl<I, V, A> ElementKernel<Indexed<I, V>> for SplitOperation<A>
impl<I, V, A> ElementKernel<Indexed<I, V>> for SplitOperation<A>
type Emission = Expanding<Ordered>
type OutShape = Indexed<ExpandedIndex<I, Positional>, V>
fn pipeline<'a>( _graphrecord: &'a GraphRecord, prepared: Self::Prepared<'a>, ) -> QueryResult<ElementPipeline<'a, Indexed<I, V>, Self>>
fn estimate(&self, input: Estimate, stats: &Stats<'_>) -> Estimate
Source§impl<I, V, A> ElementKernel<Indexed<I, V>> for StartsWithOperation<A>
impl<I, V, A> ElementKernel<Indexed<I, V>> for StartsWithOperation<A>
type Emission = <A as ArgumentSource<Keyed<I>>>::Retention
type OutShape = Indexed<I, Mask>
fn pipeline<'a>( _graphrecord: &'a GraphRecord, prepared: Self::Prepared<'a>, ) -> QueryResult<ElementPipeline<'a, Indexed<I, V>, Self>>
fn estimate(&self, input: Estimate, _stats: &Stats<'_>) -> Estimate
Source§impl<I, V, A> ElementKernel<Indexed<I, V>> for StripPrefixOperation<A>
impl<I, V, A> ElementKernel<Indexed<I, V>> for StripPrefixOperation<A>
type Emission = <A as ArgumentSource<Keyed<I>>>::Retention
type OutShape = Indexed<I, V>
fn pipeline<'a>( _graphrecord: &'a GraphRecord, prepared: Self::Prepared<'a>, ) -> QueryResult<ElementPipeline<'a, Indexed<I, V>, Self>>
fn estimate(&self, input: Estimate, _stats: &Stats<'_>) -> Estimate
Source§impl<I, V, A> ElementKernel<Indexed<I, V>> for StripSuffixOperation<A>
impl<I, V, A> ElementKernel<Indexed<I, V>> for StripSuffixOperation<A>
type Emission = <A as ArgumentSource<Keyed<I>>>::Retention
type OutShape = Indexed<I, V>
fn pipeline<'a>( _graphrecord: &'a GraphRecord, prepared: Self::Prepared<'a>, ) -> QueryResult<ElementPipeline<'a, Indexed<I, V>, Self>>
fn estimate(&self, input: Estimate, _stats: &Stats<'_>) -> Estimate
Source§impl<I, V> ElementKernel<Indexed<I, V>> for TrimOperationwhere
I: IndexDomain,
V: StringValue,
impl<I, V> ElementKernel<Indexed<I, V>> for TrimOperationwhere
I: IndexDomain,
V: StringValue,
Source§impl<I, V> ElementKernel<Indexed<I, V>> for TrimEndOperationwhere
I: IndexDomain,
V: StringValue,
impl<I, V> ElementKernel<Indexed<I, V>> for TrimEndOperationwhere
I: IndexDomain,
V: StringValue,
Source§impl<I, V> ElementKernel<Indexed<I, V>> for TrimStartOperationwhere
I: IndexDomain,
V: StringValue,
impl<I, V> ElementKernel<Indexed<I, V>> for TrimStartOperationwhere
I: IndexDomain,
V: StringValue,
Source§impl<I, V> ElementKernel<Indexed<I, V>> for UppercaseOperationwhere
I: IndexDomain,
V: StringValue,
impl<I, V> ElementKernel<Indexed<I, V>> for UppercaseOperationwhere
I: IndexDomain,
V: StringValue,
Source§impl<I, V, M> ElementKernel<Indexed<I, V>> for FilterOperation<M>
impl<I, V, M> ElementKernel<Indexed<I, V>> for FilterOperation<M>
Source§impl<K: IndexDomain> ElementKernel<Indexed<K, Unit>> for IndexOperation
impl<K: IndexDomain> ElementKernel<Indexed<K, Unit>> for IndexOperation
type Emission = Preserving
type OutShape = Indexed<K, IndexValue<K>>
fn pipeline<'a>( _graphrecord: &'a GraphRecord, _prepared: Self::Prepared<'a>, ) -> QueryResult<ElementPipeline<'a, Indexed<K, Unit>, Self>>
fn estimate(&self, input: Estimate, _stats: &Stats<'_>) -> Estimate
Source§impl ElementKernel<Indexed<u32, Unit>> for EndpointOperation
impl ElementKernel<Indexed<u32, Unit>> for EndpointOperation
type Emission = Preserving
type OutShape = Indexed<u32, EntityReference<GraphRecordAttribute>>
fn pipeline<'a>( graphrecord: &'a GraphRecord, prepared: Self::Prepared<'a>, ) -> QueryResult<ElementPipeline<'a, Indexed<EdgeIndex, Unit>, Self>>
fn estimate(&self, input: Estimate, stats: &Stats<'_>) -> Estimate
Source§impl ElementKernel<Indexed<u32, Unit>> for ViaNodesOperation
impl ElementKernel<Indexed<u32, Unit>> for ViaNodesOperation
type Emission = Expanding<Ordered>
type OutShape = Indexed<ExpandedIndex<u32, EdgeEndpointRole>, EntityReference<GraphRecordAttribute>>
fn pipeline<'a>( graphrecord: &'a GraphRecord, _prepared: Self::Prepared<'a>, ) -> QueryResult<ElementPipeline<'a, Indexed<EdgeIndex, Unit>, Self>>
fn estimate(&self, input: Estimate, stats: &Stats<'_>) -> Estimate
Source§impl<K: IndexDomain, V: ValueDomain> ElementShape for Indexed<K, V>
impl<K: IndexDomain, V: ValueDomain> ElementShape for Indexed<K, V>
type Element<'a> = (<K as IndexDomain>::Index<'a>, Result<<V as ValueDomain>::Value<'a>, Box<Failure>>)
type ValueDomain = V
Source§impl<I: IndexDomain, V: ValueDomain, W: BareValueDomain, E: ElementEmission> ElementTransition<Bare<W>, E> for Indexed<I, V>
impl<I: IndexDomain, V: ValueDomain, W: BareValueDomain, E: ElementEmission> ElementTransition<Bare<W>, E> for Indexed<I, V>
type Pipeline<'a> = Pipeline<'a, (<I as IndexDomain>::Index<'a>, Result<<V as ValueDomain>::Value<'a>, Box<Failure>>), <E as ElementEmission>::Step<Result<<W as ValueDomain>::Value<'a>, Box<Failure>>>, E>
fn apply<'a, C: Arity>( values: C::Container<'a, Self::Element<'a>>, pipeline: Self::Pipeline<'a>, ) -> <E::OutArity<C> as Arity>::Container<'a, <Bare<W> as ElementShape>::Element<'a>>
Source§impl<P: IndexDomain, C: IndexDomain, V: ValueDomain, W: ValueDomain> ElementTransition<Indexed<ExpandedIndex<P, C>, W>, Expanding<Ordered>> for Indexed<P, V>
impl<P: IndexDomain, C: IndexDomain, V: ValueDomain, W: ValueDomain> ElementTransition<Indexed<ExpandedIndex<P, C>, W>, Expanding<Ordered>> for Indexed<P, V>
type Pipeline<'a> = Pipeline<'a, (<P as IndexDomain>::Index<'a>, <V as ValueDomain>::Value<'a>), Result<Vec<ExpandedChild<'a, C, W>>, Box<Failure>>, Expanding<Ordered>> where Self: 'a, Indexed<ExpandedIndex<P, C>, W>: 'a
fn apply<'a, A: Arity>( values: A::Container<'a, Self::Element<'a>>, pipeline: Self::Pipeline<'a>, ) -> <<Expanding<Ordered> as ElementEmission>::OutArity<A> as Arity>::Container<'a, <Indexed<ExpandedIndex<P, C>, W> as ElementShape>::Element<'a>>
Source§impl<P: IndexDomain, C: IndexDomain, V: ValueDomain, W: ValueDomain> ElementTransition<Indexed<ExpandedIndex<P, C>, W>, Expanding<Unordered>> for Indexed<P, V>
impl<P: IndexDomain, C: IndexDomain, V: ValueDomain, W: ValueDomain> ElementTransition<Indexed<ExpandedIndex<P, C>, W>, Expanding<Unordered>> for Indexed<P, V>
type Pipeline<'a> = Pipeline<'a, (<P as IndexDomain>::Index<'a>, <V as ValueDomain>::Value<'a>), Result<Vec<ExpandedChild<'a, C, W>>, Box<Failure>>, Expanding<Unordered>> where Self: 'a, Indexed<ExpandedIndex<P, C>, W>: 'a
fn apply<'a, A: Arity>( values: A::Container<'a, Self::Element<'a>>, pipeline: Self::Pipeline<'a>, ) -> <<Expanding<Unordered> as ElementEmission>::OutArity<A> as Arity>::Container<'a, <Indexed<ExpandedIndex<P, C>, W> as ElementShape>::Element<'a>>
Source§impl<I: IndexDomain, V: ValueDomain, W: ValueDomain, E: Retention> ElementTransition<Indexed<I, W>, E> for Indexed<I, V>
impl<I: IndexDomain, V: ValueDomain, W: ValueDomain, E: Retention> ElementTransition<Indexed<I, W>, E> for Indexed<I, V>
type Pipeline<'a> = Pipeline<'a, (<I as IndexDomain>::Index<'a>, Result<<V as ValueDomain>::Value<'a>, Box<Failure>>), <E as ElementEmission>::Step<Result<<W as ValueDomain>::Value<'a>, Box<Failure>>>, E>
fn apply<'a, C: Arity>( values: C::Container<'a, Self::Element<'a>>, pipeline: Self::Pipeline<'a>, ) -> <E::OutArity<C> as Arity>::Container<'a, <Indexed<I, W> as ElementShape>::Element<'a>>
Source§impl<I: IndexDomain, V: ValueDomain, O: OrderState> EnumerableArity<Indexed<I, V>, I> for Multiple<O>
impl<I: IndexDomain, V: ValueDomain, O: OrderState> EnumerableArity<Indexed<I, V>, I> for Multiple<O>
Source§impl<I: IndexDomain, V: ValueDomain> EnumerableArity<Indexed<I, V>, I> for Single
impl<I: IndexDomain, V: ValueDomain> EnumerableArity<Indexed<I, V>, I> for Single
Source§impl<I: IndexDomain, V: ValueDomain> EnumerableArity<Indexed<I, V>, I> for Definite
impl<I: IndexDomain, V: ValueDomain> EnumerableArity<Indexed<I, V>, I> for Definite
Source§impl LaneKernel<Indexed<GraphRecordAttribute, Unit>, Definite> for EdgesOperation
impl LaneKernel<Indexed<GraphRecordAttribute, Unit>, Definite> for EdgesOperation
type Output = OperandHandle<Indexed<u32, Unit>, Multiple<Unordered>>
fn execute<'a>( graphrecord: &'a GraphRecord, value: KeyedStream<'a, NodeIndex, Unit, Definite>, direction: Self::Prepared<'a>, ) -> QueryResult<<Self::Output as EvaluateOperand>::ReturnValue<'a>>
fn estimate(&self, input: Estimate, stats: &Stats<'_>) -> Estimate
Source§impl LaneKernel<Indexed<GraphRecordAttribute, Unit>, Definite> for NeighborsOperation
impl LaneKernel<Indexed<GraphRecordAttribute, Unit>, Definite> for NeighborsOperation
type Output = OperandHandle<Indexed<GraphRecordAttribute, Unit>, Multiple<Unordered>>
fn execute<'a>( graphrecord: &'a GraphRecord, value: KeyedStream<'a, NodeIndex, Unit, Definite>, direction: Self::Prepared<'a>, ) -> QueryResult<<Self::Output as EvaluateOperand>::ReturnValue<'a>>
fn estimate(&self, input: Estimate, stats: &Stats<'_>) -> Estimate
Source§impl<O: OrderState> LaneKernel<Indexed<GraphRecordAttribute, Unit>, Multiple<O>> for EdgesOperation
impl<O: OrderState> LaneKernel<Indexed<GraphRecordAttribute, Unit>, Multiple<O>> for EdgesOperation
type Output = OperandHandle<Indexed<u32, Unit>, Multiple<Unordered>>
fn execute<'a>( graphrecord: &'a GraphRecord, values: KeyedStream<'a, NodeIndex, Unit, Multiple<O>>, direction: Self::Prepared<'a>, ) -> QueryResult<<Self::Output as EvaluateOperand>::ReturnValue<'a>>
fn estimate(&self, input: Estimate, stats: &Stats<'_>) -> Estimate
Source§impl<O: OrderState> LaneKernel<Indexed<GraphRecordAttribute, Unit>, Multiple<O>> for NeighborsOperation
impl<O: OrderState> LaneKernel<Indexed<GraphRecordAttribute, Unit>, Multiple<O>> for NeighborsOperation
type Output = OperandHandle<Indexed<GraphRecordAttribute, Unit>, Multiple<Unordered>>
fn execute<'a>( graphrecord: &'a GraphRecord, values: KeyedStream<'a, NodeIndex, Unit, Multiple<O>>, direction: Self::Prepared<'a>, ) -> QueryResult<<Self::Output as EvaluateOperand>::ReturnValue<'a>>
fn estimate(&self, input: Estimate, stats: &Stats<'_>) -> Estimate
Source§impl LaneKernel<Indexed<GraphRecordAttribute, Unit>, Single> for EdgesOperation
impl LaneKernel<Indexed<GraphRecordAttribute, Unit>, Single> for EdgesOperation
type Output = OperandHandle<Indexed<u32, Unit>, Multiple<Unordered>>
fn execute<'a>( graphrecord: &'a GraphRecord, value: KeyedStream<'a, NodeIndex, Unit, Single>, direction: Self::Prepared<'a>, ) -> QueryResult<<Self::Output as EvaluateOperand>::ReturnValue<'a>>
fn estimate(&self, input: Estimate, stats: &Stats<'_>) -> Estimate
Source§impl LaneKernel<Indexed<GraphRecordAttribute, Unit>, Single> for NeighborsOperation
impl LaneKernel<Indexed<GraphRecordAttribute, Unit>, Single> for NeighborsOperation
type Output = OperandHandle<Indexed<GraphRecordAttribute, Unit>, Multiple<Unordered>>
fn execute<'a>( graphrecord: &'a GraphRecord, value: KeyedStream<'a, NodeIndex, Unit, Single>, direction: Self::Prepared<'a>, ) -> QueryResult<<Self::Output as EvaluateOperand>::ReturnValue<'a>>
fn estimate(&self, input: Estimate, stats: &Stats<'_>) -> Estimate
Source§impl<E: EntityDomain, I: IndexDomain> LaneKernel<Indexed<I, EntityReference<E>>, Definite> for SelectOperation
impl<E: EntityDomain, I: IndexDomain> LaneKernel<Indexed<I, EntityReference<E>>, Definite> for SelectOperation
type Output = OperandHandle<Indexed<E, Unit>, Definite>
fn execute<'a>( _graphrecord: &'a GraphRecord, value: KeyedStream<'a, I, EntityReference<E>, Definite>, _prepared: Self::Prepared<'a>, ) -> QueryResult<<Self::Output as EvaluateOperand>::ReturnValue<'a>>
fn estimate(&self, _input: Estimate, _stats: &Stats<'_>) -> Estimate
Source§impl<E: EntityDomain, I: IndexDomain, O: OrderState> LaneKernel<Indexed<I, EntityReference<E>>, Multiple<O>> for SelectOperation
impl<E: EntityDomain, I: IndexDomain, O: OrderState> LaneKernel<Indexed<I, EntityReference<E>>, Multiple<O>> for SelectOperation
type Output = OperandHandle<Indexed<E, Unit>, Multiple<Unordered>>
fn execute<'a>( _graphrecord: &'a GraphRecord, values: KeyedStream<'a, I, EntityReference<E>, Multiple<O>>, _prepared: Self::Prepared<'a>, ) -> QueryResult<<Self::Output as EvaluateOperand>::ReturnValue<'a>>
fn estimate(&self, input: Estimate, _stats: &Stats<'_>) -> Estimate
Source§impl<E: EntityDomain, I: IndexDomain> LaneKernel<Indexed<I, EntityReference<E>>, Single> for SelectOperation
impl<E: EntityDomain, I: IndexDomain> LaneKernel<Indexed<I, EntityReference<E>>, Single> for SelectOperation
type Output = OperandHandle<Indexed<E, Unit>, Single>
fn execute<'a>( _graphrecord: &'a GraphRecord, value: KeyedStream<'a, I, EntityReference<E>, Single>, _prepared: Self::Prepared<'a>, ) -> QueryResult<<Self::Output as EvaluateOperand>::ReturnValue<'a>>
fn estimate(&self, input: Estimate, _stats: &Stats<'_>) -> Estimate
Source§impl<I: IndexDomain> LaneKernel<Indexed<I, EntityReference<GraphRecordAttribute>>, Definite> for EdgesOperation
impl<I: IndexDomain> LaneKernel<Indexed<I, EntityReference<GraphRecordAttribute>>, Definite> for EdgesOperation
type Output = OperandHandle<Indexed<u32, Unit>, Multiple<Unordered>>
fn execute<'a>( graphrecord: &'a GraphRecord, value: KeyedStream<'a, I, EntityReference<NodeIndex>, Definite>, direction: Self::Prepared<'a>, ) -> QueryResult<<Self::Output as EvaluateOperand>::ReturnValue<'a>>
fn estimate(&self, input: Estimate, stats: &Stats<'_>) -> Estimate
Source§impl<I: IndexDomain> LaneKernel<Indexed<I, EntityReference<GraphRecordAttribute>>, Definite> for NeighborsOperation
impl<I: IndexDomain> LaneKernel<Indexed<I, EntityReference<GraphRecordAttribute>>, Definite> for NeighborsOperation
type Output = OperandHandle<Indexed<GraphRecordAttribute, Unit>, Multiple<Unordered>>
fn execute<'a>( graphrecord: &'a GraphRecord, value: KeyedStream<'a, I, EntityReference<NodeIndex>, Definite>, direction: Self::Prepared<'a>, ) -> QueryResult<<Self::Output as EvaluateOperand>::ReturnValue<'a>>
fn estimate(&self, input: Estimate, stats: &Stats<'_>) -> Estimate
Source§impl<I: IndexDomain, O: OrderState> LaneKernel<Indexed<I, EntityReference<GraphRecordAttribute>>, Multiple<O>> for EdgesOperation
impl<I: IndexDomain, O: OrderState> LaneKernel<Indexed<I, EntityReference<GraphRecordAttribute>>, Multiple<O>> for EdgesOperation
type Output = OperandHandle<Indexed<u32, Unit>, Multiple<Unordered>>
fn execute<'a>( graphrecord: &'a GraphRecord, values: KeyedStream<'a, I, EntityReference<NodeIndex>, Multiple<O>>, direction: Self::Prepared<'a>, ) -> QueryResult<<Self::Output as EvaluateOperand>::ReturnValue<'a>>
fn estimate(&self, input: Estimate, stats: &Stats<'_>) -> Estimate
Source§impl<I: IndexDomain, O: OrderState> LaneKernel<Indexed<I, EntityReference<GraphRecordAttribute>>, Multiple<O>> for NeighborsOperation
impl<I: IndexDomain, O: OrderState> LaneKernel<Indexed<I, EntityReference<GraphRecordAttribute>>, Multiple<O>> for NeighborsOperation
type Output = OperandHandle<Indexed<GraphRecordAttribute, Unit>, Multiple<Unordered>>
fn execute<'a>( graphrecord: &'a GraphRecord, values: KeyedStream<'a, I, EntityReference<NodeIndex>, Multiple<O>>, direction: Self::Prepared<'a>, ) -> QueryResult<<Self::Output as EvaluateOperand>::ReturnValue<'a>>
fn estimate(&self, input: Estimate, stats: &Stats<'_>) -> Estimate
Source§impl<I: IndexDomain> LaneKernel<Indexed<I, EntityReference<GraphRecordAttribute>>, Single> for EdgesOperation
impl<I: IndexDomain> LaneKernel<Indexed<I, EntityReference<GraphRecordAttribute>>, Single> for EdgesOperation
type Output = OperandHandle<Indexed<u32, Unit>, Multiple<Unordered>>
fn execute<'a>( graphrecord: &'a GraphRecord, value: KeyedStream<'a, I, EntityReference<NodeIndex>, Single>, direction: Self::Prepared<'a>, ) -> QueryResult<<Self::Output as EvaluateOperand>::ReturnValue<'a>>
fn estimate(&self, input: Estimate, stats: &Stats<'_>) -> Estimate
Source§impl<I: IndexDomain> LaneKernel<Indexed<I, EntityReference<GraphRecordAttribute>>, Single> for NeighborsOperation
impl<I: IndexDomain> LaneKernel<Indexed<I, EntityReference<GraphRecordAttribute>>, Single> for NeighborsOperation
type Output = OperandHandle<Indexed<GraphRecordAttribute, Unit>, Multiple<Unordered>>
fn execute<'a>( graphrecord: &'a GraphRecord, value: KeyedStream<'a, I, EntityReference<NodeIndex>, Single>, direction: Self::Prepared<'a>, ) -> QueryResult<<Self::Output as EvaluateOperand>::ReturnValue<'a>>
fn estimate(&self, input: Estimate, stats: &Stats<'_>) -> Estimate
Source§impl<I: IndexDomain> LaneKernel<Indexed<I, EntityReference<u32>>, Definite> for NodesOperation
impl<I: IndexDomain> LaneKernel<Indexed<I, EntityReference<u32>>, Definite> for NodesOperation
type Output = OperandHandle<Indexed<GraphRecordAttribute, Unit>, Multiple<Unordered>>
fn execute<'a>( graphrecord: &'a GraphRecord, value: KeyedStream<'a, I, EntityReference<EdgeIndex>, Definite>, _prepared: Self::Prepared<'a>, ) -> QueryResult<<Self::Output as EvaluateOperand>::ReturnValue<'a>>
fn estimate(&self, input: Estimate, stats: &Stats<'_>) -> Estimate
Source§impl<I: IndexDomain, O: OrderState> LaneKernel<Indexed<I, EntityReference<u32>>, Multiple<O>> for NodesOperation
impl<I: IndexDomain, O: OrderState> LaneKernel<Indexed<I, EntityReference<u32>>, Multiple<O>> for NodesOperation
type Output = OperandHandle<Indexed<GraphRecordAttribute, Unit>, Multiple<Unordered>>
fn execute<'a>( graphrecord: &'a GraphRecord, values: KeyedStream<'a, I, EntityReference<EdgeIndex>, Multiple<O>>, _prepared: Self::Prepared<'a>, ) -> QueryResult<<Self::Output as EvaluateOperand>::ReturnValue<'a>>
fn estimate(&self, input: Estimate, stats: &Stats<'_>) -> Estimate
Source§impl<I: IndexDomain> LaneKernel<Indexed<I, EntityReference<u32>>, Single> for NodesOperation
impl<I: IndexDomain> LaneKernel<Indexed<I, EntityReference<u32>>, Single> for NodesOperation
type Output = OperandHandle<Indexed<GraphRecordAttribute, Unit>, Multiple<Unordered>>
fn execute<'a>( graphrecord: &'a GraphRecord, value: KeyedStream<'a, I, EntityReference<EdgeIndex>, Single>, _prepared: Self::Prepared<'a>, ) -> QueryResult<<Self::Output as EvaluateOperand>::ReturnValue<'a>>
fn estimate(&self, input: Estimate, stats: &Stats<'_>) -> Estimate
Source§impl<I: IndexDomain, O: OrderState> LaneKernel<Indexed<I, Mask>, Multiple<O>> for AllOperation
impl<I: IndexDomain, O: OrderState> LaneKernel<Indexed<I, Mask>, Multiple<O>> for AllOperation
type Output = OperandHandle<Bare<Mask>, Definite>
fn execute<'a>( _graphrecord: &'a GraphRecord, values: KeyedStream<'a, I, Mask, Multiple<O>>, _prepared: Self::Prepared<'a>, ) -> QueryResult<<Self::Output as EvaluateOperand>::ReturnValue<'a>>
fn estimate(&self, _input: Estimate, _stats: &Stats<'_>) -> Estimate
Source§impl<I: IndexDomain, O: OrderState> LaneKernel<Indexed<I, Mask>, Multiple<O>> for AnyOperation
impl<I: IndexDomain, O: OrderState> LaneKernel<Indexed<I, Mask>, Multiple<O>> for AnyOperation
type Output = OperandHandle<Bare<Mask>, Definite>
fn execute<'a>( _graphrecord: &'a GraphRecord, values: KeyedStream<'a, I, Mask, Multiple<O>>, _prepared: Self::Prepared<'a>, ) -> QueryResult<<Self::Output as EvaluateOperand>::ReturnValue<'a>>
fn estimate(&self, _input: Estimate, _stats: &Stats<'_>) -> Estimate
Source§impl<I, V, K, C> LaneKernel<Indexed<I, V>, C> for GroupByOperation<K>where
I: IndexDomain,
V: ValueDomain,
K: ArgumentSource<Keyed<I>>,
K::ValueDomain: GroupingValue,
C: PartitionArity<Indexed<I, V>>,
impl<I, V, K, C> LaneKernel<Indexed<I, V>, C> for GroupByOperation<K>where
I: IndexDomain,
V: ValueDomain,
K: ArgumentSource<Keyed<I>>,
K::ValueDomain: GroupingValue,
C: PartitionArity<Indexed<I, V>>,
type Output = GroupOperand<I, <<K as SourceDomain>::ValueDomain as GroupingValue>::Key, OperandHandle<Indexed<I, V>, C>>
fn execute<'a>( _graphrecord: &'a GraphRecord, values: KeyedStream<'a, I, V, C>, prepared: Self::Prepared<'a>, ) -> QueryResult<<Self::Output as EvaluateOperand>::ReturnValue<'a>>
fn estimate(&self, input: Estimate, stats: &Stats<'_>) -> Estimate
Source§impl<I: IndexDomain, V: ValueDomain> LaneKernel<Indexed<I, V>, Definite> for CountOperation
impl<I: IndexDomain, V: ValueDomain> LaneKernel<Indexed<I, V>, Definite> for CountOperation
type Output = OperandHandle<Bare<Scalar>, Definite>
fn execute<'a>( _graphrecord: &'a GraphRecord, value: KeyedStream<'a, I, V, Definite>, _prepared: Self::Prepared<'a>, ) -> QueryResult<<Self::Output as EvaluateOperand>::ReturnValue<'a>>
fn estimate(&self, _input: Estimate, _stats: &Stats<'_>) -> Estimate
Source§impl<I: IndexDomain, V: ValueDomain> LaneKernel<Indexed<I, V>, Definite> for Raise
impl<I: IndexDomain, V: ValueDomain> LaneKernel<Indexed<I, V>, Definite> for Raise
type Output = OperandHandle<Indexed<I, V>, Definite>
fn execute<'a>( _graphrecord: &'a GraphRecord, value: KeyedStream<'a, I, V, Definite>, _prepared: Self::Prepared<'a>, ) -> QueryResult<<Self::Output as EvaluateOperand>::ReturnValue<'a>>
fn estimate(&self, input: Estimate, _stats: &Stats<'_>) -> Estimate
Source§impl<I, V, C> LaneKernel<Indexed<I, V>, Definite> for RaiseWhen<C>
impl<I, V, C> LaneKernel<Indexed<I, V>, Definite> for RaiseWhen<C>
type Output = OperandHandle<Indexed<I, V>, Definite>
fn execute<'a>( graphrecord: &'a GraphRecord, value: KeyedStream<'a, I, V, Definite>, condition: Self::Prepared<'a>, ) -> QueryResult<<Self::Output as EvaluateOperand>::ReturnValue<'a>>
fn estimate(&self, input: Estimate, _stats: &Stats<'_>) -> Estimate
Source§impl<I: IndexDomain, V: ValueDomain, D: Diagnostic> LaneKernel<Indexed<I, V>, Definite> for RaiseErrorsOf<D>
impl<I: IndexDomain, V: ValueDomain, D: Diagnostic> LaneKernel<Indexed<I, V>, Definite> for RaiseErrorsOf<D>
type Output = OperandHandle<Indexed<I, V>, Definite>
fn execute<'a>( _graphrecord: &'a GraphRecord, value: KeyedStream<'a, I, V, Definite>, _prepared: Self::Prepared<'a>, ) -> QueryResult<<Self::Output as EvaluateOperand>::ReturnValue<'a>>
fn estimate(&self, input: Estimate, _stats: &Stats<'_>) -> Estimate
Source§impl<I: IndexDomain, V: ValueDomain, G: ErrorGroup> LaneKernel<Indexed<I, V>, Definite> for RaiseErrorsIn<G>
impl<I: IndexDomain, V: ValueDomain, G: ErrorGroup> LaneKernel<Indexed<I, V>, Definite> for RaiseErrorsIn<G>
type Output = OperandHandle<Indexed<I, V>, Definite>
fn execute<'a>( _graphrecord: &'a GraphRecord, value: KeyedStream<'a, I, V, Definite>, _prepared: Self::Prepared<'a>, ) -> QueryResult<<Self::Output as EvaluateOperand>::ReturnValue<'a>>
fn estimate(&self, input: Estimate, _stats: &Stats<'_>) -> Estimate
Source§impl<I: IndexDomain, V: ValueDomain, E: Error + 'static> LaneKernel<Indexed<I, V>, Definite> for RaiseErrorsWithCause<E>
impl<I: IndexDomain, V: ValueDomain, E: Error + 'static> LaneKernel<Indexed<I, V>, Definite> for RaiseErrorsWithCause<E>
type Output = OperandHandle<Indexed<I, V>, Definite>
fn execute<'a>( _graphrecord: &'a GraphRecord, value: KeyedStream<'a, I, V, Definite>, _prepared: Self::Prepared<'a>, ) -> QueryResult<<Self::Output as EvaluateOperand>::ReturnValue<'a>>
fn estimate(&self, input: Estimate, _stats: &Stats<'_>) -> Estimate
Source§impl<I, V, D, C> LaneKernel<Indexed<I, V>, Definite> for RaiseWhenErrorsOf<D, C>where
I: IndexDomain,
V: ValueDomain,
D: Diagnostic,
C: ArgumentSource<Unaligned, Mask, Retention = Preserving>,
impl<I, V, D, C> LaneKernel<Indexed<I, V>, Definite> for RaiseWhenErrorsOf<D, C>where
I: IndexDomain,
V: ValueDomain,
D: Diagnostic,
C: ArgumentSource<Unaligned, Mask, Retention = Preserving>,
type Output = OperandHandle<Indexed<I, V>, Definite>
fn execute<'a>( graphrecord: &'a GraphRecord, value: KeyedStream<'a, I, V, Definite>, condition: Self::Prepared<'a>, ) -> QueryResult<<Self::Output as EvaluateOperand>::ReturnValue<'a>>
fn estimate(&self, input: Estimate, _stats: &Stats<'_>) -> Estimate
Source§impl<I, V, G, C> LaneKernel<Indexed<I, V>, Definite> for RaiseWhenErrorsIn<G, C>where
I: IndexDomain,
V: ValueDomain,
G: ErrorGroup,
C: ArgumentSource<Unaligned, Mask, Retention = Preserving>,
impl<I, V, G, C> LaneKernel<Indexed<I, V>, Definite> for RaiseWhenErrorsIn<G, C>where
I: IndexDomain,
V: ValueDomain,
G: ErrorGroup,
C: ArgumentSource<Unaligned, Mask, Retention = Preserving>,
type Output = OperandHandle<Indexed<I, V>, Definite>
fn execute<'a>( graphrecord: &'a GraphRecord, value: KeyedStream<'a, I, V, Definite>, condition: Self::Prepared<'a>, ) -> QueryResult<<Self::Output as EvaluateOperand>::ReturnValue<'a>>
fn estimate(&self, input: Estimate, _stats: &Stats<'_>) -> Estimate
Source§impl<I, V, E, C> LaneKernel<Indexed<I, V>, Definite> for RaiseWhenErrorsWithCause<E, C>where
I: IndexDomain,
V: ValueDomain,
E: Error + 'static,
C: ArgumentSource<Unaligned, Mask, Retention = Preserving>,
impl<I, V, E, C> LaneKernel<Indexed<I, V>, Definite> for RaiseWhenErrorsWithCause<E, C>where
I: IndexDomain,
V: ValueDomain,
E: Error + 'static,
C: ArgumentSource<Unaligned, Mask, Retention = Preserving>,
type Output = OperandHandle<Indexed<I, V>, Definite>
fn execute<'a>( graphrecord: &'a GraphRecord, value: KeyedStream<'a, I, V, Definite>, condition: Self::Prepared<'a>, ) -> QueryResult<<Self::Output as EvaluateOperand>::ReturnValue<'a>>
fn estimate(&self, input: Estimate, _stats: &Stats<'_>) -> Estimate
Source§impl<I: IndexDomain, V: ValueDomain, O: OrderState> LaneKernel<Indexed<I, V>, Multiple<O>> for CountOperation
impl<I: IndexDomain, V: ValueDomain, O: OrderState> LaneKernel<Indexed<I, V>, Multiple<O>> for CountOperation
type Output = OperandHandle<Bare<Scalar>, Definite>
fn execute<'a>( _graphrecord: &'a GraphRecord, values: KeyedStream<'a, I, V, Multiple<O>>, _prepared: Self::Prepared<'a>, ) -> QueryResult<<Self::Output as EvaluateOperand>::ReturnValue<'a>>
fn estimate(&self, _input: Estimate, _stats: &Stats<'_>) -> Estimate
Source§impl<I, V, O> LaneKernel<Indexed<I, V>, Multiple<O>> for MaximumOperationwhere
I: IndexDomain,
V: ValueOrdering + BareValueDomain,
O: OrderState,
V::Owned: Debug + Display + Send + Sync,
impl<I, V, O> LaneKernel<Indexed<I, V>, Multiple<O>> for MaximumOperationwhere
I: IndexDomain,
V: ValueOrdering + BareValueDomain,
O: OrderState,
V::Owned: Debug + Display + Send + Sync,
type Output = OperandHandle<Bare<V>, Single>
fn execute<'a>( _graphrecord: &'a GraphRecord, values: KeyedStream<'a, I, V, Multiple<O>>, _prepared: Self::Prepared<'a>, ) -> QueryResult<<Self::Output as EvaluateOperand>::ReturnValue<'a>>
fn estimate(&self, input: Estimate, _stats: &Stats<'_>) -> Estimate
Source§impl<I, V, O> LaneKernel<Indexed<I, V>, Multiple<O>> for MeanOperation
impl<I, V, O> LaneKernel<Indexed<I, V>, Multiple<O>> for MeanOperation
type Output = OperandHandle<Bare<V>, Single>
fn execute<'a>( _graphrecord: &'a GraphRecord, values: KeyedStream<'a, I, V, Multiple<O>>, _prepared: Self::Prepared<'a>, ) -> QueryResult<<Self::Output as EvaluateOperand>::ReturnValue<'a>>
fn estimate(&self, input: Estimate, _stats: &Stats<'_>) -> Estimate
Source§impl<I, V, O> LaneKernel<Indexed<I, V>, Multiple<O>> for MedianOperationwhere
I: IndexDomain,
V: ValueMedian + BareValueDomain,
O: OrderState,
V::Owned: Debug + Display + Send + Sync,
impl<I, V, O> LaneKernel<Indexed<I, V>, Multiple<O>> for MedianOperationwhere
I: IndexDomain,
V: ValueMedian + BareValueDomain,
O: OrderState,
V::Owned: Debug + Display + Send + Sync,
type Output = OperandHandle<Bare<V>, Single>
fn execute<'a>( _graphrecord: &'a GraphRecord, values: KeyedStream<'a, I, V, Multiple<O>>, _prepared: Self::Prepared<'a>, ) -> QueryResult<<Self::Output as EvaluateOperand>::ReturnValue<'a>>
fn estimate(&self, input: Estimate, _stats: &Stats<'_>) -> Estimate
Source§impl<I, V, O> LaneKernel<Indexed<I, V>, Multiple<O>> for MinimumOperationwhere
I: IndexDomain,
V: ValueOrdering + BareValueDomain,
O: OrderState,
V::Owned: Debug + Display + Send + Sync,
impl<I, V, O> LaneKernel<Indexed<I, V>, Multiple<O>> for MinimumOperationwhere
I: IndexDomain,
V: ValueOrdering + BareValueDomain,
O: OrderState,
V::Owned: Debug + Display + Send + Sync,
type Output = OperandHandle<Bare<V>, Single>
fn execute<'a>( _graphrecord: &'a GraphRecord, values: KeyedStream<'a, I, V, Multiple<O>>, _prepared: Self::Prepared<'a>, ) -> QueryResult<<Self::Output as EvaluateOperand>::ReturnValue<'a>>
fn estimate(&self, input: Estimate, _stats: &Stats<'_>) -> Estimate
Source§impl<I: IndexDomain, V: ValueMode + BareValueDomain, O: OrderState> LaneKernel<Indexed<I, V>, Multiple<O>> for ModeOperation
impl<I: IndexDomain, V: ValueMode + BareValueDomain, O: OrderState> LaneKernel<Indexed<I, V>, Multiple<O>> for ModeOperation
type Output = OperandHandle<Bare<V>, Multiple<O>>
fn execute<'a>( _graphrecord: &'a GraphRecord, values: KeyedStream<'a, I, V, Multiple<O>>, _prepared: Self::Prepared<'a>, ) -> QueryResult<<Self::Output as EvaluateOperand>::ReturnValue<'a>>
fn estimate(&self, input: Estimate, stats: &Stats<'_>) -> Estimate
Source§impl<I, V, O> LaneKernel<Indexed<I, V>, Multiple<O>> for ProductOperation
impl<I, V, O> LaneKernel<Indexed<I, V>, Multiple<O>> for ProductOperation
type Output = OperandHandle<Bare<V>, Single>
fn execute<'a>( _graphrecord: &'a GraphRecord, values: KeyedStream<'a, I, V, Multiple<O>>, _prepared: Self::Prepared<'a>, ) -> QueryResult<<Self::Output as EvaluateOperand>::ReturnValue<'a>>
fn estimate(&self, input: Estimate, _stats: &Stats<'_>) -> Estimate
Source§impl<I, V, O> LaneKernel<Indexed<I, V>, Multiple<O>> for RandomOperation
impl<I, V, O> LaneKernel<Indexed<I, V>, Multiple<O>> for RandomOperation
type Output = OperandHandle<Indexed<I, V>, Single>
fn execute<'a>( _graphrecord: &'a GraphRecord, values: KeyedStream<'a, I, V, Multiple<O>>, _prepared: Self::Prepared<'a>, ) -> QueryResult<<Self::Output as EvaluateOperand>::ReturnValue<'a>>
fn estimate(&self, input: Estimate, _stats: &Stats<'_>) -> Estimate
Source§impl<I, V, O> LaneKernel<Indexed<I, V>, Multiple<O>> for StandardDeviationOperation
impl<I, V, O> LaneKernel<Indexed<I, V>, Multiple<O>> for StandardDeviationOperation
type Output = OperandHandle<Bare<Scalar>, Single>
fn execute<'a>( _graphrecord: &'a GraphRecord, values: KeyedStream<'a, I, V, Multiple<O>>, _prepared: Self::Prepared<'a>, ) -> QueryResult<<Self::Output as EvaluateOperand>::ReturnValue<'a>>
fn estimate(&self, input: Estimate, _stats: &Stats<'_>) -> Estimate
Source§impl<I, V, O> LaneKernel<Indexed<I, V>, Multiple<O>> for SumOperation
impl<I, V, O> LaneKernel<Indexed<I, V>, Multiple<O>> for SumOperation
type Output = OperandHandle<Bare<V>, Single>
fn execute<'a>( _graphrecord: &'a GraphRecord, values: KeyedStream<'a, I, V, Multiple<O>>, _prepared: Self::Prepared<'a>, ) -> QueryResult<<Self::Output as EvaluateOperand>::ReturnValue<'a>>
fn estimate(&self, input: Estimate, _stats: &Stats<'_>) -> Estimate
Source§impl<I: IndexDomain, V: ValueEquivalence, O: OrderState> LaneKernel<Indexed<I, V>, Multiple<O>> for UniqueCountOperation
impl<I: IndexDomain, V: ValueEquivalence, O: OrderState> LaneKernel<Indexed<I, V>, Multiple<O>> for UniqueCountOperation
type Output = OperandHandle<Bare<Scalar>, Definite>
fn execute<'a>( _graphrecord: &'a GraphRecord, values: KeyedStream<'a, I, V, Multiple<O>>, _prepared: Self::Prepared<'a>, ) -> QueryResult<<Self::Output as EvaluateOperand>::ReturnValue<'a>>
fn estimate(&self, _input: Estimate, _stats: &Stats<'_>) -> Estimate
Source§impl<I, V, O> LaneKernel<Indexed<I, V>, Multiple<O>> for VarianceOperation
impl<I, V, O> LaneKernel<Indexed<I, V>, Multiple<O>> for VarianceOperation
type Output = OperandHandle<Bare<Scalar>, Single>
fn execute<'a>( _graphrecord: &'a GraphRecord, values: KeyedStream<'a, I, V, Multiple<O>>, _prepared: Self::Prepared<'a>, ) -> QueryResult<<Self::Output as EvaluateOperand>::ReturnValue<'a>>
fn estimate(&self, input: Estimate, _stats: &Stats<'_>) -> Estimate
Source§impl<I: IndexDomain, V: ValueDomain, O: OrderState> LaneKernel<Indexed<I, V>, Multiple<O>> for Raise
impl<I: IndexDomain, V: ValueDomain, O: OrderState> LaneKernel<Indexed<I, V>, Multiple<O>> for Raise
type Output = OperandHandle<Indexed<I, V>, Multiple<O>>
fn execute<'a>( _graphrecord: &'a GraphRecord, values: KeyedStream<'a, I, V, Multiple<O>>, _prepared: Self::Prepared<'a>, ) -> QueryResult<<Self::Output as EvaluateOperand>::ReturnValue<'a>>
fn estimate(&self, input: Estimate, _stats: &Stats<'_>) -> Estimate
Source§impl<I, V, O, C> LaneKernel<Indexed<I, V>, Multiple<O>> for RaiseWhen<C>where
I: IndexDomain,
V: ValueDomain,
O: OrderState,
C: ArgumentSource<Unaligned, Mask, Retention = Preserving>,
impl<I, V, O, C> LaneKernel<Indexed<I, V>, Multiple<O>> for RaiseWhen<C>where
I: IndexDomain,
V: ValueDomain,
O: OrderState,
C: ArgumentSource<Unaligned, Mask, Retention = Preserving>,
type Output = OperandHandle<Indexed<I, V>, Multiple<O>>
fn execute<'a>( graphrecord: &'a GraphRecord, values: KeyedStream<'a, I, V, Multiple<O>>, condition: Self::Prepared<'a>, ) -> QueryResult<<Self::Output as EvaluateOperand>::ReturnValue<'a>>
fn estimate(&self, input: Estimate, _stats: &Stats<'_>) -> Estimate
Source§impl<I: IndexDomain, V: ValueDomain, O: OrderState, D: Diagnostic> LaneKernel<Indexed<I, V>, Multiple<O>> for RaiseErrorsOf<D>
impl<I: IndexDomain, V: ValueDomain, O: OrderState, D: Diagnostic> LaneKernel<Indexed<I, V>, Multiple<O>> for RaiseErrorsOf<D>
type Output = OperandHandle<Indexed<I, V>, Multiple<O>>
fn execute<'a>( _graphrecord: &'a GraphRecord, values: KeyedStream<'a, I, V, Multiple<O>>, _prepared: Self::Prepared<'a>, ) -> QueryResult<<Self::Output as EvaluateOperand>::ReturnValue<'a>>
fn estimate(&self, input: Estimate, _stats: &Stats<'_>) -> Estimate
Source§impl<I: IndexDomain, V: ValueDomain, O: OrderState, G: ErrorGroup> LaneKernel<Indexed<I, V>, Multiple<O>> for RaiseErrorsIn<G>
impl<I: IndexDomain, V: ValueDomain, O: OrderState, G: ErrorGroup> LaneKernel<Indexed<I, V>, Multiple<O>> for RaiseErrorsIn<G>
type Output = OperandHandle<Indexed<I, V>, Multiple<O>>
fn execute<'a>( _graphrecord: &'a GraphRecord, values: KeyedStream<'a, I, V, Multiple<O>>, _prepared: Self::Prepared<'a>, ) -> QueryResult<<Self::Output as EvaluateOperand>::ReturnValue<'a>>
fn estimate(&self, input: Estimate, _stats: &Stats<'_>) -> Estimate
Source§impl<I: IndexDomain, V: ValueDomain, O: OrderState, E: Error + 'static> LaneKernel<Indexed<I, V>, Multiple<O>> for RaiseErrorsWithCause<E>
impl<I: IndexDomain, V: ValueDomain, O: OrderState, E: Error + 'static> LaneKernel<Indexed<I, V>, Multiple<O>> for RaiseErrorsWithCause<E>
type Output = OperandHandle<Indexed<I, V>, Multiple<O>>
fn execute<'a>( _graphrecord: &'a GraphRecord, values: KeyedStream<'a, I, V, Multiple<O>>, _prepared: Self::Prepared<'a>, ) -> QueryResult<<Self::Output as EvaluateOperand>::ReturnValue<'a>>
fn estimate(&self, input: Estimate, _stats: &Stats<'_>) -> Estimate
Source§impl<I, V, O, D, C> LaneKernel<Indexed<I, V>, Multiple<O>> for RaiseWhenErrorsOf<D, C>where
I: IndexDomain,
V: ValueDomain,
O: OrderState,
D: Diagnostic,
C: ArgumentSource<Unaligned, Mask, Retention = Preserving>,
impl<I, V, O, D, C> LaneKernel<Indexed<I, V>, Multiple<O>> for RaiseWhenErrorsOf<D, C>where
I: IndexDomain,
V: ValueDomain,
O: OrderState,
D: Diagnostic,
C: ArgumentSource<Unaligned, Mask, Retention = Preserving>,
type Output = OperandHandle<Indexed<I, V>, Multiple<O>>
fn execute<'a>( graphrecord: &'a GraphRecord, values: KeyedStream<'a, I, V, Multiple<O>>, condition: Self::Prepared<'a>, ) -> QueryResult<<Self::Output as EvaluateOperand>::ReturnValue<'a>>
fn estimate(&self, input: Estimate, _stats: &Stats<'_>) -> Estimate
Source§impl<I, V, O, G, C> LaneKernel<Indexed<I, V>, Multiple<O>> for RaiseWhenErrorsIn<G, C>where
I: IndexDomain,
V: ValueDomain,
O: OrderState,
G: ErrorGroup,
C: ArgumentSource<Unaligned, Mask, Retention = Preserving>,
impl<I, V, O, G, C> LaneKernel<Indexed<I, V>, Multiple<O>> for RaiseWhenErrorsIn<G, C>where
I: IndexDomain,
V: ValueDomain,
O: OrderState,
G: ErrorGroup,
C: ArgumentSource<Unaligned, Mask, Retention = Preserving>,
type Output = OperandHandle<Indexed<I, V>, Multiple<O>>
fn execute<'a>( graphrecord: &'a GraphRecord, values: KeyedStream<'a, I, V, Multiple<O>>, condition: Self::Prepared<'a>, ) -> QueryResult<<Self::Output as EvaluateOperand>::ReturnValue<'a>>
fn estimate(&self, input: Estimate, _stats: &Stats<'_>) -> Estimate
Source§impl<I, V, O, E, C> LaneKernel<Indexed<I, V>, Multiple<O>> for RaiseWhenErrorsWithCause<E, C>where
I: IndexDomain,
V: ValueDomain,
O: OrderState,
E: Error + 'static,
C: ArgumentSource<Unaligned, Mask, Retention = Preserving>,
impl<I, V, O, E, C> LaneKernel<Indexed<I, V>, Multiple<O>> for RaiseWhenErrorsWithCause<E, C>where
I: IndexDomain,
V: ValueDomain,
O: OrderState,
E: Error + 'static,
C: ArgumentSource<Unaligned, Mask, Retention = Preserving>,
type Output = OperandHandle<Indexed<I, V>, Multiple<O>>
fn execute<'a>( graphrecord: &'a GraphRecord, values: KeyedStream<'a, I, V, Multiple<O>>, condition: Self::Prepared<'a>, ) -> QueryResult<<Self::Output as EvaluateOperand>::ReturnValue<'a>>
fn estimate(&self, input: Estimate, _stats: &Stats<'_>) -> Estimate
Source§impl<I: IndexDomain, V: ValueDomain, O: OrderState> LaneKernel<Indexed<I, V>, Multiple<O>> for ShuffleOperation
impl<I: IndexDomain, V: ValueDomain, O: OrderState> LaneKernel<Indexed<I, V>, Multiple<O>> for ShuffleOperation
type Output = OperandHandle<Indexed<I, V>, Multiple<Ordered>>
fn execute<'a>( _graphrecord: &'a GraphRecord, values: KeyedStream<'a, I, V, Multiple<O>>, _prepared: Self::Prepared<'a>, ) -> QueryResult<<Self::Output as EvaluateOperand>::ReturnValue<'a>>
fn estimate(&self, input: Estimate, _stats: &Stats<'_>) -> Estimate
Source§impl<I, V, O> LaneKernel<Indexed<I, V>, Multiple<O>> for SortOperationwhere
I: IndexDomain,
V: ValueOrdering,
O: OrderState,
for<'a> I::Index<'a>: EnsureSortable,
for<'a> V::Value<'a>: EnsureSortable,
V::Owned: Debug + Display + Send + Sync,
impl<I, V, O> LaneKernel<Indexed<I, V>, Multiple<O>> for SortOperationwhere
I: IndexDomain,
V: ValueOrdering,
O: OrderState,
for<'a> I::Index<'a>: EnsureSortable,
for<'a> V::Value<'a>: EnsureSortable,
V::Owned: Debug + Display + Send + Sync,
type Output = OperandHandle<Indexed<I, V>, Multiple<Ordered>>
fn execute<'a>( _graphrecord: &'a GraphRecord, values: KeyedStream<'a, I, V, Multiple<O>>, _prepared: Self::Prepared<'a>, ) -> QueryResult<<Self::Output as EvaluateOperand>::ReturnValue<'a>>
fn estimate(&self, input: Estimate, _stats: &Stats<'_>) -> Estimate
Source§impl<I, V, A, O> LaneKernel<Indexed<I, V>, Multiple<O>> for SortByOperation<A>where
I: IndexDomain,
V: ValueDomain,
A: ArgumentSource<Keyed<I>>,
O: OrderState,
for<'a> I::Index<'a>: EnsureSortable,
for<'a> <A::ValueDomain as ValueDomain>::Value<'a>: EnsureSortable,
<A::ValueDomain as ValueDomain>::Owned: Debug + Display + Send + Sync,
impl<I, V, A, O> LaneKernel<Indexed<I, V>, Multiple<O>> for SortByOperation<A>where
I: IndexDomain,
V: ValueDomain,
A: ArgumentSource<Keyed<I>>,
O: OrderState,
for<'a> I::Index<'a>: EnsureSortable,
for<'a> <A::ValueDomain as ValueDomain>::Value<'a>: EnsureSortable,
<A::ValueDomain as ValueDomain>::Owned: Debug + Display + Send + Sync,
type Output = OperandHandle<Indexed<I, V>, Multiple<Ordered>>
fn execute<'a>( _graphrecord: &'a GraphRecord, values: KeyedStream<'a, I, V, Multiple<O>>, prepared: Self::Prepared<'a>, ) -> QueryResult<<Self::Output as EvaluateOperand>::ReturnValue<'a>>
fn estimate(&self, input: Estimate, _stats: &Stats<'_>) -> Estimate
Source§impl<I: IndexDomain, V: ValueDomain, O: OrderState> LaneKernel<Indexed<I, V>, Multiple<O>> for UnorderOperation
impl<I: IndexDomain, V: ValueDomain, O: OrderState> LaneKernel<Indexed<I, V>, Multiple<O>> for UnorderOperation
type Output = OperandHandle<Indexed<I, V>, Multiple<Unordered>>
fn execute<'a>( _graphrecord: &'a GraphRecord, values: KeyedStream<'a, I, V, Multiple<O>>, _prepared: Self::Prepared<'a>, ) -> QueryResult<<Self::Output as EvaluateOperand>::ReturnValue<'a>>
fn estimate(&self, input: Estimate, _stats: &Stats<'_>) -> Estimate
Source§impl<I: IndexDomain, V: ValueEquivalence, O: OrderState> LaneKernel<Indexed<I, V>, Multiple<O>> for IsDuplicatedOperation
impl<I: IndexDomain, V: ValueEquivalence, O: OrderState> LaneKernel<Indexed<I, V>, Multiple<O>> for IsDuplicatedOperation
type Output = OperandHandle<Indexed<I, Mask>, Multiple<O>>
fn execute<'a>( _graphrecord: &'a GraphRecord, values: KeyedStream<'a, I, V, Multiple<O>>, _prepared: Self::Prepared<'a>, ) -> QueryResult<<Self::Output as EvaluateOperand>::ReturnValue<'a>>
fn estimate(&self, input: Estimate, _stats: &Stats<'_>) -> Estimate
Source§impl<I: IndexDomain, V: ValueDomain> LaneKernel<Indexed<I, V>, Multiple<Ordered>> for EnumerateOperation
impl<I: IndexDomain, V: ValueDomain> LaneKernel<Indexed<I, V>, Multiple<Ordered>> for EnumerateOperation
type Output = OperandHandle<Indexed<Positional, V>, Multiple<Ordered>>
fn execute<'a>( _graphrecord: &'a GraphRecord, values: KeyedStream<'a, I, V, Multiple<Ordered>>, _prepared: Self::Prepared<'a>, ) -> QueryResult<<Self::Output as EvaluateOperand>::ReturnValue<'a>>
fn estimate(&self, input: Estimate, _stats: &Stats<'_>) -> Estimate
Source§impl<I: IndexDomain, V: ValueDomain> LaneKernel<Indexed<I, V>, Multiple<Ordered>> for FirstOperation
impl<I: IndexDomain, V: ValueDomain> LaneKernel<Indexed<I, V>, Multiple<Ordered>> for FirstOperation
type Output = OperandHandle<Indexed<I, V>, Single>
fn execute<'a>( _graphrecord: &'a GraphRecord, values: KeyedStream<'a, I, V, Multiple<Ordered>>, _prepared: Self::Prepared<'a>, ) -> QueryResult<<Self::Output as EvaluateOperand>::ReturnValue<'a>>
fn estimate(&self, input: Estimate, _stats: &Stats<'_>) -> Estimate
Source§impl<I: IndexDomain, V: ValueDomain> LaneKernel<Indexed<I, V>, Multiple<Ordered>> for LastOperation
impl<I: IndexDomain, V: ValueDomain> LaneKernel<Indexed<I, V>, Multiple<Ordered>> for LastOperation
type Output = OperandHandle<Indexed<I, V>, Single>
fn execute<'a>( _graphrecord: &'a GraphRecord, values: KeyedStream<'a, I, V, Multiple<Ordered>>, _prepared: Self::Prepared<'a>, ) -> QueryResult<<Self::Output as EvaluateOperand>::ReturnValue<'a>>
fn estimate(&self, input: Estimate, _stats: &Stats<'_>) -> Estimate
Source§impl<I: IndexDomain, V: ValueDomain> LaneKernel<Indexed<I, V>, Multiple<Ordered>> for ReverseOrderOperation
impl<I: IndexDomain, V: ValueDomain> LaneKernel<Indexed<I, V>, Multiple<Ordered>> for ReverseOrderOperation
type Output = OperandHandle<Indexed<I, V>, Multiple<Ordered>>
fn execute<'a>( _graphrecord: &'a GraphRecord, values: KeyedStream<'a, I, V, Multiple<Ordered>>, _prepared: Self::Prepared<'a>, ) -> QueryResult<<Self::Output as EvaluateOperand>::ReturnValue<'a>>
fn estimate(&self, input: Estimate, _stats: &Stats<'_>) -> Estimate
Source§impl<I: IndexDomain, V: ValueDomain> LaneKernel<Indexed<I, V>, Multiple<Ordered>> for TakeOperation
impl<I: IndexDomain, V: ValueDomain> LaneKernel<Indexed<I, V>, Multiple<Ordered>> for TakeOperation
type Output = OperandHandle<Indexed<I, V>, Multiple<Ordered>>
fn execute<'a>( _graphrecord: &'a GraphRecord, values: KeyedStream<'a, I, V, Multiple<Ordered>>, prepared: Self::Prepared<'a>, ) -> QueryResult<<Self::Output as EvaluateOperand>::ReturnValue<'a>>
fn estimate(&self, input: Estimate, _stats: &Stats<'_>) -> Estimate
Source§impl<I: IndexDomain, V: ValueEquivalence> LaneKernel<Indexed<I, V>, Multiple<Ordered>> for DropDuplicatesOperation
impl<I: IndexDomain, V: ValueEquivalence> LaneKernel<Indexed<I, V>, Multiple<Ordered>> for DropDuplicatesOperation
type Output = OperandHandle<Indexed<I, V>, Multiple<Ordered>>
fn execute<'a>( _graphrecord: &'a GraphRecord, values: KeyedStream<'a, I, V, Multiple<Ordered>>, _prepared: Self::Prepared<'a>, ) -> QueryResult<<Self::Output as EvaluateOperand>::ReturnValue<'a>>
fn estimate(&self, input: Estimate, _stats: &Stats<'_>) -> Estimate
Source§impl<I: IndexDomain, V: ValueDomain> LaneKernel<Indexed<I, V>, Single> for CountOperation
impl<I: IndexDomain, V: ValueDomain> LaneKernel<Indexed<I, V>, Single> for CountOperation
type Output = OperandHandle<Bare<Scalar>, Definite>
fn execute<'a>( _graphrecord: &'a GraphRecord, value: KeyedStream<'a, I, V, Single>, _prepared: Self::Prepared<'a>, ) -> QueryResult<<Self::Output as EvaluateOperand>::ReturnValue<'a>>
fn estimate(&self, _input: Estimate, _stats: &Stats<'_>) -> Estimate
Source§impl<I: IndexDomain, V: ValueDomain> LaneKernel<Indexed<I, V>, Single> for Raise
impl<I: IndexDomain, V: ValueDomain> LaneKernel<Indexed<I, V>, Single> for Raise
type Output = OperandHandle<Indexed<I, V>, Single>
fn execute<'a>( _graphrecord: &'a GraphRecord, value: KeyedStream<'a, I, V, Single>, _prepared: Self::Prepared<'a>, ) -> QueryResult<<Self::Output as EvaluateOperand>::ReturnValue<'a>>
fn estimate(&self, input: Estimate, _stats: &Stats<'_>) -> Estimate
Source§impl<I, V, C> LaneKernel<Indexed<I, V>, Single> for RaiseWhen<C>
impl<I, V, C> LaneKernel<Indexed<I, V>, Single> for RaiseWhen<C>
type Output = OperandHandle<Indexed<I, V>, Single>
fn execute<'a>( graphrecord: &'a GraphRecord, value: KeyedStream<'a, I, V, Single>, condition: Self::Prepared<'a>, ) -> QueryResult<<Self::Output as EvaluateOperand>::ReturnValue<'a>>
fn estimate(&self, input: Estimate, _stats: &Stats<'_>) -> Estimate
Source§impl<I: IndexDomain, V: ValueDomain, D: Diagnostic> LaneKernel<Indexed<I, V>, Single> for RaiseErrorsOf<D>
impl<I: IndexDomain, V: ValueDomain, D: Diagnostic> LaneKernel<Indexed<I, V>, Single> for RaiseErrorsOf<D>
type Output = OperandHandle<Indexed<I, V>, Single>
fn execute<'a>( _graphrecord: &'a GraphRecord, value: KeyedStream<'a, I, V, Single>, _prepared: Self::Prepared<'a>, ) -> QueryResult<<Self::Output as EvaluateOperand>::ReturnValue<'a>>
fn estimate(&self, input: Estimate, _stats: &Stats<'_>) -> Estimate
Source§impl<I: IndexDomain, V: ValueDomain, G: ErrorGroup> LaneKernel<Indexed<I, V>, Single> for RaiseErrorsIn<G>
impl<I: IndexDomain, V: ValueDomain, G: ErrorGroup> LaneKernel<Indexed<I, V>, Single> for RaiseErrorsIn<G>
type Output = OperandHandle<Indexed<I, V>, Single>
fn execute<'a>( _graphrecord: &'a GraphRecord, value: KeyedStream<'a, I, V, Single>, _prepared: Self::Prepared<'a>, ) -> QueryResult<<Self::Output as EvaluateOperand>::ReturnValue<'a>>
fn estimate(&self, input: Estimate, _stats: &Stats<'_>) -> Estimate
Source§impl<I: IndexDomain, V: ValueDomain, E: Error + 'static> LaneKernel<Indexed<I, V>, Single> for RaiseErrorsWithCause<E>
impl<I: IndexDomain, V: ValueDomain, E: Error + 'static> LaneKernel<Indexed<I, V>, Single> for RaiseErrorsWithCause<E>
type Output = OperandHandle<Indexed<I, V>, Single>
fn execute<'a>( _graphrecord: &'a GraphRecord, value: KeyedStream<'a, I, V, Single>, _prepared: Self::Prepared<'a>, ) -> QueryResult<<Self::Output as EvaluateOperand>::ReturnValue<'a>>
fn estimate(&self, input: Estimate, _stats: &Stats<'_>) -> Estimate
Source§impl<I, V, D, C> LaneKernel<Indexed<I, V>, Single> for RaiseWhenErrorsOf<D, C>where
I: IndexDomain,
V: ValueDomain,
D: Diagnostic,
C: ArgumentSource<Unaligned, Mask, Retention = Preserving>,
impl<I, V, D, C> LaneKernel<Indexed<I, V>, Single> for RaiseWhenErrorsOf<D, C>where
I: IndexDomain,
V: ValueDomain,
D: Diagnostic,
C: ArgumentSource<Unaligned, Mask, Retention = Preserving>,
type Output = OperandHandle<Indexed<I, V>, Single>
fn execute<'a>( graphrecord: &'a GraphRecord, value: KeyedStream<'a, I, V, Single>, condition: Self::Prepared<'a>, ) -> QueryResult<<Self::Output as EvaluateOperand>::ReturnValue<'a>>
fn estimate(&self, input: Estimate, _stats: &Stats<'_>) -> Estimate
Source§impl<I, V, G, C> LaneKernel<Indexed<I, V>, Single> for RaiseWhenErrorsIn<G, C>where
I: IndexDomain,
V: ValueDomain,
G: ErrorGroup,
C: ArgumentSource<Unaligned, Mask, Retention = Preserving>,
impl<I, V, G, C> LaneKernel<Indexed<I, V>, Single> for RaiseWhenErrorsIn<G, C>where
I: IndexDomain,
V: ValueDomain,
G: ErrorGroup,
C: ArgumentSource<Unaligned, Mask, Retention = Preserving>,
type Output = OperandHandle<Indexed<I, V>, Single>
fn execute<'a>( graphrecord: &'a GraphRecord, value: KeyedStream<'a, I, V, Single>, condition: Self::Prepared<'a>, ) -> QueryResult<<Self::Output as EvaluateOperand>::ReturnValue<'a>>
fn estimate(&self, input: Estimate, _stats: &Stats<'_>) -> Estimate
Source§impl<I, V, E, C> LaneKernel<Indexed<I, V>, Single> for RaiseWhenErrorsWithCause<E, C>where
I: IndexDomain,
V: ValueDomain,
E: Error + 'static,
C: ArgumentSource<Unaligned, Mask, Retention = Preserving>,
impl<I, V, E, C> LaneKernel<Indexed<I, V>, Single> for RaiseWhenErrorsWithCause<E, C>where
I: IndexDomain,
V: ValueDomain,
E: Error + 'static,
C: ArgumentSource<Unaligned, Mask, Retention = Preserving>,
type Output = OperandHandle<Indexed<I, V>, Single>
fn execute<'a>( graphrecord: &'a GraphRecord, value: KeyedStream<'a, I, V, Single>, condition: Self::Prepared<'a>, ) -> QueryResult<<Self::Output as EvaluateOperand>::ReturnValue<'a>>
fn estimate(&self, input: Estimate, _stats: &Stats<'_>) -> Estimate
Source§impl LaneKernel<Indexed<u32, Unit>, Definite> for NodesOperation
impl LaneKernel<Indexed<u32, Unit>, Definite> for NodesOperation
type Output = OperandHandle<Indexed<GraphRecordAttribute, Unit>, Multiple<Unordered>>
fn execute<'a>( graphrecord: &'a GraphRecord, value: KeyedStream<'a, EdgeIndex, Unit, Definite>, _prepared: Self::Prepared<'a>, ) -> QueryResult<<Self::Output as EvaluateOperand>::ReturnValue<'a>>
fn estimate(&self, input: Estimate, stats: &Stats<'_>) -> Estimate
Source§impl<O: OrderState> LaneKernel<Indexed<u32, Unit>, Multiple<O>> for NodesOperation
impl<O: OrderState> LaneKernel<Indexed<u32, Unit>, Multiple<O>> for NodesOperation
type Output = OperandHandle<Indexed<GraphRecordAttribute, Unit>, Multiple<Unordered>>
fn execute<'a>( graphrecord: &'a GraphRecord, values: KeyedStream<'a, EdgeIndex, Unit, Multiple<O>>, _prepared: Self::Prepared<'a>, ) -> QueryResult<<Self::Output as EvaluateOperand>::ReturnValue<'a>>
fn estimate(&self, input: Estimate, stats: &Stats<'_>) -> Estimate
Source§impl LaneKernel<Indexed<u32, Unit>, Single> for NodesOperation
impl LaneKernel<Indexed<u32, Unit>, Single> for NodesOperation
type Output = OperandHandle<Indexed<GraphRecordAttribute, Unit>, Multiple<Unordered>>
fn execute<'a>( graphrecord: &'a GraphRecord, value: KeyedStream<'a, EdgeIndex, Unit, Single>, _prepared: Self::Prepared<'a>, ) -> QueryResult<<Self::Output as EvaluateOperand>::ReturnValue<'a>>
fn estimate(&self, input: Estimate, stats: &Stats<'_>) -> Estimate
Source§impl<M: IndexDomain, V: ValueDomain> PartitionShape<M> for Indexed<M, V>
impl<M: IndexDomain, V: ValueDomain> PartitionShape<M> for Indexed<M, V>
Source§impl<I: IndexDomain, V: ValueDomain, O: OrderState> PreparedArity<Indexed<I, V>> for Multiple<O>
impl<I: IndexDomain, V: ValueDomain, O: OrderState> PreparedArity<Indexed<I, V>> for Multiple<O>
Source§impl<I: IndexDomain, V: ValueDomain> PreparedArity<Indexed<I, V>> for Single
impl<I: IndexDomain, V: ValueDomain> PreparedArity<Indexed<I, V>> for Single
type Prepared<'a> = Option<(<I as IndexDomain>::Index<'a>, Result<<V as ValueDomain>::Value<'a>, Box<Failure>>)> where Indexed<I, V>: 'a
fn prepare<'a>(
container: Self::Container<'a, <Indexed<I, V> as ElementShape>::Element<'a>>,
) -> QueryResult<Self::Prepared<'a>>where
Indexed<I, V>: 'a,
Source§impl<I: IndexDomain, V: ValueDomain> PreparedArity<Indexed<I, V>> for Definite
impl<I: IndexDomain, V: ValueDomain> PreparedArity<Indexed<I, V>> for Definite
Source§impl<K: IndexDomain, V: ReturnValueDomain> ReturnShape for Indexed<K, V>
impl<K: IndexDomain, V: ReturnValueDomain> ReturnShape for Indexed<K, V>
type ReturnElement<'a> = (<K as IndexDomain>::Index<'a>, Result<<V as ValueDomain>::Value<'a>, Box<Failure>>)
fn into_return_element(element: Self::Element<'_>) -> Self::ReturnElement<'_>
Source§impl<K: IndexDomain> ReturnShape for Indexed<K, Unit>
impl<K: IndexDomain> ReturnShape for Indexed<K, Unit>
type ReturnElement<'a> = Result<<K as IndexDomain>::Owned, Box<Failure>>
fn into_return_element(element: Self::Element<'_>) -> Self::ReturnElement<'_>
Auto Trait Implementations§
impl<K, V> Freeze for Indexed<K, V>
impl<K, V> RefUnwindSafe for Indexed<K, V>where
K: RefUnwindSafe,
V: RefUnwindSafe,
impl<K, V> Send for Indexed<K, V>
impl<K, V> Sync for Indexed<K, V>
impl<K, V> Unpin for Indexed<K, V>
impl<K, V> UnsafeUnpin for Indexed<K, V>
impl<K, V> UnwindSafe for Indexed<K, V>where
K: UnwindSafe,
V: UnwindSafe,
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
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 more