Sink (Flink : Core 2.0.0-cp1 API)

Type Parameters:

InputT - The type of the sink's input

All Superinterfaces:

Serializable
```
@Public
public interface Sink<InputT>
extends Serializable
```
Base interface for developing a sink. A basic Sink is a stateless sink that can flush data on checkpoint to achieve at-least-once consistency. Sinks with additional requirements should implement SupportsWriterState or SupportsCommitter.
The Sink needs to be serializable. All configuration should be validated eagerly. The respective sink writers are transient and will only be created in the subtasks on the taskmanagers.

- Method Summary
  
  All Methods Instance Methods Abstract Methods
  Modifier and Type Method Description
  
  SinkWriter<InputT> createWriter(WriterInitContext context)
  Creates a SinkWriter.

- Method Detail
  - createWriter
```
SinkWriter<InputT> createWriter(WriterInitContext context)
                         throws IOException
```
    Creates a SinkWriter.
    
    Parameters:
    
    context - the runtime context.
    
    Returns:
    
    A sink writer.
    
    Throws:
    
    IOException - for any failure during creation.