Skip to content

Commit 1bc6609

Browse files
committed
add java doc
1 parent e8e1067 commit 1bc6609

File tree

2 files changed

+2
-0
lines changed

2 files changed

+2
-0
lines changed

fluss-lake/fluss-lake-iceberg/src/main/java/com/alibaba/fluss/lake/iceberg/tiering/writer/DeltaTaskWriter.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -37,6 +37,7 @@
3737

3838
import java.util.List;
3939

40+
/** A {@link RecordWriter} to write to Iceberg's primary-key table. */
4041
public class DeltaTaskWriter extends RecordWriter {
4142

4243
public DeltaTaskWriter(

fluss-lake/fluss-lake-iceberg/src/main/java/com/alibaba/fluss/lake/iceberg/tiering/writer/GenericTaskDeltaWriter.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -30,6 +30,7 @@
3030

3131
import java.io.IOException;
3232

33+
/** A generic task equality delta writer. * */
3334
class GenericTaskDeltaWriter extends BaseTaskWriter<Record> {
3435
private final GenericEqualityDeltaWriter deltaWriter;
3536

0 commit comments

Comments
 (0)