程序包 org.apache.seatunnel.translation.flink.sink

类 FlinkWriterState<StateT>

java.lang.Object

org.apache.seatunnel.translation.flink.sink.FlinkWriterState<StateT>

类型参数:

StateT - The generic type of the writer state

所有已实现的接口:

Serializable

public class FlinkWriterState<StateT>
extends Object
implements Serializable

The writer state wrapper of FlinkWriterState, used to unify the different implementations of FlinkWriterState

另请参阅:

序列化表格

构造器概要

构造器

构造器	说明
FlinkWriterState(long checkpointId, StateT state)

方法概要

修饰符和类型	方法	说明
long	getCheckpointId()
StateT	getState()
void	setCheckpointId(long checkpointId)
void	setState(StateT state)

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

FlinkWriterState

public FlinkWriterState(long checkpointId,
                        StateT state)

方法详细资料

getCheckpointId

public long getCheckpointId()

setCheckpointId

public void setCheckpointId(long checkpointId)

getState

public StateT getState()

setState

public void setState(StateT state)