FlinkSinkWriter (SeaTunnel : Translation : Flink : Common 2.3.7 API)

java.lang.Object
- org.apache.seatunnel.translation.flink.sink.FlinkSinkWriter<InputT,CommT,WriterStateT>

类型参数:

InputT - The generic type of input data

CommT - The generic type of commit message

WriterStateT - The generic type of writer state

所有已实现的接口:

AutoCloseable, org.apache.flink.api.connector.sink.SinkWriter<InputT,CommitWrapper<CommT>,FlinkWriterState<WriterStateT>>
```
public class FlinkSinkWriter<InputT,CommT,WriterStateT>
extends Object
implements org.apache.flink.api.connector.sink.SinkWriter<InputT,CommitWrapper<CommT>,FlinkWriterState<WriterStateT>>
```
The sink writer implementation of SinkWriter, which is created by Sink.createWriter(org.apache.flink.api.connector.sink.Sink.InitContext, java.util.List<WriterStateT>)

嵌套类概要
- 从接口继承的嵌套类/接口 org.apache.flink.api.connector.sink.SinkWriter
  org.apache.flink.api.connector.sink.SinkWriter.Context

方法概要

所有方法实例方法具体方法
修饰符和类型	方法	说明
`void`	`close()`
`List<CommitWrapper<CommT>>`	`prepareCommit(boolean flush)`
`List<FlinkWriterState<WriterStateT>>`	`snapshotState()`
`void`	`write(InputT element, org.apache.flink.api.connector.sink.SinkWriter.Context context)`

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

从接口继承的方法 org.apache.flink.api.connector.sink.SinkWriter
snapshotState, writeWatermark

- 方法详细资料
  - write
```
public void write(InputT element,
                  org.apache.flink.api.connector.sink.SinkWriter.Context context)
           throws IOException
```
    指定者:
    
    write 在接口中 org.apache.flink.api.connector.sink.SinkWriter<InputT,CommT,WriterStateT>
    
    抛出:
    
    IOException
  - prepareCommit
```
public List<CommitWrapper<CommT>> prepareCommit(boolean flush)
                                         throws IOException
```
    指定者:
    
    prepareCommit 在接口中 org.apache.flink.api.connector.sink.SinkWriter<InputT,CommT,WriterStateT>
    
    抛出:
    
    IOException
  - snapshotState
```
public List<FlinkWriterState<WriterStateT>> snapshotState()
                                                   throws IOException
```
    指定者:
    
    snapshotState 在接口中 org.apache.flink.api.connector.sink.SinkWriter<InputT,CommT,WriterStateT>
    
    抛出:
    
    IOException
  - close
```
public void close()
           throws Exception
```
    指定者:
    
    close 在接口中 AutoCloseable
    
    抛出:
    
    Exception