Skip to content

Commit 26af2d6

Browse files
committed
fix
1 parent 89c108b commit 26af2d6

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/write/DataEvolutionTableDataWrite.scala

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -65,7 +65,7 @@ case class DataEvolutionTableDataWrite(
6565
currentWriter.write(toPaimonRow(row), rowId)
6666
}
6767

68-
def newCurrentWriter(firstRowId: Long): Unit = {
68+
private def newCurrentWriter(firstRowId: Long): Unit = {
6969
finishCurrentWriter()
7070
val (partition, numRecords) = firstRowIdToPartitionMap.getOrElse(firstRowId, null)
7171
if (partition == null) {
@@ -84,7 +84,7 @@ case class DataEvolutionTableDataWrite(
8484
currentWriter = PerFileWriter(partition, firstRowId, writer, numRecords)
8585
}
8686

87-
def finishCurrentWriter(): Unit = {
87+
private def finishCurrentWriter(): Unit = {
8888
if (currentWriter != null) {
8989
commitMessages.append(currentWriter.finish())
9090
}
@@ -111,7 +111,7 @@ case class DataEvolutionTableDataWrite(
111111
recordWriter: RecordWriter[InternalRow],
112112
numRecords: Long) {
113113

114-
var numWritten = 0
114+
private var numWritten = 0
115115

116116
def matchFirstRowId(firstRowId: Long): Boolean = {
117117
this.firstRowId == firstRowId

0 commit comments

Comments
 (0)