public static List < InputChannelDeploymentDescriptor > fromEdges ( List < ExecutionEdge > edges , boolean allowLazyDeployment ) { return edges . stream ( ) . map ( edge -> fromEdgeAndValidate ( allowLazyDeployment , edge ) ) . collect ( Collectors . toList ( ) ) ; }
Creates an input channel deployment descriptor for each partition .