Method limit

datafusion/core/src/dataframe/mod.rs:724–733

Returns a new `DataFrame` with a limited number of rows. # Arguments `skip` - Number of rows to skip before fetch any row `fetch` - Maximum number of rows to return, after skipping `skip` rows. # Example ``` # use datafusion::prelude::*; # use datafusion::error::Result; # use datafusion_common::assert_batches_sorted_eq; # #[tokio::main] # async fn main() -> Result<()> { let ctx = SessionContext:

(self, skip: usize, fetch: Option<usize>)

    /// # }
    /// ```
    pub fn limit(self, skip: usize, fetch: Option<usize>) -> Result<DataFrame> {
        let plan = LogicalPlanBuilder::from(self.plan)
            .limit(skip, fetch)?
            .build()?;
        Ok(DataFrame {
            session_state: self.session_state,
            plan,
            projection_requires_validation: self.projection_requires_validation,
        })
    }

    /// Calculate the union of two [`DataFrame`]s, preserving duplicate rows.
    ///