From b2af7b0d9367d0ba447fb34a70b1661539c5b4c0 Mon Sep 17 00:00:00 2001
From: Marco Neumann <marco@crepererum.net>
Date: Fri, 13 Jan 2023 08:29:02 +0100
Subject: [PATCH] fix: remove dead code

---
 datafusion/core/src/physical_plan/repartition/mod.rs | 10 +---------
 1 file changed, 1 insertion(+), 9 deletions(-)

diff --git a/datafusion/core/src/physical_plan/repartition/mod.rs b/datafusion/core/src/physical_plan/repartition/mod.rs
index 8567c57778c48..ec1d092ae7acb 100644
--- a/datafusion/core/src/physical_plan/repartition/mod.rs
+++ b/datafusion/core/src/physical_plan/repartition/mod.rs
@@ -46,7 +46,7 @@ use super::{RecordBatchStream, SendableRecordBatchStream};
 use crate::execution::context::TaskContext;
 use datafusion_physical_expr::PhysicalExpr;
 use futures::stream::Stream;
-use futures::{Future, FutureExt, StreamExt};
+use futures::{FutureExt, StreamExt};
 use hashbrown::HashMap;
 use parking_lot::Mutex;
 use tokio::task::JoinHandle;
@@ -224,14 +224,6 @@ impl BatchPartitioner {
     }
 }
 
-trait PartitiontFun {
-    type Fut<'a>: Future<Output = Result<()>>
-    where
-        Self: 'a;
-
-    fn c(&mut self, partition: usize, batch: RecordBatch) -> Self::Fut<'_>;
-}
-
 /// The repartition operator maps N input partitions to M output partitions based on a
 /// partitioning scheme. No guarantees are made about the order of the resulting partitions.
 #[derive(Debug)]