org.apache.paimon.utils

Class ProcedureUtils

java.lang.Object

org.apache.paimon.utils.ProcedureUtils

public class ProcedureUtils
extends Object

Utils for procedure.

Constructor Summary

Constructors

Constructor and Description
ProcedureUtils()

Method Summary

Modifier and Type	Method and Description
static Map<String,String>	fillInPartitionOptions(String expireStrategy, String timestampFormatter, String timestampPattern, String expirationTime, Integer maxExpires, String options)
static ExpireConfig.Builder	fillInSnapshotOptions(CoreOptions tableOptions, Integer retainMax, Integer retainMin, String olderThanStr, Integer maxDeletes)
static void	putAllOptions(HashMap<String,String> dynamicOptions, String options)
static void	putIfNotEmpty(HashMap<String,String> dynamicOptions, String key, String value)

Methods inherited from class java.lang.Object

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

Constructor Detail

ProcedureUtils

public ProcedureUtils()

Method Detail

fillInPartitionOptions

public static Map<String,String> fillInPartitionOptions(String expireStrategy,
                                                        String timestampFormatter,
                                                        String timestampPattern,
                                                        String expirationTime,
                                                        Integer maxExpires,
                                                        String options)

putAllOptions

public static void putAllOptions(HashMap<String,String> dynamicOptions,
                                 String options)

putIfNotEmpty

public static void putIfNotEmpty(HashMap<String,String> dynamicOptions,
                                 String key,
                                 String value)

fillInSnapshotOptions

public static ExpireConfig.Builder fillInSnapshotOptions(CoreOptions tableOptions,
                                                         Integer retainMax,
                                                         Integer retainMin,
                                                         String olderThanStr,
                                                         Integer maxDeletes)