org.apache.paimon.table.sink

Class CallbackUtils

java.lang.Object

org.apache.paimon.table.sink.CallbackUtils

public class CallbackUtils
extends Object

Utils to load callbacks.

Constructor Summary

Constructors

Constructor and Description
CallbackUtils()

Method Summary

Modifier and Type	Method and Description
static List<CommitCallback>	loadCommitCallbacks(CoreOptions coreOptions)
static List<TagCallback>	loadTagCallbacks(CoreOptions coreOptions)

Methods inherited from class java.lang.Object

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

Constructor Detail

CallbackUtils

public CallbackUtils()

Method Detail

loadTagCallbacks

public static List<TagCallback> loadTagCallbacks(CoreOptions coreOptions)

loadCommitCallbacks

public static List<CommitCallback> loadCommitCallbacks(CoreOptions coreOptions)