T
- type of recordpublic interface ChannelComputer<T> extends Serializable
Modifier and Type | Method and Description |
---|---|
int |
channel(T record) |
static int |
select(BinaryRow partition,
int bucket,
int numChannels) |
static int |
select(int bucket,
int numChannels) |
void |
setup(int numChannels) |
static <T,R> ChannelComputer<R> |
transform(ChannelComputer<T> input,
SerializableFunction<R,T> converter) |
void setup(int numChannels)
int channel(T record)
static int select(BinaryRow partition, int bucket, int numChannels)
static int select(int bucket, int numChannels)
static <T,R> ChannelComputer<R> transform(ChannelComputer<T> input, SerializableFunction<R,T> converter)
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.