public class BucketsRowChannelComputer extends Object implements ChannelComputer<org.apache.flink.table.data.RowData>
Constructor and Description |
---|
BucketsRowChannelComputer() |
Modifier and Type | Method and Description |
---|---|
int |
channel(org.apache.flink.table.data.RowData rowData) |
void |
setup(int numberOfChannels) |
String |
toString() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
select, select, transform
public void setup(int numberOfChannels)
setup
in interface ChannelComputer<org.apache.flink.table.data.RowData>
public int channel(org.apache.flink.table.data.RowData rowData)
channel
in interface ChannelComputer<org.apache.flink.table.data.RowData>
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.