clippy

Author: comphead

datafusion/catalog/src/stream.rs

@@ -28,9 +28,7 @@ use std::sync::Arc;
 use crate::{Session, TableProvider, TableProviderFactory};
 use arrow::array::{RecordBatch, RecordBatchReader, RecordBatchWriter};
 use arrow::datatypes::SchemaRef;
-use datafusion_common::{
-    config_err, exec_datafusion_err, plan_err, Constraints, DataFusionError, Result,
-};
+use datafusion_common::{config_err, plan_err, Constraints, DataFusionError, Result};
 use datafusion_common_runtime::SpawnedTask;
 use datafusion_datasource::sink::{DataSink, DataSinkExec};
 use datafusion_execution::{SendableRecordBatchStream, TaskContext};

datafusion/core/src/datasource/file_format/arrow.rs

@@ -42,7 +42,6 @@ use arrow::ipc::reader::FileReader;
 use arrow::ipc::writer::IpcWriteOptions;
 use arrow::ipc::{root_as_message, CompressionType};
 use datafusion_catalog::Session;
-use datafusion_common::exec_datafusion_err;
 use datafusion_common::parsers::CompressionTypeVariant;
 use datafusion_common::{
     internal_datafusion_err, not_impl_err, DataFusionError, GetExt, Statistics,

datafusion/datasource-parquet/src/file_format.rs

@@ -43,8 +43,8 @@ use datafusion_common::encryption::map_config_decryption_to_decryption;
 use datafusion_common::encryption::FileDecryptionProperties;
 use datafusion_common::parsers::CompressionTypeVariant;
 use datafusion_common::{
-    exec_datafusion_err, internal_datafusion_err, internal_err, not_impl_err,
-    DataFusionError, GetExt, HashSet, Result, DEFAULT_PARQUET_EXTENSION,
+    internal_datafusion_err, internal_err, not_impl_err, DataFusionError, GetExt,
+    HashSet, Result, DEFAULT_PARQUET_EXTENSION,
 };
 use datafusion_common::{HashMap, Statistics};
 use datafusion_common_runtime::{JoinSet, SpawnedTask};