| BroadcastingOutput |
An Output that can be used to emit elements and other messages to multiple outputs.
|
| CopyingBroadcastingOutput |
Special version of BroadcastingOutput that performs a shallow copy of the StreamRecord to ensure that multi-output works correctly. |
| CopyingFirstInputOfTwoInputStreamOperatorOutput |
An Output that can be used to emit copying elements and other messages for the first
input of TwoInputStreamOperator.
|
| CopyingOneInputStreamOperatorOutput |
An Output that can be used to emit copying elements and other messages for OneInputStreamOperator.
|
| CopyingSecondInputOfTwoInputStreamOperatorOutput |
An Output that can be used to emit copying elements and other messages for the second
input of TwoInputStreamOperator.
|
| FirstInputOfTwoInputStreamOperatorOutput |
An Output that can be used to emit elements and other messages for the first input of
TwoInputStreamOperator.
|
| OneInputStreamOperatorOutput |
An Output that can be used to emit elements and other messages for OneInputStreamOperator.
|
| OutputBase |
Base Output that can be used to emit elements and other messages in MultipleInputStreamOperatorBase.
|
| SecondInputOfTwoInputStreamOperatorOutput |
An Output that can be used to emit elements and other messages for the second input of
TwoInputStreamOperator.
|