org.apache.flink.statefun.flink.io.spi

Interface SinkProvider

All Known Implementing Classes:

KafkaSinkProvider, KinesisSinkProvider

public interface SinkProvider

Method Summary

Modifier and Type	Method and Description
<T> org.apache.flink.streaming.api.functions.sink.SinkFunction<T>	forSpec(EgressSpec<T> spec)

Method Detail

forSpec

<T> org.apache.flink.streaming.api.functions.sink.SinkFunction<T> forSpec(EgressSpec<T> spec)