Class InputGateUtil
- java.lang.Object
-
- org.apache.flink.streaming.runtime.io.InputGateUtil
-
@Internal public class InputGateUtil extends Object
Utility for dealing with input gates. This will either just return the singleInputGate
that was passed in or create aUnionInputGate
if severalinput gates
are given.
-
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static InputGate
createInputGate(List<IndexedInputGate> inputGates)
-
-
-
Method Detail
-
createInputGate
public static InputGate createInputGate(List<IndexedInputGate> inputGates)
-
-