Package | Description |
---|---|
org.apache.flink.table.planner.plan.nodes.exec | |
org.apache.flink.table.planner.plan.nodes.exec.serde |
Modifier and Type | Method and Description |
---|---|
static ExecNodeGraph |
ExecNodeGraph.createExecNodeGraph(String jsonPlan,
SerdeContext serdeCtx) |
static String |
ExecNodeGraph.createJsonPlan(ExecNodeGraph execGraph,
SerdeContext serdeCtx) |
Modifier and Type | Method and Description |
---|---|
SerdeContext |
FlinkDeserializationContext.getSerdeContext() |
Modifier and Type | Method and Description |
---|---|
ExecNodeGraph |
ExecNodeGraphJsonPlanGenerator.JsonPlanGraph.convertToExecNodeGraph(SerdeContext serdeCtx) |
static org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.ObjectMapper |
JsonSerdeUtil.createObjectMapper(SerdeContext serdeCtx)
Create an
ObjectMapper which DeserializationContext wraps a SerdeContext . |
LogicalType |
LogicalTypeJsonDeserializer.deserialize(org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.JsonNode logicalTypeNode,
SerdeContext serdeCtx) |
static ExecNodeGraph |
ExecNodeGraphJsonPlanGenerator.generateExecNodeGraph(String jsonPlan,
SerdeContext serdeCtx)
Generate
ExecNodeGraph based on the given JSON plan. |
static String |
ExecNodeGraphJsonPlanGenerator.generateJsonPlan(ExecNodeGraph execGraph,
SerdeContext serdeCtx)
Generate JSON plan based on the given
ExecNodeGraph . |
Constructor and Description |
---|
FlinkDeserializationContext(org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.deser.DefaultDeserializationContext src,
SerdeContext serdeCtx) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.