Package org.apache.flink.cdc.connectors.fluss.source.event

Class TableSubscriptionEvent

java.lang.Object

org.apache.flink.cdc.connectors.fluss.source.event.TableSubscriptionEvent

All Implemented Interfaces:

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

public class TableSubscriptionEvent
extends Object
implements org.apache.flink.api.connector.source.SourceEvent

Authoritative source-table subscription snapshot sent from the enumerator to a reader.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
TableSubscriptionEvent(Set<org.apache.fluss.metadata.TablePath> subscribedTablePaths, Map<org.apache.fluss.metadata.TablePath,Long> pendingRemovalRequests)
TableSubscriptionEvent(Set<org.apache.fluss.metadata.TablePath> subscribedTablePaths, Map<org.apache.fluss.metadata.TablePath,Long> pendingRemovalRequests, Set<org.apache.fluss.metadata.TablePath> fencedTablePaths)

Method Summary

Modifier and Type	Method	Description
Set<org.apache.fluss.metadata.TablePath>	getFencedTablePaths()
Map<org.apache.fluss.metadata.TablePath,Long>	getPendingRemovalRequests()
Set<org.apache.fluss.metadata.TablePath>	getSubscribedTablePaths()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

TableSubscriptionEvent

public TableSubscriptionEvent(Set<org.apache.fluss.metadata.TablePath> subscribedTablePaths,
                              Map<org.apache.fluss.metadata.TablePath,Long> pendingRemovalRequests)

TableSubscriptionEvent

public TableSubscriptionEvent(Set<org.apache.fluss.metadata.TablePath> subscribedTablePaths,
                              Map<org.apache.fluss.metadata.TablePath,Long> pendingRemovalRequests,
                              Set<org.apache.fluss.metadata.TablePath> fencedTablePaths)

Method Detail

getSubscribedTablePaths

public Set<org.apache.fluss.metadata.TablePath> getSubscribedTablePaths()

getPendingRemovalRequests

public Map<org.apache.fluss.metadata.TablePath,Long> getPendingRemovalRequests()

getFencedTablePaths

public Set<org.apache.fluss.metadata.TablePath> getFencedTablePaths()

toString

public String toString()

Overrides:

toString in class Object