K
- Type of the keyT
- Type of the data@Internal public class CustomPartitionerWrapper<K,T> extends StreamPartitioner<T>
numberOfChannels
Constructor and Description |
---|
CustomPartitionerWrapper(Partitioner<K> partitioner,
KeySelector<T,K> keySelector) |
Modifier and Type | Method and Description |
---|---|
StreamPartitioner<T> |
copy() |
int |
selectChannel(SerializationDelegate<StreamRecord<T>> record)
Returns the logical channel index, to which the given record should be written.
|
String |
toString() |
isBroadcast, setup
public CustomPartitionerWrapper(Partitioner<K> partitioner, KeySelector<T,K> keySelector)
public int selectChannel(SerializationDelegate<StreamRecord<T>> record)
ChannelSelector
UnsupportedOperationException
).record
- the record to determine the output channels for.public StreamPartitioner<T> copy()
copy
in class StreamPartitioner<T>
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.