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

Interface FlinkIoModule.Binder

All Known Implementing Classes:

StatefulFunctionsUniverse

Enclosing interface:

FlinkIoModule

public static interface FlinkIoModule.Binder

Method Summary

Modifier and Type	Method and Description
void	bindSinkProvider(EgressType type, SinkProvider provider)
void	bindSourceProvider(IngressType type, SourceProvider provider)

Method Detail

bindSourceProvider

void bindSourceProvider(IngressType type,
                        SourceProvider provider)

bindSinkProvider

void bindSinkProvider(EgressType type,
                      SinkProvider provider)