InputT- The type of the sink's input
@PublicEvolving public interface Sink<InputT> extends Serializable
Sinkis a stateless sink that can flush data on checkpoint to achieve at-least-once consistency. Sinks with additional requirements should implement
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
|Modifier and Type||Interface and Description|
The interface exposes some runtime info for creating a
|Modifier and Type||Method and Description|
SinkWriter<InputT> createWriter(Sink.InitContext context) throws IOException
context- the runtime context.
IOException- for any failure during creation.
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.