org.apache.flink.statefun.sdk.kinesis.ingress

Class KinesisIngressSpec<T>

java.lang.Object

org.apache.flink.statefun.sdk.kinesis.ingress.KinesisIngressSpec<T>

All Implemented Interfaces:

IngressSpec<T>

public final class KinesisIngressSpec<T>
extends java.lang.Object
implements IngressSpec<T>

Method Summary

Modifier and Type	Method and Description
OptionalProperty<AwsCredentials>	awsCredentials()
OptionalProperty<AwsRegion>	awsRegion()
KinesisIngressDeserializer<T>	deserializer()
IngressIdentifier<T>	id() Returns the unique identifier of the ingress.
java.util.Properties	properties()
KinesisIngressStartupPosition	startupPosition()
java.util.List<java.lang.String>	streams()
IngressType	type() Returns the type of the ingress.

Methods inherited from class java.lang.Object

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

Method Detail

id

public IngressIdentifier<T> id()

Description copied from interface: IngressSpec

Returns the unique identifier of the ingress.

Specified by:

id in interface IngressSpec<T>

Returns:

the unique identifier of the ingress.

type

public IngressType type()

Description copied from interface: IngressSpec

Returns the type of the ingress.

Specified by:

type in interface IngressSpec<T>

Returns:

the type of the ingress.

streams

public java.util.List<java.lang.String> streams()

deserializer

public KinesisIngressDeserializer<T> deserializer()

startupPosition

public KinesisIngressStartupPosition startupPosition()

awsRegion

public OptionalProperty<AwsRegion> awsRegion()

awsCredentials

public OptionalProperty<AwsCredentials> awsCredentials()

properties

public java.util.Properties properties()