File tree 2 files changed +6
-0
lines changed
datafusion/core/src/dataframe
2 files changed +6
-0
lines changed Original file line number Diff line number Diff line change @@ -1147,6 +1147,7 @@ impl DataFrame {
1147
1147
/// ```
1148
1148
/// # use datafusion::prelude::*;
1149
1149
/// # use datafusion::error::Result;
1150
+ /// # use std::fs;
1150
1151
/// # #[tokio::main]
1151
1152
/// # async fn main() -> Result<()> {
1152
1153
/// use datafusion::dataframe::DataFrameWriteOptions;
@@ -1159,6 +1160,7 @@ impl DataFrame {
1159
1160
/// DataFrameWriteOptions::new(),
1160
1161
/// None, // can also specify CSV writing options here
1161
1162
/// ).await?;
1163
+ /// # fs::remove_file("output.csv")?;
1162
1164
/// # Ok(())
1163
1165
/// # }
1164
1166
/// ```
@@ -1199,6 +1201,7 @@ impl DataFrame {
1199
1201
/// ```
1200
1202
/// # use datafusion::prelude::*;
1201
1203
/// # use datafusion::error::Result;
1204
+ /// # use std::fs;
1202
1205
/// # #[tokio::main]
1203
1206
/// # async fn main() -> Result<()> {
1204
1207
/// use datafusion::dataframe::DataFrameWriteOptions;
@@ -1210,6 +1213,7 @@ impl DataFrame {
1210
1213
/// "output.json",
1211
1214
/// DataFrameWriteOptions::new(),
1212
1215
/// ).await?;
1216
+ /// # fs::remove_file("output.json")?;
1213
1217
/// # Ok(())
1214
1218
/// # }
1215
1219
/// ```
Original file line number Diff line number Diff line change @@ -32,6 +32,7 @@ impl DataFrame {
32
32
/// ```
33
33
/// # use datafusion::prelude::*;
34
34
/// # use datafusion::error::Result;
35
+ /// # use std::fs;
35
36
/// # #[tokio::main]
36
37
/// # async fn main() -> Result<()> {
37
38
/// use datafusion::dataframe::DataFrameWriteOptions;
@@ -44,6 +45,7 @@ impl DataFrame {
44
45
/// DataFrameWriteOptions::new(),
45
46
/// None, // can also specify parquet writing options here
46
47
/// ).await?;
48
+ /// # fs::remove_file("output.parquet")?;
47
49
/// # Ok(())
48
50
/// # }
49
51
/// ```
You can’t perform that action at this time.
0 commit comments