org.apache.paimon.table.sink

Interface WriteSelector

All Superinterfaces:

Serializable

All Known Implementing Classes:

FixedBucketWriteSelector

public interface WriteSelector
extends Serializable

The WriteSelector determines to which logical downstream writers a record should be written to.

Method Summary

Modifier and Type	Method and Description
int	select(InternalRow row, int numWriters) Returns the logical writer index, to which the given record should be written.

Method Detail

select

int select(InternalRow row,
           int numWriters)

Returns the logical writer index, to which the given record should be written.