org.apache.paimon.flink.sink

Class MultiTableCommittableChannelComputer

java.lang.Object

org.apache.paimon.flink.sink.MultiTableCommittableChannelComputer

All Implemented Interfaces:

Serializable, ChannelComputer<MultiTableCommittable>

public class MultiTableCommittableChannelComputer
extends Object
implements ChannelComputer<MultiTableCommittable>

ChannelComputer for MultiTableCommittable.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
MultiTableCommittableChannelComputer()

Method Summary

Modifier and Type	Method and Description
int	channel(MultiTableCommittable multiTableCommittable)
static int	computeChannel(String database, String table, int numChannels)
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

MultiTableCommittableChannelComputer

public MultiTableCommittableChannelComputer()

Method Detail

setup

public void setup(int numChannels)

Specified by:

setup in interface ChannelComputer<MultiTableCommittable>

channel

public int channel(MultiTableCommittable multiTableCommittable)

Specified by:

channel in interface ChannelComputer<MultiTableCommittable>

computeChannel

public static int computeChannel(String database,
                                 String table,
                                 int numChannels)

toString

public String toString()

Overrides:

toString in class Object