类的使用
org.apache.seatunnel.translation.flink.source.SplitWrapper

使用SplitWrapper的程序包

程序包	说明
org.apache.seatunnel.translation.flink.source

org.apache.seatunnel.translation.flink.source中SplitWrapper的使用

返回SplitWrapper的org.apache.seatunnel.translation.flink.source中的方法

修饰符和类型	方法	说明
SplitWrapper<SplitT>	SplitWrapperSerializer.deserialize(int version, byte[] serialized)

返回变量类型为SplitWrapper的类型的org.apache.seatunnel.translation.flink.source中的方法

修饰符和类型	方法	说明
org.apache.flink.api.connector.source.SplitEnumerator<SplitWrapper<SplitT>,EnumStateT>	FlinkSource.createEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<SplitWrapper<SplitT>> enumContext)
org.apache.flink.api.connector.source.SourceReader<org.apache.seatunnel.api.table.type.SeaTunnelRow,SplitWrapper<SplitT>>	FlinkSource.createReader(org.apache.flink.api.connector.source.SourceReaderContext readerContext)
org.apache.flink.core.io.SimpleVersionedSerializer<SplitWrapper<SplitT>>	FlinkSource.getSplitSerializer()
org.apache.flink.api.connector.source.SplitEnumerator<SplitWrapper<SplitT>,EnumStateT>	FlinkSource.restoreEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<SplitWrapper<SplitT>> enumContext, EnumStateT checkpoint)
List<SplitWrapper<SplitT>>	FlinkSourceReader.snapshotState(long checkpointId)

参数类型为SplitWrapper的org.apache.seatunnel.translation.flink.source中的方法

修饰符和类型	方法	说明
byte[]	SplitWrapperSerializer.serialize(SplitWrapper<SplitT> obj)

类型变量类型为SplitWrapper的org.apache.seatunnel.translation.flink.source中的方法参数

修饰符和类型	方法	说明
void	FlinkSourceReader.addSplits(List<SplitWrapper<SplitT>> splits)
void	FlinkSourceEnumerator.addSplitsBack(List<SplitWrapper<SplitT>> splits, int subtaskId)
org.apache.flink.api.connector.source.SplitEnumerator<SplitWrapper<SplitT>,EnumStateT>	FlinkSource.createEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<SplitWrapper<SplitT>> enumContext)
org.apache.flink.api.connector.source.SplitEnumerator<SplitWrapper<SplitT>,EnumStateT>	FlinkSource.restoreEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<SplitWrapper<SplitT>> enumContext, EnumStateT checkpoint)

类型变量类型为SplitWrapper的org.apache.seatunnel.translation.flink.source中的构造器参数

构造器	说明
FlinkSourceEnumerator(org.apache.seatunnel.api.source.SourceSplitEnumerator<SplitT,EnumStateT> enumerator, org.apache.flink.api.connector.source.SplitEnumeratorContext<SplitWrapper<SplitT>> enumContext)
FlinkSourceSplitEnumeratorContext(org.apache.flink.api.connector.source.SplitEnumeratorContext<SplitWrapper<SplitT>> enumContext)