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.
Reports last emitted
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–2023 The Apache Software Foundation. All rights reserved.