Package org.apache.iceberg.flink.source.split

Class SplitRequestEvent

java.lang.Object

org.apache.iceberg.flink.source.split.SplitRequestEvent

All Implemented Interfaces:

Serializable, org.apache.flink.api.connector.source.SourceEvent

@Internal
public class SplitRequestEvent
extends Object
implements org.apache.flink.api.connector.source.SourceEvent

We can remove this class once FLINK-21364 is resolved.

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
SplitRequestEvent()
SplitRequestEvent(Collection<String> finishedSplitIds)
SplitRequestEvent(Collection<String> finishedSplitIds, String requesterHostname)

Method Summary

Modifier and Type	Method	Description
Collection<String>	finishedSplitIds()
String	requesterHostname()

Methods inherited from class java.lang.Object

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

Constructor Details

SplitRequestEvent

public SplitRequestEvent()

SplitRequestEvent

public SplitRequestEvent(Collection<String> finishedSplitIds)

SplitRequestEvent

public SplitRequestEvent(Collection<String> finishedSplitIds,
 String requesterHostname)

Method Details

finishedSplitIds

public Collection<String> finishedSplitIds()

requesterHostname

public String requesterHostname()