From d25ac8e47f07bc0f2e446caa80384b7f6414a116 Mon Sep 17 00:00:00 2001 From: Piotr Findeisen Date: Thu, 28 Nov 2024 20:24:11 +0100 Subject: [PATCH] fixup! fixup! fixup! fixup! Apply clippy fixes --- datafusion/catalog/src/catalog.rs | 1 - datafusion/physical-plan/src/aggregates/topk/heap.rs | 2 +- 2 files changed, 1 insertion(+), 2 deletions(-) diff --git a/datafusion/catalog/src/catalog.rs b/datafusion/catalog/src/catalog.rs index 048a7f14ed378..85f2dede2f277 100644 --- a/datafusion/catalog/src/catalog.rs +++ b/datafusion/catalog/src/catalog.rs @@ -101,7 +101,6 @@ use datafusion_common::Result; /// [`UnityCatalogProvider`]: https://github.com/delta-io/delta-rs/blob/951436ecec476ce65b5ed3b58b50fb0846ca7b91/crates/deltalake-core/src/data_catalog/unity/datafusion.rs#L111-L123 /// /// [`TableProvider`]: crate::TableProvider - pub trait CatalogProvider: Debug + Sync + Send { /// Returns the catalog provider as [`Any`] /// so that it can be downcast to a specific implementation. diff --git a/datafusion/physical-plan/src/aggregates/topk/heap.rs b/datafusion/physical-plan/src/aggregates/topk/heap.rs index 61569e511a883..ec1277f8fd558 100644 --- a/datafusion/physical-plan/src/aggregates/topk/heap.rs +++ b/datafusion/physical-plan/src/aggregates/topk/heap.rs @@ -367,7 +367,7 @@ impl TopKHeap { impl Display for TopKHeap { fn fmt(&self, f: &mut Formatter<'_>) -> std::fmt::Result { let mut output = String::new(); - if self.heap.first().is_some() { + if !self.heap.is_empty() { self._tree_print(0, String::new(), true, &mut output); } write!(f, "{}", output)