risingwave_
stream
2.4.0-alpha
In risingwave_
stream::
task
Modules
await_tree_key
barrier_manager
env
stream_manager
Structs
ActorEvalErrorReport
BarrierCompleteResult
CreateMviewProgressReporter
ExecutorParams
LocalBarrierManager
LocalStreamManager
PartialGraphId
SharedContext
StreamEnvironment
Constants
ENABLE_BARRIER_AGGREGATION
Type Aliases
ActorHandle
ActorId
AtomicU64Ref
ConsumableChannelPair
DispatcherId
FragmentId
UpDownActorIds
UpDownFragmentIds
risingwave_stream
::
task
Type Alias
UpDownActorIds
Copy item path
Settings
Help
Summary
Source
pub type UpDownActorIds = (
ActorId
,
ActorId
);