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

Class RoutableKinesisIngressSpec

java.lang.Object

org.apache.flink.statefun.flink.io.kinesis.binders.ingress.v1.RoutableKinesisIngressSpec

public class RoutableKinesisIngressSpec
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	RoutableKinesisIngressSpec.Builder

Method Summary

Modifier and Type	Method and Description
IngressIdentifier<com.google.protobuf.Message>	id()
KinesisIngressSpec<com.google.protobuf.Message>	toUniversalKinesisIngressSpec()

Methods inherited from class java.lang.Object

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

Method Detail

toUniversalKinesisIngressSpec

public KinesisIngressSpec<com.google.protobuf.Message> toUniversalKinesisIngressSpec()

id

public IngressIdentifier<com.google.protobuf.Message> id()