org.apache.flink.statefun.flink.io.datastream

Class SinkFunctionSpec<T>

java.lang.Object

org.apache.flink.statefun.flink.io.datastream.SinkFunctionSpec<T>

Type Parameters:

T - The input type output by the sink.

All Implemented Interfaces:

java.io.Serializable, EgressSpec<T>

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

An EgressSpec that can run any Apache Flink SinkFunction.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
SinkFunctionSpec(EgressIdentifier<T> id, org.apache.flink.streaming.api.functions.sink.SinkFunction<T> delegate)

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

SinkFunctionSpec

public SinkFunctionSpec(EgressIdentifier<T> id,
                        org.apache.flink.streaming.api.functions.sink.SinkFunction<T> delegate)

Parameters:

id - A unique egress identifier.

delegate - The underlying sink that the egress will delegate to at runtime.

Method Detail

id

public final 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 final 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.