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()