org.apache.paimon.flink.sink

Class RowWithBucketChannelComputer

java.lang.Object

org.apache.paimon.flink.sink.RowWithBucketChannelComputer

All Implemented Interfaces:

Serializable, ChannelComputer<org.apache.flink.api.java.tuple.Tuple2<InternalRow,Integer>>

public class RowWithBucketChannelComputer
extends Object
implements ChannelComputer<org.apache.flink.api.java.tuple.Tuple2<InternalRow,Integer>>

Hash key of a RowData with bucket.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
RowWithBucketChannelComputer(TableSchema schema)

Method Summary

Modifier and Type	Method and Description
int	channel(org.apache.flink.api.java.tuple.Tuple2<InternalRow,Integer> record)
void	setup(int numChannels)
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

RowWithBucketChannelComputer

public RowWithBucketChannelComputer(TableSchema schema)

Method Detail

setup

public void setup(int numChannels)

Specified by:

setup in interface ChannelComputer<org.apache.flink.api.java.tuple.Tuple2<InternalRow,Integer>>

channel

public int channel(org.apache.flink.api.java.tuple.Tuple2<InternalRow,Integer> record)

Specified by:

channel in interface ChannelComputer<org.apache.flink.api.java.tuple.Tuple2<InternalRow,Integer>>

toString

public String toString()

Overrides:

toString in class Object