org.apache.paimon.flink.sink

Class BucketsRowChannelComputer

java.lang.Object

org.apache.paimon.flink.sink.BucketsRowChannelComputer

All Implemented Interfaces:

Serializable, ChannelComputer<org.apache.flink.table.data.RowData>

public class BucketsRowChannelComputer
extends Object
implements ChannelComputer<org.apache.flink.table.data.RowData>

ChannelComputer to partition RowData from CompactBucketsTable.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
BucketsRowChannelComputer()

Method Summary

Modifier and Type	Method and Description
int	channel(org.apache.flink.table.data.RowData rowData)
void	setup(int numberOfChannels)
String	toString()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.paimon.table.sink.ChannelComputer

select, select, transform

Constructor Detail

BucketsRowChannelComputer

public BucketsRowChannelComputer()

Method Detail

setup

public void setup(int numberOfChannels)

Specified by:

setup in interface ChannelComputer<org.apache.flink.table.data.RowData>

channel

public int channel(org.apache.flink.table.data.RowData rowData)

Specified by:

channel in interface ChannelComputer<org.apache.flink.table.data.RowData>

toString

public String toString()

Overrides:

toString in class Object