org.apache.iceberg.flink.source.split

Class SplitRequestEvent

java.lang.Object

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

All Implemented Interfaces:

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

@Internal
public class SplitRequestEvent
extends java.lang.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 and Description
SplitRequestEvent()
SplitRequestEvent(java.util.Collection<java.lang.String> finishedSplitIds)
SplitRequestEvent(java.util.Collection<java.lang.String> finishedSplitIds, java.lang.String requesterHostname)

Method Summary

Modifier and Type	Method and Description
java.util.Collection<java.lang.String>	finishedSplitIds()
java.lang.String	requesterHostname()

Methods inherited from class java.lang.Object

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

Constructor Detail

SplitRequestEvent

public SplitRequestEvent()

SplitRequestEvent

public SplitRequestEvent(java.util.Collection<java.lang.String> finishedSplitIds)

SplitRequestEvent

public SplitRequestEvent(java.util.Collection<java.lang.String> finishedSplitIds,
                         java.lang.String requesterHostname)

Method Detail

finishedSplitIds

public java.util.Collection<java.lang.String> finishedSplitIds()

requesterHostname

public java.lang.String requesterHostname()