public class RowAssignerChannelComputer extends Object implements ChannelComputer<InternalRow>
RowData
.Constructor and Description |
---|
RowAssignerChannelComputer(TableSchema schema,
Integer numAssigners) |
Modifier and Type | Method and Description |
---|---|
int |
channel(InternalRow record) |
void |
setup(int numChannels) |
String |
toString() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
select, select, transform
public RowAssignerChannelComputer(TableSchema schema, Integer numAssigners)
public void setup(int numChannels)
setup
in interface ChannelComputer<InternalRow>
public int channel(InternalRow record)
channel
in interface ChannelComputer<InternalRow>
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.