org.apache.paimon.flink.sink

Class StateUtils

java.lang.Object

org.apache.paimon.flink.sink.StateUtils

public class StateUtils
extends Object

Utility class for sink state manipulation.

Constructor Summary

Constructors

Constructor and Description
StateUtils()

Method Summary

Modifier and Type	Method and Description
static <T> T	getSingleValueFromState(org.apache.flink.runtime.state.StateInitializationContext context, String stateName, Class<T> valueClass, T defaultValue)

Methods inherited from class java.lang.Object

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

Constructor Detail

StateUtils

public StateUtils()

Method Detail

getSingleValueFromState

@Nullable
public static <T> T getSingleValueFromState(org.apache.flink.runtime.state.StateInitializationContext context,
                                                      String stateName,
                                                      Class<T> valueClass,
                                                      T defaultValue)
                                               throws Exception

Throws:

Exception