org.apache.paimon.table.sink

Class FixedBucketWriteSelector

java.lang.Object

org.apache.paimon.table.sink.FixedBucketWriteSelector

All Implemented Interfaces:

Serializable, WriteSelector

public class FixedBucketWriteSelector
extends Object
implements WriteSelector

A WriteSelector for BucketMode.HASH_FIXED.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
FixedBucketWriteSelector(TableSchema schema)

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.

Methods inherited from class java.lang.Object

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

Constructor Detail

FixedBucketWriteSelector

public FixedBucketWriteSelector(TableSchema schema)

Method Detail

select

public int select(InternalRow row,
                  int numWriters)

Description copied from interface: WriteSelector

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

Specified by:

select in interface WriteSelector