Class PaimonWriterState
- java.lang.Object
-
- org.apache.flink.cdc.connectors.paimon.sink.v2.PaimonWriterState
-
public class PaimonWriterState extends Object
The state ofPaimonWriter.
-
-
Field Summary
Fields Modifier and Type Field Description static intVERSION
-
Constructor Summary
Constructors Constructor Description PaimonWriterState(String commitUser)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description StringgetCommitUser()byte[]getSerializedBytesCache()voidsetSerializedBytesCache(byte[] serializedBytesCache)
-
-
-
Field Detail
-
VERSION
public static final int VERSION
- See Also:
- Constant Field Values
-
-
Constructor Detail
-
PaimonWriterState
public PaimonWriterState(String commitUser)
-
-
Method Detail
-
getCommitUser
public String getCommitUser()
-
getSerializedBytesCache
public byte[] getSerializedBytesCache()
-
setSerializedBytesCache
public void setSerializedBytesCache(byte[] serializedBytesCache)
-
-