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
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.