public class LatestFinishedSplitsSizeEvent extends Object implements org.apache.flink.api.connector.source.SourceEvent
SourceEvent that MySqlSourceEnumerator sends to MySqlSourceReader to
pass the latest finished snapshot splits size.| Constructor and Description |
|---|
LatestFinishedSplitsSizeEvent(int latestFinishedSplitsSize) |
Copyright © 2022 The Apache Software Foundation. All rights reserved.