A source event that adds splits to a source reader.
A source event sent from the SplitEnumerator to the SourceReader to indicate that no more splits will be assigned to the source reader anymore.
An event to request splits, sent typically from the Source Reader to the Source Enumerator.
A wrapper operator event that contains a custom defined operator event.
Signals source operators the maximum watermark that emitted records can have.
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.