Package org.apache.flink.table.planner.utils

Class StreamExchangeModeUtils

java.lang.Object

org.apache.flink.table.planner.utils.StreamExchangeModeUtils

@Internal
public class StreamExchangeModeUtils
extends Object

Utility class to load job-wide exchange mode.

Constructor Summary

Constructors

Constructor	Description
StreamExchangeModeUtils()

Method Summary

Modifier and Type	Method	Description
static StreamExchangeMode	getBatchStreamExchangeMode(ReadableConfig config, StreamExchangeMode requiredExchangeMode)

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamExchangeModeUtils

public StreamExchangeModeUtils()

Method Detail

getBatchStreamExchangeMode

public static StreamExchangeMode getBatchStreamExchangeMode(ReadableConfig config,
                                                            StreamExchangeMode requiredExchangeMode)