org.apache.flink.api.common.typeinfo.TypeInformation.isKeyType()方法的使用及代码示例

本文整理了Java中org.apache.flink.api.common.typeinfo.TypeInformation.isKeyType()方法的一些代码示例，展示了TypeInformation.isKeyType()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。TypeInformation.isKeyType()方法的具体详情如下：
包路径：org.apache.flink.api.common.typeinfo.TypeInformation
类名称：TypeInformation
方法名：isKeyType

TypeInformation.isKeyType介绍

[英]Checks whether this type can be used as a key. As a bare minimum, types have to be hashable and comparable to be keys.
[中]检查此类型是否可用作密钥。作为最低要求，类型必须是可散列的，并且可以与键进行比较。

代码示例

代码示例来源：origin: apache/flink

/**
* Checks whether this type can be used as a key for sorting.
* The order produced by sorting this type must be meaningful.
*/
@PublicEvolving
public boolean isSortKeyType() {
return isKeyType();
}

代码示例来源：origin: apache/flink

/**
* Constructor which is overwriting the default constructor.
* @param type Types of tuple whether to check if given fields are key types.
* @param fields Array of integers which are used as key for comparison. The order of indexes
* is regarded in the reduce function. First index has highest priority and last index has
* least priority.
*/
public SelectByMinFunction(TupleTypeInfo type, int... fields) {
this.fields = fields;
// Check correctness of each position
for (int field : fields) {
// Is field inside array
if (field <0 || field >= type.getArity()) {
throw new java.lang.IndexOutOfBoundsException(
"MinReduceFunction field position " + field + " is out of range.");
}
// Check whether type is comparable
if (!type.getTypeAt(field).isKeyType()) {
throw new java.lang.IllegalArgumentException(
"MinReduceFunction supports only key(Comparable) types.");
}
}
}

代码示例来源：origin: apache/flink

/**
* Constructor which is overwriting the default constructor.
* @param type Types of tuple whether to check if given fields are key types.
* @param fields Array of integers which are used as key for comparison. The order of indexes
* is regarded in the reduce function. First index has highest priority and last index has
* least priority.
*/
public SelectByMaxFunction(TupleTypeInfo type, int... fields) {
this.fields = fields;
// Check correctness of each position
for (int field : fields) {
// Is field inside array
if (field <0 || field >= type.getArity()) {
throw new IndexOutOfBoundsException(
"MinReduceFunction field position " + field + " is out of range.");
}
// Check whether type is comparable
if (!type.getTypeAt(field).isKeyType()) {
throw new java.lang.IllegalArgumentException(
"MinReduceFunction supports only key(Comparable) types.");
}
}
}

代码示例来源：origin: apache/flink

public SelectorFunctionKeys(KeySelector keyExtractor, TypeInformation inputType, TypeInformation keyType) {
if (keyExtractor == null) {
throw new NullPointerException("Key extractor must not be null.");
}
if (keyType == null) {
throw new NullPointerException("Key type must not be null.");
}
if (!keyType.isKeyType()) {
throw new InvalidProgramException("Return type "+keyType+" of KeySelector "+keyExtractor.getClass()+" is not a valid key type");
}
this.keyExtractor = keyExtractor;
this.inputType = inputType;
this.keyType = keyType;
this.originalKeyTypes = new TypeInformation[] {keyType};
if (keyType instanceof CompositeType) {
this.keyFields = ((CompositeType)keyType).getFlatFields(ExpressionKeys.SELECT_ALL_CHAR);
}
else {
this.keyFields = new ArrayList<>(1);
this.keyFields.add(new FlatFieldDescriptor(0, keyType));
}
}

代码示例来源：origin: apache/flink

@Override
@PublicEvolving
public boolean isKeyType() {
for(int i=0;i if (!this.getTypeAt(i).isKeyType()) {
return false;
}
}
return true;
}

代码示例来源：origin: apache/flink

