Skip to content

Commit df5ec78

Browse files
committed
rename property to customProperty
1 parent 533fa9d commit df5ec78

File tree

3 files changed

+7
-7
lines changed

3 files changed

+7
-7
lines changed

fluss-common/src/main/java/com/alibaba/fluss/lake/writer/WriterInitContext.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -69,5 +69,5 @@ public interface WriterInitContext {
6969
*
7070
* @return the table custom properties
7171
*/
72-
Map<String, String> properties();
72+
Map<String, String> customProperties();
7373
}

fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/tiering/source/TieringWriterInitContext.java

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -33,19 +33,19 @@ public class TieringWriterInitContext implements WriterInitContext {
3333
private final TableBucket tableBucket;
3434
private final Schema schema;
3535
@Nullable private final String partition;
36-
private final Map<String, String> properties;
36+
private final Map<String, String> customProperties;
3737

3838
public TieringWriterInitContext(
3939
TablePath tablePath,
4040
TableBucket tableBucket,
4141
@Nullable String partition,
4242
Schema schema,
43-
Map<String, String> properties) {
43+
Map<String, String> customProperties) {
4444
this.tablePath = tablePath;
4545
this.tableBucket = tableBucket;
4646
this.partition = partition;
4747
this.schema = schema;
48-
this.properties = properties;
48+
this.customProperties = customProperties;
4949
}
5050

5151
@Override
@@ -70,7 +70,7 @@ public Schema schema() {
7070
}
7171

7272
@Override
73-
public Map<String, String> properties() {
74-
return properties;
73+
public Map<String, String> customProperties() {
74+
return customProperties;
7575
}
7676
}

fluss-lake/fluss-lake-paimon/src/test/java/com/alibaba/fluss/lake/paimon/tiering/PaimonTieringTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -693,7 +693,7 @@ public String partition() {
693693
}
694694

695695
@Override
696-
public Map<String, String> properties() {
696+
public Map<String, String> customProperties() {
697697
// don't care about table custom properties for Paimon lake writer
698698
return new HashMap<>();
699699
}

0 commit comments

Comments
 (0)