Package io.delta.kernel.internal.compaction

Class LogCompactionWriter

Object

io.delta.kernel.internal.compaction.LogCompactionWriter

public class LogCompactionWriter
extends Object

Utility for writing out log compactions.

Constructor Summary

Constructors

Constructor	Description
LogCompactionWriter(Path dataPath, Path logPath, long startVersion, long endVersion, long minFileRetentionTimestampMillis)

Method Summary

Modifier and Type	Method	Description
static boolean	shouldCompact(long commitVersion, long compactionInterval)	Utility to determine if log compaction should run for the given commit version.
void	writeLogCompactionFile(Engine engine)

Methods inherited from class java.lang.Object

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

Constructor Details

LogCompactionWriter

public LogCompactionWriter(Path dataPath,
 Path logPath,
 long startVersion,
 long endVersion,
 long minFileRetentionTimestampMillis)

Method Details

writeLogCompactionFile

public void writeLogCompactionFile(Engine engine)
                            throws IOException

Throws:

IOException

shouldCompact

public static boolean shouldCompact(long commitVersion,
 long compactionInterval)

Utility to determine if log compaction should run for the given commit version.