risingwave_common/row/
ordered.rs

1// Copyright 2025 RisingWave Labs
2//
3// Licensed under the Apache License, Version 2.0 (the "License");
4// you may not use this file except in compliance with the License.
5// You may obtain a copy of the License at
6//
7//     http://www.apache.org/licenses/LICENSE-2.0
8//
9// Unless required by applicable law or agreed to in writing, software
10// distributed under the License is distributed on an "AS IS" BASIS,
11// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12// See the License for the specific language governing permissions and
13// limitations under the License.
14
15use super::{OwnedRow, Row};
16use crate::types::{DefaultOrd, DefaultOrdered, DefaultPartialOrd};
17use crate::util::sort_util::{OrderType, cmp_datum_iter, partial_cmp_datum_iter};
18
19impl<R: Row> Row for DefaultOrdered<R> {
20    deref_forward_row! {}
21
22    fn into_owned_row(self) -> OwnedRow {
23        self.into_inner().into_owned_row()
24    }
25}
26
27impl<R: Row> DefaultPartialOrd for R {
28    fn default_partial_cmp(&self, other: &Self) -> Option<std::cmp::Ordering> {
29        partial_cmp_datum_iter(
30            self.iter(),
31            other.iter(),
32            std::iter::repeat(OrderType::default()),
33        )
34    }
35}
36
37impl<R: Row> DefaultOrd for R {
38    fn default_cmp(&self, other: &Self) -> std::cmp::Ordering {
39        // NOTE(rc): This is slightly different from `cmp_rows`, for this function won't
40        // check the length of rows.
41        cmp_datum_iter(
42            self.iter(),
43            other.iter(),
44            std::iter::repeat(OrderType::default()),
45        )
46    }
47}
risingwave_common/row/ordered.rs

risingwave_common/row/
ordered.rs
