| 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 |