Skip to content

Commit 11bc5b7

Browse files
authored
fix: project_bacth to project_batch (apache#848)
1 parent 21d9568 commit 11bc5b7

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

crates/iceberg/src/arrow/record_batch_projector.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -119,7 +119,7 @@ impl RecordBatchProjector {
119119
}
120120

121121
/// Do projection with record batch
122-
pub(crate) fn project_bacth(&self, batch: RecordBatch) -> Result<RecordBatch> {
122+
pub(crate) fn project_batch(&self, batch: RecordBatch) -> Result<RecordBatch> {
123123
RecordBatch::try_new(
124124
self.projected_schema.clone(),
125125
self.project_column(batch.columns())?,
@@ -209,7 +209,7 @@ mod test {
209209
])) as ArrayRef;
210210
let batch = RecordBatch::try_new(schema, vec![int_array, struct_array]).unwrap();
211211

212-
let projected_batch = projector.project_bacth(batch).unwrap();
212+
let projected_batch = projector.project_batch(batch).unwrap();
213213
assert_eq!(projected_batch.num_columns(), 2);
214214
let projected_int_array = projected_batch
215215
.column(0)

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -133,7 +133,7 @@ pub struct EqualityDeleteFileWriter<B: FileWriterBuilder> {
133133
#[async_trait::async_trait]
134134
impl<B: FileWriterBuilder> IcebergWriter for EqualityDeleteFileWriter<B> {
135135
async fn write(&mut self, batch: RecordBatch) -> Result<()> {
136-
let batch = self.projector.project_bacth(batch)?;
136+
let batch = self.projector.project_batch(batch)?;
137137
if let Some(writer) = self.inner_writer.as_mut() {
138138
writer.write(&batch).await
139139
} else {
@@ -409,7 +409,7 @@ mod test {
409409
let data_file = res.into_iter().next().unwrap();
410410

411411
// check
412-
let to_write_projected = projector.project_bacth(to_write)?;
412+
let to_write_projected = projector.project_batch(to_write)?;
413413
check_parquet_data_file_with_equality_delete_write(
414414
&file_io,
415415
&data_file,

0 commit comments

Comments
 (0)