UnionStreamOperator (Flink : 2.0-SNAPSHOT API)

java.lang.Object
- org.apache.flink.streaming.api.operators.AbstractStreamOperator<OUT>
- - org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator<OUT,MapFunction<IN,OUT>>
  - - org.apache.flink.streaming.api.operators.StreamMap<RowData,RowData>
    - - org.apache.flink.table.runtime.operators.multipleinput.UnionStreamOperator

All Implemented Interfaces:

Serializable, CheckpointListener, BoundedMultiInput, Input<RowData>, KeyContext, KeyContextHandler, OneInputStreamOperator<RowData,RowData>, OutputTypeConfigurable<RowData>, StreamOperator<RowData>, StreamOperatorStateHandler.CheckpointedStreamOperator, UserFunctionProvider<MapFunction<RowData,RowData>>, YieldingOperator<RowData>
```
public class UnionStreamOperator
extends StreamMap<RowData,RowData>
implements BoundedMultiInput
```
A special operator which collects all inputs' records and forwards them in MultipleInputStreamOperatorBase.

See Also:

Serialized Form

Field Summary
- Fields inherited from class org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator
  userFunction
- Fields inherited from class org.apache.flink.streaming.api.operators.AbstractStreamOperator
  config, lastRecordAttributes1, lastRecordAttributes2, latencyStats, LOG, metrics, output, processingTimeService, stateHandler, stateKeySelector1, stateKeySelector2, timeServiceManager

Constructor Summary

Constructors
Constructor Description

UnionStreamOperator()

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`endInput(int inputId)`	It is notified that no more data will arrive from the input identified by the `inputId`.

Methods inherited from class org.apache.flink.streaming.api.operators.StreamMap
processElement

Methods inherited from class org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator
close, finish, getUserFunction, getUserFunctionParameters, initializeState, notifyCheckpointAborted, notifyCheckpointComplete, open, setOutputType, setup, snapshotState

Methods inherited from class org.apache.flink.streaming.api.operators.AbstractStreamOperator
getContainingTask, getCurrentKey, getExecutionConfig, getInternalTimerService, getKeyedStateBackend, getKeyedStateStore, getMetricGroup, getOperatorConfig, getOperatorID, getOperatorName, getOperatorStateBackend, getOrCreateKeyedState, getPartitionedState, getPartitionedState, getProcessingTimeService, getRuntimeContext, getStateKeySelector1, getStateKeySelector2, getTimeServiceManager, getUserCodeClassloader, hasKeyContext1, hasKeyContext2, initializeState, isUsingCustomRawKeyedState, prepareSnapshotPreBarrier, processLatencyMarker, processLatencyMarker1, processLatencyMarker2, processRecordAttributes, processRecordAttributes1, processRecordAttributes2, processWatermark, processWatermark1, processWatermark2, processWatermarkStatus, processWatermarkStatus1, processWatermarkStatus2, reportOrForwardLatencyMarker, setCurrentKey, setKeyContextElement1, setKeyContextElement2, setMailboxExecutor, setProcessingTimeService, snapshotState, useSplittableTimers

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.flink.api.common.state.CheckpointListener
notifyCheckpointAborted, notifyCheckpointComplete

Methods inherited from interface org.apache.flink.streaming.api.operators.Input
processLatencyMarker, processRecordAttributes, processWatermark, processWatermarkStatus

Methods inherited from interface org.apache.flink.streaming.api.operators.KeyContext
getCurrentKey, setCurrentKey

Methods inherited from interface org.apache.flink.streaming.api.operators.KeyContextHandler
hasKeyContext

Methods inherited from interface org.apache.flink.streaming.api.operators.OneInputStreamOperator
setKeyContextElement

Methods inherited from interface org.apache.flink.streaming.api.operators.StreamOperator
close, finish, getMetricGroup, getOperatorAttributes, getOperatorID, initializeState, open, prepareSnapshotPreBarrier, setKeyContextElement1, setKeyContextElement2, snapshotState

- Constructor Detail
  - UnionStreamOperator
```
public UnionStreamOperator()
```
- Method Detail
  - endInput
```
public void endInput(int inputId)
              throws Exception
```
    Description copied from interface: BoundedMultiInput
    
    It is notified that no more data will arrive from the input identified by the inputId. The inputId is numbered starting from 1, and `1` indicates the first input.
    WARNING: It is not safe to use this method to commit any transactions or other side effects! You can use this method to e.g. flush data buffered for the given input or implement an ordered reading from multiple inputs via InputSelectable.
    
    Specified by:
    
    endInput in interface BoundedMultiInput
    
    Throws:
    
    Exception