Uses of Interface
org.apache.paimon.utils.SerializableConsumer

Packages that use SerializableConsumer

Package	Description
org.apache.paimon.flink.orphan
org.apache.paimon.operation

Uses of SerializableConsumer in org.apache.paimon.flink.orphan

Methods in org.apache.paimon.flink.orphan with parameters of type SerializableConsumer

Modifier and Type	Method and Description
static long	FlinkOrphanFilesClean.executeDatabaseOrphanFiles(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env, Catalog catalog, long olderThanMillis, SerializableConsumer<Path> fileCleaner, Integer parallelism, String databaseName, String tableName)

Constructors in org.apache.paimon.flink.orphan with parameters of type SerializableConsumer

Constructor and Description
FlinkOrphanFilesClean(FileStoreTable table, long olderThanMillis, SerializableConsumer<Path> fileCleaner, Integer parallelism)

Uses of SerializableConsumer in org.apache.paimon.operation

Fields in org.apache.paimon.operation declared as SerializableConsumer

Modifier and Type	Field and Description
protected SerializableConsumer<Path>	OrphanFilesClean.fileCleaner

Methods in org.apache.paimon.operation that return SerializableConsumer

Modifier and Type	Method and Description
static SerializableConsumer<Path>	OrphanFilesClean.createFileCleaner(Catalog catalog, Boolean dryRun)

Methods in org.apache.paimon.operation with parameters of type SerializableConsumer

Modifier and Type	Method and Description
static List<LocalOrphanFilesClean>	LocalOrphanFilesClean.createOrphanFilesCleans(Catalog catalog, String databaseName, String tableName, long olderThanMillis, SerializableConsumer<Path> fileCleaner, Integer parallelism)
static long	LocalOrphanFilesClean.executeDatabaseOrphanFiles(Catalog catalog, String databaseName, String tableName, long olderThanMillis, SerializableConsumer<Path> fileCleaner, Integer parallelism)

Constructors in org.apache.paimon.operation with parameters of type SerializableConsumer

Constructor and Description
LocalOrphanFilesClean(FileStoreTable table, long olderThanMillis, SerializableConsumer<Path> fileCleaner)
OrphanFilesClean(FileStoreTable table, long olderThanMillis, SerializableConsumer<Path> fileCleaner)