Class 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 Detail

      • RequestSplitEvent

        public RequestSplitEvent()
        Creates a new RequestSplitEvent with no host information.
      • RequestSplitEvent

        public RequestSplitEvent​(@Nullable
                                 String hostName)
        Creates a new RequestSplitEvent with a hostname.