java.lang.Object
- org.apache.seatunnel.translation.flink.source.FlinkSource<SplitT,EnumStateT>

类型参数:

SplitT - The generic type of source split

EnumStateT - The generic type of enumerator state

所有已实现的接口:

Serializable, org.apache.flink.api.connector.source.Source<org.apache.seatunnel.api.table.type.SeaTunnelRow,SplitWrapper<SplitT>,EnumStateT>, org.apache.flink.api.java.typeutils.ResultTypeQueryable<org.apache.seatunnel.api.table.type.SeaTunnelRow>
```
public class FlinkSource<SplitT extends org.apache.seatunnel.api.source.SourceSplit,EnumStateT extends Serializable>
extends Object
implements org.apache.flink.api.connector.source.Source<org.apache.seatunnel.api.table.type.SeaTunnelRow,SplitWrapper<SplitT>,EnumStateT>, org.apache.flink.api.java.typeutils.ResultTypeQueryable<org.apache.seatunnel.api.table.type.SeaTunnelRow>
```
The source implementation of Source, used for proxy all SeaTunnelSource in flink.

另请参阅:

序列化表格

构造器概要

构造器
构造器	说明
`FlinkSource(org.apache.seatunnel.api.source.SeaTunnelSource<org.apache.seatunnel.api.table.type.SeaTunnelRow,SplitT,EnumStateT> source, org.apache.seatunnel.shade.com.typesafe.config.Config envConfig)`

方法概要

所有方法实例方法具体方法
修饰符和类型	方法	说明
`org.apache.flink.api.connector.source.SplitEnumerator<SplitWrapper<SplitT>,EnumStateT>`	`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>>`	`createReader(org.apache.flink.api.connector.source.SourceReaderContext readerContext)`
`org.apache.flink.api.connector.source.Boundedness`	`getBoundedness()`
`org.apache.flink.core.io.SimpleVersionedSerializer<EnumStateT>`	`getEnumeratorCheckpointSerializer()`
`org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.seatunnel.api.table.type.SeaTunnelRow>`	`getProducedType()`
`org.apache.flink.core.io.SimpleVersionedSerializer<SplitWrapper<SplitT>>`	`getSplitSerializer()`
`org.apache.flink.api.connector.source.SplitEnumerator<SplitWrapper<SplitT>,EnumStateT>`	`restoreEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<SplitWrapper<SplitT>> enumContext, EnumStateT checkpoint)`

从类继承的方法 java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

FlinkSource

public FlinkSource(org.apache.seatunnel.api.source.SeaTunnelSource<org.apache.seatunnel.api.table.type.SeaTunnelRow,SplitT,EnumStateT> source,
                   org.apache.seatunnel.shade.com.typesafe.config.Config envConfig)

方法详细资料
- getBoundedness
```
public org.apache.flink.api.connector.source.Boundedness getBoundedness()
```
  指定者:
  
  getBoundedness 在接口中 org.apache.flink.api.connector.source.Source<org.apache.seatunnel.api.table.type.SeaTunnelRow,SplitWrapper<SplitT extends org.apache.seatunnel.api.source.SourceSplit>,EnumStateT extends Serializable>
- createReader
```
public org.apache.flink.api.connector.source.SourceReader<org.apache.seatunnel.api.table.type.SeaTunnelRow,SplitWrapper<SplitT>> createReader(org.apache.flink.api.connector.source.SourceReaderContext readerContext)
                                                                                                                                             throws Exception
```
  指定者:
  
  createReader 在接口中 org.apache.flink.api.connector.source.Source<org.apache.seatunnel.api.table.type.SeaTunnelRow,SplitWrapper<SplitT extends org.apache.seatunnel.api.source.SourceSplit>,EnumStateT extends Serializable>
  
  抛出:
  
  Exception
- createEnumerator
```
public org.apache.flink.api.connector.source.SplitEnumerator<SplitWrapper<SplitT>,EnumStateT> createEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<SplitWrapper<SplitT>> enumContext)
                                                                                                              throws Exception
```
  指定者:
  
  createEnumerator 在接口中 org.apache.flink.api.connector.source.Source<org.apache.seatunnel.api.table.type.SeaTunnelRow,SplitWrapper<SplitT extends org.apache.seatunnel.api.source.SourceSplit>,EnumStateT extends Serializable>
  
  抛出:
  
  Exception
- restoreEnumerator
```
public org.apache.flink.api.connector.source.SplitEnumerator<SplitWrapper<SplitT>,EnumStateT> restoreEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<SplitWrapper<SplitT>> enumContext,
                                                                                                                      EnumStateT checkpoint)
                                                                                                               throws Exception
```
  指定者:
  
  restoreEnumerator 在接口中 org.apache.flink.api.connector.source.Source<org.apache.seatunnel.api.table.type.SeaTunnelRow,SplitWrapper<SplitT extends org.apache.seatunnel.api.source.SourceSplit>,EnumStateT extends Serializable>
  
  抛出:
  
  Exception
- getSplitSerializer
```
public org.apache.flink.core.io.SimpleVersionedSerializer<SplitWrapper<SplitT>> getSplitSerializer()
```
  指定者:
  
  getSplitSerializer 在接口中 org.apache.flink.api.connector.source.Source<org.apache.seatunnel.api.table.type.SeaTunnelRow,SplitWrapper<SplitT extends org.apache.seatunnel.api.source.SourceSplit>,EnumStateT extends Serializable>
- getEnumeratorCheckpointSerializer
```
public org.apache.flink.core.io.SimpleVersionedSerializer<EnumStateT> getEnumeratorCheckpointSerializer()
```
  指定者:
  
  getEnumeratorCheckpointSerializer 在接口中 org.apache.flink.api.connector.source.Source<org.apache.seatunnel.api.table.type.SeaTunnelRow,SplitWrapper<SplitT extends org.apache.seatunnel.api.source.SourceSplit>,EnumStateT extends Serializable>
- getProducedType
```
public org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.seatunnel.api.table.type.SeaTunnelRow> getProducedType()
```
  指定者:
  
  getProducedType 在接口中 org.apache.flink.api.java.typeutils.ResultTypeQueryable<SplitT extends org.apache.seatunnel.api.source.SourceSplit>

类 FlinkSource<SplitT extends org.apache.seatunnel.api.source.SourceSplit,​EnumStateT extends Serializable>

构造器概要

方法概要

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

构造器详细资料

FlinkSource

方法详细资料

getBoundedness

createReader

createEnumerator

restoreEnumerator

getSplitSerializer

getEnumeratorCheckpointSerializer

getProducedType

类 FlinkSource<SplitT extends org.apache.seatunnel.api.source.SourceSplit,EnumStateT extends Serializable>