public class ExecNodeGraph extends Object
ExecNodeGraph
representing the ExecNode
topology.Constructor and Description |
---|
ExecNodeGraph(List<ExecNode<?>> rootNodes) |
ExecNodeGraph(String flinkVersion,
List<ExecNode<?>> rootNodes) |
Modifier and Type | Method and Description |
---|---|
static ExecNodeGraph |
createExecNodeGraph(String jsonPlan,
SerdeContext serdeCtx) |
static String |
createJsonPlan(ExecNodeGraph execGraph,
SerdeContext serdeCtx) |
String |
getFlinkVersion() |
List<ExecNode<?>> |
getRootNodes() |
public String getFlinkVersion()
public static String createJsonPlan(ExecNodeGraph execGraph, SerdeContext serdeCtx)
public static ExecNodeGraph createExecNodeGraph(String jsonPlan, SerdeContext serdeCtx)
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.