/// Run the input through the deduplicator and return results
Run the input through the deduplicator and return results
Run the input through the deduplicator and return results
async fn dedupe(input: Vec<RecordBatch>, sort_keys: Vec<PhysicalSortExpr>) -> TestResults {
        test_helpers::maybe_start_logging();
        // Setup in memory stream
        let schema = input[0].schema();
        let projection = None;
        let input = Arc::new(MemoryExec::try_new(&[input], schema, projection).unwrap());
        // Create and run the deduplicator
        let exec = Arc::new(DeduplicateExec::new(input, sort_keys));
        let output = test_collect(Arc::clone(&exec) as Arc<dyn ExecutionPlan>).await;
        TestResults { output, exec }
    }
async fn dedupe ( input : Vec < RecordBatch > , sort_keys : Vec < PhysicalSortExpr > ) -> TestResults { test_helpers :: maybe_start_logging ( ) ; // Setup in memory stream let schema = input [ 0 ] . schema ( ) ; let projection = None ; let input = Arc :: new ( MemoryExec :: try_new ( & [ input ] , schema , projection ) . unwrap ( ) ) ; // Create and run the deduplicator let exec = Arc :: new ( DeduplicateExec :: new ( input , sort_keys ) ) ; let output = test_collect ( Arc :: clone ( & exec ) as Arc < dyn ExecutionPlan > ) . await ; TestResults { output , exec } }
Run the input through the deduplicator and return results
Run the input through the deduplicator and return results
input
Vec<RecordBatch>
sort_keys
Vec<PhysicalSortExpr>