| Class | Description |
|---|---|
| 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. |
| Exception | Description |
|---|---|
| ExceptionInMultipleInputOperatorException |
A special exception that signifies that the cause exception came from a
MultipleInputStreamOperatorBase. |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.