remove unused code

Author: YaroslavLitvinov

crates/catalog/src/lib.rs

@@ -29,70 +29,3 @@ where
     .join()
     .unwrap_or_else(|_| error::ThreadPanickedWhileExecutingFutureSnafu.fail()?)
 }
-
-pub mod test_utils {
-    use datafusion::arrow::array::{ArrayRef, RecordBatch};
-    use datafusion::arrow::compute::{
-        SortColumn, SortOptions, lexsort_to_indices, take_record_batch,
-    };
-    use datafusion::arrow::datatypes::{DataType, Field, Schema};
-    use std::collections::HashSet;
-    use std::sync::Arc;
-
-    #[allow(clippy::unwrap_used, clippy::must_use_candidate)]
-    pub fn sort_record_batch_by_sortable_columns(batch: &RecordBatch) -> RecordBatch {
-        let sort_columns: Vec<SortColumn> = (0..batch.num_columns())
-            .filter_map(|i| {
-                let col = batch.column(i).clone();
-                let field = batch.schema().field(i).clone();
-                if matches!(field.data_type(), DataType::Null) {
-                    None
-                } else {
-                    Some(SortColumn {
-                        values: col,
-                        options: Some(SortOptions::default()),
-                    })
-                }
-            })
-            .collect();
-
-        if sort_columns.is_empty() {
-            return batch.clone();
-        }
-
-        let indices = lexsort_to_indices(&sort_columns, Some(batch.num_rows())).unwrap();
-        take_record_batch(batch, &indices).unwrap()
-    }
-
-    #[allow(clippy::unwrap_used, clippy::must_use_candidate)]
-    pub fn remove_columns_from_batches<S: ::std::hash::BuildHasher>(
-        batches: Vec<RecordBatch>,
-        excluded_columns: &HashSet<&str, S>,
-    ) -> Vec<RecordBatch> {
-        batches
-            .into_iter()
-            .map(|batch| {
-                let schema = batch.schema();
-                let indices: Vec<usize> = schema
-                    .fields()
-                    .iter()
-                    .enumerate()
-                    .filter_map(|(i, f)| {
-                        if excluded_columns.contains(f.name().as_str()) {
-                            None
-                        } else {
-                            Some(i)
-                        }
-                    })
-                    .collect();
-
-                let columns: Vec<ArrayRef> =
-                    indices.iter().map(|&i| batch.column(i).clone()).collect();
-                let fields: Vec<Field> = indices.iter().map(|&i| schema.field(i).clone()).collect();
-                let new_schema = Arc::new(Schema::new(fields));
-
-                RecordBatch::try_new(new_schema, columns).unwrap()
-            })
-            .collect()
-    }
-}