Package | Description |
---|---|
org.apache.flink.table.runtime.operators.join.stream |
Class and 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 . |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.