JobExecutePlan |
JobExecutePlan.addVerticesItem(VerticesEntity verticesItem) |
JobExecutePlan |
JobExecutePlan.duration(String duration) |
JobExecutePlan |
JobExecutePlan.endTime(Long endTime) |
JobExecutePlan |
FlinkJobExecutePlanResponse.getExecuteGraph()
Get executeGraph
|
JobExecutePlan |
JobExecutePlan.isStoppable(Boolean isStoppable) |
JobExecutePlan |
JobExecutePlan.jid(String jid) |
JobExecutePlan |
JobExecutePlan.jmxMetricPort(String jmxMetricPort) |
JobExecutePlan |
JobExecutePlan.name(String name) |
JobExecutePlan |
JobExecutePlan.now(Long now) |
JobExecutePlan |
JobExecutePlan.plan(PlanEntity plan) |
JobExecutePlan |
JobExecutePlan.startTime(Long startTime) |
JobExecutePlan |
JobExecutePlan.state(String state) |
JobExecutePlan |
JobExecutePlan.vertices(List<VerticesEntity> vertices) |