org.apache.paimon.migrate

Class FileMetaUtils

java.lang.Object

org.apache.paimon.migrate.FileMetaUtils

public class FileMetaUtils
extends Object

To construct file meta data for external files.

Constructor Summary

Constructors

Constructor and Description
FileMetaUtils()

Method Summary

Modifier and Type	Method and Description
static CommitMessage	commitFile(BinaryRow partition, List<DataFileMeta> dataFileMetas)
static List<DataFileMeta>	construct(FileIO fileIO, String format, String location, Table paimonTable, java.util.function.Predicate<FileStatus> filter, Path dir, Map<Path,Path> rollback)
static BinaryRow	writePartitionValue(RowType partitionRowType, Map<String,String> partitionValues, List<BinaryWriter.ValueSetter> valueSetters, String partitionDefaultName)

Methods inherited from class java.lang.Object

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

Constructor Detail

FileMetaUtils

public FileMetaUtils()

Method Detail

construct

public static List<DataFileMeta> construct(FileIO fileIO,
                                           String format,
                                           String location,
                                           Table paimonTable,
                                           java.util.function.Predicate<FileStatus> filter,
                                           Path dir,
                                           Map<Path,Path> rollback)
                                    throws IOException

Throws:

IOException

commitFile

public static CommitMessage commitFile(BinaryRow partition,
                                       List<DataFileMeta> dataFileMetas)

writePartitionValue

public static BinaryRow writePartitionValue(RowType partitionRowType,
                                            Map<String,String> partitionValues,
                                            List<BinaryWriter.ValueSetter> valueSetters,
                                            String partitionDefaultName)