org.apache.flink.statefun.flink.io.kinesis.binders.egress.v1

Class GenericKinesisEgressSpec

java.lang.Object

org.apache.flink.statefun.flink.io.kinesis.binders.egress.v1.GenericKinesisEgressSpec

public final class GenericKinesisEgressSpec
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	GenericKinesisEgressSpec.Builder

Method Summary

Modifier and Type	Method and Description
EgressIdentifier<TypedValue>	id()
KinesisEgressSpec<TypedValue>	toUniversalKinesisEgressSpec()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

toUniversalKinesisEgressSpec

public KinesisEgressSpec<TypedValue> toUniversalKinesisEgressSpec()

id

public EgressIdentifier<TypedValue> id()