public class BinaryHashPartitioner extends StreamPartitioner<RowData>
BinaryRowData
.numberOfChannels
Constructor and Description |
---|
BinaryHashPartitioner(GeneratedHashFunction genHashFunc,
String[] hashFieldNames) |
Modifier and Type | Method and Description |
---|---|
StreamPartitioner<RowData> |
copy() |
boolean |
equals(Object o) |
SubtaskStateMapper |
getDownstreamSubtaskStateMapper()
Defines the behavior of this partitioner, when downstream rescaled during recovery of
in-flight data.
|
int |
hashCode() |
boolean |
isPointwise() |
int |
selectChannel(SerializationDelegate<StreamRecord<RowData>> record)
Returns the logical channel index, to which the given record should be written.
|
String |
toString() |
getUpstreamSubtaskStateMapper, isBroadcast, setup
public BinaryHashPartitioner(GeneratedHashFunction genHashFunc, String[] hashFieldNames)
public StreamPartitioner<RowData> copy()
copy
in class StreamPartitioner<RowData>
public int selectChannel(SerializationDelegate<StreamRecord<RowData>> record)
ChannelSelector
UnsupportedOperationException
).record
- the record to determine the output channels for.public SubtaskStateMapper getDownstreamSubtaskStateMapper()
StreamPartitioner
getDownstreamSubtaskStateMapper
in class StreamPartitioner<RowData>
public boolean isPointwise()
isPointwise
in class StreamPartitioner<RowData>
public boolean equals(Object o)
equals
in class StreamPartitioner<RowData>
public int hashCode()
hashCode
in class StreamPartitioner<RowData>
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.