org.apache.paimon.utils

Class HintFileUtils

java.lang.Object

org.apache.paimon.utils.HintFileUtils

public class HintFileUtils
extends Object

Utils for hint files.

Field Summary

Fields

Modifier and Type	Field and Description
static String	EARLIEST
static String	LATEST

Constructor Summary

Constructors

Constructor and Description
HintFileUtils()

Method Summary

Modifier and Type	Method and Description
static void	commitEarliestHint(FileIO fileIO, long id, Path dir)
static void	commitHint(FileIO fileIO, long id, String fileName, Path dir)
static void	commitLatestHint(FileIO fileIO, long id, Path dir)
static void	deleteLatestHint(FileIO fileIO, Path dir)
static Long	findByListFiles(FileIO fileIO, java.util.function.BinaryOperator<Long> reducer, Path dir, String prefix)
static Long	findEarliest(FileIO fileIO, Path dir, String prefix, java.util.function.Function<Long,Path> file)
static Long	findLatest(FileIO fileIO, Path dir, String prefix, java.util.function.Function<Long,Path> file)
static Long	readHint(FileIO fileIO, String fileName, Path dir)

Methods inherited from class java.lang.Object

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

Field Detail

EARLIEST

public static final String EARLIEST

See Also:

Constant Field Values

LATEST

public static final String LATEST

See Also:

Constant Field Values

Constructor Detail

HintFileUtils

public HintFileUtils()

Method Detail

findLatest

@Nullable
public static Long findLatest(FileIO fileIO,
                                        Path dir,
                                        String prefix,
                                        java.util.function.Function<Long,Path> file)
                                 throws IOException

Throws:

IOException

findEarliest

@Nullable
public static Long findEarliest(FileIO fileIO,
                                          Path dir,
                                          String prefix,
                                          java.util.function.Function<Long,Path> file)
                                   throws IOException

Throws:

IOException

readHint

public static Long readHint(FileIO fileIO,
                            String fileName,
                            Path dir)

findByListFiles

public static Long findByListFiles(FileIO fileIO,
                                   java.util.function.BinaryOperator<Long> reducer,
                                   Path dir,
                                   String prefix)
                            throws IOException

Throws:

IOException

commitLatestHint

public static void commitLatestHint(FileIO fileIO,
                                    long id,
                                    Path dir)
                             throws IOException

Throws:

IOException

commitEarliestHint

public static void commitEarliestHint(FileIO fileIO,
                                      long id,
                                      Path dir)
                               throws IOException

Throws:

IOException

deleteLatestHint

public static void deleteLatestHint(FileIO fileIO,
                                    Path dir)
                             throws IOException

Throws:

IOException

commitHint

public static void commitHint(FileIO fileIO,
                              long id,
                              String fileName,
                              Path dir)
                       throws IOException

Throws:

IOException