Add comment.

JSOD11 · jayshrivastava · commit 1a3fe1c2857a · 2025-11-01T17:32:42.000-04:00
diff --git a/src/protobuf/distributed_codec.rs b/src/protobuf/distributed_codec.rs
@@ -239,7 +239,7 @@ impl PhysicalExtensionCodec for DistributedCodec {
     }
 }
 
-/// A key that uniquely identifies a stage in a query
+/// A key that uniquely identifies a stage in a query.
 #[derive(Clone, Hash, Eq, PartialEq, ::prost::Message)]
 pub struct StageKey {
     /// Our query id
@@ -254,6 +254,7 @@ pub struct StageKey {
 }
 
 impl StageKey {
+    /// Creates a new `StageKey`.
     pub fn new(query_id: Bytes, stage_id: u64, task_number: u64) -> StageKey {
         Self {
             query_id,

Original file line number	Diff line number	Diff line change
`@@ -239,7 +239,7 @@ impl PhysicalExtensionCodec for DistributedCodec {`
`239`	`239`	`}`
`240`	`240`	`}`
`241`	`241`
`242`		`-/// A key that uniquely identifies a stage in a query`
	`242`	`+/// A key that uniquely identifies a stage in a query.`
`243`	`243`	`#[derive(Clone, Hash, Eq, PartialEq, ::prost::Message)]`
`244`	`244`	`pub struct StageKey {`
`245`	`245`	`/// Our query id`
`@@ -254,6 +254,7 @@ pub struct StageKey {`
`254`	`254`	`}`
`255`	`255`
`256`	`256`	`impl StageKey {`
	`257`	+ /// Creates a new `StageKey`.
`257`	`258`	`pub fn new(query_id: Bytes, stage_id: u64, task_number: u64) -> StageKey {`
`258`	`259`	`Self {`
`259`	`260`	`query_id,`