Class | Description |
---|---|
AbstractStreamingJoinOperator |
Abstract implementation for streaming unbounded Join operator which defines some member fields
can be shared between different implementations.
|
AbstractStreamingJoinOperator.AssociatedRecords |
The
AbstractStreamingJoinOperator.AssociatedRecords is the records associated to the input row. |
AbstractStreamingJoinOperator.OuterRecord |
An
AbstractStreamingJoinOperator.OuterRecord is a composite of record and numOfAssociations . |
StreamingJoinOperator |
Streaming unbounded Join operator which supports INNER/LEFT/RIGHT/FULL JOIN.
|
StreamingSemiAntiJoinOperator |
Streaming unbounded Join operator which supports SEMI/ANTI JOIN.
|
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.