pub struct CogroupedKStream<K, VOut> { /* private fields */ }Expand description
A handle that collects the cogrouped inputs. The terminal aggregate and
windowed_by* consume it.
builder and inputs are pub(crate), so the windowed-handle modules can
move the inputs into their own handles. Build this type through the DSL entry
points.
Implementations§
Source§impl<K, VOut> CogroupedKStream<K, VOut>
impl<K, VOut> CogroupedKStream<K, VOut>
Sourcepub fn cogroup<Vn, A>(self, grouped: KGroupedStream<K, Vn>, agg: A) -> Self
pub fn cogroup<Vn, A>(self, grouped: KGroupedStream<K, Vn>, agg: A) -> Self
Chain another co-partitioned input with its own aggregator.
Sourcepub fn aggregate_explicit<KS, VS, I>(
self,
init: I,
materialized: impl Into<Materialized<KS, VS>>,
) -> KTable<K, VOut, KS, VS>
pub fn aggregate_explicit<KS, VS, I>( self, init: I, materialized: impl Into<Materialized<KS, VS>>, ) -> KTable<K, VOut, KS, VS>
Non-windowed terminal aggregation, which gives a KTable<K, VOut>.
Sourcepub fn aggregate<I>(
self,
init: I,
store_name: impl Into<String>,
) -> KTable<K, VOut, <K as DefaultSerde>::Serde, <VOut as DefaultSerde>::Serde>where
K: DefaultSerde,
VOut: DefaultSerde,
<K as DefaultSerde>::Serde: Serde<K> + Clone,
<VOut as DefaultSerde>::Serde: Serde<VOut> + Clone,
I: Fn() -> VOut + Send + Sync + 'static,
pub fn aggregate<I>(
self,
init: I,
store_name: impl Into<String>,
) -> KTable<K, VOut, <K as DefaultSerde>::Serde, <VOut as DefaultSerde>::Serde>where
K: DefaultSerde,
VOut: DefaultSerde,
<K as DefaultSerde>::Serde: Serde<K> + Clone,
<VOut as DefaultSerde>::Serde: Serde<VOut> + Clone,
I: Fn() -> VOut + Send + Sync + 'static,
Non-windowed terminal aggregation with default serdes.
Source§impl<K, VOut> CogroupedKStream<K, VOut>
impl<K, VOut> CogroupedKStream<K, VOut>
Sourcepub fn windowed_by_session(
self,
windows: SessionWindows,
) -> SessionWindowedCogroupedStream<K, VOut>
pub fn windowed_by_session( self, windows: SessionWindows, ) -> SessionWindowedCogroupedStream<K, VOut>
windowedBy(SessionWindows): switch to a session-windowed cogroup
(KIP-150).
Unlike the time-windowed and sliding-windowed cogroup, the terminal
aggregate_explicit needs a merger. The merger combines two session
aggregates when the runtime merges sessions after an inactivity gap
expires.
Source§impl<K, VOut> CogroupedKStream<K, VOut>
impl<K, VOut> CogroupedKStream<K, VOut>
Sourcepub fn windowed_by_sliding(
self,
windows: SlidingWindows,
) -> SlidingWindowedCogroupedStream<K, VOut>
pub fn windowed_by_sliding( self, windows: SlidingWindows, ) -> SlidingWindowedCogroupedStream<K, VOut>
windowedBy(SlidingWindows): switch to a sliding-windowed cogroup
(KIP-450).
Source§impl<K, VOut> CogroupedKStream<K, VOut>
impl<K, VOut> CogroupedKStream<K, VOut>
Sourcepub fn windowed_by(
self,
windows: TimeWindows,
) -> TimeWindowedCogroupedStream<K, VOut>
pub fn windowed_by( self, windows: TimeWindows, ) -> TimeWindowedCogroupedStream<K, VOut>
windowedBy(TimeWindows): turn this cogroup into a time-windowed cogroup.
Auto Trait Implementations§
impl<K, VOut> !RefUnwindSafe for CogroupedKStream<K, VOut>
impl<K, VOut> !Send for CogroupedKStream<K, VOut>
impl<K, VOut> !Sync for CogroupedKStream<K, VOut>
impl<K, VOut> !UnwindSafe for CogroupedKStream<K, VOut>
impl<K, VOut> Freeze for CogroupedKStream<K, VOut>
impl<K, VOut> Unpin for CogroupedKStream<K, VOut>
impl<K, VOut> UnsafeUnpin for CogroupedKStream<K, VOut>
Blanket Implementations§
§impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
§impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
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
impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
§impl<K, Q> Comparable<Q> for K
impl<K, Q> Comparable<Q> for K
§impl<T> Downcast for Twhere
T: Any,
impl<T> Downcast for Twhere
T: Any,
§fn into_any(self: Box<T>) -> Box<dyn Any>
fn into_any(self: Box<T>) -> Box<dyn Any>
Box<dyn Trait> (where Trait: Downcast) to Box<dyn Any>, which can then be
downcast into Box<dyn ConcreteType> where ConcreteType implements Trait.§fn into_any_rc(self: Rc<T>) -> Rc<dyn Any>
fn into_any_rc(self: Rc<T>) -> Rc<dyn Any>
Rc<Trait> (where Trait: Downcast) to Rc<Any>, which can then be further
downcast into Rc<ConcreteType> where ConcreteType implements Trait.§fn as_any(&self) -> &(dyn Any + 'static)
fn as_any(&self) -> &(dyn Any + 'static)
&Trait (where Trait: Downcast) to &Any. This is needed since Rust cannot
generate &Any’s vtable from &Trait’s.§fn as_any_mut(&mut self) -> &mut (dyn Any + 'static)
fn as_any_mut(&mut self) -> &mut (dyn Any + 'static)
&mut Trait (where Trait: Downcast) to &Any. This is needed since Rust cannot
generate &mut Any’s vtable from &mut Trait’s.§impl<K, Q> Equivalent<Q> for K
impl<K, Q> Equivalent<Q> for K
§fn equivalent(&self, key: &Q) -> bool
fn equivalent(&self, key: &Q) -> bool
key and return true if they are equal.impl<T> ErasedDestructor for Twhere
T: 'static,
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
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>
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§impl<T> Paint for Twhere
T: ?Sized,
impl<T> Paint for Twhere
T: ?Sized,
§fn fg(&self, value: Color) -> Painted<&T>
fn fg(&self, value: Color) -> Painted<&T>
Returns a styled value derived from self with the foreground set to
value.
This method should be used rarely. Instead, prefer to use color-specific
builder methods like red() and
green(), which have the same functionality but are
pithier.
§Example
Set foreground color to white using fg():
use yansi::{Paint, Color};
painted.fg(Color::White);Set foreground color to white using white().
use yansi::Paint;
painted.white();§fn bright_black(&self) -> Painted<&T>
fn bright_black(&self) -> Painted<&T>
§fn bright_red(&self) -> Painted<&T>
fn bright_red(&self) -> Painted<&T>
§fn bright_green(&self) -> Painted<&T>
fn bright_green(&self) -> Painted<&T>
§fn bright_yellow(&self) -> Painted<&T>
fn bright_yellow(&self) -> Painted<&T>
§fn bright_blue(&self) -> Painted<&T>
fn bright_blue(&self) -> Painted<&T>
§fn bright_magenta(&self) -> Painted<&T>
fn bright_magenta(&self) -> Painted<&T>
§fn bright_cyan(&self) -> Painted<&T>
fn bright_cyan(&self) -> Painted<&T>
§fn bright_white(&self) -> Painted<&T>
fn bright_white(&self) -> Painted<&T>
§fn bg(&self, value: Color) -> Painted<&T>
fn bg(&self, value: Color) -> Painted<&T>
Returns a styled value derived from self with the background set to
value.
This method should be used rarely. Instead, prefer to use color-specific
builder methods like on_red() and
on_green(), which have the same functionality but
are pithier.
§Example
Set background color to red using fg():
use yansi::{Paint, Color};
painted.bg(Color::Red);Set background color to red using on_red().
use yansi::Paint;
painted.on_red();§fn on_primary(&self) -> Painted<&T>
fn on_primary(&self) -> Painted<&T>
§fn on_magenta(&self) -> Painted<&T>
fn on_magenta(&self) -> Painted<&T>
§fn on_bright_black(&self) -> Painted<&T>
fn on_bright_black(&self) -> Painted<&T>
§fn on_bright_red(&self) -> Painted<&T>
fn on_bright_red(&self) -> Painted<&T>
§fn on_bright_green(&self) -> Painted<&T>
fn on_bright_green(&self) -> Painted<&T>
§fn on_bright_yellow(&self) -> Painted<&T>
fn on_bright_yellow(&self) -> Painted<&T>
§fn on_bright_blue(&self) -> Painted<&T>
fn on_bright_blue(&self) -> Painted<&T>
§fn on_bright_magenta(&self) -> Painted<&T>
fn on_bright_magenta(&self) -> Painted<&T>
§fn on_bright_cyan(&self) -> Painted<&T>
fn on_bright_cyan(&self) -> Painted<&T>
§fn on_bright_white(&self) -> Painted<&T>
fn on_bright_white(&self) -> Painted<&T>
§fn attr(&self, value: Attribute) -> Painted<&T>
fn attr(&self, value: Attribute) -> Painted<&T>
Enables the styling [Attribute] value.
This method should be used rarely. Instead, prefer to use
attribute-specific builder methods like bold() and
underline(), which have the same functionality
but are pithier.
§Example
Make text bold using attr():
use yansi::{Paint, Attribute};
painted.attr(Attribute::Bold);Make text bold using using bold().
use yansi::Paint;
painted.bold();§fn rapid_blink(&self) -> Painted<&T>
fn rapid_blink(&self) -> Painted<&T>
§fn quirk(&self, value: Quirk) -> Painted<&T>
fn quirk(&self, value: Quirk) -> Painted<&T>
Enables the yansi [Quirk] value.
This method should be used rarely. Instead, prefer to use quirk-specific
builder methods like mask() and
wrap(), which have the same functionality but are
pithier.
§Example
Enable wrapping using .quirk():
use yansi::{Paint, Quirk};
painted.quirk(Quirk::Wrap);Enable wrapping using wrap().
use yansi::Paint;
painted.wrap();§fn clear(&self) -> Painted<&T>
👎Deprecated since 1.0.1: renamed to resetting() due to conflicts with Vec::clear().
The clear() method will be removed in a future release.
fn clear(&self) -> Painted<&T>
renamed to resetting() due to conflicts with Vec::clear().
The clear() method will be removed in a future release.
§fn whenever(&self, value: Condition) -> Painted<&T>
fn whenever(&self, value: Condition) -> Painted<&T>
Conditionally enable styling based on whether the [Condition] value
applies. Replaces any previous condition.
See the crate level docs for more details.
§Example
Enable styling painted only when both stdout and stderr are TTYs:
use yansi::{Paint, Condition};
painted.red().on_yellow().whenever(Condition::STDOUTERR_ARE_TTY);