org.apache.paimon.flink.sink

Class RowDataChannelComputer

java.lang.Object

org.apache.paimon.flink.sink.RowDataChannelComputer

All Implemented Interfaces:

Serializable, ChannelComputer<InternalRow>

public class RowDataChannelComputer
extends Object
implements ChannelComputer<InternalRow>

ChannelComputer for InternalRow.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
RowDataChannelComputer(TableSchema schema, boolean hasLogSink)

Method Summary

Modifier and Type	Method and Description
int	channel(BinaryRow partition, int bucket)
int	channel(InternalRow 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

RowDataChannelComputer

public RowDataChannelComputer(TableSchema schema,
                              boolean hasLogSink)

Method Detail

setup

public void setup(int numChannels)

Specified by:

setup in interface ChannelComputer<InternalRow>

channel

public int channel(InternalRow record)

Specified by:

channel in interface ChannelComputer<InternalRow>

channel

public int channel(BinaryRow partition,
                   int bucket)

toString

public String toString()

Overrides:

toString in class Object