org.apache.flink.api.java.typeutils.ObjectArrayTypeInfo.getInfoFor()方法的使用及代码示例

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

ObjectArrayTypeInfo.getInfoFor介绍

[英]Creates a new org.apache.flink.api.java.typeutils.ObjectArrayTypeInfo from a TypeInformation for the component type.

This must be used in cases where the complete type of the array is not available as a java.lang.reflect.Type or java.lang.Class.
[中]创建一个新组织。阿帕奇。弗林克。应用程序编程接口。JAVAtypeutils。组件类型的类型信息中的ObjectArrayTypeInfo。
这必须在完整类型的数组不能作为java应用程序使用的情况下使用。朗，反思一下。输入或java。朗，同学们。

代码示例

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

/**
* Returns type information for Java arrays of object types (such as String[],
* Integer[]). The array itself must not be null. Null values for elements are supported.
*
* @param elementType element type of the array
*/
@SuppressWarnings("unchecked")
public static TypeInformation OBJECT_ARRAY(TypeInformation elementType) {
if (elementType == Types.STRING) {
return (TypeInformation) BasicArrayTypeInfo.STRING_ARRAY_TYPE_INFO;
}
return ObjectArrayTypeInfo.getInfoFor(elementType);
}

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

@Override
protected ObjectArrayTypeInfo[] getTestData() {
return new ObjectArrayTypeInfo[] {
ObjectArrayTypeInfo.getInfoFor(TestClass[].class, new GenericTypeInfo<>(TestClass.class)),
ObjectArrayTypeInfo.getInfoFor(TestClass[].class, new PojoTypeInfo<>(TestClass.class, new ArrayList()))
};
}

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

TypeInformation elementType = schemaToTypeInfo(elementSchema);
return ObjectArrayTypeInfo.getInfoFor(elementType);
case MAP:
TypeDescription keySchema = schema.getChildren().get(0);

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

Class classArray = (Class) (java.lang.reflect.Array.newInstance(componentClass, 0).getClass());
return ObjectArrayTypeInfo.getInfoFor(classArray, componentInfo);

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

@Test
public void testObjectArrayKeyRejection() {
KeySelector, Object[]> keySelector =
new KeySelector, Object[]>() {
@Override
public Object[] getKey(Tuple2 value) throws Exception {
Object[] ks = new Object[value.f0.length];
for (int i = 0; i ks[i] = new Object();
}
return ks;
}
};
ObjectArrayTypeInfo keyTypeInfo = ObjectArrayTypeInfo.getInfoFor(
Object[].class, new GenericTypeInfo<>(Object.class));
testKeyRejection(keySelector, keyTypeInfo);
}

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

in2Type);
return ObjectArrayTypeInfo.getInfoFor(clazz, componentTypeInfo);

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

/**
* Returns type information for Java arrays of object types (such as String[],
* Integer[]). The array itself must not be null. Null values for elements are supported.
*
* @param elementType element type of the array
*/
@SuppressWarnings("unchecked")
public static TypeInformation OBJECT_ARRAY(TypeInformation elementType) {
if (elementType == Types.STRING) {
return (TypeInformation) BasicArrayTypeInfo.STRING_ARRAY_TYPE_INFO;
}
return ObjectArrayTypeInfo.getInfoFor(elementType);
}

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

/**
* Returns type information for Java arrays of object types (such as String[],
* Integer[]). The array itself must not be null. Null values for elements are supported.
*
* @param elementType element type of the array
*/
@SuppressWarnings("unchecked")
public static TypeInformation OBJECT_ARRAY(TypeInformation elementType) {
if (elementType == Types.STRING) {
return (TypeInformation) BasicArrayTypeInfo.STRING_ARRAY_TYPE_INFO;
}
return ObjectArrayTypeInfo.getInfoFor(elementType);
}

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

arrayInfo = ObjectArrayTypeInfo.getInfoFor(loadClass("[L" + returnType.getTypeClass().getName() + ";"),
returnType);
for (int i = 1; i arrayPrefix += "[";
arrayInfo = ObjectArrayTypeInfo.getInfoFor(loadClass(arrayPrefix + "L" +
returnType.getTypeClass().getName() + ";"), arrayInfo);

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

in2Type);
return ObjectArrayTypeInfo.getInfoFor(clazz, componentTypeInfo);

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

in2Type);
return ObjectArrayTypeInfo.getInfoFor(clazz, componentTypeInfo);

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

Class classArray = (Class) (java.lang.reflect.Array.newInstance(componentClass, 0).getClass());
return ObjectArrayTypeInfo.getInfoFor(classArray, componentInfo);

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

Class classArray = (Class) (java.lang.reflect.Array.newInstance(componentClass, 0).getClass());
return ObjectArrayTypeInfo.getInfoFor(classArray, componentInfo);

代码示例来源：origin: dataArtisans/cascading-flink

new org.apache.flink.api.java.typeutils.TupleTypeInfo<>(
new TupleTypeInfo(Fields.UNKNOWN),
ObjectArrayTypeInfo.getInfoFor(new TupleTypeInfo(Fields.UNKNOWN))
);