Skip to content
Merged
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
13 changes: 9 additions & 4 deletions datafusion/core/src/dataframe/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -1013,11 +1013,16 @@ impl DataFrame {
))
}

/// Write this DataFrame to the referenced table
/// Write this DataFrame to the referenced table by name.
/// This method uses on the same underlying implementation
/// as the SQL Insert Into statement.
/// Unlike most other DataFrame methods, this method executes
/// eagerly, writing data, and returning the count of rows written.
/// as the SQL Insert Into statement. Unlike most other DataFrame methods,
/// this method executes eagerly. Data is written to the table using an
/// execution plan returned by the [TableProvider]'s insert_into method.
/// Refer to the documentation of the specific [TableProvider] to determine
/// the expected data returned by the insert_into plan via this method.
/// For the built in ListingTable provider, a single [RecordBatch] containing
/// a single column and row representing the count of total rows written
/// is returned.
pub async fn write_table(
self,
table_name: &str,
Expand Down