Package org.apache.flink.cdc.connectors.base.utils

Class EnvironmentUtils

java.lang.Object

org.apache.flink.cdc.connectors.base.utils.EnvironmentUtils

public class EnvironmentUtils
extends Object

Utilities for environment information at runtime.

Method Summary

Modifier and Type	Method	Description
static void	checkSupportCheckpointsAfterTasksFinished(boolean closeIdleReaders)
static VersionComparable	runtimeFlinkVersion()
static boolean	supportCheckpointsAfterTasksFinished()

Methods inherited from class java.lang.Object

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

Method Detail

runtimeFlinkVersion

public static VersionComparable runtimeFlinkVersion()

supportCheckpointsAfterTasksFinished

public static boolean supportCheckpointsAfterTasksFinished()

checkSupportCheckpointsAfterTasksFinished

public static void checkSupportCheckpointsAfterTasksFinished(boolean closeIdleReaders)