org.apache.paimon.flink.lookup

Interface FullCacheLookupTable.TableBulkLoader

Enclosing class:

FullCacheLookupTable

public static interface FullCacheLookupTable.TableBulkLoader

Bulk loader for the table.

Method Summary

Modifier and Type	Method and Description
void	finish()
void	write(byte[] key, byte[] value)

Method Detail

write

void write(byte[] key,
           byte[] value)
    throws BulkLoader.WriteException,
           IOException

Throws:

BulkLoader.WriteException

IOException

finish

void finish()
     throws IOException

Throws:

IOException