org.apache.paimon.flink.copy

Class SnapshotHintChannelComputer

java.lang.Object

org.apache.paimon.flink.copy.SnapshotHintChannelComputer

All Implemented Interfaces:

Serializable, ChannelComputer<CopyFileInfo>

public class SnapshotHintChannelComputer
extends Object
implements ChannelComputer<CopyFileInfo>

ChannelComputer for distributing CopyFileInfo records into SnapshotHintOperator for recreate snapshot hints.

CopyFileInfos are distributed by target table name, so the creation of snapshot hints of each table is handled by only one parallelism.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
SnapshotHintChannelComputer()

Method Summary

Modifier and Type	Method and Description
int	channel(CopyFileInfo record)
void	setup(int numChannels)

Methods inherited from class java.lang.Object

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

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

select, select, startChannel, transform

Constructor Detail

SnapshotHintChannelComputer

public SnapshotHintChannelComputer()

Method Detail

setup

public void setup(int numChannels)

Specified by:

setup in interface ChannelComputer<CopyFileInfo>

channel

public int channel(CopyFileInfo record)

Specified by:

channel in interface ChannelComputer<CopyFileInfo>