Sink (Flink : Core 1.18.1-cp1 API)

Type Parameters:

InputT - The type of the sink's input

All Superinterfaces:

Serializable

All Known Subinterfaces:

StatefulSink<InputT,WriterStateT>, TwoPhaseCommittingSink<InputT,CommT>
```
@PublicEvolving
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 StatefulSink or TwoPhaseCommittingSink.
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.

- Nested Class Summary
  
  Nested Classes
  Modifier and Type Interface Description
  
  static interface Sink.InitContext
  The interface exposes some runtime info for creating a SinkWriter.
- Method Summary
  
  All Methods Instance Methods Abstract Methods
  Modifier and Type Method Description
  
  SinkWriter<InputT> createWriter(Sink.InitContext context)
  Creates a SinkWriter.

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