if (!field.getType().isKeyType()) {
throw new InvalidProgramException("This type (" + field.getType() + ") cannot be used as key.");
if (!type.isKeyType()) {
throw new InvalidProgramException("This type (" + type + ") cannot be used as key.");

代码示例来源：origin: apache/flink

if(!ffd.getType().isKeyType()) {
throw new InvalidProgramException("This type (" + ffd.getType() + ") cannot be used as key.");

代码示例来源：origin: org.apache.flink/flink-core

/**
* Checks whether this type can be used as a key for sorting.
* The order produced by sorting this type must be meaningful.
*/
@PublicEvolving
public boolean isSortKeyType() {
return isKeyType();
}

代码示例来源：origin: com.alibaba.blink/flink-core

/**
* Checks whether this type can be used as a key for sorting.
* The order produced by sorting this type must be meaningful.
*/
@PublicEvolving
public boolean isSortKeyType() {
return isKeyType();
}

代码示例来源：origin: org.apache.flink/flink-core

public SelectorFunctionKeys(KeySelector keyExtractor, TypeInformation inputType, TypeInformation keyType) {
if (keyExtractor == null) {
throw new NullPointerException("Key extractor must not be null.");
}
if (keyType == null) {
throw new NullPointerException("Key type must not be null.");
}
if (!keyType.isKeyType()) {
throw new InvalidProgramException("Return type "+keyType+" of KeySelector "+keyExtractor.getClass()+" is not a valid key type");
}
this.keyExtractor = keyExtractor;
this.inputType = inputType;
this.keyType = keyType;
this.originalKeyTypes = new TypeInformation[] {keyType};
if (keyType instanceof CompositeType) {
this.keyFields = ((CompositeType)keyType).getFlatFields(ExpressionKeys.SELECT_ALL_CHAR);
}
else {
this.keyFields = new ArrayList<>(1);
this.keyFields.add(new FlatFieldDescriptor(0, keyType));
}
}

代码示例来源：origin: org.apache.flink/flink-java

/**
* Constructor which is overwriting the default constructor.
* @param type Types of tuple whether to check if given fields are key types.
* @param fields Array of integers which are used as key for comparison. The order of indexes
* is regarded in the reduce function. First index has highest priority and last index has
* least priority.
*/
public SelectByMinFunction(TupleTypeInfo type, int... fields) {
this.fields = fields;
// Check correctness of each position
for (int field : fields) {
// Is field inside array
if (field <0 || field >= type.getArity()) {
throw new java.lang.IndexOutOfBoundsException(
"MinReduceFunction field position " + field + " is out of range.");
}
// Check whether type is comparable
if (!type.getTypeAt(field).isKeyType()) {
throw new java.lang.IllegalArgumentException(
"MinReduceFunction supports only key(Comparable) types.");
}
}
}

代码示例来源：origin: org.apache.flink/flink-java

/**
* Constructor which is overwriting the default constructor.
* @param type Types of tuple whether to check if given fields are key types.
* @param fields Array of integers which are used as key for comparison. The order of indexes
* is regarded in the reduce function. First index has highest priority and last index has
* least priority.
*/
public SelectByMaxFunction(TupleTypeInfo type, int... fields) {
this.fields = fields;
// Check correctness of each position
for (int field : fields) {
// Is field inside array
if (field <0 || field >= type.getArity()) {
throw new IndexOutOfBoundsException(
"MinReduceFunction field position " + field + " is out of range.");
}
// Check whether type is comparable
if (!type.getTypeAt(field).isKeyType()) {
throw new java.lang.IllegalArgumentException(
"MinReduceFunction supports only key(Comparable) types.");
}
}
}

代码示例来源：origin: com.alibaba.blink/flink-java

/**
* Constructor which is overwriting the default constructor.
* @param type Types of tuple whether to check if given fields are key types.
* @param fields Array of integers which are used as key for comparison. The order of indexes
* is regarded in the reduce function. First index has highest priority and last index has
* least priority.
*/
public SelectByMinFunction(TupleTypeInfo type, int... fields) {
this.fields = fields;
// Check correctness of each position
for (int field : fields) {
// Is field inside array
if (field <0 || field >= type.getArity()) {
throw new java.lang.IndexOutOfBoundsException(
"MinReduceFunction field position " + field + " is out of range.");
}
// Check whether type is comparable
if (!type.getTypeAt(field).isKeyType()) {
throw new java.lang.IllegalArgumentException(
"MinReduceFunction supports only key(Comparable) types.");
}
}
}

代码示例来源：origin: com.alibaba.blink/flink-java

/**
* Constructor which is overwriting the default constructor.
* @param type Types of tuple whether to check if given fields are key types.
* @param fields Array of integers which are used as key for comparison. The order of indexes
* is regarded in the reduce function. First index has highest priority and last index has
* least priority.
*/
public SelectByMaxFunction(TupleTypeInfo type, int... fields) {
this.fields = fields;
// Check correctness of each position
for (int field : fields) {
// Is field inside array
if (field <0 || field >= type.getArity()) {
throw new IndexOutOfBoundsException(
"MinReduceFunction field position " + field + " is out of range.");
}
// Check whether type is comparable
if (!type.getTypeAt(field).isKeyType()) {
throw new java.lang.IllegalArgumentException(
"MinReduceFunction supports only key(Comparable) types.");
}
}
}

代码示例来源：origin: com.alibaba.blink/flink-core

public SelectorFunctionKeys(KeySelector keyExtractor, TypeInformation inputType, TypeInformation keyType) {
if (keyExtractor == null) {
throw new NullPointerException("Key extractor must not be null.");
}
if (keyType == null) {
throw new NullPointerException("Key type must not be null.");
}
if (!keyType.isKeyType()) {
throw new InvalidProgramException("Return type "+keyType+" of KeySelector "+keyExtractor.getClass()+" is not a valid key type");
}
this.keyExtractor = keyExtractor;
this.inputType = inputType;
this.keyType = keyType;
this.originalKeyTypes = new TypeInformation[] {keyType};
if (keyType instanceof CompositeType) {
this.keyFields = ((CompositeType)keyType).getFlatFields(ExpressionKeys.SELECT_ALL_CHAR);
}
else {
this.keyFields = new ArrayList<>(1);
this.keyFields.add(new FlatFieldDescriptor(0, keyType));
}
}

代码示例来源：origin: com.alibaba.blink/flink-core

@Override
@PublicEvolving
public boolean isKeyType() {
for(int i=0;i if (!this.getTypeAt(i).isKeyType()) {
return false;
}
}
return true;
}

代码示例来源：origin: org.apache.flink/flink-core

@Override
@PublicEvolving
public boolean isKeyType() {
for(int i=0;i if (!this.getTypeAt(i).isKeyType()) {
return false;
}
}
return true;
}

代码示例来源：origin: org.apache.flink/flink-core

if (!field.getType().isKeyType()) {
throw new InvalidProgramException("This type (" + field.getType() + ") cannot be used as key.");
if (!type.isKeyType()) {
throw new InvalidProgramException("This type (" + type + ") cannot be used as key.");

代码示例来源：origin: com.alibaba.blink/flink-core

if(!ffd.getType().isKeyType()) {
throw new InvalidProgramException("This type (" + ffd.getType() + ") cannot be used as key.");

代码示例来源：origin: org.apache.flink/flink-core

if(!ffd.getType().isKeyType()) {
throw new InvalidProgramException("This type (" + ffd.getType() + ") cannot be used as key.");