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() |
SubtaskStateMapper |
getDownstreamSubtaskStateMapper()
Defines the behavior of this partitioner, when downstream rescaled during recovery of
in-flight data.
|
boolean |
isPointwise() |
int |
selectChannel(SerializationDelegate<StreamRecord<T>> record)
Returns the logical channel index, to which the given record should be written.
|
String |
toString() |
equals, getUpstreamSubtaskStateMapper, hashCode, 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 SubtaskStateMapper getDownstreamSubtaskStateMapper()
StreamPartitioner
getDownstreamSubtaskStateMapper
in class StreamPartitioner<T>
public StreamPartitioner<T> copy()
copy
in class StreamPartitioner<T>
public boolean isPointwise()
isPointwise
in class StreamPartitioner<T>
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.