org.apache.paimon.flink.utils

Class MultiTablesCompactorUtil

java.lang.Object

org.apache.paimon.flink.utils.MultiTablesCompactorUtil

public class MultiTablesCompactorUtil
extends Object

Utility methods for dedicated compaction job for multi-tables.

Constructor Summary

Constructors

Constructor and Description
MultiTablesCompactorUtil()

Method Summary

Modifier and Type	Method and Description
static Map<String,String>	compactOptions(boolean isStreaming)
static boolean	shouldCompactTable(Identifier tableIdentifier, Pattern includingPattern, Pattern excludingPattern)

Methods inherited from class java.lang.Object

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

Constructor Detail

MultiTablesCompactorUtil

public MultiTablesCompactorUtil()

Method Detail

compactOptions

public static Map<String,String> compactOptions(boolean isStreaming)

shouldCompactTable

public static boolean shouldCompactTable(Identifier tableIdentifier,
                                         Pattern includingPattern,
                                         Pattern excludingPattern)