yjshen commented on a change in pull request #1687:
URL: https://github.com/apache/arrow-datafusion/pull/1687#discussion_r793194166
##########
File path: datafusion/src/physical_plan/sorts/sort_preserving_merge.rs
##########
@@ -58,6 +58,27 @@ use crate::physical_plan::{
/// provided each partition of the input plan is sorted with respect to
/// these sort expressions, this operator will yield a single partition
/// that is also sorted with respect to them
+///
+/// ```text
+/// ┌─────────────────────────┐
+/// │ ┌───┬───┬───┬───┐ │
+/// │ │ A │ B │ C │ D │ ... │──┐
+/// │ └───┴───┴───┴───┘ │ │
+/// └─────────────────────────┘ │ ┌───────────────────┐
┌───────────────────────────────┐
+/// Stream 1 │ │ │ │
┌───┬───╦═══╦───┬───╦═══╗ │
+/// ├─▶│SortPreservingMerge│───▶│ │ A │ B ║ B ║ C
│ D ║ E ║ ... │
+/// │ │ │ │
└───┴─▲─╩═══╩───┴───╩═══╝ │
+/// ┌─────────────────────────┐ │ └───────────────────┘
└─┬─────┴───────────────────────┘
+/// │ ╔═══╦═══╗ │ │
+/// │ ║ B ║ E ║ ... │──┘ │
+/// │ ╚═══╩═══╝ │ Note Stable Sort: the merged
stream
+/// └─────────────────────────┘ places equal rows from stream 1
+/// Stream 2
+///
+///
+/// Input Streams Output stream
+/// (sorted) (sorted)
+/// ```
Review comment:
Nice diagram!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
