Class RequestSplitEvent
- java.lang.Object
-
- org.apache.flink.runtime.source.event.RequestSplitEvent
-
- All Implemented Interfaces:
Serializable
,OperatorEvent
public final class RequestSplitEvent extends Object implements OperatorEvent
An event to request splits, sent typically from the Source Reader to the Source Enumerator.This event optionally carries the hostname of the location where the reader runs, to support locality-aware work assignment.
- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description RequestSplitEvent()
Creates a newRequestSplitEvent
with no host information.RequestSplitEvent(String hostName)
Creates a newRequestSplitEvent
with a hostname.
-
-
-
Constructor Detail
-
RequestSplitEvent
public RequestSplitEvent()
Creates a newRequestSplitEvent
with no host information.
-
RequestSplitEvent
public RequestSplitEvent(@Nullable String hostName)
Creates a newRequestSplitEvent
with a hostname.
-
-