org.apache.flink.api.connector.sink2

Interface Sink<InputT>

Type Parameters:

InputT - The type of the sink's input

All Superinterfaces:

Serializable

All Known Subinterfaces:

StatefulSink<InputT,WriterStateT>, TwoPhaseCommittingSink<InputT,CommT>, WithPostCommitTopology<InputT,CommT>, WithPreCommitTopology<InputT,CommT>, WithPreWriteTopology<InputT>

All Known Implementing Classes:

AsyncSinkBase, FileSink, PrintSink, SinkV1Adapter, UpsertTestSink

@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 and Description
static interface	Sink.InitContext The interface exposes some runtime info for creating a SinkWriter.

Method Summary

Modifier and Type	Method and 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.