Interface Sink

pulsar-io/core/src/main/java/org/apache/pulsar/io/core/Sink.java:29–48

Generic sink interface users can implement to run Sink on top of Pulsar Functions.

 * Generic sink interface users can implement to run Sink on top of Pulsar Functions.
 */
@InterfaceAudience.Public
@InterfaceStability.Stable
public interface Sink<T> extends AutoCloseable {
    /**
     * Open connector with configuration.
     *
     * @param config initialization config
     * @param sinkContext environment where the sink connector is running
     * @throws Exception IO type exceptions when opening a connector
     */
    void open(Map<String, Object> config, SinkContext sinkContext) throws Exception;

    /**
     * Write a message to Sink.
     *
     * @param record record to write to sink
     * @throws Exception
     */
    void write(Record<T> record) throws Exception;
}