Class OffsetCommitAckEvent

  • All Implemented Interfaces:
    Serializable, org.apache.flink.api.connector.source.SourceEvent

    public class OffsetCommitAckEvent
    extends Object
    implements org.apache.flink.api.connector.source.SourceEvent
    The SourceEvent that PostgresSourceReader broadcasts to PostgresSourceEnumerator to tell the enumerator that offset commit is already suspend. Then the enumerator can assign new added table's snapshot splits.
    See Also:
    Serialized Form
    • Constructor Detail

      • OffsetCommitAckEvent

        public OffsetCommitAckEvent()