org.apache.flink.statefun.flink.harness.io

Class SupplyingIngressSpec<T>

java.lang.Object

org.apache.flink.statefun.flink.harness.io.SupplyingIngressSpec<T>

All Implemented Interfaces:

java.io.Serializable, IngressSpec<T>

public final class SupplyingIngressSpec<T>
extends java.lang.Object
implements IngressSpec<T>, java.io.Serializable

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
SupplyingIngressSpec(IngressIdentifier<T> id, SerializableSupplier<T> supplier, long productionDelayInMilliseconds)

Method Summary

Modifier and Type	Method and Description
IngressIdentifier<T>	id() Returns the unique identifier of the ingress.
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

Constructor Detail

SupplyingIngressSpec

public SupplyingIngressSpec(IngressIdentifier<T> id,
                            SerializableSupplier<T> supplier,
                            long productionDelayInMilliseconds)

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.