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

Class SourceFunctionSpec<T>

java.lang.Object

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

Type Parameters:

T - The input type consumed by the source.

All Implemented Interfaces:

java.io.Serializable, IngressSpec<T>

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

An IngressSpec that can run any Apache Flink SourceFunction.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
SourceFunctionSpec(IngressIdentifier<T> id, org.apache.flink.streaming.api.functions.source.SourceFunction<T> delegate)

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

SourceFunctionSpec

public SourceFunctionSpec(IngressIdentifier<T> id,
                          org.apache.flink.streaming.api.functions.source.SourceFunction<T> delegate)

Parameters:

id - A unique ingress identifier.

delegate - The underlying source function that this spec will delegate to at runtime.

Method Detail

id

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