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

Interface SourceProvider

All Known Implementing Classes:

KafkaSourceProvider, KinesisSourceProvider

public interface SourceProvider

Method Summary

Modifier and Type	Method and Description
<T> org.apache.flink.streaming.api.functions.source.SourceFunction<T>	forSpec(IngressSpec<T> spec)

Method Detail

forSpec

<T> org.apache.flink.streaming.api.functions.source.SourceFunction<T> forSpec(IngressSpec<T> spec)