org.apache.paimon.flink.sink

Class RewriteFileIndexSink.FileIndexProcessor

java.lang.Object

org.apache.paimon.flink.sink.RewriteFileIndexSink.FileIndexProcessor

Enclosing class:

RewriteFileIndexSink

public static class RewriteFileIndexSink.FileIndexProcessor
extends Object

Does the file index rewrite.

Constructor Summary

Constructors

Constructor and Description
FileIndexProcessor(FileStoreTable table)

Method Summary

Modifier and Type	Method and Description
DataFileMeta	process(BinaryRow partition, int bucket, DataFileMeta dataFileMeta)

Methods inherited from class java.lang.Object

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

Constructor Detail

FileIndexProcessor

public FileIndexProcessor(FileStoreTable table)

Method Detail

process

public DataFileMeta process(BinaryRow partition,
                            int bucket,
                            DataFileMeta dataFileMeta)
                     throws IOException

Throws:

IOException