public class SnapshotHintChannelComputer extends Object implements ChannelComputer<CloneFileInfo>
ChannelComputer
for distributing CloneFileInfo
records into SnapshotHintOperator
for recreate snapshot hints.
CloneFileInfo
s are distributed by target table name, so the creation of snapshot hints
of each table is handled by only one parallelism.
Constructor and Description |
---|
SnapshotHintChannelComputer() |
Modifier and Type | Method and Description |
---|---|
int |
channel(CloneFileInfo record) |
void |
setup(int numChannels) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
select, select, transform
public void setup(int numChannels)
setup
in interface ChannelComputer<CloneFileInfo>
public int channel(CloneFileInfo record)
channel
in interface ChannelComputer<CloneFileInfo>
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.