verticesToDeploy = deploymentOptionsByVertex.keySet() | verticesToDeploy = executionVertexDeploymentOptions.stream().map(ExecutionVertexDeploymentOption::getExecutionVertexId).collect(Collectors.toList()) | deploymentOptionsByVertex.keySet() | executionVertexDeploymentOptions.stream().map(ExecutionVertexDeploymentOption::getExecutionVertexId).collect(Collectors.toList()) | flink | 24b77dbdfe072ab6087284b34f95e44b50e2610f | org.apache.flink.runtime.scheduler.DefaultScheduler | | _1 | verticesToDeploy |
---|
_2 | verticesToDeploy |
---|
| xyz | deploymentOptionsByVertex.keySet() |
---|
| - java.util.stream.Collectors
| xyz | executionVertexDeploymentOptions.stream().map(ExecutionVertexDeploymentOption::getExecutionVertexId).collect(Collectors.toList()) |
---|
| AssignedTo | False |