VariableLengthByteKeyAndValueComparator (Flink : Streaming Java 1.20.0 API)

java.lang.Object
- org.apache.flink.api.common.typeutils.TypeComparator<org.apache.flink.api.java.tuple.Tuple2<byte[],INPUT>>
- - org.apache.flink.streaming.api.operators.sortpartition.VariableLengthByteKeyAndValueComparator<INPUT>

所有已实现的接口:

Serializable
```
@Internal
public class VariableLengthByteKeyAndValueComparator<INPUT>
extends org.apache.flink.api.common.typeutils.TypeComparator<org.apache.flink.api.java.tuple.Tuple2<byte[],INPUT>>
```
The VariableLengthByteKeyAndValueComparator is used by KeyedSortPartitionOperator to compare records according to both the record key and record value. The length of record key must be variable and will be read from DataInputView.

另请参阅:

序列化表格

构造器概要

构造器
构造器和说明

VariableLengthByteKeyAndValueComparator(org.apache.flink.api.common.typeutils.TypeComparator<INPUT> valueComparator)

构造器
构造器和说明
`VariableLengthByteKeyAndValueComparator(org.apache.flink.api.common.typeutils.TypeComparator<INPUT> valueComparator)`

方法概要

所有方法实例方法具体方法
限定符和类型	方法和说明
`int`	`compare(org.apache.flink.api.java.tuple.Tuple2<byte[],INPUT> first, org.apache.flink.api.java.tuple.Tuple2<byte[],INPUT> second)`
`int`	`compareSerialized(org.apache.flink.core.memory.DataInputView firstSource, org.apache.flink.core.memory.DataInputView secondSource)`
`int`	`compareToReference(org.apache.flink.api.common.typeutils.TypeComparator<org.apache.flink.api.java.tuple.Tuple2<byte[],INPUT>> referencedComparator)`
`org.apache.flink.api.common.typeutils.TypeComparator<org.apache.flink.api.java.tuple.Tuple2<byte[],INPUT>>`	`duplicate()`
`boolean`	`equalToReference(org.apache.flink.api.java.tuple.Tuple2<byte[],INPUT> candidate)`
`int`	`extractKeys(Object record, Object[] target, int index)`
`org.apache.flink.api.common.typeutils.TypeComparator<?>[]`	`getFlatComparators()`
`int`	`getNormalizeKeyLen()`
`int`	`hash(org.apache.flink.api.java.tuple.Tuple2<byte[],INPUT> record)`
`boolean`	`invertNormalizedKey()`
`boolean`	`isNormalizedKeyPrefixOnly(int keyBytes)`
`void`	`putNormalizedKey(org.apache.flink.api.java.tuple.Tuple2<byte[],INPUT> record, org.apache.flink.core.memory.MemorySegment target, int offset, int numBytes)`
`org.apache.flink.api.java.tuple.Tuple2<byte[],INPUT>`	`readWithKeyDenormalization(org.apache.flink.api.java.tuple.Tuple2<byte[],INPUT> reuse, org.apache.flink.core.memory.DataInputView source)`
`void`	`setReference(org.apache.flink.api.java.tuple.Tuple2<byte[],INPUT> toCompare)`
`boolean`	`supportsNormalizedKey()`
`boolean`	`supportsSerializationWithKeyNormalization()`
`void`	`writeWithKeyNormalization(org.apache.flink.api.java.tuple.Tuple2<byte[],INPUT> record, org.apache.flink.core.memory.DataOutputView target)`

从类继承的方法 org.apache.flink.api.common.typeutils.TypeComparator
compareAgainstReference, supportsCompareAgainstReference

从类继承的方法 java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- 构造器详细资料
  - VariableLengthByteKeyAndValueComparator
```
public VariableLengthByteKeyAndValueComparator(org.apache.flink.api.common.typeutils.TypeComparator<INPUT> valueComparator)
```
- 方法详细资料
  - hash
```
public int hash(org.apache.flink.api.java.tuple.Tuple2<byte[],INPUT> record)
```
    指定者:
    
    hash 在类中 org.apache.flink.api.common.typeutils.TypeComparator<org.apache.flink.api.java.tuple.Tuple2<byte[],INPUT>>
  - setReference
```
public void setReference(org.apache.flink.api.java.tuple.Tuple2<byte[],INPUT> toCompare)
```
    指定者:
    
    setReference 在类中 org.apache.flink.api.common.typeutils.TypeComparator<org.apache.flink.api.java.tuple.Tuple2<byte[],INPUT>>
  - equalToReference
```
public boolean equalToReference(org.apache.flink.api.java.tuple.Tuple2<byte[],INPUT> candidate)
```
    指定者:
    
    equalToReference 在类中 org.apache.flink.api.common.typeutils.TypeComparator<org.apache.flink.api.java.tuple.Tuple2<byte[],INPUT>>
  - compareToReference
```
public int compareToReference(org.apache.flink.api.common.typeutils.TypeComparator<org.apache.flink.api.java.tuple.Tuple2<byte[],INPUT>> referencedComparator)
```
    指定者:
    
    compareToReference 在类中 org.apache.flink.api.common.typeutils.TypeComparator<org.apache.flink.api.java.tuple.Tuple2<byte[],INPUT>>
  - compare
