org.apache.flink.table.planner.utils

Class RowLevelModificationContextUtils

java.lang.Object

org.apache.flink.table.planner.utils.RowLevelModificationContextUtils

public class RowLevelModificationContextUtils
extends Object

Utils for putting/getting RowLevelModificationScanContext/SupportsRowLevelModificationScan.RowLevelModificationType in current thread, it enables to put/get them in different methods.

Constructor Summary

Constructors

Constructor and Description
RowLevelModificationContextUtils()

Method Summary

Modifier and Type	Method and Description
static void	clearContext()
static org.apache.flink.table.connector.source.abilities.SupportsRowLevelModificationScan.RowLevelModificationType	getModificationType()
static org.apache.flink.table.connector.RowLevelModificationScanContext	getScanContext()
static void	setModificationType(org.apache.flink.table.connector.source.abilities.SupportsRowLevelModificationScan.RowLevelModificationType rowLevelModificationType)
static void	setScanContext(org.apache.flink.table.connector.RowLevelModificationScanContext scanContext)

Methods inherited from class java.lang.Object

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

Constructor Detail

RowLevelModificationContextUtils

public RowLevelModificationContextUtils()

Method Detail

setModificationType

public static void setModificationType(org.apache.flink.table.connector.source.abilities.SupportsRowLevelModificationScan.RowLevelModificationType rowLevelModificationType)

getModificationType

public static org.apache.flink.table.connector.source.abilities.SupportsRowLevelModificationScan.RowLevelModificationType getModificationType()

setScanContext

public static void setScanContext(org.apache.flink.table.connector.RowLevelModificationScanContext scanContext)

getScanContext

public static org.apache.flink.table.connector.RowLevelModificationScanContext getScanContext()

clearContext

public static void clearContext()