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

Class ConsumingEgressSpec<T>

java.lang.Object

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

All Implemented Interfaces:

java.io.Serializable, EgressSpec<T>

public final class ConsumingEgressSpec<T>
extends java.lang.Object
implements EgressSpec<T>, java.io.Serializable

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
ConsumingEgressSpec(EgressIdentifier<T> id, SerializableConsumer<T> consumer)

Method Summary

Modifier and Type	Method and Description
EgressIdentifier<T>	id() Returns the unique identifier of the egress.
EgressType	type() Returns the type of the egress.

Methods inherited from class java.lang.Object

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

Constructor Detail

ConsumingEgressSpec

public ConsumingEgressSpec(EgressIdentifier<T> id,
                           SerializableConsumer<T> consumer)

Method Detail

id

public EgressIdentifier<T> id()

Description copied from interface: EgressSpec

Returns the unique identifier of the egress.

Specified by:

id in interface EgressSpec<T>

Returns:

the unique identifier of the egress.

type

public EgressType type()

Description copied from interface: EgressSpec

Returns the type of the egress.

Specified by:

type in interface EgressSpec<T>

Returns:

the type of the egress.