@Internal
public class SplitRequestEvent
extends java.lang.Object
implements org.apache.flink.api.connector.source.SourceEvent
Constructor and Description |
---|
SplitRequestEvent() |
SplitRequestEvent(java.util.Collection<java.lang.String> finishedSplitIds) |
SplitRequestEvent(java.util.Collection<java.lang.String> finishedSplitIds,
java.lang.String requesterHostname) |
Modifier and Type | Method and Description |
---|---|
java.util.Collection<java.lang.String> |
finishedSplitIds() |
java.lang.String |
requesterHostname() |