@@ -1147,22 +1147,34 @@ impl LogicalPlanBuilder {
1147
1147
}
1148
1148
1149
1149
/// Converts a `Arc<LogicalPlan>` into `LogicalPlanBuilder`
1150
- /// fn employee_schema() -> Schema {
1151
- /// Schema::new(vec![
1152
- /// Field::new("id", DataType::Int32, false),
1153
- /// Field::new("first_name", DataType::Utf8, false),
1154
- /// Field::new("last_name", DataType::Utf8, false),
1155
- /// Field::new("state", DataType::Utf8, false),
1156
- /// Field::new("salary", DataType::Int32, false),
1157
- /// ])
1158
- /// }
1150
+ /// ```
1151
+ /// # use datafusion_expr::{Expr, expr, col, LogicalPlanBuilder, logical_plan::table_scan};
1152
+ /// # use datafusion_common::Result;
1153
+ /// # use arrow::datatypes::{Schema, DataType, Field};
1154
+ /// # fn main() -> Result<()> {
1155
+ /// #
1156
+ /// # fn employee_schema() -> Schema {
1157
+ /// # Schema::new(vec![
1158
+ /// # Field::new("id", DataType::Int32, false),
1159
+ /// # Field::new("first_name", DataType::Utf8, false),
1160
+ /// # Field::new("last_name", DataType::Utf8, false),
1161
+ /// # Field::new("state", DataType::Utf8, false),
1162
+ /// # Field::new("salary", DataType::Int32, false),
1163
+ /// # ])
1164
+ /// # }
1165
+ /// #
1166
+ /// // Create the plan
1159
1167
/// let plan = table_scan(Some("employee_csv"), &employee_schema(), Some(vec![3, 4]))?
1160
1168
/// .sort(vec![
1161
1169
/// Expr::Sort(expr::Sort::new(Box::new(col("state")), true, true)),
1162
1170
/// Expr::Sort(expr::Sort::new(Box::new(col("salary")), false, false)),
1163
1171
/// ])?
1164
1172
/// .build()?;
1165
- /// let plan_builder: LogicalPlanBuilder = Arc::new(plan).into();
1173
+ /// // Convert LogicalPlan into LogicalPlanBuilder
1174
+ /// let plan_builder: LogicalPlanBuilder = std::sync::Arc::new(plan).into();
1175
+ /// # Ok(())
1176
+ /// # }
1177
+ /// ```
1166
1178
1167
1179
impl From < Arc < LogicalPlan > > for LogicalPlanBuilder {
1168
1180
fn from ( plan : Arc < LogicalPlan > ) -> Self {
0 commit comments