Package org.apache.flink.optimizer.plantranslate

Class JsonMapper

java.lang.Object

org.apache.flink.optimizer.plantranslate.JsonMapper

public class JsonMapper
extends Object

Constructor Summary

Constructors

Constructor	Description
JsonMapper()

Method Summary

Modifier and Type	Method	Description
static String	getLocalStrategyString(org.apache.flink.runtime.operators.util.LocalStrategy localStrategy)
static String	getOperatorStrategyString(org.apache.flink.runtime.operators.DriverStrategy strategy)
static String	getOperatorStrategyString(org.apache.flink.runtime.operators.DriverStrategy strategy, String firstInputName, String secondInputName)
static String	getOptimizerPropertiesJson(org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.JsonFactory jsonFactory, PlanNode node)
static String	getShipStrategyString(org.apache.flink.runtime.operators.shipping.ShipStrategyType shipType)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

JsonMapper

public JsonMapper()

Method Detail

getOperatorStrategyString

public static String getOperatorStrategyString(org.apache.flink.runtime.operators.DriverStrategy strategy)

getOperatorStrategyString

public static String getOperatorStrategyString(org.apache.flink.runtime.operators.DriverStrategy strategy,
                                               String firstInputName,
                                               String secondInputName)

getShipStrategyString

public static String getShipStrategyString(org.apache.flink.runtime.operators.shipping.ShipStrategyType shipType)

getLocalStrategyString

public static String getLocalStrategyString(org.apache.flink.runtime.operators.util.LocalStrategy localStrategy)

getOptimizerPropertiesJson

public static String getOptimizerPropertiesJson(org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.JsonFactory jsonFactory,
                                                PlanNode node)