Skip to content

Commit e56ab4e

Browse files
committed
minor
1 parent db20df1 commit e56ab4e

File tree

1 file changed

+3
-3
lines changed
  • crates/integrations/datafusion/src/physical_plan

1 file changed

+3
-3
lines changed

crates/integrations/datafusion/src/physical_plan/commit.rs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -29,7 +29,7 @@ use datafusion::physical_expr::{EquivalenceProperties, Partitioning};
2929
use datafusion::physical_plan::execution_plan::{Boundedness, EmissionType};
3030
use datafusion::physical_plan::stream::RecordBatchStreamAdapter;
3131
use datafusion::physical_plan::{
32-
DisplayAs, DisplayFormatType, ExecutionPlan, ExecutionPlanProperties, PlanProperties,
32+
DisplayAs, DisplayFormatType, ExecutionPlan, PlanProperties,
3333
};
3434
use futures::StreamExt;
3535
use iceberg::Catalog;
@@ -40,8 +40,8 @@ use iceberg::transaction::Transaction;
4040
use crate::physical_plan::DATA_FILES_COL_NAME;
4141
use crate::to_datafusion_error;
4242

43-
/// IcebergCommitExec is responsible for collecting results from multiple IcebergWriteExec
44-
/// instances and using Transaction::fast_append to commit the data files written.
43+
/// IcebergCommitExec is responsible for collecting the files written and use
44+
/// [`Transaction::fast_append`] to commit the data files written.
4545
#[derive(Debug)]
4646
pub(crate) struct IcebergCommitExec {
4747
table: Table,

0 commit comments

Comments
 (0)