org.apache.flink.runtime.source.event

Class SourceEventWrapper

java.lang.Object

org.apache.flink.runtime.source.event.SourceEventWrapper

All Implemented Interfaces:

Serializable, OperatorEvent

public class SourceEventWrapper
extends Object
implements OperatorEvent

A wrapper operator event that contains a custom defined operator event.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
SourceEventWrapper(org.apache.flink.api.connector.source.SourceEvent sourceEvent)

Method Summary

Modifier and Type	Method and Description
org.apache.flink.api.connector.source.SourceEvent	getSourceEvent()
String	toString()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.runtime.operators.coordination.OperatorEvent

isLossTolerant

Constructor Detail

SourceEventWrapper

public SourceEventWrapper(org.apache.flink.api.connector.source.SourceEvent sourceEvent)

Method Detail

getSourceEvent

public org.apache.flink.api.connector.source.SourceEvent getSourceEvent()

Returns:

The SourceEvent in this SourceEventWrapper.

toString

public String toString()

Overrides:

toString in class Object