unused imports removed

datafusion-integration/src/execution/mod.rs

@@ -1,22 +1,9 @@
-use datafusion::arrow::array::RecordBatch;
-use datafusion::error::DataFusionError::NotImplemented;
-use datafusion::error::Result;
-use datafusion::physical_plan::collect;
-
-use datafusion::execution::context::SessionContext;
-use datafusion::physical_plan::ExecutionPlan;
 use datafusion_proto::protobuf::physical_plan_node::PhysicalPlanType;
 use datafusion_proto::protobuf::PhysicalPlanNode;
-mod operators;
 mod operators_conversion;
-use datafusion::datasource::physical_plan::FileScanConfig;
-use datafusion::datasource::physical_plan::{CsvConfig, CsvOpener};
-use std::os::unix::net::SocketAddr;
-use std::sync::Arc;
 use vayu::pipeline::Source;
 use vayu::pipeline::{self, IntermediateOperator};
 
-use vayu::operators::scan::ScanOperator;
 use vayu::pipeline::Pipeline;
 
 pub async fn get_pipeline(plan: PhysicalPlanNode) -> pipeline::Pipeline {
@@ -61,7 +48,6 @@ fn make_pipeline(pipeline: &mut pipeline::Pipeline, node: PhysicalPlanNode) {
 
             pipeline.source_operator = Some(Box::new(so) as Box<dyn Source>);
             pipeline.state.schema = Some(schema);
-            // TODO: add ScanOperator to pipeline
         }
 
         _ => {

datafusion-integration/src/execution/operators_conversion.rs

@@ -21,7 +21,6 @@ use std::sync::Arc;
 use vayu::operators::filter::FilterOperator;
 
 use vayu::operators::scan::ScanOperator;
-use vayu::pipeline::Source;
 fn str_to_byte(s: &String, descriptions: &str) -> Result<u8> {
     if s.len() != 1 {
         return Err(NotImplemented(String::from("size not one")));

datafusion-integration/src/main.rs

@@ -15,11 +15,9 @@
 // specific language governing permissions and limitations
 // under the License.
 
-use arrow::record_batch::RecordBatch;
 use arrow::util::pretty;
 use datafusion::error::Result;
 use datafusion::execution::context::SessionState;
-use datafusion::physical_plan::displayable;
 
 use datafusion::{dataframe, prelude::*};
 use datafusion_proto::physical_plan::{AsExecutionPlan, DefaultPhysicalExtensionCodec};