Skip to content

Commit

Permalink
[MINOR] Remove redundant fileId from HoodieAppendHandle (#10901)
Browse files Browse the repository at this point in the history
Co-authored-by: Vova Kolmakov <kolmakov.vladimir@huawei-partners.com>
  • Loading branch information
2 people authored and yihua committed May 14, 2024
1 parent 219f181 commit 5d7ca35
Show file tree
Hide file tree
Showing 2 changed files with 0 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -90,7 +90,6 @@ public class HoodieAppendHandle<T, I, K, O> extends HoodieWriteHandle<T, I, K, O
private static final AtomicLong RECORD_COUNTER = new AtomicLong(1);
private static final int NUMBER_OF_RECORDS_TO_ESTIMATE_RECORD_SIZE = 100;

protected final String fileId;
// Buffer for holding records in memory before they are flushed to disk
private final List<HoodieRecord> recordList = new ArrayList<>();
// Buffer for holding records (to be deleted) in memory before they are flushed to disk
Expand Down Expand Up @@ -153,7 +152,6 @@ public HoodieAppendHandle(HoodieWriteConfig config, String instantTime, HoodieTa
public HoodieAppendHandle(HoodieWriteConfig config, String instantTime, HoodieTable<T, I, K, O> hoodieTable,
String partitionPath, String fileId, Iterator<HoodieRecord<T>> recordItr, TaskContextSupplier taskContextSupplier) {
super(config, instantTime, partitionPath, fileId, hoodieTable, taskContextSupplier);
this.fileId = fileId;
this.recordItr = recordItr;
this.sizeEstimator = new DefaultSizeEstimator();
this.statuses = new ArrayList<>();
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -46,7 +46,6 @@
import javax.annotation.Nullable;

import java.io.IOException;
import java.text.ParseException;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;
Expand Down

0 comments on commit 5d7ca35

Please sign in to comment.