Uses of Interface
org.apache.flink.statefun.sdk.io.EgressSpec

Packages that use EgressSpec

Package	Description
org.apache.flink.statefun.flink.core
org.apache.flink.statefun.flink.harness.io
org.apache.flink.statefun.flink.io.datastream
org.apache.flink.statefun.flink.io.kafka
org.apache.flink.statefun.flink.io.kinesis
org.apache.flink.statefun.flink.io.spi
org.apache.flink.statefun.sdk.kafka
org.apache.flink.statefun.sdk.kinesis.egress
org.apache.flink.statefun.sdk.spi

Uses of EgressSpec in org.apache.flink.statefun.flink.core

Methods in org.apache.flink.statefun.flink.core that return types with arguments of type EgressSpec

Modifier and Type	Method and Description
java.util.Map<EgressIdentifier<?>,EgressSpec<?>>	StatefulFunctionsUniverse.egress()

Methods in org.apache.flink.statefun.flink.core with parameters of type EgressSpec

Modifier and Type	Method and Description
<T> void	StatefulFunctionsUniverse.bindEgress(EgressSpec<T> spec)

Uses of EgressSpec in org.apache.flink.statefun.flink.harness.io

Classes in org.apache.flink.statefun.flink.harness.io that implement EgressSpec

Modifier and Type	Class and Description
class	ConsumingEgressSpec<T>

Uses of EgressSpec in org.apache.flink.statefun.flink.io.datastream

Classes in org.apache.flink.statefun.flink.io.datastream that implement EgressSpec

Modifier and Type	Class and Description
class	SinkFunctionSpec<T> An EgressSpec that can run any Apache Flink SinkFunction.

Uses of EgressSpec in org.apache.flink.statefun.flink.io.kafka

Methods in org.apache.flink.statefun.flink.io.kafka with parameters of type EgressSpec

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

Uses of EgressSpec in org.apache.flink.statefun.flink.io.kinesis

Methods in org.apache.flink.statefun.flink.io.kinesis with parameters of type EgressSpec

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

Uses of EgressSpec in org.apache.flink.statefun.flink.io.spi

Methods in org.apache.flink.statefun.flink.io.spi with parameters of type EgressSpec

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

Uses of EgressSpec in org.apache.flink.statefun.sdk.kafka

Classes in org.apache.flink.statefun.sdk.kafka that implement EgressSpec

Modifier and Type	Class and Description
class	KafkaEgressSpec<OutT>

Uses of EgressSpec in org.apache.flink.statefun.sdk.kinesis.egress

Classes in org.apache.flink.statefun.sdk.kinesis.egress that implement EgressSpec

Modifier and Type	Class and Description
class	KinesisEgressSpec<T>

Uses of EgressSpec in org.apache.flink.statefun.sdk.spi

Methods in org.apache.flink.statefun.sdk.spi with parameters of type EgressSpec

Modifier and Type	Method and Description
<T> void	StatefulFunctionModule.Binder.bindEgress(EgressSpec<T> spec) Binds an EgressSpec to the Stateful Functions application.