Skip to content

Commit

Permalink
add comments
Browse files Browse the repository at this point in the history
  • Loading branch information
fuyufjh committed Sep 15, 2023
1 parent 1202303 commit 4314c7b
Showing 1 changed file with 4 additions and 0 deletions.
4 changes: 4 additions & 0 deletions src/stream/src/executor/dispatch.rs
Original file line number Diff line number Diff line change
Expand Up @@ -490,8 +490,12 @@ pub trait Dispatcher: Debug + 'static {

/// The ID of the dispatcher. A [`DispatchExecutor`] may have multiple dispatchers with
/// different IDs.
///
/// Note that the dispatcher id is always equal to the downstream fragment id.
/// See also `proto/stream_plan.proto`.
fn dispatcher_id(&self) -> DispatcherId;

/// Dispatcher id in string. See [`dispatcher_id`].
fn dispatcher_id_str(&self) -> &str;

/// Whether the dispatcher has no outputs. If so, it'll be cleaned up from the
Expand Down

0 comments on commit 4314c7b

Please sign in to comment.