```
public int compare(org.apache.flink.api.java.tuple.Tuple2<byte[],INPUT> first,
                   org.apache.flink.api.java.tuple.Tuple2<byte[],INPUT> second)
```
    指定者:
    
    compare 在类中 org.apache.flink.api.common.typeutils.TypeComparator<org.apache.flink.api.java.tuple.Tuple2<byte[],INPUT>>
  - compareSerialized
```
public int compareSerialized(org.apache.flink.core.memory.DataInputView firstSource,
                             org.apache.flink.core.memory.DataInputView secondSource)
                      throws IOException
```
    指定者:
    
    compareSerialized 在类中 org.apache.flink.api.common.typeutils.TypeComparator<org.apache.flink.api.java.tuple.Tuple2<byte[],INPUT>>
    
    抛出:
    
    IOException
  - supportsNormalizedKey
```
public boolean supportsNormalizedKey()
```
    指定者:
    
    supportsNormalizedKey 在类中 org.apache.flink.api.common.typeutils.TypeComparator<org.apache.flink.api.java.tuple.Tuple2<byte[],INPUT>>
  - getNormalizeKeyLen
```
public int getNormalizeKeyLen()
```
    指定者:
    
    getNormalizeKeyLen 在类中 org.apache.flink.api.common.typeutils.TypeComparator<org.apache.flink.api.java.tuple.Tuple2<byte[],INPUT>>
  - isNormalizedKeyPrefixOnly
```
public boolean isNormalizedKeyPrefixOnly(int keyBytes)
```
    指定者:
    
    isNormalizedKeyPrefixOnly 在类中 org.apache.flink.api.common.typeutils.TypeComparator<org.apache.flink.api.java.tuple.Tuple2<byte[],INPUT>>
  - putNormalizedKey
```
public void putNormalizedKey(org.apache.flink.api.java.tuple.Tuple2<byte[],INPUT> record,
                             org.apache.flink.core.memory.MemorySegment target,
                             int offset,
                             int numBytes)
```
    指定者:
    
    putNormalizedKey 在类中 org.apache.flink.api.common.typeutils.TypeComparator<org.apache.flink.api.java.tuple.Tuple2<byte[],INPUT>>
  - invertNormalizedKey
```
public boolean invertNormalizedKey()
```
    指定者:
    
    invertNormalizedKey 在类中 org.apache.flink.api.common.typeutils.TypeComparator<org.apache.flink.api.java.tuple.Tuple2<byte[],INPUT>>
  - duplicate
```
public org.apache.flink.api.common.typeutils.TypeComparator<org.apache.flink.api.java.tuple.Tuple2<byte[],INPUT>> duplicate()
```
    指定者:
    
    duplicate 在类中 org.apache.flink.api.common.typeutils.TypeComparator<org.apache.flink.api.java.tuple.Tuple2<byte[],INPUT>>
  - extractKeys
```
public int extractKeys(Object record,
                       Object[] target,
                       int index)
```
    指定者:
    
    extractKeys 在类中 org.apache.flink.api.common.typeutils.TypeComparator<org.apache.flink.api.java.tuple.Tuple2<byte[],INPUT>>
  - getFlatComparators
```
public org.apache.flink.api.common.typeutils.TypeComparator<?>[] getFlatComparators()
```
    指定者:
    
    getFlatComparators 在类中 org.apache.flink.api.common.typeutils.TypeComparator<org.apache.flink.api.java.tuple.Tuple2<byte[],INPUT>>
  - supportsSerializationWithKeyNormalization
```
public boolean supportsSerializationWithKeyNormalization()
```
    指定者:
    
    supportsSerializationWithKeyNormalization 在类中 org.apache.flink.api.common.typeutils.TypeComparator<org.apache.flink.api.java.tuple.Tuple2<byte[],INPUT>>
  - writeWithKeyNormalization
```
public void writeWithKeyNormalization(org.apache.flink.api.java.tuple.Tuple2<byte[],INPUT> record,
                                      org.apache.flink.core.memory.DataOutputView target)
```
    指定者:
    
    writeWithKeyNormalization 在类中 org.apache.flink.api.common.typeutils.TypeComparator<org.apache.flink.api.java.tuple.Tuple2<byte[],INPUT>>
  - readWithKeyDenormalization
```
public org.apache.flink.api.java.tuple.Tuple2<byte[],INPUT> readWithKeyDenormalization(org.apache.flink.api.java.tuple.Tuple2<byte[],INPUT> reuse,
                                                                                       org.apache.flink.core.memory.DataInputView source)
```
    指定者:
    
    readWithKeyDenormalization 在类中 org.apache.flink.api.common.typeutils.TypeComparator<org.apache.flink.api.java.tuple.Tuple2<byte[],INPUT>>

类 VariableLengthByteKeyAndValueComparator<INPUT>

构造器概要

方法概要

从类继承的方法 org.apache.flink.api.common.typeutils.TypeComparator

从类继承的方法 java.lang.Object

构造器详细资料

VariableLengthByteKeyAndValueComparator

方法详细资料

hash

setReference

equalToReference

compareToReference

compare

compareSerialized

supportsNormalizedKey

getNormalizeKeyLen

isNormalizedKeyPrefixOnly

putNormalizedKey

invertNormalizedKey

duplicate

extractKeys

getFlatComparators

supportsSerializationWithKeyNormalization

writeWithKeyNormalization

readWithKeyDenormalization