Package org.apache.flink.runtime.source.event

Class AddSplitEvent<SplitT>

java.lang.Object

org.apache.flink.runtime.source.event.AddSplitEvent<SplitT>

Type Parameters:

SplitT - the type of splits.

All Implemented Interfaces:

Serializable, OperatorEvent

public class AddSplitEvent<SplitT>
extends Object
implements OperatorEvent

A source event that adds splits to a source reader.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
AddSplitEvent(List<SplitT> splits, SimpleVersionedSerializer<SplitT> splitSerializer)

Method Summary

Modifier and Type	Method	Description
List<SplitT>	splits(SimpleVersionedSerializer<SplitT> splitSerializer)
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

AddSplitEvent

public AddSplitEvent(List<SplitT> splits,
                     SimpleVersionedSerializer<SplitT> splitSerializer)
              throws IOException

Throws:

IOException

Method Detail

splits

public List<SplitT> splits(SimpleVersionedSerializer<SplitT> splitSerializer)
                    throws IOException

Throws:

IOException

toString

public String toString()

Overrides:

toString in class Object