Skip to content

Commit c1c3e9d

Browse files
author
ZENOTME
committed
refine name
1 parent 813bdb4 commit c1c3e9d

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

crates/iceberg/src/writer/base_writer/position_delete_file_writer.rs

+4-4
Original file line numberDiff line numberDiff line change
@@ -101,12 +101,12 @@ pub struct PositionDeleteWriter<B: FileWriterBuilder> {
101101

102102
#[async_trait::async_trait]
103103
impl<B: FileWriterBuilder> IcebergWriter<Vec<PositionDeleteInput>> for PositionDeleteWriter<B> {
104-
async fn write(&mut self, input: Vec<PositionDeleteInput>) -> Result<()> {
104+
async fn write(&mut self, inputs: Vec<PositionDeleteInput>) -> Result<()> {
105105
let mut path_column_builder = StringBuilder::new();
106106
let mut offset_column_builder = PrimitiveBuilder::<Int64Type>::new();
107-
for input in input.into_iter() {
108-
for offset in input.offsets {
109-
path_column_builder.append_value(&input.path);
107+
for pd_input in inputs.into_iter() {
108+
for offset in pd_input.offsets {
109+
path_column_builder.append_value(&pd_input.path);
110110
offset_column_builder.append_value(offset);
111111
}
112112
}

0 commit comments

Comments
 (0)