async fn execute(&self, partition: usize) -> Result<SendableRecordBatchStream> {
        if 0 != partition {
            return Err(DataFusionError::Internal(format!(
                "TopKExec invalid partition {}",
                partition
            )));
        }

        Ok(Box::pin(TopKReader {
            input: self.input.execute(partition).await?,
            k: self.k,
            done: false,
        }))
    }
/// Execute one partition and return an iterator over RecordBatch
Execute one partition and return an iterator over RecordBatch
Execute one partition and return an iterator over RecordBatch
async fn execute(&self, partition: usize) -> Result<SendableRecordBatchStream> {
        if 0 != partition {
            return Err(DataFusionError::Internal(format!(
                "TopKExec invalid partition {}",
                partition
            )));
        }
        Ok(Box::pin(TopKReader {
            input: self.input.execute(partition).await?,
            k: self.k,
            done: false,
        }))
    }
async fn execute ( & self , partition : usize ) -> Result < SendableRecordBatchStream > { if 0 != partition { return Err ( DataFusionError :: Internal ( format ! ( " " partition ) ) ) ; } Ok ( Box :: pin ( TopKReader { input : self . input . execute ( partition ) . await ? , k : self . k , done : false , } ) ) }
Execute one partition and return an iterator over RecordBatch
Execute one partition and return an iterator over RecordBatch
&self
partition
usize
&self
partition
usize